167 int rc = msg_->
close ();
178 int rc = msg_->
close();
201 int rc = msg_->
init ();
212 if (!pipe_->
write (msg_)) {
std::vector< zmq::pipe_t * >::size_type size_type
int send_to_all(zmq::msg_t *msg_)
void swap(size_type index1_, size_type index2_)
void activated(zmq::pipe_t *pipe_)
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_)
size_type index(T *item_)
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_)