summaryrefslogtreecommitdiff
path: root/src/pgm_receiver.hpp
diff options
context:
space:
mode:
authorSteven McCoy <steven.mccoy@miru.hk>2010-09-28 22:46:56 +0200
committerMartin Sustrik <sustrik@250bpm.com>2010-09-30 09:11:51 +0200
commitd14be62499478f31cf641399982ecdf4f6f158c4 (patch)
tree5e9e3d5b5097c1a5942180d0bf9c20569c8e3797 /src/pgm_receiver.hpp
parent96d85b20982926e60d5065cba3203971c9eeed63 (diff)
more fixes to (e)pgm transport
Diffstat (limited to 'src/pgm_receiver.hpp')
-rw-r--r--src/pgm_receiver.hpp7
1 files changed, 7 insertions, 0 deletions
diff --git a/src/pgm_receiver.hpp b/src/pgm_receiver.hpp
index f32d37e..627a658 100644
--- a/src/pgm_receiver.hpp
+++ b/src/pgm_receiver.hpp
@@ -59,9 +59,16 @@ namespace zmq
// i_poll_events interface implementation.
void in_event ();
+ void timer_event (int token);
private:
+ // RX timeout timer ID.
+ enum {rx_timer_id = 0xa1};
+
+ // RX timer is running.
+ bool has_rx_timer;
+
// If joined is true we are already getting messages from the peer.
// It it's false, we are getting data but still we haven't seen
// beginning of a message.