diff options
| author | Martin Hurton <hurtonm@gmail.com> | 2010-03-02 22:23:34 +0100 |
|---|---|---|
| committer | Martin Hurton <hurtonm@gmail.com> | 2010-03-12 11:07:39 +0100 |
| commit | 923609b0922c3bf07f16c8c99aba4fe98f08ef60 (patch) | |
| tree | df52d53536c6ed2ea8487f03137cf6bc66320444 /src/req.hpp | |
| parent | 42e575cb6b62fe1e5d12d2e4fb5c6874d47eb57e (diff) | |
Implement flow control for ZMQ_REQ sockets
Diffstat (limited to 'src/req.hpp')
| -rw-r--r-- | src/req.hpp | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/req.hpp b/src/req.hpp index 4058b08..531c06f 100644 --- a/src/req.hpp +++ b/src/req.hpp @@ -64,6 +64,9 @@ namespace zmq typedef yarray_t <class reader_t> in_pipes_t; in_pipes_t in_pipes; + // Number of active pipes. + size_t active; + // Req_t load-balances the requests - 'current' points to the session // that's processing the request at the moment. out_pipes_t::size_type current; |