X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=src%2Fprotocol.c;h=482808a7e71885c6cf37d24ce42444f9d18c8aac;hb=4c57e6902219ecca1872e18e34365d8e54a0f407;hp=b4cb5ad5e2af15ebdd8c83812e5f965ab05990ff;hpb=3bba8e95482de6f03d04dba4808e9add2071296b;p=meshlink diff --git a/src/protocol.c b/src/protocol.c index b4cb5ad5..482808a7 100644 --- a/src/protocol.c +++ b/src/protocol.c @@ -207,7 +207,7 @@ static void age_past_requests(event_loop_t *loop, void *data) { } if(left) { - timeout_set(&mesh->loop, &mesh->past_request_timeout, &(struct timeval) { + timeout_set(&mesh->loop, &mesh->past_request_timeout, &(struct timespec) { 10, prng(mesh, TIMER_FUDGE) }); } @@ -228,7 +228,7 @@ bool seen_request(meshlink_handle_t *mesh, const char *request) { new->firstseen = mesh->loop.now.tv_sec; if(!mesh->past_request_tree->head) { - timeout_set(&mesh->loop, &mesh->past_request_timeout, &(struct timeval) { + timeout_set(&mesh->loop, &mesh->past_request_timeout, &(struct timespec) { 10, prng(mesh, TIMER_FUDGE) }); } @@ -242,7 +242,7 @@ void init_requests(meshlink_handle_t *mesh) { assert(!mesh->past_request_tree); mesh->past_request_tree = splay_alloc_tree((splay_compare_t) past_request_compare, (splay_action_t) free_past_request); - timeout_add(&mesh->loop, &mesh->past_request_timeout, age_past_requests, NULL, &(struct timeval) { + timeout_add(&mesh->loop, &mesh->past_request_timeout, age_past_requests, NULL, &(struct timespec) { 0, 0 }); }