X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=src%2Fmeshlink_internal.h;h=a96050bfff1636e0ebc845e738ce0e2f88846a00;hb=6837594e6cf27ec8128b4dd125e6f68a0888602c;hp=8c67aa3e4daf3c2adc0aaa93f74e4eaa3c7d0223;hpb=11d4da4957cb576abe9ee79c9893809a34f1f3d9;p=meshlink diff --git a/src/meshlink_internal.h b/src/meshlink_internal.h index 8c67aa3e..a96050bf 100644 --- a/src/meshlink_internal.h +++ b/src/meshlink_internal.h @@ -55,17 +55,8 @@ typedef struct listen_socket_t { struct io_t udp; sockaddr_t sa; sockaddr_t broadcast_sa; - bool bindto; } listen_socket_t; -typedef enum proxytype_t { - PROXY_NONE = 0, - PROXY_SOCKS4, - PROXY_SOCKS4A, - PROXY_SOCKS5, - PROXY_HTTP, -} proxytype_t; - struct meshlink_open_params { char *confbase; char *appname; @@ -100,6 +91,7 @@ struct meshlink_handle { struct node_t *self; meshlink_log_cb_t log_cb; meshlink_log_level_t log_level; + void *packet; // The most important network-related members come first int reachable; @@ -128,7 +120,6 @@ struct meshlink_handle { int contradicting_del_edge; int sleeptime; time_t connection_burst_time; - time_t last_config_check; time_t last_hard_try; time_t last_unreachable; timeout_t pingtimer; @@ -175,6 +166,7 @@ struct meshlink_handle { FILE *lockfile; void *config_key; char *external_address_url; + struct list_t *invitation_addresses; // Thread management pthread_t thread; @@ -193,12 +185,15 @@ struct meshlink_handle { char *catta_servicetype; unsigned int catta_interfaces; - // Proxy configuration, currently not exposed. - char *proxyhost; - char *proxyport; - char *proxyuser; - char *proxypass; - proxytype_t proxytype; + // PFROUTE + io_t pfroute_io; + + // ADNS + pthread_t adns_thread; + pthread_cond_t adns_cond; + meshlink_queue_t adns_queue; + meshlink_queue_t adns_done_queue; + signal_t adns_signal; }; /// A handle for a MeshLink node. @@ -231,6 +226,7 @@ typedef struct meshlink_aio_buffer { struct meshlink_channel { struct node_t *node; void *priv; + bool in_callback; struct utcp_connection *c; meshlink_aio_buffer_t *aio_send; @@ -245,14 +241,14 @@ typedef struct meshlink_packethdr { uint8_t source[16]; } __attribute__((__packed__)) meshlink_packethdr_t; -extern void meshlink_send_from_queue(event_loop_t *loop, void *mesh); -extern void update_node_status(meshlink_handle_t *mesh, struct node_t *n); -extern void update_node_pmtu(meshlink_handle_t *mesh, struct node_t *n); +void meshlink_send_from_queue(event_loop_t *loop, void *mesh); +void update_node_status(meshlink_handle_t *mesh, struct node_t *n); +void update_node_pmtu(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 void handle_duplicate_node(meshlink_handle_t *mesh, struct node_t *n); -extern void handle_network_change(meshlink_handle_t *mesh, bool online); -extern void call_error_cb(meshlink_handle_t *mesh, meshlink_errno_t meshlink_errno); +void handle_duplicate_node(meshlink_handle_t *mesh, struct node_t *n); +void handle_network_change(meshlink_handle_t *mesh, bool online); +void call_error_cb(meshlink_handle_t *mesh, meshlink_errno_t meshlink_errno); /// Per-instance PRNG static inline int prng(meshlink_handle_t *mesh, uint64_t max) { @@ -260,6 +256,6 @@ static inline int prng(meshlink_handle_t *mesh, uint64_t max) { } /// Fudge value of ~0.1 seconds, in microseconds. -static const unsigned int TIMER_FUDGE = 0x20000; +static const unsigned int TIMER_FUDGE = 0x8000000; #endif