X-Git-Url: http://git.meshlink.io/?p=meshlink;a=blobdiff_plain;f=src%2Fnet.c;h=2ee8aee446bc1df899354fb1cb93c1373e7aa844;hp=020ffd4f75de85855620a169349216b9b6cf8efe;hb=8c8b506da9ce578fe6e6e406a91bbd21af13f7a3;hpb=6a0c9818677d1c5507bd8fa9d4378dbb324f6fbc diff --git a/src/net.c b/src/net.c index 020ffd4f..2ee8aee4 100644 --- a/src/net.c +++ b/src/net.c @@ -92,13 +92,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 +123,16 @@ static void timeout_handler(event_loop_t *loop, void *data) { } } + if(c->status.active && c->last_key_renewal + 3600 < mesh->loop.now.tv_sec) { + 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 +613,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); } @@ -626,6 +629,8 @@ static void periodic_handler(event_loop_t *loop, void *data) { sptps_stop(&n->sptps); n->status.waitingforkey = false; n->last_req_key = 0; + } else { + n->last_req_key = mesh->loop.now.tv_sec; } } }