#include <own.hpp>

Inheritance diagram for zmq::own_t:

[legend]

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

Protected Member Functions
bool	is_terminating () const

void	launch_child (own_t *object_)

virtual void	process_destroy ()

void	process_term (int linger_) ZMQ_OVERRIDE

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

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

virtual void	process_term_endpoint (std::string *endpoint_)

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
options_t	options

Private Types
typedef std::set< own_t * >	owned_t

Private Member Functions
void	check_term_acks ()

void	process_own (own_t *object_) ZMQ_OVERRIDE

void	process_seqnum () ZMQ_OVERRIDE

void	process_term_ack () ZMQ_OVERRIDE

void	process_term_req (own_t *object_) ZMQ_OVERRIDE

void	set_owner (own_t *owner_)

Private Attributes
owned_t	_owned

own_t *	_owner

uint64_t	_processed_seqnum

atomic_counter_t	_sent_seqnum

int	_term_acks

bool	_terminating

Detailed Description

Definition at line 21 of file own.hpp.

Member Typedef Documentation

◆ owned_t

typedef std::set<own_t *> zmq::own_t::owned_t

private

Definition at line 110 of file own.hpp.

Constructor & Destructor Documentation

◆ own_t() [1/2]

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

◆ own_t() [2/2]

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

◆ ~own_t()

zmq::own_t::~own_t ( )

protected

Definition at line 29 of file own.cpp.

Member Function Documentation

◆ check_term_acks()

void zmq::own_t::check_term_acks ( )

private

Definition at line 165 of file own.cpp.

◆ inc_seqnum()

void zmq::own_t::inc_seqnum ( )

Definition at line 39 of file own.cpp.

◆ is_terminating()

bool zmq::own_t::is_terminating ( ) const

protected

Definition at line 123 of file own.cpp.

◆ launch_child()

void zmq::own_t::launch_child ( own_t * object_ )

protected

Definition at line 54 of file own.cpp.

◆ process_destroy()

void zmq::own_t::process_destroy ( )

protectedvirtual

Reimplemented in zmq::socket_base_t.

Definition at line 182 of file own.cpp.

◆ process_own()

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

privatevirtual

Reimplemented from zmq::object_t.

Definition at line 91 of file own.cpp.

◆ process_seqnum()

void zmq::own_t::process_seqnum ( )

privatevirtual

Reimplemented from zmq::object_t.

Definition at line 45 of file own.cpp.

◆ process_term()

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

protectedvirtual

Reimplemented from zmq::object_t.

Reimplemented in 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 128 of file own.cpp.

◆ process_term_ack()

void zmq::own_t::process_term_ack ( )

privatevirtual

Reimplemented from zmq::object_t.

Definition at line 160 of file own.cpp.

◆ process_term_req()

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

privatevirtual

Reimplemented from zmq::object_t.

Definition at line 71 of file own.cpp.

◆ register_term_acks()

void zmq::own_t::register_term_acks ( int count_ )

Definition at line 146 of file own.cpp.

◆ set_owner()

void zmq::own_t::set_owner ( own_t * owner_ )

private

Definition at line 33 of file own.cpp.

◆ term_child()

void zmq::own_t::term_child ( own_t * object_ )

protected

Definition at line 66 of file own.cpp.

◆ terminate()

void zmq::own_t::terminate ( )

protected

Definition at line 105 of file own.cpp.

◆ unregister_term_ack()

void zmq::own_t::unregister_term_ack ( )

Definition at line 151 of file own.cpp.

Member Data Documentation

◆ _owned

owned_t zmq::own_t::_owned

private

Definition at line 111 of file own.hpp.

◆ _owner

own_t* zmq::own_t::_owner

private

Definition at line 106 of file own.hpp.

◆ _processed_seqnum

uint64_t zmq::own_t::_processed_seqnum

private

Definition at line 102 of file own.hpp.

◆ _sent_seqnum

atomic_counter_t zmq::own_t::_sent_seqnum

private

Definition at line 99 of file own.hpp.

◆ _term_acks

int zmq::own_t::_term_acks

private

Definition at line 114 of file own.hpp.

◆ _terminating

bool zmq::own_t::_terminating

private

Definition at line 96 of file own.hpp.

◆ options

options_t zmq::own_t::options

protected

Definition at line 78 of file own.hpp.

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

Public Member Functions

Protected Member Functions

Protected Attributes

Private Types

Private Member Functions

Private Attributes

Detailed Description

Member Typedef Documentation

◆ owned_t

Constructor & Destructor Documentation

◆ own_t() [1/2]

◆ own_t() [2/2]

◆ ~own_t()

Member Function Documentation

◆ check_term_acks()

◆ inc_seqnum()

◆ is_terminating()

◆ launch_child()

◆ process_destroy()

◆ process_own()

◆ process_seqnum()

◆ process_term()

◆ process_term_ack()

◆ process_term_req()

◆ register_term_acks()

◆ set_owner()

◆ term_child()

◆ terminate()

◆ unregister_term_ack()

Member Data Documentation

◆ _owned

◆ _owner

◆ _processed_seqnum

◆ _sent_seqnum

◆ _term_acks

◆ _terminating

◆ options