Make AIO more useful for UDP-style channels.

When doing AIO on a UDP-style channel, only try to send up to one MTU at
a time. Also ensure that the poll callback is triggered every time
something is sent on UDP channels, since the AIO code relies heavily on
the poll callback to work.

diff --git a/src/meshlink.c b/src/meshlink.c
index a5bf2c90ac3f6f33916d8eafceadb98a24f56ebd..35640eb91f6cb7871c514583cab3e6baaf1adcdc 100644 (file)
--- a/src/meshlink.c
+++ b/src/meshlink.c
@@ -4115,6 +4115,14 @@ static void channel_poll(struct utcp_connection *connection, size_t len) {
                        todo = len;
                }
 
+               if(connection->flags == UTCP_UDP) {
+                       size_t pmtu = utcp_get_mtu(connection->utcp);
+
+                       if(todo > pmtu) {
+                               todo = pmtu;
+                       }
+               }
+
                if(aio->data) {
                        sent = utcp_send(connection, (char *)aio->data + aio->done, todo);
                } else {

diff --git a/src/utcp.c b/src/utcp.c
index ca91bee26ef6d21c0f0f57dd743c27c0f9b14f8b..221b6933485adef3c9dcb199343e7a2bbcbc8fbb 100644 (file)
--- a/src/utcp.c
+++ b/src/utcp.c
@@ -891,6 +891,8 @@ ssize_t utcp_send(struct utcp_connection *c, const void *data, size_t len) {
                        errno = EMSGSIZE;
                        return -1;
                }
+
+               c->do_poll = true;
        } else {
                return 0;
        }