X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=src%2Fmeshlink_internal.h;h=b31c16eb1cc3b92fef8bd1373f9c07573a11e2d9;hb=230b5907e242aa48bb8c8d09450fbd3767e9c24a;hp=63a71dc048dc0f81d693908dab280a396fbf9499;hpb=2200060c4eaadae36b8150aa33b0db7c0d74722f;p=meshlink diff --git a/src/meshlink_internal.h b/src/meshlink_internal.h index 63a71dc0..b31c16eb 100644 --- a/src/meshlink_internal.h +++ b/src/meshlink_internal.h @@ -1,6 +1,9 @@ +#ifndef MESHLINK_INTERNAL_H +#define MESHLINK_INTERNAL_H + /* meshlink_internal.h -- Internal parts of the public API. - Copyright (C) 2014 Guus Sliepen + Copyright (C) 2014-2019 Guus Sliepen This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by @@ -17,8 +20,9 @@ 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. */ -#ifndef MESHLINK_INTERNAL_H -#define MESHLINK_INTERNAL_H +#ifdef MESHLINK_H +#error You must not include both meshlink.h and meshlink_internal.h! +#endif #include "system.h" @@ -33,10 +37,17 @@ #define MAXSOCKETS 8 /* Probably overkill... */ -struct AvahiServer; -struct AvahiSServiceBrowser; -struct AvahiSimplePoll; -struct AvahiSEntryGroup; +static const char meshlink_invitation_label[] = "MeshLink invitation"; +static const char meshlink_tcp_label[] = "MeshLink TCP"; +static const char meshlink_udp_label[] = "MeshLink UDP"; + +#define MESHLINK_CONFIG_VERSION 1 +#define MESHLINK_INVITATION_VERSION 1 + +struct CattaServer; +struct CattaSServiceBrowser; +struct CattaSimplePoll; +struct CattaSEntryGroup; typedef struct listen_socket_t { struct io_t tcp; @@ -51,33 +62,43 @@ typedef enum proxytype_t { PROXY_SOCKS4A, PROXY_SOCKS5, PROXY_HTTP, - PROXY_EXEC, } proxytype_t; -typedef struct outpacketqueue { - meshlink_node_t *destination; - const void *data; - unsigned int len; -} outpacketqueue_t; +struct meshlink_open_params { + char *confbase; + char *appname; + char *name; + dev_class_t devclass; + + int netns; + + const void *key; + size_t keylen; +}; /// A handle for an instance of MeshLink. struct meshlink_handle { char *name; - char *appname; - dclass_t dclass; void *priv; + char *appname; + int32_t devclass; + char *confbase; + FILE *conffile; meshlink_receive_cb_t receive_cb; meshlink_node_status_cb_t node_status_cb; meshlink_log_cb_t log_cb; meshlink_log_level_t log_level; + meshlink_channel_accept_cb_t channel_accept_cb; + meshlink_node_duplicate_cb_t node_duplicate_cb; + meshlink_connection_try_cb_t connection_try_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; @@ -85,12 +106,12 @@ struct meshlink_handle { struct node_t *self; - struct splay_tree_t *config; struct splay_tree_t *edges; struct splay_tree_t *nodes; struct list_t *connections; struct list_t *outgoings; + struct list_t *submeshes; meshlink_queue_t outpacketqueue; @@ -112,15 +133,20 @@ struct meshlink_handle { char *proxypass; proxytype_t proxytype; + bool discovery; // Whether Catta is enabled or not bool localdiscovery; sockaddr_t localdiscovery_address; + bool default_blacklist; + hash_t *node_udp_cache; struct connection_t *everyone; + struct ecdsa *private_key; struct ecdsa *invitation_key; + int invitation_timeout; - int pinginterval; /* seconds between pings */ - int pingtimeout; /* seconds to wait for response */ + int pinginterval; /* seconds between pings */ + int pingtimeout; /* seconds to wait for response */ int maxtimeout; int sock; @@ -135,11 +161,15 @@ struct meshlink_handle { pthread_t discovery_thread; bool discovery_threadstarted; - struct AvahiServer *avahi_server; - struct AvahiSServiceBrowser *avahi_browser; - struct AvahiSimplePoll *avahi_poll; - struct AvahiSEntryGroup *avahi_group; - char* avahi_servicetype; + struct CattaServer *catta_server; + struct CattaSServiceBrowser *catta_browser; + struct CattaSimplePoll *catta_poll; + struct CattaSEntryGroup *catta_group; + char *catta_servicetype; + unsigned int catta_interfaces; + + int netns; + void *config_key; }; /// A handle for a MeshLink node. @@ -148,16 +178,43 @@ struct meshlink_node { void *priv; }; +/// A handle for a node Sub-Mesh. +struct meshlink_submesh { + const char *name; + 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]; uint8_t source[16]; -} __attribute__ ((__packed__)) meshlink_packethdr_t; +} __attribute__((__packed__)) meshlink_packethdr_t; -extern void meshlink_send_from_queue(event_loop_t* el,meshlink_handle_t *mesh); +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 check_port(meshlink_handle_t *mesh); +extern void handle_duplicate_node(meshlink_handle_t *mesh, struct node_t *n); +extern void handle_network_change(meshlink_handle_t *mesh, bool online); + +/// Device class traits +typedef struct { + unsigned int min_connects; + unsigned int max_connects; + int edge_weight; +} dev_class_traits_t; -extern int weight_from_dclass(dclass_t dclass); +extern dev_class_traits_t dev_class_traits[]; -#endif // MESHLINK_INTERNAL_H +#endif