From f9521c6b6a35103c03b742a311a34d7b04da0b84 Mon Sep 17 00:00:00 2001
From: Martin Hurton <hurtonm@gmail.com>
Date: Tue, 2 Mar 2010 09:02:40 +0100
Subject: PGM: implement flow control

---
 src/pgm_receiver.hpp | 9 +++++++++
 1 file changed, 9 insertions(+)

(limited to 'src/pgm_receiver.hpp')

diff --git a/src/pgm_receiver.hpp b/src/pgm_receiver.hpp
index dd9402f..becdfce 100644
--- a/src/pgm_receiver.hpp
+++ b/src/pgm_receiver.hpp
@@ -98,6 +98,15 @@ namespace zmq
         //  Parent session.
         i_inout *inout;
 
+        //  Most recently used decoder.
+        zmq_decoder_t *mru_decoder;
+
+        //  Number of bytes not consumed by the decoder due to pipe overflow.
+        size_t pending_bytes;
+
+        //  Pointer to data still waiting to be processed by the decoder.
+        unsigned char *pending_ptr;
+
         //  Poll handle associated with PGM socket.
         handle_t socket_handle;
 
-- 
cgit v1.2.3