X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=src%2Fmeshlink_internal.h;h=1bf3085c92884975e5abe55c29a193f820d707e9;hb=4fdc68b822dc2a160e3142e0cb97b75879444a13;hp=72cf638e613fac9d9ba4219a1602fd092339bde6;hpb=ae011af4d6186f2ff5582e2a6c48406be89da164;p=meshlink diff --git a/src/meshlink_internal.h b/src/meshlink_internal.h index 72cf638e..1bf3085c 100644 --- a/src/meshlink_internal.h +++ b/src/meshlink_internal.h @@ -49,10 +49,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; @@ -79,6 +87,9 @@ struct meshlink_handle { struct list_t *outpacketqueue; + struct splay_tree_t *past_request_tree; + timeout_t past_request_timeout; + int contradicting_add_edge; int contradicting_del_edge; int sleeptime; @@ -129,4 +140,7 @@ typedef struct meshlink_packethdr { uint8_t source[16]; } __attribute__ ((__packed__)) meshlink_packethdr_t; +extern void meshlink_send_from_queue(event_loop_t* el,meshlink_handle_t *mesh); + + #endif // MESHLINK_INTERNAL_H