diff options
author | Martin Hurton <hurtonm@gmail.com> | 2010-03-02 10:48:30 +0100 |
---|---|---|
committer | Martin Hurton <hurtonm@gmail.com> | 2010-03-12 11:07:38 +0100 |
commit | 06d7a447378c8e9f0805c219deaf8e7e7ef1eeb0 (patch) | |
tree | 5d06fda5d5cdb30b81c3f5712c1b07593ff0e645 /src/pub.hpp | |
parent | f9c84a1a689f4f64cfa45cb22d4f02ec246c7f93 (diff) |
Implement flow control for ZMQ_PUB sockets
Diffstat (limited to 'src/pub.hpp')
-rw-r--r-- | src/pub.hpp | 7 |
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&); }; |