static void node_status_cb(meshlink_handle_t *mesh, meshlink_node_t *node,
bool reachable);
static void channel_receive_cb(meshlink_handle_t *mesh, meshlink_channel_t *channel, const void *dat, size_t len);
-static bool channel_accept(meshlink_handle_t *mesh, meshlink_channel_t *channel, uint16_t port, const void *dat, size_t len);
pmtu_attr_t node_pmtu[2];
static time_t node_shutdown_time = 0;
}
// Node status callback
-static void node_status_cb(meshlink_handle_t *mesh, meshlink_node_t *node,
- bool reachable) {
+static void node_status_cb(meshlink_handle_t *mesh, meshlink_node_t *node, bool reachable) {
+ (void)mesh;
+
// Signal pthread_cond_wait if peer is reachable
if(!strcasecmp(node->name, "peer") && reachable) {
set_sync_flag(&peer_reachable, true);
return;
}
-static bool channel_accept(meshlink_handle_t *mesh, meshlink_channel_t *channel, uint16_t port, const void *dat, size_t len) {
- (void)dat;
- (void)len;
-
- assert(port == CHANNEL_PORT);
-
- // If the channel is from peer node set receive callback for it else reject the channel
- if(!strcmp(channel->node->name, "peer")) {
- meshlink_set_channel_receive_cb(mesh, channel, channel_receive_cb);
- mesh->priv = channel;
-
- return true;
- }
-
- return false;
-}
-
/* channel receive callback */
static void channel_receive_cb(meshlink_handle_t *mesh, meshlink_channel_t *channel, const void *dat, size_t len) {
if(len == 0) {
cur_time = time(NULL);
assert(cur_time != -1);
- bool mtu_probe = false;
-
if(node_shutdown_time && cur_time >= node_shutdown_time) {
test_pmtu_nut_running = false;
}
node_pmtu[i].mtu_discovery.count += 1;
node_pmtu[i].mtu_size = mtu_len;
- } else if(sscanf(text, "SPTPS key exchange with %s succesful", node_name) == 1) {
+ } else if(sscanf(text, "SPTPS key exchange with %s successful", node_name) == 1) {
find_node_index(i, node_name);
node_pmtu[i].mtu_start.time = cur_time;
node_pmtu[i].mtu_start.count += 1;
print_mtu_calc(node_pmtu[NODE_PMTU_PEER]);
fprintf(stderr, "\nNODE_PMTU_RELAY :\n");
print_mtu_calc(node_pmtu[NODE_PMTU_RELAY]);
+
+ return NULL;
}