From 923609b0922c3bf07f16c8c99aba4fe98f08ef60 Mon Sep 17 00:00:00 2001 From: Martin Hurton Date: Tue, 2 Mar 2010 22:23:34 +0100 Subject: Implement flow control for ZMQ_REQ sockets --- src/req.hpp | 3 +++ 1 file changed, 3 insertions(+) (limited to 'src/req.hpp') 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 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; -- cgit v1.2.3