#include <channel.hpp>

Inheritance diagram for zmq::ZMQ_FINAL< T, N >:

[legend]

Classes
struct	pending_connection_t

Public Types
enum	{ term_tid = 0, reaper_tid = 1 }

Public Member Functions
void	add_signaler (signaler_t *signaler_)

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

bool	check_hwm () const

bool	check_read ()

bool	check_read ()

bool	check_read ()

bool	check_tag () const

bool	check_write ()

zmq::io_thread_t *	choose_io_thread (uint64_t affinity_)

void	clear_signalers ()

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

uint32_t	connect_peer (const char *endpoint_uri_)

void	connect_pending (const char addr_, zmq::socket_base_t bind_socket_)

zmq::socket_base_t *	create_socket (int type_)

	ctx_t ()

int	decode (const unsigned char *data_, size_t size_, size_t &bytes_used_)

void	destroy_socket (zmq::socket_base_t *socket_)

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

	dish_session_t (zmq::io_thread_t io_thread_, bool connect_, zmq::socket_base_t socket_, const options_t &options_, address_t *addr_)

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

endpoint_t	find_endpoint (const char *addr_)

bool	flush ()

bool	flush ()

void	flush ()

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

int	get (int option_)

int	get (int option_, void optval_, const size_t optvallen_)

void	get_buffer (unsigned char *data_, size_t size_)

const endpoint_uri_pair_t &	get_endpoint () const

const endpoint_uri_pair_t &	get_endpoint_pair () const

fd_t	get_fd () const

int	get_load () const

mailbox_t *	get_mailbox ()

mailbox_t *	get_mailbox ()

poller_t *	get_poller () const

zmq::object_t *	get_reaper () const

const blob_t &	get_routing_id () const

uint32_t	get_server_socket_routing_id () const

bool	has_handshake_stage () ZMQ_FINAL

	hello_msg_session_t (zmq::io_thread_t io_thread_, bool connect_, zmq::socket_base_t socket_, const options_t &options_, address_t *addr_)

void	hiccup ()

void	in_event ()

void	in_event ()

void	in_event ()

int	init (address_t *address_, bool send_, bool recv_)

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

	mailbox_safe_t (mutex_t *sync_)

	mailbox_t ()

msg_t *	msg ()

msg_t *	msg ()

msg_t *	msg ()

msg_t *	msg ()

int	next_handshake_command (msg_t *msg_)

int	next_handshake_command (msg_t *msg_)

int	next_handshake_command (msg_t *msg_)

	null_mechanism_t (session_base_t *session_, const std::string &peer_address_, const options_t &options_)

void	out_event ()

void	out_event ()

void	out_event ()

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

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

void	pend_connection (const std::string &addr_, const endpoint_t &endpoint_, pipe_t **pipes_)

	plain_client_t (session_base_t *session_, const options_t &options_)

	plain_server_t (session_base_t *session_, const std::string &peer_address_, const options_t &options_)

void	plug (zmq::io_thread_t io_thread_, class session_base_t session_)

bool	probe (bool(*fn_)(const T &))

bool	probe (bool(*fn_)(const T &))

int	process_handshake_command (msg_t *msg_)

int	process_handshake_command (msg_t *msg_)

int	process_handshake_command (msg_t *msg_)

void	process_stop ()

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

int	pull_msg (msg_t *msg_)

int	pull_msg (msg_t *msg_)

int	pull_msg (msg_t *msg_)

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

int	push_msg (msg_t *msg_)

int	push_msg (msg_t *msg_)

int	push_msg (msg_t *msg_)

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

	radio_session_t (zmq::io_thread_t io_thread_, bool connect_, zmq::socket_base_t socket_, const options_t &options_, address_t *addr_)

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

	raw_decoder_t (size_t bufsize_)

	raw_encoder_t (size_t bufsize_)

	raw_engine_t (fd_t fd_, const options_t &options_, const endpoint_uri_pair_t &endpoint_uri_pair_)

bool	read (msg_t *msg_)

bool	read (T *value_)

bool	read (T *value_)

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

int	recv (command_t *cmd_, int timeout_)

int	recv (command_t *cmd_, int timeout_)

int	register_endpoint (const char *addr_, const endpoint_t &endpoint_)

void	remove_signaler (signaler_t *signaler_)

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

	req_session_t (zmq::io_thread_t io_thread_, bool connect_, zmq::socket_base_t socket_, const options_t &options_, address_t *addr_)

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

void	reset ()

void	reset ()

void	reset ()

void	reset ()

void	resize_buffer (size_t)

bool	restart_input ()

void	restart_output ()

void	rollback () const

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

void	send (const command_t &cmd_)

void	send (const command_t &cmd_)

void	send_command (uint32_t tid_, const command_t &command_)

void	send_disconnect_msg ()

void	send_hiccup_msg (const std::vector< unsigned char > &hiccup_)

void	send_hwms_to_peer (int inhwm_, int outhwm_)

void	send_stats_to_peer (own_t *socket_base_)

int	set (int option_, const void *optval_, size_t optvallen_)

void	set_auth_method_basic (const std::string &username, const std::string &password)

void	set_auth_method_none ()

void	set_disconnect_msg (const std::vector< unsigned char > &disconnect_)

void	set_endpoint_pair (endpoint_uri_pair_t endpoint_pair_)

void	set_event_sink (i_pipe_events *sink_)

void	set_hwms (int inhwm_, int outhwm_)

void	set_hwms_boost (int inhwmboost_, int outhwmboost_)

int	set_local_address (const char *addr_)

int	set_local_address (const char *addr_)

void	set_nodelay ()

void	set_router_socket_routing_id (const blob_t &router_socket_routing_id_)

void	set_server_socket_routing_id (uint32_t server_socket_routing_id_)

int	shutdown ()

	socks_connecter_t (zmq::io_thread_t io_thread_, zmq::session_base_t session_, const options_t &options_, address_t addr_, address_t proxy_addr_, bool delayed_start_)

void	start ()

void	start ()

status_t	status () const

status_t	status () const

void	stop ()

void	stop ()

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

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

	tcp_connecter_t (zmq::io_thread_t io_thread_, zmq::session_base_t session_, const options_t &options_, address_t *addr_, bool delayed_start_)

	tcp_listener_t (zmq::io_thread_t io_thread_, zmq::socket_base_t socket_, const options_t &options_)

void	terminate ()

int	terminate ()

void	terminate (bool delay_)

void	timer_event (int id_)

void	timer_event (int id_)

	udp_engine_t (const options_t &options_)

int	unregister_endpoint (const std::string &addr_, const socket_base_t *socket_)

void	unregister_endpoints (const zmq::socket_base_t *socket_)

bool	unwrite (T *)

bool	unwrite (T *value_)

	v1_decoder_t (size_t bufsize_, int64_t maxmsgsize_)

	v1_encoder_t (size_t bufsize_)

	v2_decoder_t (size_t bufsize_, int64_t maxmsgsize_, bool zero_copy_)

	v2_encoder_t (size_t bufsize_)

	v3_1_encoder_t (size_t bufsize_)

bool	valid () const

bool	valid () const

bool	write (const msg_t *msg_)

void	write (const T &value_, bool incomplete_)

void	write (const T &value_, bool incomplete_)

	ws_connecter_t (zmq::io_thread_t io_thread_, zmq::session_base_t session_, const options_t &options_, address_t *addr_, bool delayed_start_, bool wss_, const std::string &tls_hostname_)

	ws_decoder_t (size_t bufsize_, int64_t maxmsgsize_, bool zero_copy_, bool must_mask_)

	ws_encoder_t (size_t bufsize_, bool must_mask_)

	ws_listener_t (zmq::io_thread_t io_thread_, zmq::socket_base_t socket_, const options_t &options_, bool wss_)

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

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

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

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

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

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

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

bool	xhas_in ()

bool	xhas_in ()

bool	xhas_in ()

bool	xhas_in ()

bool	xhas_in ()

bool	xhas_in ()

bool	xhas_in ()

bool	xhas_in ()

bool	xhas_out ()

bool	xhas_out ()

bool	xhas_out ()

bool	xhas_out ()

bool	xhas_out ()

bool	xhas_out ()

bool	xhas_out ()

void	xpipe_terminated (zmq::pipe_t *pipe_)

void	xpipe_terminated (zmq::pipe_t *pipe_)

void	xpipe_terminated (zmq::pipe_t *pipe_)

void	xpipe_terminated (zmq::pipe_t *pipe_)

void	xpipe_terminated (zmq::pipe_t *pipe_)

void	xpipe_terminated (zmq::pipe_t *pipe_)

void	xread_activated (zmq::pipe_t *pipe_)

void	xread_activated (zmq::pipe_t *pipe_)

void	xread_activated (zmq::pipe_t *pipe_)

void	xread_activated (zmq::pipe_t *pipe_)

void	xread_activated (zmq::pipe_t *pipe_)

int	xrecv (zmq::msg_t *msg_)

int	xrecv (zmq::msg_t *msg_)

int	xrecv (zmq::msg_t *msg_)

int	xrecv (zmq::msg_t *msg_)

int	xrecv (zmq::msg_t *msg_)

int	xrecv (zmq::msg_t *msg_)

int	xrecv (zmq::msg_t *msg_)

int	xrecv (zmq::msg_t *msg_)

int	xsend (zmq::msg_t *msg_)

int	xsend (zmq::msg_t *msg_)

int	xsend (zmq::msg_t *msg_)

int	xsend (zmq::msg_t *msg_)

int	xsend (zmq::msg_t *msg_)

int	xsend (zmq::msg_t *msg_)

int	xsend (zmq::msg_t *msg_)

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

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

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

void	xwrite_activated (zmq::pipe_t *pipe_)

void	xwrite_activated (zmq::pipe_t *pipe_)

void	xwrite_activated (zmq::pipe_t *pipe_)

void	xwrite_activated (zmq::pipe_t *pipe_)

	ypipe_conflate_t ()

	ypipe_t ()

int	zap_msg_available ()

void	zap_msg_available ()

	zmtp_engine_t (fd_t fd_, const options_t &options_, const endpoint_uri_pair_t &endpoint_uri_pair_)

	~channel_t ()

	~client_t ()

	~ctx_t ()

	~dgram_t ()

	~dish_session_t ()

	~dish_t ()

	~gather_t ()

	~hello_msg_session_t ()

	~io_thread_t ()

	~mailbox_safe_t ()

	~mailbox_t ()

	~null_mechanism_t ()

	~pair_t ()

	~plain_client_t ()

	~plain_server_t ()

	~pub_t ()

	~pull_t ()

	~push_t ()

	~radio_session_t ()

	~radio_t ()

	~raw_decoder_t ()

	~raw_encoder_t ()

	~raw_engine_t ()

	~reaper_t ()

	~rep_t ()

	~req_session_t ()

	~req_t ()

	~scatter_t ()

	~socks_connecter_t ()

	~stream_t ()

	~sub_t ()

	~tcp_connecter_t ()

	~udp_engine_t ()

	~v1_decoder_t ()

	~v1_encoder_t ()

	~v2_decoder_t ()

	~v2_encoder_t ()

	~v3_1_encoder_t () ZMQ_FINAL

	~ws_connecter_t ()

	~ws_decoder_t ()

	~ws_encoder_t ()

	~ws_listener_t ()

	~zmtp_engine_t ()

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

virtual int	get_peer_state (const void *routing_id_, size_t routing_id_size_) const

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

bool	has_in ()

bool	has_out ()

void	hiccuped (pipe_t *pipe_) 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	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	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
void	create_engine (fd_t fd)

void	create_engine (fd_t fd, const std::string &local_address_)

void	error (error_reason_t reason_)

std::string	get_socket_name (fd_t fd_, socket_end_t socket_end_) const

std::string	get_socket_name (fd_t fd_, socket_end_t socket_end_) const

bool	handshake ()

bool	handshake ()

void	plug_internal ()

void	plug_internal ()

int	process_command_message (msg_t *msg_)

int	process_heartbeat_message (msg_t *msg_)

int	produce_ping_message (msg_t *msg_)

int	produce_pong_message (msg_t *msg_)

int	recv_reply_pipe (zmq::msg_t *msg_)

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

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

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

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

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

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

bool	xhas_in ()

bool	xhas_in ()

bool	xhas_in ()

bool	xhas_in ()

bool	xhas_out ()

bool	xhas_out ()

bool	xhas_out ()

bool	xhas_out ()

bool	xhas_out ()

void	xhiccuped (pipe_t *pipe_)

int	xjoin (const char *group_)

int	xleave (const char *group_)

void	xpipe_terminated (zmq::pipe_t *pipe_)

void	xpipe_terminated (zmq::pipe_t *pipe_)

void	xpipe_terminated (zmq::pipe_t *pipe_)

void	xpipe_terminated (zmq::pipe_t *pipe_)

void	xpipe_terminated (zmq::pipe_t *pipe_)

void	xpipe_terminated (zmq::pipe_t *pipe_)

void	xread_activated (zmq::pipe_t *pipe_)

void	xread_activated (zmq::pipe_t *pipe_)

void	xread_activated (zmq::pipe_t *pipe_)

void	xread_activated (zmq::pipe_t *pipe_)

int	xrecv (zmq::msg_t *msg_)

int	xrecv (zmq::msg_t *msg_)

int	xrecv (zmq::msg_t *msg_)

int	xrecv (zmq::msg_t *msg_)

int	xsend (zmq::msg_t *msg_)

int	xsend (zmq::msg_t *msg_)

int	xsend (zmq::msg_t *msg_)

int	xsend (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_)

void	xwrite_activated (zmq::pipe_t *pipe_)

void	xwrite_activated (zmq::pipe_t *pipe_)

void	xwrite_activated (zmq::pipe_t *pipe_)

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	xpipe_terminated (pipe_t *pipe_)=0

virtual void	xread_activated (pipe_t *pipe_)

virtual void	xwrite_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_attach (zmq::i_engine *engine_)

virtual void	process_conn_failed ()

virtual void	process_plug ()

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

Protected Attributes
atomic_ptr_t< T >	_c

T *	_f

yqueue_t< T, N >	_queue

T *	_r

T *	_w

dbuffer_t< T >	dbuffer

bool	reader_awake

Protected Attributes inherited from zmq::socket_base_t
mutex_t	_sync

Protected Attributes inherited from zmq::own_t
options_t	options

Private Types
enum	{ group, body }

enum	{ active, delimiter_received, waiting_for_delimiter, term_ack_sent, term_req_sent1, term_req_sent2 }

enum	{ group, body }

enum	{ bottom, request_id, body }

enum	{ unplugged, waiting_for_reconnect_time, waiting_for_proxy_connection, sending_greeting, waiting_for_choice, sending_basic_auth_request, waiting_for_auth_response, sending_request, waiting_for_response }

enum	{ socks_no_auth_required = 0x00, socks_basic_auth = 0x02, socks_no_acceptable_method = 0xff }

enum	{ connect_timer_id = 2 }

enum	{ connect_timer_id = 2 }

typedef ypipe_t< command_t, command_pipe_granularity >	cpipe_t

typedef ypipe_t< command_t, command_pipe_granularity >	cpipe_t

typedef std::vector< uint32_t >	empty_slots_t

typedef std::map< std::string, endpoint_t >	endpoints_t

typedef bool(zmtp_engine_t::*	handshake_fun_t) ()

typedef std::vector< zmq::io_thread_t * >	io_threads_t

typedef std::multimap< std::string, pending_connection_t >	pending_connections_t

enum	side { connect_side, bind_side }

typedef array_t< socket_base_t >	sockets_t

enum	state_t { sending_hello, waiting_for_welcome, sending_initiate, waiting_for_ready, error_command_received, ready }

typedef std::multimap< std::string, pipe_t * >	subscriptions_t

typedef std::set< std::string >	subscriptions_t

typedef std::vector< pipe_t * >	udp_pipes_t

typedef ypipe_base_t< msg_t >	upipe_t

Private Member Functions
fd_t	accept ()

fd_t	accept ()

void	add_connect_timer ()

void	add_connect_timer ()

int	add_membership (fd_t s_, const udp_address_t *addr_)

zmq::fd_t	check_proxy_connection () const

fd_t	connect ()

fd_t	connect ()

int	connect_to_proxy ()

int	create_socket (const char *addr_)

int	create_socket (const char *addr_)

int	eight_byte_size_ready (unsigned char const *)

int	eight_byte_size_ready (unsigned char const *)

void	error ()

void	error (error_reason_t reason_)

int	flags_ready (unsigned char const *)

int	flags_ready (unsigned char const *)

int	flags_ready (unsigned char const *)

bool	handshake_v1_0 ()

bool	handshake_v1_0_unversioned ()

bool	handshake_v2_0 ()

bool	handshake_v3_0 ()

bool	handshake_v3_1 ()

bool	handshake_v3_x (bool downgrade_sub)

void	identify_peer (pipe_t *pipe_, bool locally_initiated_)

void	in_event ()

void	in_event ()

void	in_event ()

int	long_size_ready (unsigned char const *)

int	mask_ready (unsigned char const *)

void	message_ready ()

void	message_ready ()

void	message_ready ()

void	message_ready ()

int	message_ready (unsigned char const *)

int	message_ready (unsigned char const *)

int	message_ready (unsigned char const *)

int	one_byte_size_ready (unsigned char const *)

int	one_byte_size_ready (unsigned char const *)

int	opcode_ready (unsigned char const *)

int	open ()

int	open ()

int	open ()

void	out_event ()

void	out_event ()

void	out_event ()

	pipe_t (object_t parent_, upipe_t inpipe_, upipe_t *outpipe_, int inhwm_, int outhwm_, bool conflate_)

void	process_activate_read () ZMQ_OVERRIDE

void	process_activate_write (uint64_t msgs_read_) ZMQ_OVERRIDE

void	process_delimiter ()

int	process_error (const unsigned char *cmd_data_, size_t data_size_)

int	process_error_command (const unsigned char *cmd_data_, size_t data_size_)

int	process_hello (msg_t *msg_)

void	process_hiccup (void *pipe_) ZMQ_OVERRIDE

int	process_initiate (msg_t *msg_)

void	process_pipe_hwm (int inhwm_, int outhwm_) ZMQ_OVERRIDE

void	process_pipe_peer_stats (uint64_t queue_count_, own_t socket_base_, endpoint_uri_pair_t endpoint_pair_) ZMQ_OVERRIDE

void	process_pipe_term () ZMQ_OVERRIDE

void	process_pipe_term_ack () ZMQ_OVERRIDE

int	process_ready (const unsigned char *cmd_data_, size_t data_size_)

int	process_ready_command (const unsigned char *cmd_data_, size_t data_size_)

void	process_reap (zmq::socket_base_t *socket_)

void	process_reaped ()

int	process_routing_id_msg (msg_t *msg_)

void	process_stop ()

void	process_term (int linger_)

void	process_term (int linger_)

int	process_welcome (const unsigned char *cmd_data_, size_t data_size_)

void	produce_error (msg_t *msg_) const

void	produce_hello (msg_t *msg_) const

void	produce_initiate (msg_t *msg_) const

void	produce_ready (msg_t *msg_) const

int	push_raw_msg_to_session (msg_t *msg_)

void	raw_message_ready ()

int	receive_greeting ()

void	receive_greeting_versioned ()

int	resolve_raw_address (const char *name_, size_t length_)

int	routing_id_msg (msg_t *msg_)

void	send_subscriptions (pipe_t *pipe_)

void	send_zap_request ()

void	send_zap_request (const std::string &username_, const std::string &password_)

void	set_peer (pipe_t *peer_)

int	set_udp_multicast_iface (fd_t s_, bool is_ipv6_, const udp_address_t *addr_)

int	short_size_ready (unsigned char const *)

int	size_first_byte_ready (unsigned char const *)

void	size_ready ()

void	size_ready ()

void	size_ready ()

void	size_ready ()

int	size_ready (uint64_t size_, unsigned char const *)

int	size_ready (unsigned char const *)

bool	start ()

void	start_connecting ()

void	start_connecting ()

void	start_connecting ()

void	timer_event (int id_)

void	timer_event (int id_)

bool	tune_socket (fd_t fd_)

bool	tune_socket (fd_t fd_)

int	xxrecv (zmq::msg_t *msg_)

	~pipe_t () ZMQ_OVERRIDE

Static Private Member Functions
static int	compute_lwm (int hwm_)

static void	connect_inproc_sockets (zmq::socket_base_t *bind_socket_, const options_t &bind_options_, const pending_connection_t &pending_connection_, side side_)

static bool	is_delimiter (const msg_t &msg_)

static int	parse_address (const std::string &address_, std::string &hostname_, uint16_t &port_)

static int	process_server_response (const socks_auth_response_t &response_)

static int	process_server_response (const socks_choice_t &response_)

static int	process_server_response (const socks_response_t &response_)

static void	produce_welcome (msg_t *msg_)

static handshake_fun_t	select_handshake_fun (bool unversioned, unsigned char revision, unsigned char minor)

static int	set_udp_multicast_loop (fd_t s_, bool is_ipv6_, bool loop_)

static int	set_udp_multicast_ttl (fd_t s_, bool is_ipv6_, int hops_)

static int	set_udp_reuse_address (fd_t s_, bool on_)

static int	set_udp_reuse_port (fd_t s_, bool on_)

static void	sockaddr_to_msg (zmq::msg_t msg_, const sockaddr_in addr_)

Private Attributes
bool	_active

tcp_address_t	_address

ws_address_t	_address

address_t *	_address

shared_message_memory_allocator	_allocator

int	_auth_method

std::string	_auth_password

socks_auth_response_decoder_t	_auth_response_decoder

std::string	_auth_username

socks_basic_auth_request_encoder_t	_basic_auth_request_encoder

bool	_blocky

socks_choice_decoder_t	_choice_decoder

condition_variable_t	_cond_var

const bool	_conflate

bool	_connect_timer_started

cpipe_t	_cpipe

zmq::pipe_t *	_current_out

bool	_delay

msg_t	_disconnect_msg

dist_t	_dist

const endpoint_uri_pair_t	_empty_endpoint

empty_slots_t	_empty_slots

endpoint_uri_pair_t	_endpoint_pair

endpoints_t	_endpoints

mutex_t	_endpoints_sync

bool	_error_command_received

bool	_error_command_sent

fd_t	_fd

fq_t	_fq

unsigned int	_greeting_bytes_read

socks_greeting_encoder_t	_greeting_encoder

unsigned char	_greeting_recv [v3_greeting_size]

unsigned char	_greeting_send [v3_greeting_size]

size_t	_greeting_size

msg_t	_group_msg

handle_t	_handle

bool	_has_message

int	_heartbeat_timeout

const std::string &	_hostname

int	_hwm

bool	_in_active

char	_in_buffer [MAX_UDP_MSG]

int	_in_hwm_boost

upipe_t *	_in_pipe

msg_t	_in_progress

int	_io_thread_count

io_threads_t	_io_threads

bool	_ipv6

bool	_is_binary

lb_t	_lb

bool	_lossy

int	_lwm

mailbox_t	_mailbox

poller_t::handle_t	_mailbox_handle

unsigned char	_mask [4]

msg_t	_masked_msg

const int64_t	_max_msg_size

int	_max_msgsz

int	_max_sockets

msg_t	_message

bool	_message_begins

bool	_more_out

unsigned char	_msg_flags

uint64_t	_msgs_read

uint64_t	_msgs_written

bool	_must_mask

const bool	_must_mask

bool	_new_pipe

uint32_t	_next_integral_routing_id

zmq::ws_protocol_t::opcode_t	_opcode

options_t	_options

bool	_out_active

const struct sockaddr *	_out_address

zmq_socklen_t	_out_address_len

char	_out_buffer [MAX_UDP_MSG]

int	_out_hwm_boost

upipe_t *	_out_pipe

pipe_t *	_peer

uint32_t	_peer_last_routing_id

uint64_t	_peers_msgs_read

pending_connections_t	_pending_connections

msg_t	_pending_msg

zmq::pipe_t *	_pipe

bool	_plugged

poller_t *	_poller

msg_t	_pong_msg

bool	_prefetched

msg_t	_prefetched_msg

msg_t	_prefetched_routing_id

address_t *	_proxy_addr

sockaddr_in	_raw_address

bool	_ready_command_received

bool	_ready_command_sent

zmq::reaper_t *	_reaper

bool	_receiving_reply

bool	_recv_enabled

zmq::pipe_t *	_reply_pipe

bool	_request_begins

socks_request_encoder_t	_request_encoder

uint32_t	_request_id

bool	_request_id_frames_enabled

socks_response_decoder_t	_response_decoder

blob_t	_router_socket_routing_id

msg_t	_routing_id_msg

bool	_routing_id_sent

bool	_send_enabled

bool	_sending_reply

int	_server_socket_routing_id

session_base_t *	_session

signaler_t	_signaler

std::vector< zmq::signaler_t * >	_signalers

i_pipe_events *	_sink

uint64_t	_size

mutex_t	_slot_sync

std::vector< i_mailbox * >	_slots

int	_sockets

sockets_t	_sockets

bool	_starting

state_t	_state

enum zmq::ZMQ_FINAL:: { ... }	_state

enum zmq::ZMQ_FINAL:: { ... }	_state

enum zmq::ZMQ_FINAL:: { ... }	_state

enum zmq::ZMQ_FINAL:: { ... }	_state

int	_status

bool	_strict

bool	_subscription_required

subscriptions_t	_subscriptions

mutex_t	_sync

mutex_t *const	_sync

uint32_t	_tag

mailbox_t	_term_mailbox

bool	_terminating

unsigned char	_tmp_buf [10]

unsigned char	_tmpbuf [8]

udp_pipes_t	_udp_pipes

bool	_wss

bool	_zap_reply_received

bool	_zap_request_sent

const bool	_zero_copy

bool	_zero_copy

Static Private Attributes
static atomic_counter_t	max_socket_id

static const size_t	signature_size = 10

static const size_t	v2_greeting_size = 12

static const size_t	v3_greeting_size = 64

Friends
int	pipepair (zmq::object_t parents_[2], zmq::pipe_t pipes_[2], const int hwms_[2], const bool conflate_[2])

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

Detailed Description

template<typename T, int N>
class zmq::ZMQ_FINAL< T, N >

private

Definition at line 130 of file pipe.hpp.

Member Enumeration Documentation

◆ anonymous enum

template<typename T , int N>

anonymous enum

Enumerator
term_tid
reaper_tid

Definition at line 126 of file ctx.hpp.

◆ anonymous enum

template<typename T , int N>

anonymous enum

private

Enumerator
group
body

Definition at line 82 of file dish.hpp.

◆ anonymous enum

template<typename T , int N>

anonymous enum

private

Enumerator
active
delimiter_received
waiting_for_delimiter
term_ack_sent
term_req_sent1
term_req_sent2

Definition at line 206 of file pipe.hpp.

◆ anonymous enum

template<typename T , int N>

anonymous enum

private

Enumerator
group
body

Definition at line 74 of file radio.hpp.

◆ anonymous enum

template<typename T , int N>

anonymous enum

private

Enumerator
bottom
request_id
body

Definition at line 77 of file req.hpp.

◆ anonymous enum

template<typename T , int N>

anonymous enum

private

Enumerator
unplugged
waiting_for_reconnect_time
waiting_for_proxy_connection
sending_greeting
waiting_for_choice
sending_basic_auth_request
waiting_for_auth_response
sending_request
waiting_for_response

Definition at line 36 of file socks_connecter.hpp.

◆ anonymous enum

template<typename T , int N>

anonymous enum

private

Enumerator
socks_no_auth_required
socks_basic_auth
socks_no_acceptable_method

Definition at line 50 of file socks_connecter.hpp.

◆ anonymous enum

template<typename T , int N>

anonymous enum

private

Enumerator
connect_timer_id

Definition at line 26 of file tcp_connecter.hpp.

◆ anonymous enum

template<typename T , int N>

anonymous enum

private

Enumerator
connect_timer_id

Definition at line 31 of file ws_connecter.hpp.

◆ side

template<typename T , int N>

enum zmq::ZMQ_FINAL::side

private

Enumerator
connect_side
bind_side

Definition at line 224 of file ctx.hpp.

◆ state_t

template<typename T , int N>

enum zmq::ZMQ_FINAL::state_t

private

Enumerator
sending_hello
waiting_for_welcome
sending_initiate
waiting_for_ready
error_command_received
ready

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::~pair_t ( )

◆ ~pipe_t()

template<typename T , int N>

◆ add_membership()

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::add_membership	(	fd_t	s_,
		const udp_address_t *	addr_
	)

private

◆ add_signaler()

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::add_signaler ( signaler_t * signaler_ )

◆ channel_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::channel_t	(	zmq::ctx_t *	parent_,
		uint32_t	tid_,
		int	sid_
	)

◆ check_hwm()

template<typename T , int N>

bool zmq::ZMQ_FINAL< T, N >::check_hwm ( ) const

◆ check_proxy_connection()

template<typename T , int N>

zmq::fd_t zmq::ZMQ_FINAL< T, N >::check_proxy_connection ( ) const

private

◆ check_read() [1/3]

template<typename T , int N>

bool zmq::ZMQ_FINAL< T, N >::check_read ( )

inline

Definition at line 60 of file ypipe_conflate.hpp.

◆ check_read() [2/3]

template<typename T , int N>

bool zmq::ZMQ_FINAL< T, N >::check_read ( )

◆ check_read() [3/3]

template<typename T , int N>

bool zmq::ZMQ_FINAL< T, N >::check_read ( )

template<typename T , int N>

static int zmq::ZMQ_FINAL< T, N >::compute_lwm ( int hwm_ )

staticprivate

◆ connect() [1/2]

template<typename T , int N>

fd_t zmq::ZMQ_FINAL< T, N >::connect ( )

private

◆ connect() [2/2]

template<typename T , int N>

fd_t zmq::ZMQ_FINAL< T, N >::connect ( )

private

◆ connect_inproc_sockets()

template<typename T , int N>

static void zmq::ZMQ_FINAL< T, N >::connect_inproc_sockets	(	zmq::socket_base_t *	bind_socket_,
		const options_t &	bind_options_,
		const pending_connection_t &	pending_connection_,
		side	side_
	)

staticprivate

◆ connect_peer()

template<typename T , int N>

uint32_t zmq::ZMQ_FINAL< T, N >::connect_peer ( const char * endpoint_uri_ )

◆ connect_pending()

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::connect_pending	(	const char *	addr_,
		zmq::socket_base_t *	bind_socket_
	)

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::dish_session_t	(	zmq::io_thread_t *	io_thread_,
		bool	connect_,
		zmq::socket_base_t *	socket_,
		const options_t &	options_,
		address_t *	addr_
	)

◆ dish_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::dish_t	(	zmq::ctx_t *	parent_,
		uint32_t	tid_,
		int	sid_
	)

template<typename T , int N>

bool zmq::ZMQ_FINAL< T, N >::flush ( )

inline

Definition at line 54 of file ypipe_conflate.hpp.

◆ flush() [2/3]

template<typename T , int N>

bool zmq::ZMQ_FINAL< T, N >::flush ( )

inline

Definition at line 76 of file ypipe.hpp.

◆ flush() [3/3]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::flush ( )

◆ gather_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::gather_t	(	zmq::ctx_t *	parent_,
		uint32_t	tid_,
		int	sid_
	)

◆ get() [1/2]

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::get ( int option_ )

◆ get() [2/2]

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::get	(	int	option_,
		void *	optval_,
		const size_t *	optvallen_
	)

◆ get_buffer()

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::get_buffer	(	unsigned char **	data_,
		size_t *	size_
	)

◆ get_socket_name() [1/2]

template<typename T , int N>

std::string zmq::ZMQ_FINAL< T, N >::get_socket_name	(	fd_t	fd_,
		socket_end_t	socket_end_
	)		const

protected

◆ get_socket_name() [2/2]

template<typename T , int N>

std::string zmq::ZMQ_FINAL< T, N >::get_socket_name	(	fd_t	fd_,
		socket_end_t	socket_end_
	)		const

private

◆ has_handshake_stage()

template<typename T , int N>

bool zmq::ZMQ_FINAL< T, N >::has_handshake_stage ( )

inline

Definition at line 25 of file udp_engine.hpp.

◆ hello_msg_session_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::hello_msg_session_t	(	zmq::io_thread_t *	io_thread_,
		bool	connect_,
		zmq::socket_base_t *	socket_,
		const options_t &	options_,
		address_t *	addr_
	)

◆ hiccup()

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::hiccup ( )

◆ identify_peer()

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::identify_peer	(	pipe_t *	pipe_,
		bool	locally_initiated_
	)

Reimplemented from zmq::socket_base_t.

◆ init()

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::init	(	address_t *	address_,
		bool	send_,
		bool	recv_
	)

◆ io_thread_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::io_thread_t	(	zmq::ctx_t *	ctx_,
		uint32_t	tid_
	)

◆ is_delimiter()

template<typename T , int N>

static bool zmq::ZMQ_FINAL< T, N >::is_delimiter ( const msg_t & msg_ )

staticprivate

◆ long_size_ready()

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::long_size_ready ( unsigned char const * )

private

◆ mailbox_safe_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::mailbox_safe_t ( mutex_t * sync_ )

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::next_handshake_command ( msg_t * msg_ )

◆ next_handshake_command() [2/3]

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::next_handshake_command ( msg_t * msg_ )

◆ next_handshake_command() [3/3]

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::next_handshake_command ( msg_t * msg_ )

◆ null_mechanism_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::null_mechanism_t	(	session_base_t *	session_,
		const std::string &	peer_address_,
		const options_t &	options_
	)

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::pair_t	(	zmq::ctx_t *	parent_,
		uint32_t	tid_,
		int	sid_
	)

◆ parse_address()

template<typename T , int N>

static int zmq::ZMQ_FINAL< T, N >::parse_address	(	const std::string &	address_,
		std::string &	hostname_,
		uint16_t &	port_
	)

staticprivate

◆ peer_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::peer_t	(	zmq::ctx_t *	parent_,
		uint32_t	tid_,
		int	sid_
	)

◆ pend_connection()

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::pend_connection	(	const std::string &	addr_,
		const endpoint_t &	endpoint_,
		pipe_t **	pipes_
	)

◆ pipe_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::pipe_t	(	object_t *	parent_,
		upipe_t *	inpipe_,
		upipe_t *	outpipe_,
		int	inhwm_,
		int	outhwm_,
		bool	conflate_
	)

private

◆ plain_client_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::plain_client_t	(	session_base_t *	session_,
		const options_t &	options_
	)

◆ plain_server_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::plain_server_t	(	session_base_t *	session_,
		const std::string &	peer_address_,
		const options_t &	options_
	)

◆ plug()

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::plug	(	zmq::io_thread_t *	io_thread_,
		class session_base_t *	session_
	)

◆ plug_internal() [1/2]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::plug_internal ( )

protected

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::process_command_message ( msg_t * msg_ )

protected

◆ process_delimiter()

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::process_delimiter ( )

private

◆ process_error()

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::process_error	(	const unsigned char *	cmd_data_,
		size_t	data_size_
	)

private

◆ process_error_command()

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::process_error_command	(	const unsigned char *	cmd_data_,
		size_t	data_size_
	)

private

◆ process_handshake_command() [1/3]

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::process_handshake_command ( msg_t * msg_ )

◆ process_handshake_command() [2/3]

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::process_handshake_command ( msg_t * msg_ )

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::process_hiccup ( void * pipe_ )

privatevirtual

Reimplemented from zmq::object_t.

◆ process_initiate()

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::process_initiate ( msg_t * msg_ )

private

◆ process_pipe_hwm()

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::process_pipe_hwm	(	int	inhwm_,
		int	outhwm_
	)

privatevirtual

Reimplemented from zmq::object_t.

◆ process_pipe_peer_stats()

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::process_pipe_peer_stats	(	uint64_t	queue_count_,
		own_t *	socket_base_,
		endpoint_uri_pair_t *	endpoint_pair_
	)

privatevirtual

Reimplemented from zmq::object_t.

◆ process_pipe_term()

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::process_pipe_term ( )

privatevirtual

Reimplemented from zmq::object_t.

◆ process_pipe_term_ack()

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::process_pipe_term_ack ( )

privatevirtual

Reimplemented from zmq::object_t.

◆ process_ready()

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::process_ready	(	const unsigned char *	cmd_data_,
		size_t	data_size_
	)

private

◆ process_ready_command()

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::process_ready_command	(	const unsigned char *	cmd_data_,
		size_t	data_size_
	)

private

◆ process_reap()

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::process_reap ( zmq::socket_base_t * socket_ )

privatevirtual

Reimplemented from zmq::object_t.

◆ process_reaped()

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::process_reaped ( )

privatevirtual

Reimplemented from zmq::object_t.

◆ process_routing_id_msg()

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::process_routing_id_msg ( msg_t * msg_ )

private

◆ process_server_response() [1/3]

template<typename T , int N>

static int zmq::ZMQ_FINAL< T, N >::process_server_response ( const socks_auth_response_t & response_ )

staticprivate

◆ process_server_response() [2/3]

template<typename T , int N>

static int zmq::ZMQ_FINAL< T, N >::process_server_response ( const socks_choice_t & response_ )

staticprivate

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::process_welcome	(	const unsigned char *	cmd_data_,
		size_t	data_size_
	)

private

◆ push_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::push_t	(	zmq::ctx_t *	parent_,
		uint32_t	tid_,
		int	sid_
	)

◆ radio_session_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::radio_session_t	(	zmq::io_thread_t *	io_thread_,
		bool	connect_,
		zmq::socket_base_t *	socket_,
		const options_t &	options_,
		address_t *	addr_
	)

◆ radio_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::radio_t	(	zmq::ctx_t *	parent_,
		uint32_t	tid_,
		int	sid_
	)

◆ raw_decoder_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::raw_decoder_t ( size_t bufsize_ )

◆ raw_encoder_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::raw_encoder_t ( size_t bufsize_ )

◆ raw_engine_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::raw_engine_t	(	fd_t	fd_,
		const options_t &	options_,
		const endpoint_uri_pair_t &	endpoint_uri_pair_
	)

◆ raw_message_ready()

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::raw_message_ready ( )

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::reaper_t	(	zmq::ctx_t *	ctx_,
		uint32_t	tid_
	)

◆ receive_greeting()

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::receive_greeting ( )

private

◆ receive_greeting_versioned()

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::receive_greeting_versioned ( )

private

◆ recv() [1/2]

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::recv	(	command_t *	cmd_,
		int	timeout_
	)

◆ recv() [2/2]

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::recv	(	command_t *	cmd_,
		int	timeout_
	)

◆ recv_reply_pipe()

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::recv_reply_pipe ( zmq::msg_t * msg_ )

protected

◆ register_endpoint()

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::register_endpoint	(	const char *	addr_,
		const endpoint_t &	endpoint_
	)

◆ remove_signaler()

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::remove_signaler ( signaler_t * signaler_ )

◆ rep_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::rep_t	(	zmq::ctx_t *	parent_,
		uint32_t	tid_,
		int	sid_
	)

◆ req_session_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::req_session_t	(	zmq::io_thread_t *	io_thread_,
		bool	connect_,
		zmq::socket_base_t *	socket_,
		const options_t &	options_,
		address_t *	addr_
	)

◆ req_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::req_t	(	zmq::ctx_t *	parent_,
		uint32_t	tid_,
		int	sid_
	)

◆ reset() [1/4]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::reset ( )

◆ reset() [2/4]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::reset ( )

◆ reset() [3/4]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::reset ( )

◆ reset() [4/4]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::reset ( )

◆ resize_buffer()

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::resize_buffer ( size_t )

inline

Definition at line 29 of file raw_decoder.hpp.

◆ resolve_raw_address()

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::resolve_raw_address	(	const char *	name_,
		size_t	length_
	)

private

◆ restart_input()

template<typename T , int N>

bool zmq::ZMQ_FINAL< T, N >::restart_input ( )

◆ restart_output()

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::send_zap_request	(	const std::string &	username_,
		const std::string &	password_
	)

private

◆ set()

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::set	(	int	option_,
		const void *	optval_,
		size_t	optvallen_
	)

◆ set_auth_method_basic()

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::set_auth_method_basic	(	const std::string &	username,
		const std::string &	password
	)

◆ set_auth_method_none()

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::set_auth_method_none ( )

◆ set_peer()

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::set_peer ( pipe_t * peer_ )

private

◆ set_router_socket_routing_id()

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::set_router_socket_routing_id ( const blob_t & router_socket_routing_id_ )

◆ set_server_socket_routing_id()

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::set_server_socket_routing_id ( uint32_t server_socket_routing_id_ )

◆ set_udp_multicast_iface()

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::set_udp_multicast_iface	(	fd_t	s_,
		bool	is_ipv6_,
		const udp_address_t *	addr_
	)

private

◆ set_udp_multicast_loop()

template<typename T , int N>

static int zmq::ZMQ_FINAL< T, N >::set_udp_multicast_loop	(	fd_t	s_,
		bool	is_ipv6_,
		bool	loop_
	)

staticprivate

◆ set_udp_multicast_ttl()

template<typename T , int N>

static int zmq::ZMQ_FINAL< T, N >::set_udp_multicast_ttl	(	fd_t	s_,
		bool	is_ipv6_,
		int	hops_
	)

staticprivate

◆ set_udp_reuse_address()

template<typename T , int N>

static int zmq::ZMQ_FINAL< T, N >::set_udp_reuse_address	(	fd_t	s_,
		bool	on_
	)

staticprivate

◆ set_udp_reuse_port()

template<typename T , int N>

static int zmq::ZMQ_FINAL< T, N >::set_udp_reuse_port	(	fd_t	s_,
		bool	on_
	)

staticprivate

◆ short_size_ready()

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::short_size_ready ( unsigned char const * )

private

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::size_ready	(	uint64_t	size_,
		unsigned char const *
	)

private

◆ size_ready() [6/6]

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::size_ready ( unsigned char const * )

private

◆ sockaddr_to_msg()

template<typename T , int N>

static void zmq::ZMQ_FINAL< T, N >::sockaddr_to_msg	(	zmq::msg_t *	msg_,
		const sockaddr_in *	addr_
	)

staticprivate

◆ socks_connecter_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::socks_connecter_t	(	zmq::io_thread_t *	io_thread_,
		zmq::session_base_t *	session_,
		const options_t &	options_,
		address_t *	addr_,
		address_t *	proxy_addr_,
		bool	delayed_start_
	)

◆ start() [1/3]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::start ( )

template<typename T , int N>

status_t zmq::ZMQ_FINAL< T, N >::status ( ) const

◆ status() [2/2]

template<typename T , int N>

status_t zmq::ZMQ_FINAL< T, N >::status ( ) const

◆ stop() [1/2]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::stop ( )

◆ stop() [2/2]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::stop ( )

◆ stream_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::stream_t	(	zmq::ctx_t *	parent_,
		uint32_t	tid_,
		int	sid_
	)

◆ sub_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::sub_t	(	zmq::ctx_t *	parent_,
		uint32_t	tid_,
		int	sid_
	)

◆ tcp_connecter_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::tcp_connecter_t	(	zmq::io_thread_t *	io_thread_,
		zmq::session_base_t *	session_,
		const options_t &	options_,
		address_t *	addr_,
		bool	delayed_start_
	)

◆ tcp_listener_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::tcp_listener_t	(	zmq::io_thread_t *	io_thread_,
		zmq::socket_base_t *	socket_,
		const options_t &	options_
	)

◆ terminate() [1/3]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::terminate ( )

◆ terminate() [2/3]

template<typename T , int N>

template<typename T , int N>

bool zmq::ZMQ_FINAL< T, N >::tune_socket ( fd_t fd_ )

private

◆ tune_socket() [2/2]

template<typename T , int N>

bool zmq::ZMQ_FINAL< T, N >::tune_socket ( fd_t fd_ )

private

◆ udp_engine_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::udp_engine_t ( const options_t & options_ )

◆ unregister_endpoint()

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::unregister_endpoint	(	const std::string &	addr_,
		const socket_base_t *	socket_
	)

zmq::ZMQ_FINAL< T, N >::v1_decoder_t	(	size_t	bufsize_,
		int64_t	maxmsgsize_
	)

◆ v1_encoder_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::v1_encoder_t ( size_t bufsize_ )

◆ v2_decoder_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::v2_decoder_t	(	size_t	bufsize_,
		int64_t	maxmsgsize_,
		bool	zero_copy_
	)

◆ v2_encoder_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::v2_encoder_t ( size_t bufsize_ )

◆ v3_1_encoder_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::v3_1_encoder_t ( size_t bufsize_ )

◆ valid() [1/2]

template<typename T , int N>

bool zmq::ZMQ_FINAL< T, N >::valid ( ) const

◆ valid() [2/2]

template<typename T , int N>

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::ws_connecter_t	(	zmq::io_thread_t *	io_thread_,
		zmq::session_base_t *	session_,
		const options_t &	options_,
		address_t *	addr_,
		bool	delayed_start_,
		bool	wss_,
		const std::string &	tls_hostname_
	)

◆ ws_decoder_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::ws_decoder_t	(	size_t	bufsize_,
		int64_t	maxmsgsize_,
		bool	zero_copy_,
		bool	must_mask_
	)

◆ ws_encoder_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::ws_encoder_t	(	size_t	bufsize_,
		bool	must_mask_
	)

◆ ws_listener_t()

template<typename T , int N>

zmq::ZMQ_FINAL< T, N >::ws_listener_t	(	zmq::io_thread_t *	io_thread_,
		zmq::socket_base_t *	socket_,
		const options_t &	options_,
		bool	wss_
	)

◆ xattach_pipe() [1/13]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::xattach_pipe	(	zmq::pipe_t *	pipe_,
		bool	subscribe_to_all_,
		bool	locally_initiated_
	)

virtual

Implements zmq::socket_base_t.

◆ xattach_pipe() [2/13]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::xattach_pipe	(	zmq::pipe_t *	pipe_,
		bool	subscribe_to_all_,
		bool	locally_initiated_
	)

protectedvirtual

Implements zmq::socket_base_t.

◆ xattach_pipe() [3/13]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::xattach_pipe	(	zmq::pipe_t *	pipe_,
		bool	subscribe_to_all_,
		bool	locally_initiated_
	)

virtual

Implements zmq::socket_base_t.

◆ xattach_pipe() [4/13]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::xattach_pipe	(	zmq::pipe_t *	pipe_,
		bool	subscribe_to_all_,
		bool	locally_initiated_
	)

virtual

Implements zmq::socket_base_t.

◆ xattach_pipe() [5/13]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::xattach_pipe	(	zmq::pipe_t *	pipe_,
		bool	subscribe_to_all_,
		bool	locally_initiated_
	)

virtual

Implements zmq::socket_base_t.

◆ xattach_pipe() [6/13]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::xattach_pipe	(	zmq::pipe_t *	pipe_,
		bool	subscribe_to_all_,
		bool	locally_initiated_
	)

protectedvirtual

Implements zmq::socket_base_t.

◆ xattach_pipe() [7/13]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::xattach_pipe	(	zmq::pipe_t *	pipe_,
		bool	subscribe_to_all_,
		bool	locally_initiated_
	)

protectedvirtual

Implements zmq::socket_base_t.

◆ xattach_pipe() [8/13]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::xattach_pipe	(	zmq::pipe_t *	pipe_,
		bool	subscribe_to_all_,
		bool	locally_initiated_
	)

protectedvirtual

Implements zmq::socket_base_t.

◆ xattach_pipe() [9/13]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::xattach_pipe	(	zmq::pipe_t *	pipe_,
		bool	subscribe_to_all_,
		bool	locally_initiated_
	)

protectedvirtual

Implements zmq::socket_base_t.

◆ xattach_pipe() [10/13]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::xattach_pipe	(	zmq::pipe_t *	pipe_,
		bool	subscribe_to_all_,
		bool	locally_initiated_
	)

virtual

Implements zmq::socket_base_t.

◆ xattach_pipe() [11/13]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::xattach_pipe	(	zmq::pipe_t *	pipe_,
		bool	subscribe_to_all_,
		bool	locally_initiated_
	)

protectedvirtual

Implements zmq::socket_base_t.

◆ xattach_pipe() [12/13]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::xattach_pipe	(	zmq::pipe_t *	pipe_,
		bool	subscribe_to_all_ = `false`,
		bool	locally_initiated_ = `false`
	)

virtual

Implements zmq::socket_base_t.

◆ xattach_pipe() [13/13]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::xattach_pipe	(	zmq::pipe_t *	pipe_,
		bool	subscribe_to_all_ = `false`,
		bool	locally_initiated_ = `false`
	)

◆ xpipe_terminated() [2/12]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::xpipe_terminated ( zmq::pipe_t * pipe_ )

protected

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::xpipe_terminated ( zmq::pipe_t * pipe_ )

◆ xpipe_terminated() [8/12]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::xpipe_terminated ( zmq::pipe_t * pipe_ )

◆ xpipe_terminated() [9/12]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::xpipe_terminated ( zmq::pipe_t * pipe_ )

◆ xpipe_terminated() [10/12]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::xpipe_terminated ( zmq::pipe_t * pipe_ )

protected

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::xread_activated ( zmq::pipe_t * pipe_ )

◆ xread_activated() [3/9]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::xread_activated ( zmq::pipe_t * pipe_ )

protected

◆ xread_activated() [4/9]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::xread_activated ( zmq::pipe_t * pipe_ )

◆ xread_activated() [5/9]

template<typename T , int N>

void zmq::ZMQ_FINAL< T, N >::xread_activated ( zmq::pipe_t * pipe_ )

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::xsend ( zmq::msg_t * msg_ )

virtual

Reimplemented from zmq::socket_base_t.

◆ xsetsockopt() [1/4]

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::xsetsockopt	(	int	option_,
		const void *	optval_,
		size_t	optvallen_
	)

protectedvirtual

Reimplemented from zmq::socket_base_t.

◆ xsetsockopt() [2/4]

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::xsetsockopt	(	int	option_,
		const void *	optval_,
		size_t	optvallen_
	)

virtual

Reimplemented from zmq::socket_base_t.

◆ xsetsockopt() [3/4]

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::xsetsockopt	(	int	option_,
		const void *	optval_,
		size_t	optvallen_
	)

virtual

Reimplemented from zmq::socket_base_t.

◆ xsetsockopt() [4/4]

template<typename T , int N>

int zmq::ZMQ_FINAL< T, N >::xsetsockopt	(	int	option_,
		const void *	optval_,
		size_t	optvallen_
	)

virtual

Reimplemented from zmq::socket_base_t.