PGM: implement flow control

1 files changed, 9 insertions, 0 deletions

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;