diff options
| author | Garrett D'Amore <garrett@damore.org> | 2017-03-07 11:41:27 -0800 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2017-03-07 11:41:27 -0800 |
| commit | f5c259eec0cd3fa5cd623e159cbfec83b4a500d5 (patch) | |
| tree | 623e47d37a45968c9e06dc58223bf75abbabd6f0 /src/core/timer.c | |
| parent | f397fec0e0524ff73ee501642a5dca5cf22064e2 (diff) | |
| download | nng-f5c259eec0cd3fa5cd623e159cbfec83b4a500d5.tar.gz nng-f5c259eec0cd3fa5cd623e159cbfec83b4a500d5.tar.bz2 nng-f5c259eec0cd3fa5cd623e159cbfec83b4a500d5.zip | |
Req/Rep now callback driven.
Diffstat (limited to 'src/core/timer.c')
| -rw-r--r-- | src/core/timer.c | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/core/timer.c b/src/core/timer.c index 778a82b7..f64c1294 100644 --- a/src/core/timer.c +++ b/src/core/timer.c @@ -113,6 +113,10 @@ nni_timer_schedule(nni_timer_node *node, nni_time when) nni_mtx_lock(&timer->t_list_mx); + if (nni_list_active(&timer->t_entries, node)) { + nni_list_remove(&timer->t_entries, node); + } + srch = nni_list_first(&timer->t_entries); while ((srch != NULL) && (srch->t_expire < node->t_expire)) { srch = nni_list_next(&timer->t_entries, srch); |