#include <router.hpp>

Inheritance diagram for zmq::router_t:

[legend]

Public Member Functions
int	get_peer_state (const void *routing_id_, size_t routing_id_size_) const ZMQ_FINAL

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

void	xattach_pipe (zmq::pipe_t *pipe_, bool subscribe_to_all_, bool locally_initiated_) ZMQ_FINAL

bool	xhas_in () ZMQ_OVERRIDE

bool	xhas_out () ZMQ_OVERRIDE

void	xpipe_terminated (zmq::pipe_t *pipe_) ZMQ_FINAL

void	xread_activated (zmq::pipe_t *pipe_) ZMQ_FINAL

int	xrecv (zmq::msg_t *msg_) ZMQ_OVERRIDE

int	xsend (zmq::msg_t *msg_) ZMQ_OVERRIDE

int	xsetsockopt (int option_, const void *optval_, size_t optvallen_) ZMQ_FINAL

	~router_t () ZMQ_OVERRIDE

Public Member Functions inherited from zmq::socket_base_t
void	add_signaler (signaler_t *s_)

int	bind (const char *endpoint_uri_)

bool	check_tag () const

int	close ()

int	connect (const char *endpoint_uri_)

void	event_accept_failed (const endpoint_uri_pair_t &endpoint_uri_pair_, int err_)

void	event_accepted (const endpoint_uri_pair_t &endpoint_uri_pair_, zmq::fd_t fd_)

void	event_bind_failed (const endpoint_uri_pair_t &endpoint_uri_pair_, int err_)

void	event_close_failed (const endpoint_uri_pair_t &endpoint_uri_pair_, int err_)

void	event_closed (const endpoint_uri_pair_t &endpoint_uri_pair_, zmq::fd_t fd_)

void	event_connect_delayed (const endpoint_uri_pair_t &endpoint_uri_pair_, int err_)

void	event_connect_retried (const endpoint_uri_pair_t &endpoint_uri_pair_, int interval_)

void	event_connected (const endpoint_uri_pair_t &endpoint_uri_pair_, zmq::fd_t fd_)

void	event_disconnected (const endpoint_uri_pair_t &endpoint_uri_pair_, zmq::fd_t fd_)

void	event_handshake_failed_auth (const endpoint_uri_pair_t &endpoint_uri_pair_, int err_)

void	event_handshake_failed_no_detail (const endpoint_uri_pair_t &endpoint_uri_pair_, int err_)

void	event_handshake_failed_protocol (const endpoint_uri_pair_t &endpoint_uri_pair_, int err_)

void	event_handshake_succeeded (const endpoint_uri_pair_t &endpoint_uri_pair_, int err_)

void	event_listening (const endpoint_uri_pair_t &endpoint_uri_pair_, zmq::fd_t fd_)

i_mailbox *	get_mailbox () const

int	getsockopt (int option_, void optval_, size_t optvallen_)

bool	has_in ()

bool	has_out ()

void	hiccuped (pipe_t *pipe_) ZMQ_FINAL

void	in_event () ZMQ_FINAL

bool	is_disconnected () const

bool	is_thread_safe () const

int	join (const char *group_)

int	leave (const char *group_)

void	lock ()

int	monitor (const char *endpoint_, uint64_t events_, int event_version_, int type_)

void	out_event () ZMQ_FINAL

void	pipe_terminated (pipe_t *pipe_) ZMQ_FINAL

int	query_pipes_stats ()

void	read_activated (pipe_t *pipe_) ZMQ_FINAL

int	recv (zmq::msg_t *msg_, int flags_)

void	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 *endpoint_uri_)

void	timer_event (int id_) ZMQ_FINAL

void	unlock ()

void	write_activated (pipe_t *pipe_) ZMQ_FINAL

Public Member Functions inherited from zmq::own_t
void	inc_seqnum ()

	own_t (zmq::ctx_t *parent_, uint32_t tid_)

	own_t (zmq::io_thread_t *io_thread_, const options_t &options_)

void	register_term_acks (int count_)

void	unregister_term_ack ()

Public Member Functions inherited from zmq::object_t
ctx_t *	get_ctx () const

uint32_t	get_tid () const

	object_t (object_t *parent_)

	object_t (zmq::ctx_t *ctx_, uint32_t tid_)

void	process_command (const 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_)

virtual	~object_t ()

Public Member Functions inherited from zmq::array_item_t<>
	array_item_t ()

int	get_array_index () const

void	set_array_index (int index_)

virtual	~array_item_t () ZMQ_DEFAULT

Public Member Functions inherited from zmq::i_poll_events
virtual	~i_poll_events () ZMQ_DEFAULT

Public Member Functions inherited from zmq::i_pipe_events
virtual void	hiccuped (zmq::pipe_t *pipe_)=0

virtual void	pipe_terminated (zmq::pipe_t *pipe_)=0

virtual void	read_activated (zmq::pipe_t *pipe_)=0

virtual void	write_activated (zmq::pipe_t *pipe_)=0

virtual	~i_pipe_events () ZMQ_DEFAULT

Protected Member Functions
int	rollback ()

Protected Member Functions inherited from zmq::routing_socket_base_t
void	add_out_pipe (blob_t routing_id_, pipe_t *pipe_)

template<typename Func >
bool	any_of_out_pipes (Func func_)

bool	connect_routing_id_is_set () const

void	erase_out_pipe (const pipe_t *pipe_)

std::string	extract_connect_routing_id ()

bool	has_out_pipe (const blob_t &routing_id_) const

out_pipe_t *	lookup_out_pipe (const blob_t &routing_id_)

const out_pipe_t *	lookup_out_pipe (const blob_t &routing_id_) const

	routing_socket_base_t (class ctx_t *parent_, uint32_t tid_, int sid_)

out_pipe_t	try_erase_out_pipe (const blob_t &routing_id_)

int	xsetsockopt (int option_, const void *optval_, size_t optvallen_) ZMQ_OVERRIDE

void	xwrite_activated (pipe_t *pipe_) ZMQ_FINAL

	~routing_socket_base_t () ZMQ_OVERRIDE

Protected Member Functions inherited from zmq::socket_base_t
int	connect_internal (const char *endpoint_uri_)

void	process_destroy () ZMQ_FINAL

	socket_base_t (zmq::ctx_t *parent_, uint32_t tid_, int sid_, bool thread_safe_=false)

virtual int	xgetsockopt (int option_, void optval_, size_t optvallen_)

virtual void	xhiccuped (pipe_t *pipe_)

virtual int	xjoin (const char *group_)

virtual int	xleave (const char *group_)

virtual void	xpipe_terminated (pipe_t *pipe_)=0

virtual void	xread_activated (pipe_t *pipe_)

	~socket_base_t () ZMQ_OVERRIDE

Protected Member Functions inherited from zmq::own_t
bool	is_terminating () const

void	launch_child (own_t *object_)

void	term_child (own_t *object_)

void	terminate ()

	~own_t () ZMQ_OVERRIDE

Protected Member Functions inherited from zmq::object_t
zmq::io_thread_t *	choose_io_thread (uint64_t affinity_) const

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_) const

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_conn_failed ()

virtual void	process_hiccup (void *pipe_)

virtual void	process_pipe_hwm (int inhwm_, int outhwm_)

virtual void	process_pipe_peer_stats (uint64_t queue_count_, zmq::own_t socket_base_, endpoint_uri_pair_t endpoint_pair_)

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_conn_failed (zmq::session_base_t *destination_)

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_hwm (zmq::pipe_t *destination_, int inhwm_, int outhwm_)

void	send_pipe_peer_stats (zmq::pipe_t destination_, uint64_t queue_count_, zmq::own_t socket_base, endpoint_uri_pair_t *endpoint_pair_)

void	send_pipe_stats_publish (zmq::own_t destination_, uint64_t outbound_queue_count_, uint64_t inbound_queue_count_, endpoint_uri_pair_t endpoint_pair_)

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_endpoint (own_t destination_, std::string endpoint_)

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 Member Functions
bool	identify_peer (pipe_t *pipe_, bool locally_initiated_)

Private Attributes
std::set< pipe_t * >	_anonymous_pipes

zmq::pipe_t *	_current_in

zmq::pipe_t *	_current_out

fq_t	_fq

bool	_handover

bool	_mandatory

bool	_more_in

bool	_more_out

uint32_t	_next_integral_routing_id

bool	_prefetched

msg_t	_prefetched_id

msg_t	_prefetched_msg

bool	_probe_router

bool	_raw_socket

bool	_routing_id_sent

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
mutex_t	_sync

Protected Attributes inherited from zmq::own_t
options_t	options

Detailed Description

Definition at line 21 of file router.hpp.

Constructor & Destructor Documentation

◆ router_t()

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

Definition at line 12 of file router.cpp.

◆ ~router_t()

zmq::router_t::~router_t ( )

Definition at line 38 of file router.cpp.

Member Function Documentation

◆ get_peer_state()

int zmq::router_t::get_peer_state	(	const void *	routing_id_,
		size_t	routing_id_size_
	)		const

virtual

Todo:: does it make any sense to check the inpipe as well?

Reimplemented from zmq::socket_base_t.

Definition at line 404 of file router.cpp.

◆ identify_peer()

bool zmq::router_t::identify_peer	(	pipe_t *	pipe_,
		bool	locally_initiated_
	)

private

Definition at line 427 of file router.cpp.

◆ rollback()

int zmq::router_t::rollback ( )

protected

Definition at line 334 of file router.cpp.

◆ xattach_pipe()

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

virtual

Implements zmq::socket_base_t.

Definition at line 45 of file router.cpp.

◆ xhas_in()

bool zmq::router_t::xhas_in ( )

virtual

Reimplemented from zmq::socket_base_t.

Definition at line 344 of file router.cpp.

◆ xhas_out()

bool zmq::router_t::xhas_out ( )

virtual

Reimplemented from zmq::socket_base_t.

Definition at line 392 of file router.cpp.

◆ xpipe_terminated()

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

Definition at line 136 of file router.cpp.

◆ xread_activated()

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

Definition at line 147 of file router.cpp.

◆ xrecv()

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

virtual

Reimplemented from zmq::socket_base_t.

Definition at line 263 of file router.cpp.

◆ xsend()

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

virtual

Reimplemented from zmq::socket_base_t.

Definition at line 161 of file router.cpp.

◆ xsetsockopt()

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

virtual

Reimplemented from zmq::socket_base_t.

Definition at line 75 of file router.cpp.

Member Data Documentation

◆ _anonymous_pipes

std::set<pipe_t *> zmq::router_t::_anonymous_pipes

private

Definition at line 76 of file router.hpp.

◆ _current_in

zmq::pipe_t* zmq::router_t::_current_in

private

Definition at line 67 of file router.hpp.

◆ _current_out

zmq::pipe_t* zmq::router_t::_current_out

private

Definition at line 79 of file router.hpp.

◆ _fq

fq_t zmq::router_t::_fq

private

Definition at line 51 of file router.hpp.

◆ _handover

bool zmq::router_t::_handover

private

Definition at line 99 of file router.hpp.

◆ _mandatory

bool zmq::router_t::_mandatory

private

Definition at line 90 of file router.hpp.

◆ _more_in

bool zmq::router_t::_more_in

private

Definition at line 73 of file router.hpp.

◆ _more_out

bool zmq::router_t::_more_out

private

Definition at line 82 of file router.hpp.

◆ _next_integral_routing_id

uint32_t zmq::router_t::_next_integral_routing_id

private

Definition at line 86 of file router.hpp.

◆ _prefetched

bool zmq::router_t::_prefetched

private

Definition at line 54 of file router.hpp.

◆ _prefetched_id

msg_t zmq::router_t::_prefetched_id

private

Definition at line 61 of file router.hpp.

◆ _prefetched_msg

msg_t zmq::router_t::_prefetched_msg

private

Definition at line 64 of file router.hpp.

◆ _probe_router

bool zmq::router_t::_probe_router

private

Definition at line 94 of file router.hpp.

◆ _raw_socket

bool zmq::router_t::_raw_socket

private

Definition at line 91 of file router.hpp.

◆ _routing_id_sent

bool zmq::router_t::_routing_id_sent

private

Definition at line 58 of file router.hpp.

◆ _terminate_current_in

bool zmq::router_t::_terminate_current_in

private

Definition at line 70 of file router.hpp.

The documentation for this class was generated from the following files:

Public Member Functions

Protected Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ router_t()

◆ ~router_t()

Member Function Documentation

◆ get_peer_state()

◆ identify_peer()

◆ rollback()

◆ xattach_pipe()

◆ xhas_in()

◆ xhas_out()

◆ xpipe_terminated()

◆ xread_activated()

◆ xrecv()

◆ xsend()

◆ xsetsockopt()

Member Data Documentation

◆ _anonymous_pipes

◆ _current_in

◆ _current_out

◆ _fq

◆ _handover

◆ _mandatory

◆ _more_in

◆ _more_out

◆ _next_integral_routing_id

◆ _prefetched

◆ _prefetched_id

◆ _prefetched_msg

◆ _probe_router

◆ _raw_socket

◆ _routing_id_sent

◆ _terminate_current_in