mirrors/Astral
1
0
Fork 0
mirror of https://github.com/Mathewnd/Astral.git synced 2026-11-01 06:58:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

localsocket: fix issue with fd passing

Browse Source
This commit is contained in:
Matheus
2025-11-04 00:34:23 -03:00
parent f0708899d3
commit 2bafdee791
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
kernel-src/io/net/localsocket.c
+5 -2
View File
@@ -237,9 +237,11 @@ static int sendctrl(socket_t *socket, sockctrl_t *ctrl, size_t len, size_t datas
// create a new barrier secion // create a new barrier secion
__assert(peer->barrierwrite != peer->barriercurrent + BARRIER_SIZE); __assert(peer->barrierwrite != peer->barriercurrent + BARRIER_SIZE);
if (peer->bytesremaining[peer->barrierwrite % BARRIER_SIZE])
++peer->barrierwrite;
peer->filesremaining[peer->barrierwrite % BARRIER_SIZE] = fdcount; peer->filesremaining[peer->barrierwrite % BARRIER_SIZE] = fdcount;
peer->bytesremaining[peer->barrierwrite % BARRIER_SIZE] = datasent; peer->bytesremaining[peer->barrierwrite % BARRIER_SIZE] = datasent;
++peer->barrierwrite;
} }
ctrl = SOCK_CTRL_NEXT(ctrl); ctrl = SOCK_CTRL_NEXT(ctrl);
@@ -466,7 +468,8 @@ static int localsock_recv(socket_t *socket, sockdesc_t *sockdesc) {
// check if we should step forward from that barrier // check if we should step forward from that barrier
localsocket->bytesremaining[localsocket->barriercurrent % BARRIER_SIZE] -= recvcount; localsocket->bytesremaining[localsocket->barriercurrent % BARRIER_SIZE] -= recvcount;
if (localsocket->bytesremaining[localsocket->barriercurrent % BARRIER_SIZE] == 0) if (localsocket->bytesremaining[localsocket->barriercurrent % BARRIER_SIZE] == 0 &&
localsocket->bytesremaining[(localsocket->barriercurrent + 1) % BARRIER_SIZE])
++localsocket->barriercurrent; ++localsocket->barriercurrent;
} }