summaryrefslogtreecommitdiff
path: root/src/lb.hpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/lb.hpp')
-rw-r--r--src/lb.hpp13
1 files changed, 9 insertions, 4 deletions
diff --git a/src/lb.hpp b/src/lb.hpp
index 526a727..e69385e 100644
--- a/src/lb.hpp
+++ b/src/lb.hpp
@@ -21,25 +21,30 @@
#define __ZMQ_LB_HPP_INCLUDED__
#include "yarray.hpp"
+#include "pipe.hpp"
namespace zmq
{
// Class manages a set of outbound pipes. On send it load balances
// messages fairly among the pipes.
- class lb_t
+ class lb_t : public i_writer_events
{
public:
lb_t ();
~lb_t ();
- void attach (class writer_t *pipe_);
- void detach (class writer_t *pipe_);
- void revive (class writer_t *pipe_);
+ void attach (writer_t *pipe_);
+ void term_pipes ();
+ bool has_pipes ();
int send (zmq_msg_t *msg_, int flags_);
bool has_out ();
+ // i_writer_events interface implementation.
+ void activated (writer_t *pipe_);
+ void terminated (writer_t *pipe_);
+
private:
// List of outbound pipes.