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

fix timer that expired too early (fix #272)

This commit is contained in:
Emiel Bruijntjes 2018-12-17 16:11:53 +01:00
parent 1256c82d60
commit 5d1d2c2852
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
include/amqpcpp/libev.h
View File

@ -193,7 +193,7 @@ private:
/**
* Interval between heartbeats (we should send every interval / 2 a new heartbeat)
* Value zero means heartbeats are disabled.
* Value zero means heartbeats are disabled, or not yet negotiated.
* @var uint16_t
*/
uint16_t _interval = 0;
@ -270,7 +270,7 @@ private:
virtual void onActive(int fd, int events) override
{
// if the server is readable, we have some extra time before it expires
if (events & EV_READ) _expire = ev_now(_loop) + _interval;
if (_interval != 0 && (events & EV_READ)) _expire = ev_now(_loop) + _interval;
// pass on to the connection
_connection->process(fd, events);