#include <object.hpp>

Inheritance diagram for zmq::object_t:

[legend]

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

Protected Member Functions
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_bind (zmq::pipe_t *pipe_)

virtual void	process_conn_failed ()

virtual void	process_hiccup (void *pipe_)

virtual void	process_own (zmq::own_t *object_)

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_stats_publish (uint64_t outbound_queue_count_, uint64_t inbound_queue_count_, 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 ()

virtual void	process_seqnum ()

virtual void	process_stop ()

virtual void	process_term (int linger_)

virtual void	process_term_ack ()

virtual void	process_term_endpoint (std::string *endpoint_)

virtual void	process_term_req (zmq::own_t *object_)

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
void	send_command (const command_t &cmd_)

Private Attributes
zmq::ctx_t *const	_ctx

uint32_t	_tid

Detailed Description

Definition at line 28 of file object.hpp.

Constructor & Destructor Documentation

◆ object_t() [1/2]

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

◆ object_t() [2/2]

zmq::object_t::object_t ( object_t * parent_ )

Definition at line 19 of file object.cpp.

◆ ~object_t()

zmq::object_t::~object_t ( )

virtual

Definition at line 24 of file object.cpp.

Member Function Documentation

◆ choose_io_thread()

zmq::io_thread_t * zmq::object_t::choose_io_thread ( uint64_t affinity_ ) const

protected

Definition at line 186 of file object.cpp.

◆ connect_pending()

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

protected

Definition at line 175 of file object.cpp.

◆ destroy_socket()

void zmq::object_t::destroy_socket ( zmq::socket_base_t * socket_ )

protected

Definition at line 181 of file object.cpp.

◆ find_endpoint()

zmq::endpoint_t zmq::object_t::find_endpoint ( const char * addr_ ) const

protected

Definition at line 163 of file object.cpp.

◆ get_ctx()

zmq::ctx_t * zmq::object_t::get_ctx ( ) const

Definition at line 38 of file object.cpp.

◆ get_tid()

uint32_t zmq::object_t::get_tid ( ) const

Definition at line 28 of file object.cpp.

◆ log()

void zmq::object_t::log	(	const char *	format_,
			...
	)

protected

◆ pend_connection()

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

protected

Definition at line 168 of file object.cpp.

◆ process_activate_read()

void zmq::object_t::process_activate_read ( )

protectedvirtual

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

Definition at line 436 of file object.cpp.

◆ process_activate_write()

void zmq::object_t::process_activate_write ( uint64_t msgs_read_ )

protectedvirtual

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

Definition at line 441 of file object.cpp.

◆ process_attach()

void zmq::object_t::process_attach ( zmq::i_engine * engine_ )

protectedvirtual

Reimplemented in zmq::session_base_t.

Definition at line 426 of file object.cpp.

◆ process_bind()

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

protectedvirtual

Reimplemented in zmq::socket_base_t.

Definition at line 431 of file object.cpp.

◆ process_command()

void zmq::object_t::process_command ( const zmq::command_t & cmd_ )

Definition at line 43 of file object.cpp.

◆ process_conn_failed()

void zmq::object_t::process_conn_failed ( )

protectedvirtual

Reimplemented in zmq::session_base_t.

Definition at line 515 of file object.cpp.

◆ process_hiccup()

void zmq::object_t::process_hiccup ( void * pipe_ )

protectedvirtual

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

Definition at line 446 of file object.cpp.

◆ process_own()

void zmq::object_t::process_own ( zmq::own_t * object_ )

protectedvirtual

Reimplemented in zmq::own_t.

Definition at line 421 of file object.cpp.

◆ process_pipe_hwm()

void zmq::object_t::process_pipe_hwm	(	int	inhwm_,
		int	outhwm_
	)

protectedvirtual

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

Definition at line 475 of file object.cpp.

◆ process_pipe_peer_stats()

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

protectedvirtual

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

Definition at line 451 of file object.cpp.

◆ process_pipe_stats_publish()

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

protectedvirtual

Reimplemented in zmq::socket_base_t.

Definition at line 458 of file object.cpp.

◆ process_pipe_term()

void zmq::object_t::process_pipe_term ( )

protectedvirtual

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

Definition at line 465 of file object.cpp.

◆ process_pipe_term_ack()

void zmq::object_t::process_pipe_term_ack ( )

protectedvirtual

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

Definition at line 470 of file object.cpp.

◆ process_plug()

void zmq::object_t::process_plug ( )

protectedvirtual

Reimplemented in zmq::session_base_t, zmq::stream_listener_base_t, and zmq::stream_connecter_base_t.

Definition at line 416 of file object.cpp.

◆ process_reap()

void zmq::object_t::process_reap ( zmq::socket_base_t * socket_ )

protectedvirtual

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

Definition at line 500 of file object.cpp.

◆ process_reaped()

void zmq::object_t::process_reaped ( )

protectedvirtual

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

Definition at line 505 of file object.cpp.

◆ process_seqnum()

void zmq::object_t::process_seqnum ( )

protectedvirtual

Reimplemented in zmq::own_t.

Definition at line 510 of file object.cpp.

◆ process_stop()

void zmq::object_t::process_stop ( )

protectedvirtual

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

Definition at line 411 of file object.cpp.

◆ process_term()

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

protectedvirtual

Reimplemented in zmq::own_t, zmq::stream_connecter_base_t, zmq::socket_base_t, zmq::session_base_t, zmq::stream_listener_base_t, zmq::ZMQ_FINAL< T, N >, and zmq::ZMQ_FINAL< T, N >.

Definition at line 485 of file object.cpp.

◆ process_term_ack()

void zmq::object_t::process_term_ack ( )

protectedvirtual

Reimplemented in zmq::own_t.

Definition at line 490 of file object.cpp.

◆ process_term_endpoint()

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

protectedvirtual

Reimplemented in zmq::socket_base_t.

Definition at line 495 of file object.cpp.

◆ process_term_req()

void zmq::object_t::process_term_req ( zmq::own_t * object_ )

protectedvirtual

Reimplemented in zmq::own_t.

Definition at line 480 of file object.cpp.

◆ register_endpoint()

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

protected

Definition at line 146 of file object.cpp.

◆ send_activate_read()

void zmq::object_t::send_activate_read ( zmq::pipe_t * destination_ )

protected

Definition at line 258 of file object.cpp.

◆ send_activate_write()

void zmq::object_t::send_activate_write	(	zmq::pipe_t *	destination_,
		uint64_t	msgs_read_
	)

protected

Definition at line 266 of file object.cpp.

◆ send_attach()

void zmq::object_t::send_attach	(	zmq::session_base_t *	destination_,
		zmq::i_engine *	engine_,
		bool	inc_seqnum_ = `true`
	)

protected

Definition at line 222 of file object.cpp.

◆ send_bind()

void zmq::object_t::send_bind	(	zmq::own_t *	destination_,
		zmq::pipe_t *	pipe_,
		bool	inc_seqnum_ = `true`
	)

Definition at line 244 of file object.cpp.

◆ send_command()

void zmq::object_t::send_command ( const command_t & cmd_ )

private

Definition at line 520 of file object.cpp.

◆ send_conn_failed()

void zmq::object_t::send_conn_failed ( zmq::session_base_t * destination_ )

protected

Definition at line 236 of file object.cpp.

◆ send_done()

void zmq::object_t::send_done ( )

protected

Definition at line 403 of file object.cpp.

◆ send_hiccup()

void zmq::object_t::send_hiccup	(	zmq::pipe_t *	destination_,
		void *	pipe_
	)

protected

Definition at line 276 of file object.cpp.

◆ send_inproc_connected()

void zmq::object_t::send_inproc_connected ( zmq::socket_base_t * socket_ )

Definition at line 395 of file object.cpp.

◆ send_own()

void zmq::object_t::send_own	(	zmq::own_t *	destination_,
		zmq::own_t *	object_
	)

protected

Definition at line 212 of file object.cpp.

◆ send_pipe_hwm()

void zmq::object_t::send_pipe_hwm	(	zmq::pipe_t *	destination_,
		int	inhwm_,
		int	outhwm_
	)

protected

Definition at line 330 of file object.cpp.

◆ send_pipe_peer_stats()

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

protected

Definition at line 285 of file object.cpp.

◆ send_pipe_stats_publish()

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

protected

Definition at line 299 of file object.cpp.

◆ send_pipe_term()

void zmq::object_t::send_pipe_term ( zmq::pipe_t * destination_ )

protected

Definition at line 314 of file object.cpp.

◆ send_pipe_term_ack()

void zmq::object_t::send_pipe_term_ack ( zmq::pipe_t * destination_ )

protected

Definition at line 322 of file object.cpp.

◆ send_plug()

void zmq::object_t::send_plug	(	zmq::own_t *	destination_,
		bool	inc_seqnum_ = `true`
	)

protected

Definition at line 201 of file object.cpp.

◆ send_reap()

void zmq::object_t::send_reap ( zmq::socket_base_t * socket_ )

protected

Definition at line 378 of file object.cpp.

◆ send_reaped()

void zmq::object_t::send_reaped ( )

protected

Definition at line 387 of file object.cpp.

◆ send_stop()

void zmq::object_t::send_stop ( )

protected

Definition at line 191 of file object.cpp.

◆ send_term()

void zmq::object_t::send_term	(	zmq::own_t *	destination_,
		int	linger_
	)

protected

Definition at line 351 of file object.cpp.

◆ send_term_ack()

void zmq::object_t::send_term_ack ( zmq::own_t * destination_ )

protected

Definition at line 360 of file object.cpp.

◆ send_term_endpoint()

void zmq::object_t::send_term_endpoint	(	own_t *	destination_,
		std::string *	endpoint_
	)

protected

Definition at line 368 of file object.cpp.

◆ send_term_req()

void zmq::object_t::send_term_req	(	zmq::own_t *	destination_,
		zmq::own_t *	object_
	)

protected

Definition at line 342 of file object.cpp.

◆ set_tid()

void zmq::object_t::set_tid ( uint32_t id_ )

Definition at line 33 of file object.cpp.

◆ unregister_endpoint()

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

protected

Definition at line 152 of file object.cpp.

◆ unregister_endpoints()

void zmq::object_t::unregister_endpoints ( zmq::socket_base_t * socket_ )

protected

Definition at line 158 of file object.cpp.

Member Data Documentation

◆ _ctx

zmq::ctx_t* const zmq::object_t::_ctx

private

Definition at line 132 of file object.hpp.

◆ _tid

uint32_t zmq::object_t::_tid

private

Definition at line 135 of file object.hpp.

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

Public Member Functions

Protected Member Functions

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ object_t() [1/2]

◆ object_t() [2/2]

◆ ~object_t()

Member Function Documentation

◆ choose_io_thread()

◆ connect_pending()

◆ destroy_socket()

◆ find_endpoint()

◆ get_ctx()

◆ get_tid()

◆ log()

◆ pend_connection()

◆ process_activate_read()

◆ process_activate_write()

◆ process_attach()

◆ process_bind()

◆ process_command()

◆ process_conn_failed()

◆ process_hiccup()

◆ process_own()

◆ process_pipe_hwm()

◆ process_pipe_peer_stats()

◆ process_pipe_stats_publish()

◆ process_pipe_term()

◆ process_pipe_term_ack()

◆ process_plug()

◆ process_reap()

◆ process_reaped()

◆ process_seqnum()

◆ process_stop()

◆ process_term()

◆ process_term_ack()

◆ process_term_endpoint()

◆ process_term_req()

◆ register_endpoint()

◆ send_activate_read()

◆ send_activate_write()

◆ send_attach()

◆ send_bind()

◆ send_command()

◆ send_conn_failed()

◆ send_done()

◆ send_hiccup()

◆ send_inproc_connected()

◆ send_own()

◆ send_pipe_hwm()

◆ send_pipe_peer_stats()

◆ send_pipe_stats_publish()

◆ send_pipe_term()

◆ send_pipe_term_ack()

◆ send_plug()

◆ send_reap()

◆ send_reaped()

◆ send_stop()

◆ send_term()

◆ send_term_ack()

◆ send_term_endpoint()

◆ send_term_req()

◆ set_tid()

◆ unregister_endpoint()

◆ unregister_endpoints()

Member Data Documentation

◆ _ctx

◆ _tid