X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=src%2Fmeshlink_internal.h;h=c9c1eeaa38ffa9bd0f5f9bb785afaa9bafeb66c3;hb=3f6d9a24c1d4c78548bc9dab0e66e2a240a72df7;hp=8604acb64051ff928a5a7deb13d242b24e6956cb;hpb=9ba6a16d3c748d026f88b9cd96f908e95ef25521;p=meshlink diff --git a/src/meshlink_internal.h b/src/meshlink_internal.h index 8604acb6..c9c1eeaa 100644 --- a/src/meshlink_internal.h +++ b/src/meshlink_internal.h @@ -26,6 +26,7 @@ #include "hash.h" #include "logger.h" #include "meshlink.h" +#include "meshlink_queue.h" #include "sockaddr.h" #include "sptps.h" @@ -49,10 +50,18 @@ typedef enum proxytype_t { PROXY_EXEC, } proxytype_t; +typedef struct outpacketqueue { + meshlink_node_t *destination; + const void *data; + unsigned int len; +} outpacketqueue_t; + /// A handle for an instance of MeshLink. struct meshlink_handle { - char *confbase; char *name; + void *priv; + + char *confbase; meshlink_receive_cb_t receive_cb; meshlink_node_status_cb_t node_status_cb; @@ -77,7 +86,10 @@ struct meshlink_handle { struct list_t *connections; struct list_t *outgoings; - struct list_t *outpacketqueue; + meshlink_queue_t outpacketqueue; + + struct splay_tree_t *past_request_tree; + timeout_t past_request_timeout; int contradicting_add_edge; int contradicting_del_edge;