X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=src%2Fmeshlink_internal.h;h=569628cc3e6ebc05dca19f47d978c7e299c73961;hb=c023ad12147aa88810629c110ea6b1ab94267196;hp=94e8b7983d00e12a637cd78dc945c21f829e9952;hpb=282b99f3c71705bd6e34d4e4f9e8369ea63c87ed;p=meshlink

diff --git a/src/meshlink_internal.h b/src/meshlink_internal.h
index 94e8b798..569628cc 100644
--- a/src/meshlink_internal.h
+++ b/src/meshlink_internal.h
@@ -110,15 +110,21 @@ struct meshlink_handle {
 	struct splay_tree_t *past_request_tree;
 	timeout_t past_request_timeout;
 
+	int connection_burst;
 	int contradicting_add_edge;
 	int contradicting_del_edge;
 	int sleeptime;
+	time_t connection_burst_time;
 	time_t last_config_check;
+	time_t last_hard_try;
 	timeout_t pingtimer;
 	timeout_t periodictimer;
 
 	struct connection_t *everyone;
 
+	int next_pit;
+	int pits[10];
+
 	// Infrequently used callbacks
 	meshlink_node_status_cb_t node_status_cb;
 	meshlink_channel_accept_cb_t channel_accept_cb;
@@ -138,6 +144,7 @@ struct meshlink_handle {
 	int pinginterval;       /* seconds between pings */
 	int pingtimeout;        /* seconds to wait for response */
 	int maxtimeout;
+	int udp_choice;
 
 	int netns;
 
@@ -152,6 +159,9 @@ struct meshlink_handle {
 
 	// Thread management
 	pthread_t thread;
+	pthread_cond_t cond;
+	pthread_mutex_t discovery_mutex;
+	pthread_cond_t discovery_cond;
 	bool threadstarted;
 	bool discovery_threadstarted;
 
@@ -195,12 +205,28 @@ struct meshlink_submesh {
 	void *priv;
 };
 
+/// An AIO buffer.
+typedef struct meshlink_aio_buffer {
+	const void *data;
+	int fd;
+	size_t len;
+	size_t done;
+	union {
+		meshlink_aio_cb_t buffer;
+		meshlink_aio_fd_cb_t fd;
+	} cb;
+	void *priv;
+	struct meshlink_aio_buffer *next;
+} meshlink_aio_buffer_t;
+
 /// A channel.
 struct meshlink_channel {
 	struct node_t *node;
 	void *priv;
 
 	struct utcp_connection *c;
+	meshlink_aio_buffer_t *aio_send;
+	meshlink_aio_buffer_t *aio_receive;
 	meshlink_channel_receive_cb_t receive_cb;
 	meshlink_channel_poll_cb_t poll_cb;
 };
@@ -226,6 +252,6 @@ typedef struct {
 	int edge_weight;
 } dev_class_traits_t;
 
-extern dev_class_traits_t dev_class_traits[];
+extern const dev_class_traits_t dev_class_traits[];
 
 #endif