X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=src%2Fnet.c;h=0aa20439a87de39d518cb130d7c7d4852be27d9f;hb=5d583af29b3ba76f9acaeb77c0e0457268776dcb;hp=85cbf3d442fd1e60e466ca70351bbddeb1d2a126;hpb=af87825c8c8479c576af390adae502b2e5bf6e5f;p=meshlink diff --git a/src/net.c b/src/net.c index 85cbf3d4..0aa20439 100644 --- a/src/net.c +++ b/src/net.c @@ -22,6 +22,7 @@ #include "utils.h" #include "conf.h" #include "connection.h" +#include "devtools.h" #include "graph.h" #include "logger.h" #include "meshlink_internal.h" @@ -92,13 +93,6 @@ void terminate_connection(meshlink_handle_t *mesh, connection_t *c, bool report) if(outgoing) { do_outgoing_connection(mesh, outgoing); } - -#ifndef HAVE_MINGW - /* Clean up dead proxy processes */ - - while(waitpid(-1, NULL, WNOHANG) > 0); - -#endif } /* @@ -130,6 +124,18 @@ static void timeout_handler(event_loop_t *loop, void *data) { } } + if(c->status.active && c->last_key_renewal + 3600 < mesh->loop.now.tv_sec) { + devtool_sptps_renewal_probe((meshlink_node_t *)c->node); + + if(!sptps_force_kex(&c->sptps)) { + logger(mesh, MESHLINK_ERROR, "SPTPS key renewal for connection with %s failed", c->name); + terminate_connection(mesh, c, true); + continue; + } else { + c->last_key_renewal = mesh->loop.now.tv_sec; + } + } + if(c->last_ping_time + pingtimeout <= mesh->loop.now.tv_sec) { if(c->status.active) { if(c->status.pinged) { @@ -610,7 +616,7 @@ static void periodic_handler(event_loop_t *loop, void *data) { for splay_each(node_t, n, mesh->nodes) { if(n->status.dirty) { - if(node_write_config(mesh, n)) { + if(!node_write_config(mesh, n)) { logger(mesh, MESHLINK_DEBUG, "Could not update %s", n->name); } @@ -619,6 +625,7 @@ static void periodic_handler(event_loop_t *loop, void *data) { if(n->status.validkey && n->last_req_key + 3600 < mesh->loop.now.tv_sec) { logger(mesh, MESHLINK_DEBUG, "SPTPS key renewal for node %s", n->name); + devtool_sptps_renewal_probe((meshlink_node_t *)n); if(!sptps_force_kex(&n->sptps)) { logger(mesh, MESHLINK_ERROR, "SPTPS key renewal for node %s failed", n->name);