Add support for sendmmsg().

[meshlink] / src / meshlink.c

diff --git a/src/meshlink.c b/src/meshlink.c
index f14c4940800b587dcb8f14688aabd9a43ac41c0e..283a949250a95615d5d7a38bf6cff1686a281a97 100644 (file)
--- a/src/meshlink.c
+++ b/src/meshlink.c
@@ -975,6 +975,10 @@ static struct timespec idle(event_loop_t *loop, void *data) {
        meshlink_handle_t *mesh = data;
        struct timespec t, tmin = {3600, 0};
 
+#ifdef HAVE_SENDMMSG
+       flush_mmsg(mesh);
+#endif
+
        for splay_each(node_t, n, mesh->nodes) {
                if(!n->utcp) {
                        continue;
@@ -1652,7 +1656,9 @@ bool meshlink_start(meshlink_handle_t *mesh) {
                return false;
        }
 
+#if defined(HAVE_RECVMMSG) || defined(HAVE_SENDMMSG)
        init_mmsg(mesh);
+#endif
        init_outgoings(mesh);
        init_adns(mesh);
 
@@ -1727,7 +1733,9 @@ void meshlink_stop(meshlink_handle_t *mesh) {
 
        exit_adns(mesh);
        exit_outgoings(mesh);
+#if defined(HAVE_RECVMMSG) || defined(HAVE_SENDMMSG)
        exit_mmsg(mesh);
+#endif
 
        // Ensure we are considered unreachable
        if(mesh->nodes) {