![]() |
libzmq master
The Intelligent Transport Layer
|
#include <dist.hpp>
Public Member Functions | |
dist_t () | |
~dist_t () | |
void | activated (class pipe_t *pipe_) |
void | attach (class pipe_t *pipe_) |
bool | has_out () |
void | match (class pipe_t *pipe_) |
int | send_to_all (class msg_t *msg_, int flags_) |
int | send_to_matching (class msg_t *msg_, int flags_) |
void | terminated (class pipe_t *pipe_) |
void | unmatch () |
Private Types | |
typedef array_t< class pipe_t, 2 > | pipes_t |
Private Member Functions | |
dist_t (const dist_t &) | |
void | distribute (class msg_t *msg_, int flags_) |
const dist_t & | operator= (const dist_t &) |
bool | write (class pipe_t *pipe_, class msg_t *msg_) |
Private Attributes | |
pipes_t::size_type | active |
pipes_t::size_type | eligible |
pipes_t::size_type | matching |
bool | more |
pipes_t | pipes |
typedef array_t<class pipe_t, 2> zmq::dist_t::pipes_t [private] |
zmq::dist_t::~dist_t | ( | ) |
Definition at line 36 of file dist.cpp.
References zmq_assert.
zmq::dist_t::dist_t | ( | const dist_t & | ) | [private] |
void zmq::dist_t::distribute | ( | class msg_t * | msg_, |
int | flags_ | ||
) | [private] |
Definition at line 129 of file dist.cpp.
References zmq::msg_t::add_refs(), zmq::msg_t::close(), errno_assert, zmq::msg_t::init(), zmq::msg_t::is_vsm(), zmq::msg_t::rm_refs(), unlikely, and zmq_assert.
void zmq::dist_t::match | ( | class pipe_t * | pipe_ | ) |
Definition at line 59 of file dist.cpp.
Referenced by zmq::xpub_t::mark_as_matching().
int zmq::dist_t::send_to_all | ( | class msg_t * | msg_, |
int | flags_ | ||
) |
int zmq::dist_t::send_to_matching | ( | class msg_t * | msg_, |
int | flags_ | ||
) |
Definition at line 112 of file dist.cpp.
References zmq::msg_t::flags, and zmq::msg_t::more.
Definition at line 173 of file dist.cpp.
References zmq::msg_t::flags, zmq::pipe_t::flush(), zmq::msg_t::more, and zmq::pipe_t::write().
pipes_t::size_type zmq::dist_t::active [private] |
pipes_t::size_type zmq::dist_t::eligible [private] |
pipes_t::size_type zmq::dist_t::matching [private] |
bool zmq::dist_t::more [private] |
pipes_t zmq::dist_t::pipes [private] |