#include <socket_base.hpp>

Inheritance diagram for zmq::socket_base_t:

[legend]

Classes
class	inprocs_t

Public Member Functions
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

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

Static Public Member Functions
static socket_base_t *	create (int type_, zmq::ctx_t *parent_, uint32_t tid_, int sid_)

Protected Member Functions
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 void	xattach_pipe (zmq::pipe_t *pipe_, bool subscribe_to_all_=false, bool locally_initiated_=false)=0

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

virtual bool	xhas_in ()

virtual bool	xhas_out ()

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

virtual int	xrecv (zmq::msg_t *msg_)

virtual int	xsend (zmq::msg_t *msg_)

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

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

Protected Attributes
mutex_t	_sync

Protected Attributes inherited from zmq::own_t
options_t	options

Private Types
typedef std::pair< own_t , pipe_t >	endpoint_pipe_t

typedef std::multimap< std::string, endpoint_pipe_t >	endpoints_t

typedef array_t< pipe_t, 3 >	pipes_t

Private Member Functions
void	add_endpoint (const endpoint_uri_pair_t &endpoint_pair_, own_t endpoint_, pipe_t pipe_)

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

void	check_destroy ()

int	check_protocol (const std::string &protocol_) const

void	event (const endpoint_uri_pair_t &endpoint_uri_pair_, uint64_t values_[], uint64_t values_count_, uint64_t type_)

void	extract_flags (const msg_t *msg_)

void	monitor_event (uint64_t event_, const uint64_t values_[], uint64_t values_count_, const endpoint_uri_pair_t &endpoint_uri_pair_) const

void	process_bind (zmq::pipe_t *pipe_) ZMQ_FINAL

int	process_commands (int timeout_, bool throttle_)

void	process_pipe_stats_publish (uint64_t outbound_queue_count_, uint64_t inbound_queue_count_, endpoint_uri_pair_t *endpoint_pair_) ZMQ_FINAL

void	process_stop () ZMQ_FINAL

void	process_term (int linger_) ZMQ_FINAL

void	process_term_endpoint (std::string *endpoint_) ZMQ_FINAL

std::string	resolve_tcp_addr (std::string endpoint_uri_, const char *tcp_address_)

void	stop_monitor (bool send_monitor_stopped_event_=true)

void	update_pipe_options (int option_)

Static Private Member Functions
static int	parse_uri (const char *uri_, std::string &protocol_, std::string &path_)

Private Attributes
clock_t	_clock

bool	_ctx_terminated

bool	_destroyed

bool	_disconnected

endpoints_t	_endpoints

poller_t::handle_t	_handle

inprocs_t	_inprocs

std::string	_last_endpoint

uint64_t	_last_tsc

i_mailbox *	_mailbox

int64_t	_monitor_events

void *	_monitor_socket

mutex_t	_monitor_sync

pipes_t	_pipes

poller_t *	_poller

bool	_rcvmore

signaler_t *	_reaper_signaler

uint32_t	_tag

const bool	_thread_safe

int	_ticks

Friends
class	reaper_t

Detailed Description

Definition at line 31 of file socket_base.hpp.

Member Typedef Documentation

◆ endpoint_pipe_t

typedef std::pair<own_t *, pipe_t *> zmq::socket_base_t::endpoint_pipe_t

private

Definition at line 215 of file socket_base.hpp.

◆ endpoints_t

typedef std::multimap<std::string, endpoint_pipe_t> zmq::socket_base_t::endpoints_t

private

Definition at line 216 of file socket_base.hpp.

◆ pipes_t

typedef array_t<pipe_t, 3> zmq::socket_base_t::pipes_t

private

Definition at line 290 of file socket_base.hpp.

Constructor & Destructor Documentation

◆ socket_base_t()

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

protected

Definition at line 213 of file socket_base.cpp.

◆ ~socket_base_t()

zmq::socket_base_t::~socket_base_t ( )

protected

Definition at line 266 of file socket_base.cpp.

Member Function Documentation

◆ add_endpoint()

void zmq::socket_base_t::add_endpoint	(	const endpoint_uri_pair_t &	endpoint_pair_,
		own_t *	endpoint_,
		pipe_t *	pipe_
	)

private

Definition at line 1125 of file socket_base.cpp.

◆ add_signaler()

void zmq::socket_base_t::add_signaler ( signaler_t * s_ )

Definition at line 496 of file socket_base.cpp.

◆ attach_pipe()

void zmq::socket_base_t::attach_pipe	(	zmq::pipe_t *	pipe_,
		bool	subscribe_to_all_ = `false`,
		bool	locally_initiated_ = `false`
	)

private

Definition at line 382 of file socket_base.cpp.

◆ bind()

int zmq::socket_base_t::bind ( const char * endpoint_uri_ )

Definition at line 512 of file socket_base.cpp.

◆ check_destroy()

void zmq::socket_base_t::check_destroy ( )

private

Definition at line 1688 of file socket_base.cpp.

◆ check_protocol()

int zmq::socket_base_t::check_protocol ( const std::string & protocol_ ) const

private

Definition at line 318 of file socket_base.cpp.

◆ check_tag()

bool zmq::socket_base_t::check_tag ( ) const

Definition at line 117 of file socket_base.cpp.

◆ close()

int zmq::socket_base_t::close ( )

Definition at line 1389 of file socket_base.cpp.

◆ connect()

int zmq::socket_base_t::connect ( const char * endpoint_uri_ )

Definition at line 750 of file socket_base.cpp.

◆ connect_internal()

int zmq::socket_base_t::connect_internal ( const char * endpoint_uri_ )

protected

Definition at line 756 of file socket_base.cpp.

◆ create()

zmq::socket_base_t * zmq::socket_base_t::create	(	int	type_,
		zmq::ctx_t *	parent_,
		uint32_t	tid_,
		int	sid_
	)

static

Definition at line 127 of file socket_base.cpp.

◆ event()

void zmq::socket_base_t::event	(	const endpoint_uri_pair_t &	endpoint_uri_pair_,
		uint64_t	values_[],
		uint64_t	values_count_,
		uint64_t	type_
	)

private

Definition at line 1939 of file socket_base.cpp.

◆ event_accept_failed()

void zmq::socket_base_t::event_accept_failed	(	const endpoint_uri_pair_t &	endpoint_uri_pair_,
		int	err_
	)

Definition at line 1883 of file socket_base.cpp.

◆ event_accepted()

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

Definition at line 1876 of file socket_base.cpp.

◆ event_bind_failed()

void zmq::socket_base_t::event_bind_failed	(	const endpoint_uri_pair_t &	endpoint_uri_pair_,
		int	err_
	)

Definition at line 1869 of file socket_base.cpp.

◆ event_close_failed()

void zmq::socket_base_t::event_close_failed	(	const endpoint_uri_pair_t &	endpoint_uri_pair_,
		int	err_
	)

Definition at line 1897 of file socket_base.cpp.

◆ event_closed()

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

Definition at line 1890 of file socket_base.cpp.

◆ event_connect_delayed()

void zmq::socket_base_t::event_connect_delayed	(	const endpoint_uri_pair_t &	endpoint_uri_pair_,
		int	err_
	)

Definition at line 1848 of file socket_base.cpp.

◆ event_connect_retried()

void zmq::socket_base_t::event_connect_retried	(	const endpoint_uri_pair_t &	endpoint_uri_pair_,
		int	interval_
	)

Definition at line 1855 of file socket_base.cpp.

◆ event_connected()

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

Definition at line 1841 of file socket_base.cpp.

◆ event_disconnected()

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

Definition at line 1904 of file socket_base.cpp.

◆ event_handshake_failed_auth()

void zmq::socket_base_t::event_handshake_failed_auth	(	const endpoint_uri_pair_t &	endpoint_uri_pair_,
		int	err_
	)

Definition at line 1925 of file socket_base.cpp.

◆ event_handshake_failed_no_detail()

void zmq::socket_base_t::event_handshake_failed_no_detail	(	const endpoint_uri_pair_t &	endpoint_uri_pair_,
		int	err_
	)

Definition at line 1911 of file socket_base.cpp.

◆ event_handshake_failed_protocol()

void zmq::socket_base_t::event_handshake_failed_protocol	(	const endpoint_uri_pair_t &	endpoint_uri_pair_,
		int	err_
	)

Definition at line 1918 of file socket_base.cpp.

◆ event_handshake_succeeded()

void zmq::socket_base_t::event_handshake_succeeded	(	const endpoint_uri_pair_t &	endpoint_uri_pair_,
		int	err_
	)

Definition at line 1932 of file socket_base.cpp.

◆ event_listening()

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

Definition at line 1862 of file socket_base.cpp.

◆ extract_flags()

void zmq::socket_base_t::extract_flags ( const msg_t * msg_ )

private

Definition at line 1755 of file socket_base.cpp.

◆ get_mailbox()

zmq::i_mailbox * zmq::socket_base_t::get_mailbox ( ) const

Definition at line 280 of file socket_base.cpp.

◆ get_peer_state()

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

virtual

Reimplemented in zmq::router_t.

Definition at line 255 of file socket_base.cpp.

◆ getsockopt()

int zmq::socket_base_t::getsockopt	(	int	option_,
		void *	optval_,
		size_t *	optvallen_
	)

Definition at line 426 of file socket_base.cpp.

◆ has_in()

bool zmq::socket_base_t::has_in ( )

Definition at line 1409 of file socket_base.cpp.

◆ has_out()

bool zmq::socket_base_t::has_out ( )

Definition at line 1414 of file socket_base.cpp.

◆ hiccuped()

void zmq::socket_base_t::hiccuped ( pipe_t * pipe_ )

Definition at line 1716 of file socket_base.cpp.

◆ in_event()

void zmq::socket_base_t::in_event ( )

virtual

Implements zmq::i_poll_events.

Reimplemented in zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, and zmq::ZMQ_FINAL< T, N >.

Definition at line 1660 of file socket_base.cpp.

◆ is_disconnected()

bool zmq::socket_base_t::is_disconnected ( ) const

Definition at line 2045 of file socket_base.cpp.

◆ is_thread_safe()

bool zmq::socket_base_t::is_thread_safe ( ) const

Definition at line 122 of file socket_base.cpp.

◆ join()

int zmq::socket_base_t::join ( const char * group_ )

Definition at line 482 of file socket_base.cpp.

◆ leave()

int zmq::socket_base_t::leave ( const char * group_ )

Definition at line 489 of file socket_base.cpp.

◆ lock()

void zmq::socket_base_t::lock ( )

◆ monitor()

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

Definition at line 1765 of file socket_base.cpp.

◆ monitor_event()

void zmq::socket_base_t::monitor_event	(	uint64_t	event_,
		const uint64_t	values_[],
		uint64_t	values_count_,
		const endpoint_uri_pair_t &	endpoint_uri_pair_
	)		const

private

Definition at line 1951 of file socket_base.cpp.

◆ out_event()

void zmq::socket_base_t::out_event ( )

virtual

Implements zmq::i_poll_events.

Reimplemented in zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, and zmq::ZMQ_FINAL< T, N >.

Definition at line 1678 of file socket_base.cpp.

◆ parse_uri()

int zmq::socket_base_t::parse_uri	(	const char *	uri_,
		std::string &	protocol_,
		std::string &	path_
	)

staticprivate

Definition at line 296 of file socket_base.cpp.

◆ pipe_terminated()

void zmq::socket_base_t::pipe_terminated ( pipe_t * pipe_ )

Definition at line 1725 of file socket_base.cpp.

◆ process_bind()

void zmq::socket_base_t::process_bind ( zmq::pipe_t * pipe_ )

privatevirtual

Reimplemented from zmq::object_t.

Definition at line 1514 of file socket_base.cpp.

◆ process_commands()

int zmq::socket_base_t::process_commands	(	int	timeout_,
		bool	throttle_
	)

private

Definition at line 1452 of file socket_base.cpp.

◆ process_destroy()

void zmq::socket_base_t::process_destroy ( )

protectedvirtual

Reimplemented from zmq::own_t.

Definition at line 1593 of file socket_base.cpp.

◆ process_pipe_stats_publish()

void zmq::socket_base_t::process_pipe_stats_publish	(	uint64_t	outbound_queue_count_,
		uint64_t	inbound_queue_count_,
		endpoint_uri_pair_t *	endpoint_pair_
	)

privatevirtual

Reimplemented from zmq::object_t.

Definition at line 1544 of file socket_base.cpp.

◆ process_stop()

void zmq::socket_base_t::process_stop ( )

privatevirtual

Reimplemented from zmq::object_t.

Definition at line 1502 of file socket_base.cpp.

◆ process_term()

void zmq::socket_base_t::process_term ( int linger_ )

privatevirtual

Reimplemented from zmq::own_t.

Reimplemented in zmq::ZMQ_FINAL< T, N >, and zmq::ZMQ_FINAL< T, N >.

Definition at line 1519 of file socket_base.cpp.

◆ process_term_endpoint()

void zmq::socket_base_t::process_term_endpoint ( std::string * endpoint_ )

privatevirtual

Reimplemented from zmq::object_t.

Definition at line 1538 of file socket_base.cpp.

◆ query_pipes_stats()

int zmq::socket_base_t::query_pipes_stats ( )

Definition at line 1563 of file socket_base.cpp.

◆ read_activated()

void zmq::socket_base_t::read_activated ( pipe_t * pipe_ )

Definition at line 1706 of file socket_base.cpp.

◆ recv()

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

Definition at line 1293 of file socket_base.cpp.

◆ remove_signaler()

void zmq::socket_base_t::remove_signaler ( signaler_t * s_ )

Definition at line 504 of file socket_base.cpp.

◆ resolve_tcp_addr()

std::string zmq::socket_base_t::resolve_tcp_addr	(	std::string	endpoint_uri_,
		const char *	tcp_address_
	)

private

Definition at line 1098 of file socket_base.cpp.

◆ send()

int zmq::socket_base_t::send	(	zmq::msg_t *	msg_,
		int	flags_
	)

Definition at line 1205 of file socket_base.cpp.

◆ setsockopt()

int zmq::socket_base_t::setsockopt	(	int	option_,
		const void *	optval_,
		size_t	optvallen_
	)

Definition at line 401 of file socket_base.cpp.

◆ start_reaping()

void zmq::socket_base_t::start_reaping ( poller_t * poller_ )

Definition at line 1419 of file socket_base.cpp.

◆ stop()

void zmq::socket_base_t::stop ( )

Definition at line 285 of file socket_base.cpp.

◆ stop_monitor()

void zmq::socket_base_t::stop_monitor ( bool send_monitor_stopped_event_ = true )

private

Definition at line 2027 of file socket_base.cpp.

◆ term_endpoint()

int zmq::socket_base_t::term_endpoint ( const char * endpoint_uri_ )

Definition at line 1137 of file socket_base.cpp.

◆ timer_event()

void zmq::socket_base_t::timer_event ( int id_ )

virtual

Implements zmq::i_poll_events.

Reimplemented in zmq::ZMQ_FINAL< T, N >, and zmq::ZMQ_FINAL< T, N >.

Definition at line 1683 of file socket_base.cpp.

◆ unlock()

void zmq::socket_base_t::unlock ( )

◆ update_pipe_options()

void zmq::socket_base_t::update_pipe_options ( int option_ )

private

Definition at line 1583 of file socket_base.cpp.

◆ write_activated()

void zmq::socket_base_t::write_activated ( pipe_t * pipe_ )

Definition at line 1711 of file socket_base.cpp.

◆ xattach_pipe()

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

protectedpure virtual

Implemented in zmq::xpub_t, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::xsub_t, zmq::router_t, zmq::dealer_t, zmq::ZMQ_FINAL< T, N >, zmq::server_t, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, and zmq::ZMQ_FINAL< T, N >.

◆ xgetsockopt()

int zmq::socket_base_t::xgetsockopt	(	int	option_,
		void *	optval_,
		size_t *	optvallen_
	)

protectedvirtual

Reimplemented in zmq::xpub_t, and zmq::xsub_t.

Definition at line 1604 of file socket_base.cpp.

◆ xhas_in()

bool zmq::socket_base_t::xhas_in ( )

protectedvirtual

Reimplemented in zmq::dealer_t, zmq::router_t, zmq::xpub_t, zmq::xsub_t, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::server_t, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, and zmq::ZMQ_FINAL< T, N >.

Definition at line 1621 of file socket_base.cpp.

◆ xhas_out()

bool zmq::socket_base_t::xhas_out ( )

protectedvirtual

Reimplemented in zmq::xsub_t, zmq::dealer_t, zmq::router_t, zmq::xpub_t, zmq::server_t, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, and zmq::ZMQ_FINAL< T, N >.

Definition at line 1610 of file socket_base.cpp.

◆ xhiccuped()

void zmq::socket_base_t::xhiccuped ( pipe_t * pipe_ )

protectedvirtual

Reimplemented in zmq::xsub_t, and zmq::ZMQ_FINAL< T, N >.

Definition at line 1655 of file socket_base.cpp.

◆ xjoin()

int zmq::socket_base_t::xjoin ( const char * group_ )

protectedvirtual

Reimplemented in zmq::ZMQ_FINAL< T, N >.

Definition at line 1626 of file socket_base.cpp.

◆ xleave()

int zmq::socket_base_t::xleave ( const char * group_ )

protectedvirtual

Reimplemented in zmq::ZMQ_FINAL< T, N >.

Definition at line 1633 of file socket_base.cpp.

◆ xpipe_terminated()

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

protectedpure virtual

◆ xread_activated()

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

protectedvirtual

Definition at line 1646 of file socket_base.cpp.

◆ xrecv()

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

protectedvirtual

Reimplemented in zmq::dealer_t, zmq::router_t, zmq::xpub_t, zmq::xsub_t, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::server_t, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, and zmq::ZMQ_FINAL< T, N >.

Definition at line 1640 of file socket_base.cpp.

◆ xsend()

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

protectedvirtual

Reimplemented in zmq::xsub_t, zmq::dealer_t, zmq::router_t, zmq::xpub_t, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::server_t, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, and zmq::ZMQ_FINAL< T, N >.

Definition at line 1615 of file socket_base.cpp.

◆ xsetsockopt()

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

protectedvirtual

Reimplemented in zmq::routing_socket_base_t, zmq::xsub_t, zmq::dealer_t, zmq::xpub_t, zmq::router_t, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, zmq::ZMQ_FINAL< T, N >, and zmq::ZMQ_FINAL< T, N >.

Definition at line 1598 of file socket_base.cpp.

◆ xwrite_activated()

void zmq::socket_base_t::xwrite_activated ( pipe_t * pipe_ )

protectedvirtual

Reimplemented in zmq::routing_socket_base_t.

Definition at line 1650 of file socket_base.cpp.

Friends And Related Function Documentation

◆ reaper_t

friend class reaper_t

friend

Definition at line 36 of file socket_base.hpp.

Member Data Documentation

◆ _clock

clock_t zmq::socket_base_t::_clock

private

Definition at line 307 of file socket_base.hpp.

◆ _ctx_terminated

bool zmq::socket_base_t::_ctx_terminated

private

Definition at line 245 of file socket_base.hpp.

◆ _destroyed

bool zmq::socket_base_t::_destroyed

private

Definition at line 250 of file socket_base.hpp.

◆ _disconnected

bool zmq::socket_base_t::_disconnected

private

Definition at line 330 of file socket_base.hpp.

◆ _endpoints

endpoints_t zmq::socket_base_t::_endpoints

private

Definition at line 217 of file socket_base.hpp.

◆ _handle

poller_t::handle_t zmq::socket_base_t::_handle

private

Definition at line 295 of file socket_base.hpp.

◆ _inprocs

inprocs_t zmq::socket_base_t::_inprocs

private

Definition at line 231 of file socket_base.hpp.

◆ _last_endpoint

std::string zmq::socket_base_t::_last_endpoint

private

Definition at line 316 of file socket_base.hpp.

◆ _last_tsc

uint64_t zmq::socket_base_t::_last_tsc

private

Definition at line 298 of file socket_base.hpp.

◆ _mailbox

i_mailbox* zmq::socket_base_t::_mailbox

private

Definition at line 287 of file socket_base.hpp.

◆ _monitor_events

int64_t zmq::socket_base_t::_monitor_events

private

Definition at line 313 of file socket_base.hpp.

◆ _monitor_socket

void* zmq::socket_base_t::_monitor_socket

private

Definition at line 310 of file socket_base.hpp.

◆ _monitor_sync

mutex_t zmq::socket_base_t::_monitor_sync

private

Definition at line 325 of file socket_base.hpp.

◆ _pipes

pipes_t zmq::socket_base_t::_pipes

private

Definition at line 291 of file socket_base.hpp.

◆ _poller

poller_t* zmq::socket_base_t::_poller

private

Definition at line 294 of file socket_base.hpp.

◆ _rcvmore

bool zmq::socket_base_t::_rcvmore

private

Definition at line 304 of file socket_base.hpp.

◆ _reaper_signaler

signaler_t* zmq::socket_base_t::_reaper_signaler

private

Definition at line 322 of file socket_base.hpp.

◆ _sync

mutex_t zmq::socket_base_t::_sync

protected

Definition at line 191 of file socket_base.hpp.

◆ _tag

uint32_t zmq::socket_base_t::_tag

private

Definition at line 242 of file socket_base.hpp.

◆ _thread_safe

const bool zmq::socket_base_t::_thread_safe

private

Definition at line 319 of file socket_base.hpp.

◆ _ticks

int zmq::socket_base_t::_ticks

private

Definition at line 301 of file socket_base.hpp.

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

Classes

Public Member Functions

Static Public Member Functions

Protected Member Functions

Protected Attributes

Private Types

Private Member Functions

Static Private Member Functions

Private Attributes

Friends

Detailed Description

Member Typedef Documentation

◆ endpoint_pipe_t

◆ endpoints_t

◆ pipes_t

Constructor & Destructor Documentation

◆ socket_base_t()

◆ ~socket_base_t()

Member Function Documentation

◆ add_endpoint()

◆ add_signaler()

◆ attach_pipe()

◆ bind()

◆ check_destroy()

◆ check_protocol()

◆ check_tag()

◆ close()

◆ connect()

◆ connect_internal()

◆ create()

◆ event()

◆ event_accept_failed()

◆ event_accepted()

◆ event_bind_failed()

◆ event_close_failed()

◆ event_closed()

◆ event_connect_delayed()

◆ event_connect_retried()

◆ event_connected()

◆ event_disconnected()

◆ event_handshake_failed_auth()

◆ event_handshake_failed_no_detail()

◆ event_handshake_failed_protocol()

◆ event_handshake_succeeded()

◆ event_listening()

◆ extract_flags()

◆ get_mailbox()

◆ get_peer_state()

◆ getsockopt()

◆ has_in()

◆ has_out()

◆ hiccuped()

◆ in_event()

◆ is_disconnected()

◆ is_thread_safe()

◆ join()

◆ leave()

◆ lock()

◆ monitor()

◆ monitor_event()

◆ out_event()

◆ parse_uri()

◆ pipe_terminated()

◆ process_bind()

◆ process_commands()

◆ process_destroy()

◆ process_pipe_stats_publish()

◆ process_stop()

◆ process_term()

◆ process_term_endpoint()

◆ query_pipes_stats()

◆ read_activated()

◆ recv()

◆ remove_signaler()

◆ resolve_tcp_addr()

◆ send()

◆ setsockopt()

◆ start_reaping()

◆ stop()

◆ stop_monitor()