30 #ifndef __ZMQ_DIST_HPP_INCLUDED__ 31 #define __ZMQ_DIST_HPP_INCLUDED__
std::vector< zmq::pipe_t * >::size_type size_type
int send_to_all(zmq::msg_t *msg_)
void activated(zmq::pipe_t *pipe_)
const dist_t & operator=(const dist_t &)
void match(zmq::pipe_t *pipe_)
pipes_t::size_type eligible
pipes_t::size_type matching
int send_to_matching(zmq::msg_t *msg_)
void attach(zmq::pipe_t *pipe_)
bool write(zmq::pipe_t *pipe_, zmq::msg_t *msg_)
pipes_t::size_type active
void pipe_terminated(zmq::pipe_t *pipe_)
void distribute(zmq::msg_t *msg_)
array_t< zmq::pipe_t, 2 > pipes_t