X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=src%2Fmeshlink_internal.h;h=7976a55a7bb21a6be21c683b0e8b317df9dce895;hb=3e8459f81c4e7e18d645cc2f4b7e24900ed33e04;hp=321a1f356500637de994819550517657931b691c;hpb=5a7627ddb41361847ce39be96dafedcb3c87f27c;p=meshlink diff --git a/src/meshlink_internal.h b/src/meshlink_internal.h index 321a1f35..7976a55a 100644 --- a/src/meshlink_internal.h +++ b/src/meshlink_internal.h @@ -22,11 +22,30 @@ #include "system.h" -#include "node.h" +#include "event.h" +#include "hash.h" +#include "logger.h" #include "meshlink.h" -#include "splay_tree.h" +#include "sockaddr.h" +#include "sptps.h" -#define MAXSOCKETS 16 +#define MAXSOCKETS 8 /* Probably overkill... */ + +typedef struct listen_socket_t { + struct io_t tcp; + struct io_t udp; + sockaddr_t sa; + bool bindto; +} listen_socket_t; + +typedef enum proxytype_t { + PROXY_NONE = 0, + PROXY_SOCKS4, + PROXY_SOCKS4A, + PROXY_SOCKS5, + PROXY_HTTP, + PROXY_EXEC, +} proxytype_t; /// A handle for an instance of MeshLink. struct meshlink_handle { @@ -39,15 +58,55 @@ struct meshlink_handle { meshlink_log_level_t log_level; pthread_t thread; + event_loop_t loop; listen_socket_t listen_socket[MAXSOCKETS]; + int listen_sockets; + + 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; - node_t *myself; + int contradicting_add_edge; + int contradicting_del_edge; + int sleeptime; + time_t last_config_check; + timeout_t pingtimer; + timeout_t periodictimer; - splay_tree_t *config; - splay_tree_t *edges; - splay_tree_t *nodes; + char *myport; - list_t *outgoing_connections; + char *proxyhost; + char *proxyport; + char *proxyuser; + char *proxypass; + proxytype_t proxytype; + + bool localdiscovery; + sockaddr_t localdiscovery_address; + + hash_t *node_udp_cache; + struct connection_t *everyone; + struct ecdsa *invitation_key; + + debug_t debug_level; + int pinginterval; /* seconds between pings */ + int pingtimeout; /* seconds to wait for response */ + int maxtimeout; + + int sock; + sptps_t sptps; + char cookie[18], hash[18]; + char *data; + size_t thedatalen; + bool success; + char line[4096]; + char buffer[4096]; + size_t blen; }; /// A handle for a MeshLink node. @@ -56,4 +115,10 @@ struct meshlink_node { void *priv; }; +/// Header for data packets routed between nodes +typedef struct meshlink_packethdr { + uint8_t destination[16]; + uint8_t source[16]; +} __attribute__ ((__packed__)) meshlink_packethdr_t; + #endif // MESHLINK_INTERNAL_H