X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=src%2Fprotocol.c;fp=src%2Fprotocol.c;h=fd180f4faafab84fd4c3bfedf0bf465dbf96b13c;hb=b1cae6a2011f704dc4d3b02972def561d5c6bcb9;hp=95f6aa39f49eda059094a615753ce417c33a43ed;hpb=8538d6c661a083774e5b54163eaf5cdbcadcda6d;p=meshlink diff --git a/src/protocol.c b/src/protocol.c index 95f6aa39..fd180f4f 100644 --- a/src/protocol.c +++ b/src/protocol.c @@ -181,13 +181,15 @@ static void free_past_request(past_request_t *r) { free(r); } +static const int request_timeout = 60; + static void age_past_requests(event_loop_t *loop, void *data) { (void)data; meshlink_handle_t *mesh = loop->data; int left = 0, deleted = 0; for splay_each(past_request_t, p, mesh->past_request_tree) { - if(p->firstseen + mesh->pinginterval <= mesh->loop.now.tv_sec) { + if(p->firstseen + request_timeout <= mesh->loop.now.tv_sec) { splay_delete_node(mesh->past_request_tree, node), deleted++; } else { left++;