libzmq  master
ZeroMQ C++ Core Engine (LIBZMQ)
Classes | Public Member Functions | Protected Member Functions | Private Types | Private Member Functions | Private Attributes | List of all members
zmq::router_t Class Reference

#include <router.hpp>

Inheritance diagram for zmq::router_t:
Inheritance graph
[legend]
Collaboration diagram for zmq::router_t:
Collaboration graph
[legend]

Classes

struct  outpipe_t
 

Public Member Functions

 router_t (zmq::ctx_t *parent_, uint32_t tid_, int sid)
 
 ~router_t ()
 
void xattach_pipe (zmq::pipe_t *pipe_, bool subscribe_to_all_)
 
bool xhas_in ()
 
bool xhas_out ()
 
void xpipe_terminated (zmq::pipe_t *pipe_)
 
void xread_activated (zmq::pipe_t *pipe_)
 
int xrecv (zmq::msg_t *msg_)
 
int xsend (zmq::msg_t *msg_)
 
int xsetsockopt (int option_, const void *optval_, size_t optvallen_)
 
void xwrite_activated (zmq::pipe_t *pipe_)
 
- Public Member Functions inherited from zmq::socket_base_t
int add_signaler (signaler_t *s)
 
int bind (const char *addr_)
 
bool check_tag ()
 
int close ()
 
int connect (const char *addr_)
 
void event_accept_failed (const std::string &addr_, int err_)
 
void event_accepted (const std::string &addr_, int fd_)
 
void event_bind_failed (const std::string &addr_, int err_)
 
void event_close_failed (const std::string &addr_, int fd_)
 
void event_closed (const std::string &addr_, int fd_)
 
void event_connect_delayed (const std::string &addr_, int err_)
 
void event_connect_retried (const std::string &addr_, int interval_)
 
void event_connected (const std::string &addr_, int fd_)
 
void event_disconnected (const std::string &addr_, int fd_)
 
void event_listening (const std::string &addr_, int fd_)
 
i_mailbox * get_mailbox ()
 
int getsockopt (int option_, void *optval_, size_t *optvallen_)
 
bool has_in ()
 
bool has_out ()
 
void hiccuped (pipe_t *pipe_)
 
void in_event ()
 
int join (const char *group)
 
int leave (const char *group)
 
void lock ()
 
int monitor (const char *endpoint_, int events_)
 
void out_event ()
 
void pipe_terminated (pipe_t *pipe_)
 
void read_activated (pipe_t *pipe_)
 
int recv (zmq::msg_t *msg_, int flags_)
 
int remove_signaler (signaler_t *s)
 
int send (zmq::msg_t *msg_, int flags_)
 
int setsockopt (int option_, const void *optval_, size_t optvallen_)
 
void start_reaping (poller_t *poller_)
 
void stop ()
 
int term_endpoint (const char *addr_)
 
void timer_event (int id_)
 
void unlock ()
 
void write_activated (pipe_t *pipe_)
 
- Public Member Functions inherited from zmq::own_t
 own_t (zmq::ctx_t *parent_, uint32_t tid_)
 
 own_t (zmq::io_thread_t *io_thread_, const options_t &options_)
 
void inc_seqnum ()
 
void register_term_acks (int count_)
 
void unregister_term_ack ()
 
- Public Member Functions inherited from zmq::object_t
 object_t (zmq::ctx_t *ctx_, uint32_t tid_)
 
 object_t (object_t *parent_)
 
virtual ~object_t ()
 
ctx_t * get_ctx ()
 
uint32_t get_tid ()
 
void process_command (zmq::command_t &cmd_)
 
void send_bind (zmq::own_t *destination_, zmq::pipe_t *pipe_, bool inc_seqnum_=true)
 
void send_inproc_connected (zmq::socket_base_t *socket_)
 
void set_tid (uint32_t id)
 
- Public Member Functions inherited from zmq::array_item_t<>
 array_item_t ()
 
virtual ~array_item_t ()
 
int get_array_index ()
 
void set_array_index (int index_)
 
- Public Member Functions inherited from zmq::i_poll_events
virtual ~i_poll_events ()
 
- Public Member Functions inherited from zmq::i_pipe_events
virtual ~i_pipe_events ()
 

Protected Member Functions

blob_t get_credential () const
 
int rollback ()
 
- Protected Member Functions inherited from zmq::socket_base_t
 socket_base_t (zmq::ctx_t *parent_, uint32_t tid_, int sid_, bool thread_safe_=false)
 
virtual ~socket_base_t ()
 
void monitor_event (int event_, int value_, const std::string &addr_)
 
void process_destroy ()
 
void stop_monitor (bool send_monitor_stopped_event_=true)
 
virtual void xhiccuped (pipe_t *pipe_)
 
virtual int xjoin (const char *group_)
 
virtual int xleave (const char *group_)
 
- Protected Member Functions inherited from zmq::own_t
virtual ~own_t ()
 
bool is_terminating ()
 
void launch_child (own_t *object_)
 
void term_child (own_t *object_)
 
void terminate ()
 
- Protected Member Functions inherited from zmq::object_t
zmq::io_thread_t * choose_io_thread (uint64_t affinity_)
 
void connect_pending (const char *addr_, zmq::socket_base_t *bind_socket_)
 
void destroy_socket (zmq::socket_base_t *socket_)
 
zmq::endpoint_t find_endpoint (const char *addr_)
 
void log (const char *format_,...)
 
void pend_connection (const std::string &addr_, const endpoint_t &endpoint, pipe_t **pipes_)
 
virtual void process_activate_read ()
 
virtual void process_activate_write (uint64_t msgs_read_)
 
virtual void process_attach (zmq::i_engine *engine_)
 
virtual void process_hiccup (void *pipe_)
 
virtual void process_pipe_term ()
 
virtual void process_pipe_term_ack ()
 
virtual void process_plug ()
 
virtual void process_reap (zmq::socket_base_t *socket_)
 
virtual void process_reaped ()
 
int register_endpoint (const char *addr_, const zmq::endpoint_t &endpoint_)
 
void send_activate_read (zmq::pipe_t *destination_)
 
void send_activate_write (zmq::pipe_t *destination_, uint64_t msgs_read_)
 
void send_attach (zmq::session_base_t *destination_, zmq::i_engine *engine_, bool inc_seqnum_=true)
 
void send_done ()
 
void send_hiccup (zmq::pipe_t *destination_, void *pipe_)
 
void send_own (zmq::own_t *destination_, zmq::own_t *object_)
 
void send_pipe_term (zmq::pipe_t *destination_)
 
void send_pipe_term_ack (zmq::pipe_t *destination_)
 
void send_plug (zmq::own_t *destination_, bool inc_seqnum_=true)
 
void send_reap (zmq::socket_base_t *socket_)
 
void send_reaped ()
 
void send_stop ()
 
void send_term (zmq::own_t *destination_, int linger_)
 
void send_term_ack (zmq::own_t *destination_)
 
void send_term_req (zmq::own_t *destination_, zmq::own_t *object_)
 
int unregister_endpoint (const std::string &addr_, socket_base_t *socket_)
 
void unregister_endpoints (zmq::socket_base_t *socket_)
 

Private Types

typedef std::map< blob_t, outpipe_t > outpipes_t
 

Private Member Functions

 router_t (const router_t &)
 
bool identify_peer (pipe_t *pipe_)
 
const router_t & operator= (const router_t &)
 

Private Attributes

std::set< pipe_t * > anonymous_pipes
 
zmq::pipe_t * current_in
 
zmq::pipe_t * current_out
 
fq_t fq
 
bool handover
 
bool identity_sent
 
bool mandatory
 
bool more_in
 
bool more_out
 
uint32_t next_rid
 
outpipes_t outpipes
 
bool prefetched
 
msg_t prefetched_id
 
msg_t prefetched_msg
 
bool probe_router
 
bool raw_socket
 
bool terminate_current_in
 

Additional Inherited Members

- Static Public Member Functions inherited from zmq::socket_base_t
static socket_base_t * create (int type_, zmq::ctx_t *parent_, uint32_t tid_, int sid_)
 
- Protected Attributes inherited from zmq::socket_base_t
std::string connect_rid
 
- Protected Attributes inherited from zmq::own_t
options_t options
 

Detailed Description

Definition at line 49 of file router.hpp.

Member Typedef Documentation

typedef std::map<blob_t, outpipe_t> zmq::router_t::outpipes_t
private

Definition at line 114 of file router.hpp.

Constructor & Destructor Documentation

zmq::router_t::router_t ( zmq::ctx_t *  parent_,
uint32_t  tid_,
int  sid 
)

Definition at line 39 of file router.cpp.

References zmq::msg_t::init(), zmq::own_t::options, prefetched_id, prefetched_msg, zmq::options_t::raw_socket, zmq::options_t::recv_identity, zmq::options_t::type, and ZMQ_ROUTER.

Here is the call graph for this function:

zmq::router_t::~router_t ( )

Definition at line 63 of file router.cpp.

References anonymous_pipes, zmq::msg_t::close(), outpipes, prefetched_id, prefetched_msg, and zmq_assert.

Here is the call graph for this function:

zmq::router_t::router_t ( const router_t &  )
private

Member Function Documentation

zmq::blob_t zmq::router_t::get_credential ( ) const
protectedvirtual

Reimplemented from zmq::socket_base_t.

Definition at line 420 of file router.cpp.

References fq, and zmq::fq_t::get_credential().

Here is the call graph for this function:

bool zmq::router_t::identify_peer ( pipe_t *  pipe_)
private

Definition at line 425 of file router.cpp.

References zmq::pipe_t::active, zmq::msg_t::close(), zmq::socket_base_t::connect_rid, current_in, zmq::msg_t::data, handover, zmq::msg_t::init(), next_rid, zmq::own_t::options, outpipes, zmq::router_t::outpipe_t::pipe, zmq::put_uint32(), zmq::options_t::raw_socket, zmq::pipe_t::read(), zmq::pipe_t::set_identity(), zmq::msg_t::size, zmq::pipe_t::terminate(), terminate_current_in, and zmq_assert.

Referenced by xattach_pipe(), and xread_activated().

Here is the call graph for this function:

Here is the caller graph for this function:

const router_t& zmq::router_t::operator= ( const router_t &  )
private
int zmq::router_t::rollback ( void  )
protected

Definition at line 361 of file router.cpp.

References current_out, more_out, and zmq::pipe_t::rollback().

Referenced by zmq::rep_t::xrecv().

Here is the call graph for this function:

Here is the caller graph for this function:

void zmq::router_t::xattach_pipe ( zmq::pipe_t *  pipe_,
bool  subscribe_to_all_ 
)
virtual

Implements zmq::socket_base_t.

Definition at line 71 of file router.cpp.

References anonymous_pipes, zmq::fq_t::attach(), zmq::msg_t::close(), errno_assert, zmq::pipe_t::flush(), fq, identify_peer(), zmq::msg_t::init(), LIBZMQ_UNUSED, probe_router, zmq::pipe_t::write(), and zmq_assert.

Here is the call graph for this function:

bool zmq::router_t::xhas_in ( )
virtual

Reimplemented from zmq::socket_base_t.

Definition at line 371 of file router.cpp.

References current_in, zmq::msg_t::data, errno_assert, fq, zmq::pipe_t::get_identity(), identity_sent, zmq::msg_t::init_size(), zmq::msg_t::is_identity(), zmq::msg_t::more, more_in, prefetched, prefetched_id, prefetched_msg, zmq::fq_t::recvpipe(), zmq::msg_t::set_flags(), and zmq_assert.

Referenced by zmq::rep_t::xhas_in().

Here is the call graph for this function:

Here is the caller graph for this function:

bool zmq::router_t::xhas_out ( )
virtual

Reimplemented from zmq::socket_base_t.

Definition at line 412 of file router.cpp.

Referenced by zmq::rep_t::xhas_out().

Here is the caller graph for this function:

void zmq::router_t::xpipe_terminated ( zmq::pipe_t *  pipe_)
virtual

Implements zmq::socket_base_t.

Definition at line 152 of file router.cpp.

References anonymous_pipes, current_out, fq, zmq::pipe_t::get_identity(), outpipes, zmq::fq_t::pipe_terminated(), and zmq_assert.

Here is the call graph for this function:

void zmq::router_t::xread_activated ( zmq::pipe_t *  pipe_)
virtual

Reimplemented from zmq::socket_base_t.

Definition at line 167 of file router.cpp.

References zmq::fq_t::activated(), anonymous_pipes, zmq::fq_t::attach(), fq, and identify_peer().

Here is the call graph for this function:

int zmq::router_t::xrecv ( zmq::msg_t *  msg_)
virtual

Reimplemented from zmq::socket_base_t.

Definition at line 288 of file router.cpp.

References current_in, zmq::msg_t::data, errno_assert, zmq::msg_t::flags, fq, zmq::pipe_t::get_identity(), identity_sent, zmq::msg_t::init_size(), zmq::msg_t::is_identity(), zmq::msg_t::metadata, zmq::msg_t::more, more_in, zmq::msg_t::move(), prefetched, prefetched_id, prefetched_msg, zmq::fq_t::recvpipe(), zmq::msg_t::set_flags(), zmq::msg_t::set_metadata(), zmq::pipe_t::terminate(), terminate_current_in, and zmq_assert.

Referenced by zmq::rep_t::xrecv().

Here is the call graph for this function:

Here is the caller graph for this function:

int zmq::router_t::xsend ( zmq::msg_t *  msg_)
virtual

Reimplemented from zmq::socket_base_t.

Definition at line 193 of file router.cpp.

References zmq::pipe_t::active, zmq::pipe_t::check_write(), zmq::msg_t::close(), current_out, zmq::msg_t::data, EHOSTUNREACH, errno_assert, zmq::msg_t::flags, zmq::pipe_t::flush(), zmq::msg_t::init(), mandatory, zmq::msg_t::more, more_out, zmq::own_t::options, outpipes, raw_socket, zmq::options_t::raw_socket, zmq::msg_t::reset_flags(), zmq::msg_t::size, zmq::pipe_t::terminate(), unlikely, zmq::pipe_t::write(), and zmq_assert.

Referenced by zmq::rep_t::xrecv(), and zmq::rep_t::xsend().

Here is the call graph for this function:

Here is the caller graph for this function:

int zmq::router_t::xsetsockopt ( int  option_,
const void *  optval_,
size_t  optvallen_ 
)
virtual

Reimplemented from zmq::socket_base_t.

Definition at line 97 of file router.cpp.

References zmq::socket_base_t::connect_rid, handover, mandatory, zmq::own_t::options, probe_router, raw_socket, zmq::options_t::raw_socket, zmq::options_t::recv_identity, ZMQ_CONNECT_RID, ZMQ_PROBE_ROUTER, ZMQ_ROUTER_HANDOVER, ZMQ_ROUTER_MANDATORY, and ZMQ_ROUTER_RAW.

void zmq::router_t::xwrite_activated ( zmq::pipe_t *  pipe_)
virtual

Reimplemented from zmq::socket_base_t.

Definition at line 181 of file router.cpp.

References outpipes, and zmq_assert.

Member Data Documentation

std::set<pipe_t*> zmq::router_t::anonymous_pipes
private

Definition at line 111 of file router.hpp.

Referenced by xattach_pipe(), xpipe_terminated(), xread_activated(), and ~router_t().

zmq::pipe_t* zmq::router_t::current_in
private

Definition at line 96 of file router.hpp.

Referenced by identify_peer(), xhas_in(), and xrecv().

zmq::pipe_t* zmq::router_t::current_out
private

Definition at line 118 of file router.hpp.

Referenced by rollback(), xpipe_terminated(), and xsend().

fq_t zmq::router_t::fq
private

Definition at line 80 of file router.hpp.

Referenced by get_credential(), xattach_pipe(), xhas_in(), xpipe_terminated(), xread_activated(), and xrecv().

bool zmq::router_t::handover
private

Definition at line 138 of file router.hpp.

Referenced by identify_peer(), and xsetsockopt().

bool zmq::router_t::identity_sent
private

Definition at line 87 of file router.hpp.

Referenced by xhas_in(), and xrecv().

bool zmq::router_t::mandatory
private

Definition at line 129 of file router.hpp.

Referenced by xsend(), and xsetsockopt().

bool zmq::router_t::more_in
private

Definition at line 102 of file router.hpp.

Referenced by xhas_in(), and xrecv().

bool zmq::router_t::more_out
private

Definition at line 121 of file router.hpp.

Referenced by rollback(), and xsend().

uint32_t zmq::router_t::next_rid
private

Definition at line 125 of file router.hpp.

Referenced by identify_peer().

outpipes_t zmq::router_t::outpipes
private

Definition at line 115 of file router.hpp.

Referenced by identify_peer(), xpipe_terminated(), xsend(), xwrite_activated(), and ~router_t().

bool zmq::router_t::prefetched
private

Definition at line 83 of file router.hpp.

Referenced by xhas_in(), and xrecv().

msg_t zmq::router_t::prefetched_id
private

Definition at line 90 of file router.hpp.

Referenced by router_t(), xhas_in(), xrecv(), and ~router_t().

msg_t zmq::router_t::prefetched_msg
private

Definition at line 93 of file router.hpp.

Referenced by router_t(), xhas_in(), xrecv(), and ~router_t().

bool zmq::router_t::probe_router
private

Definition at line 133 of file router.hpp.

Referenced by xattach_pipe(), and xsetsockopt().

bool zmq::router_t::raw_socket
private

Definition at line 130 of file router.hpp.

Referenced by xsend(), and xsetsockopt().

bool zmq::router_t::terminate_current_in
private

Definition at line 99 of file router.hpp.

Referenced by identify_peer(), and xrecv().