X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=src%2Fmeshlink_internal.h;h=e36fd95f38b0a5f41d67b2444ff739ca55cbe4e7;hb=c6cc7da56d108f05ea6f9a2f765f699e6e2353db;hp=63a71dc048dc0f81d693908dab280a396fbf9499;hpb=f416117836dc944822cac06efb54377fb21ee66f;p=meshlink diff --git a/src/meshlink_internal.h b/src/meshlink_internal.h index 63a71dc0..e36fd95f 100644 --- a/src/meshlink_internal.h +++ b/src/meshlink_internal.h @@ -54,19 +54,14 @@ 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 *name; - char *appname; - dclass_t dclass; void *priv; + char *appname; + dev_class_t devclass; + char *confbase; meshlink_receive_cb_t receive_cb; @@ -74,10 +69,12 @@ struct meshlink_handle { meshlink_log_cb_t log_cb; meshlink_log_level_t log_level; + meshlink_channel_accept_cb_t channel_accept_cb; + pthread_t thread; bool threadstarted; pthread_mutex_t outpacketqueue_mutex; - pthread_mutex_t nodes_mutex; + pthread_mutex_t mesh_mutex; event_loop_t loop; listen_socket_t listen_socket[MAXSOCKETS]; int listen_sockets; @@ -148,6 +145,16 @@ struct meshlink_node { void *priv; }; +/// A channel. +struct meshlink_channel { + struct node_t *node; + void *priv; + + struct utcp_connection *c; + meshlink_channel_receive_cb_t receive_cb; + meshlink_channel_poll_cb_t poll_cb; +}; + /// Header for data packets routed between nodes typedef struct meshlink_packethdr { uint8_t destination[16]; @@ -155,9 +162,17 @@ typedef struct meshlink_packethdr { } __attribute__ ((__packed__)) meshlink_packethdr_t; extern void meshlink_send_from_queue(event_loop_t* el,meshlink_handle_t *mesh); +extern void update_node_status(meshlink_handle_t *mesh, struct node_t *n); extern meshlink_log_level_t global_log_level; extern meshlink_log_cb_t global_log_cb; -extern int weight_from_dclass(dclass_t dclass); +/// Device class traits +typedef struct { + unsigned int min_connects; + unsigned int max_connects; + int edge_weight; +} dev_class_traits_t; + +extern dev_class_traits_t dev_class_traits[]; #endif // MESHLINK_INTERNAL_H