jessequ
/
AMQP-CPP
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Also start it again

This commit is contained in:
Raoul Wols 2021-09-16 12:31:23 +02:00
parent e36d8abcc9
commit 658da59a1b
No known key found for this signature in database
GPG Key ID: 9FFE06A0F6AAA2DF
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
include/amqpcpp/libev.h
View File

@ -267,9 +267,12 @@ private:
// sent only after _timout/2 seconds again _from now_ (no catching up) // sent only after _timout/2 seconds again _from now_ (no catching up)
_next = now + std::max(_timeout / 2, 1); _next = now + std::max(_timeout / 2, 1);
} }
// reset the timer to trigger again later // reset the timer to trigger again later
ev_timer_set(&_timer, std::min(_next, _expire) - now, 0.0); ev_timer_set(&_timer, std::min(_next, _expire) - now, 0.0);
// and start it again
ev_timer_start(_loop, &_timer);
// and because the timer is running again, we restore the refcounter // and because the timer is running again, we restore the refcounter
ev_unref(_loop); ev_unref(_loop);