Block on sendmsg() for now
Signed-off-by: Adrien Gallouët <adrien@gallouet.fr>
This commit is contained in:
6
mud.c
6
mud.c
@@ -436,7 +436,11 @@ mud_send_path(struct mud *mud, struct mud_path *path, uint64_t now,
|
|||||||
memcpy(CMSG_DATA(cmsg), &tc, sizeof(int));
|
memcpy(CMSG_DATA(cmsg), &tc, sizeof(int));
|
||||||
}
|
}
|
||||||
|
|
||||||
ssize_t ret = sendmsg(mud->fd, &msg, flags);
|
ssize_t ret = 0;
|
||||||
|
|
||||||
|
do {
|
||||||
|
ret = sendmsg(mud->fd, &msg, flags);
|
||||||
|
} while (ret == (ssize_t)-1 && errno == EAGAIN);
|
||||||
|
|
||||||
path->send.total++;
|
path->send.total++;
|
||||||
path->send.bytes += size;
|
path->send.bytes += size;
|
||||||
|
|||||||
Reference in New Issue
Block a user