diff options
author | Martin Sustrik <sustrik@250bpm.com> | 2010-03-20 19:51:29 +0100 |
---|---|---|
committer | Martin Sustrik <sustrik@250bpm.com> | 2010-03-20 19:51:29 +0100 |
commit | 0a53ff7b9f8a212793c540535c322bfaa93d3430 (patch) | |
tree | 65c55537fa7855512a04adecd2c0df8c8d0572ba /src/pub.hpp | |
parent | f031677100b41347e09932fc973040097a2187e4 (diff) | |
parent | 93bdb792a92b9bd235c7be47a13febf429568301 (diff) |
Merge branch 'master' of git@github.com:sustrik/zeromq2
Diffstat (limited to 'src/pub.hpp')
-rw-r--r-- | src/pub.hpp | 17 |
1 files changed, 9 insertions, 8 deletions
diff --git a/src/pub.hpp b/src/pub.hpp index 89c1cd1..ac3924a 100644 --- a/src/pub.hpp +++ b/src/pub.hpp @@ -49,16 +49,17 @@ namespace zmq private: - // Outbound pipes, i.e. those the socket is sending messages to. - typedef yarray_t <class writer_t> out_pipes_t; - out_pipes_t out_pipes; + // Write the message to the pipe. Make the pipe inactive if writing + // fails. In such a case false is returned. + bool write (class writer_t *pipe_, zmq_msg_t *msg_); - // 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; + // Outbound pipes, i.e. those the socket is sending messages to. + typedef yarray_t <class writer_t> pipes_t; + pipes_t pipes; - // Check whether we can write a message to all pipes. - bool check_write (); + // Number of active pipes. All the active pipes are located at the + // beginning of the pipes array. + pipes_t::size_type active; pub_t (const pub_t&); void operator = (const pub_t&); |