X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=src%2Fmeshlink.c;h=f425b4b2f2bad692fd3030673dfe63b4c4056056;hb=22cdfa47418f42bde9e51bfbc864f2aefc05667e;hp=a5bf2c90ac3f6f33916d8eafceadb98a24f56ebd;hpb=1bd5703bb40828fd6a4dc76eeeccd2884de8decb;p=meshlink diff --git a/src/meshlink.c b/src/meshlink.c index a5bf2c90..f425b4b2 100644 --- a/src/meshlink.c +++ b/src/meshlink.c @@ -4515,7 +4515,7 @@ bool meshlink_channel_aio_send(meshlink_handle_t *mesh, meshlink_channel_t *chan /* Ensure the poll callback is set, and call it right now to push data if possible */ utcp_set_poll_cb(channel->c, channel_poll); - size_t todo = MIN(len, utcp_get_rcvbuf_free(channel->c)); + size_t todo = MIN(len, utcp_get_sndbuf_free(channel->c)); if(todo) { channel_poll(channel->c, todo); @@ -4560,7 +4560,7 @@ bool meshlink_channel_aio_fd_send(meshlink_handle_t *mesh, meshlink_channel_t *c /* Ensure the poll callback is set, and call it right now to push data if possible */ utcp_set_poll_cb(channel->c, channel_poll); - size_t left = utcp_get_rcvbuf_free(channel->c); + size_t left = utcp_get_sndbuf_free(channel->c); if(left) { channel_poll(channel->c, left);