Implement flow control for ZMQ_PUB sockets

1 files changed, 7 insertions, 0 deletions

diff --git a/src/pub.hpp b/src/pub.hpp
index a85301f..3a4fe09 100644
--- a/src/pub.hpp
+++ b/src/pub.hpp
@@ -54,6 +54,13 @@ namespace zmq
         typedef yarray_t <class writer_t> out_pipes_t;
         out_pipes_t out_pipes;
 
+        //  Pointer to the pipe we are waiting for to became writable
+        //  again; NULL if tha last send operation was successful.
+        class writer_t *stalled_pipe;
+
+        //  Check whether we can write a message to all pipes.
+        bool check_write ();
+
         pub_t (const pub_t&);
         void operator = (const pub_t&);
     };