#include <object.hpp>

Inheritance diagram for zmq::object_t:

Collaboration diagram for zmq::object_t:

Public Member Functions
	object_t (class ctx_t *ctx_, uint32_t tid_)
	object_t (object_t *parent_)
virtual	~object_t ()
ctx_t *	get_ctx ()
uint32_t	get_tid ()
void	process_command (struct command_t &cmd_)
Protected Member Functions
class io_thread_t *	choose_io_thread (uint64_t affinity_)
void	destroy_socket (class socket_base_t *socket_)
struct endpoint_t	find_endpoint (const char *addr_)
void	log (const char *format_,...)
virtual void	process_activate_read ()
virtual void	process_activate_write (uint64_t msgs_read_)
virtual void	process_attach (struct i_engine *engine_)
virtual void	process_bind (class pipe_t *pipe_)
virtual void	process_hiccup (void *pipe_)
virtual void	process_own (class own_t *object_)
virtual void	process_pipe_term ()
virtual void	process_pipe_term_ack ()
virtual void	process_plug ()
virtual void	process_reap (class 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_req (class own_t *object_)
int	register_endpoint (const char *addr_, struct endpoint_t &endpoint_)
void	send_activate_read (class pipe_t *destination_)
void	send_activate_write (class pipe_t *destination_, uint64_t msgs_read_)
void	send_attach (class session_base_t destination_, struct i_engine engine_, bool inc_seqnum_=true)
void	send_bind (class own_t destination_, class pipe_t pipe_, bool inc_seqnum_=true)
void	send_done ()
void	send_hiccup (class pipe_t destination_, void pipe_)
void	send_own (class own_t destination_, class own_t object_)
void	send_pipe_term (class pipe_t *destination_)
void	send_pipe_term_ack (class pipe_t *destination_)
void	send_plug (class own_t *destination_, bool inc_seqnum_=true)
void	send_reap (class socket_base_t *socket_)
void	send_reaped ()
void	send_stop ()
void	send_term (class own_t *destination_, int linger_)
void	send_term_ack (class own_t *destination_)
void	send_term_req (class own_t destination_, class own_t object_)
void	unregister_endpoints (class socket_base_t *socket_)
Private Member Functions
	object_t (const object_t &)
const object_t &	operator= (const object_t &)
void	send_command (command_t &cmd_)
Private Attributes
class ctx_t *	ctx
uint32_t	tid

Detailed Description

Definition at line 32 of file object.hpp.

Constructor & Destructor Documentation

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

Definition at line 33 of file object.cpp.

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

Definition at line 39 of file object.cpp.

zmq::object_t::~object_t ( ) [virtual]

Definition at line 45 of file object.cpp.

zmq::object_t::object_t ( const object_t & ) [private]

Member Function Documentation

zmq::io_thread_t * zmq::object_t::choose_io_thread ( uint64_t affinity_ ) [protected]

Definition at line 160 of file object.cpp.

References choose_io_thread().

Referenced by choose_io_thread().

Here is the call graph for this function:

Here is the caller graph for this function:

void zmq::object_t::destroy_socket ( class socket_base_t * socket_ ) [protected]

Definition at line 147 of file object.cpp.

zmq::endpoint_t zmq::object_t::find_endpoint ( const char * addr_ ) [read, protected]

Definition at line 142 of file object.cpp.

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

Definition at line 54 of file object.cpp.

uint32_t zmq::object_t::get_tid ( )

Definition at line 49 of file object.cpp.

Referenced by zmq::ctx_t::destroy_socket(), and send_command().

Here is the caller graph for this function:

void zmq::object_t::log	(	const char *	format_,
			...
	)		`[protected]`

Definition at line 152 of file object.cpp.

const object_t& zmq::object_t::operator= ( const object_t & ) [private]

void zmq::object_t::process_activate_read ( ) [protected, virtual]

Reimplemented in zmq::pipe_t.

Definition at line 390 of file object.cpp.

References zmq_assert.

void zmq::object_t::process_activate_write ( uint64_t msgs_read_ ) [protected, virtual]

Reimplemented in zmq::pipe_t.

Definition at line 395 of file object.cpp.

References zmq_assert.

void zmq::object_t::process_attach ( struct i_engine * engine_ ) [protected, virtual]

Reimplemented in zmq::session_base_t.

Definition at line 380 of file object.cpp.

References zmq_assert.

void zmq::object_t::process_bind ( class pipe_t * pipe_ ) [protected, virtual]

Reimplemented in zmq::socket_base_t.

Definition at line 385 of file object.cpp.

References zmq_assert.

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

Definition at line 59 of file object.cpp.

References zmq::command_t::activate_read, zmq::command_t::activate_write, zmq::command_t::args, zmq::command_t::attach, zmq::command_t::bind, zmq::command_t::hiccup, zmq::command_t::own, zmq::command_t::pipe_term, zmq::command_t::pipe_term_ack, zmq::command_t::plug, zmq::command_t::reap, zmq::command_t::reaped, zmq::command_t::stop, zmq::command_t::term, zmq::command_t::term_ack, zmq::command_t::term_req, zmq::command_t::type, and zmq_assert.

Referenced by zmq::reaper_t::in_event(), zmq::io_thread_t::in_event(), and zmq::socket_base_t::process_commands().

Here is the caller graph for this function:

void zmq::object_t::process_hiccup ( void * pipe_ ) [protected, virtual]

Reimplemented in zmq::pipe_t.

Definition at line 400 of file object.cpp.

References zmq_assert.

void zmq::object_t::process_own ( class own_t * object_ ) [protected, virtual]

Reimplemented in zmq::own_t.

Definition at line 375 of file object.cpp.

References zmq_assert.

void zmq::object_t::process_pipe_term ( ) [protected, virtual]

Reimplemented in zmq::pipe_t.

Definition at line 405 of file object.cpp.

References zmq_assert.

void zmq::object_t::process_pipe_term_ack ( ) [protected, virtual]

Reimplemented in zmq::pipe_t.

Definition at line 410 of file object.cpp.

References zmq_assert.

void zmq::object_t::process_plug ( ) [protected, virtual]

Reimplemented in zmq::ipc_connecter_t, zmq::ipc_listener_t, zmq::session_base_t, zmq::tcp_connecter_t, and zmq::tcp_listener_t.

Definition at line 370 of file object.cpp.

References zmq_assert.

void zmq::object_t::process_reap ( class socket_base_t * socket_ ) [protected, virtual]

Reimplemented in zmq::reaper_t.

Definition at line 430 of file object.cpp.

References zmq_assert.

void zmq::object_t::process_reaped ( ) [protected, virtual]

Reimplemented in zmq::reaper_t.

Definition at line 435 of file object.cpp.

References zmq_assert.

void zmq::object_t::process_seqnum ( ) [protected, virtual]

Reimplemented in zmq::own_t.

Definition at line 440 of file object.cpp.

References zmq_assert.

void zmq::object_t::process_stop ( ) [protected, virtual]

Reimplemented in zmq::io_thread_t, zmq::reaper_t, and zmq::socket_base_t.

Definition at line 365 of file object.cpp.

References zmq_assert.

void zmq::object_t::process_term ( int linger_ ) [protected, virtual]

Reimplemented in zmq::ipc_listener_t, zmq::own_t, zmq::session_base_t, zmq::socket_base_t, and zmq::tcp_listener_t.

Definition at line 420 of file object.cpp.

References zmq_assert.

void zmq::object_t::process_term_ack ( ) [protected, virtual]

Reimplemented in zmq::own_t.

Definition at line 425 of file object.cpp.

References zmq_assert.

void zmq::object_t::process_term_req ( class own_t * object_ ) [protected, virtual]

Reimplemented in zmq::own_t.

Definition at line 415 of file object.cpp.

References zmq_assert.

int zmq::object_t::register_endpoint	(	const char *	addr_,
		struct endpoint_t &	endpoint_
	)		`[protected]`

Definition at line 132 of file object.cpp.

void zmq::object_t::send_activate_read ( class pipe_t * destination_ ) [protected]

Definition at line 237 of file object.cpp.

References zmq::command_t::activate_read, zmq::command_t::destination, and zmq::command_t::type.

void zmq::object_t::send_activate_write	(	class pipe_t *	destination_,
		uint64_t	msgs_read_
	)		`[protected]`

Definition at line 248 of file object.cpp.

References zmq::command_t::activate_write, zmq::command_t::args, zmq::command_t::destination, and zmq::command_t::type.

void zmq::object_t::send_attach	(	class session_base_t *	destination_,
		struct i_engine *	engine_,
		bool	inc_seqnum_ = `true`
	)		`[protected]`

Definition at line 205 of file object.cpp.

References zmq::command_t::args, zmq::command_t::attach, zmq::command_t::destination, zmq::own_t::inc_seqnum(), and zmq::command_t::type.

Here is the call graph for this function:

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

Definition at line 221 of file object.cpp.

References zmq::command_t::args, zmq::command_t::bind, zmq::command_t::destination, zmq::own_t::inc_seqnum(), and zmq::command_t::type.

Here is the call graph for this function:

void zmq::object_t::send_command ( command_t & cmd_ ) [private]

Definition at line 445 of file object.cpp.

References zmq::command_t::destination, and get_tid().

Here is the call graph for this function:

void zmq::object_t::send_done ( ) [protected]

Definition at line 354 of file object.cpp.

References zmq::command_t::destination, zmq::command_t::done, zmq::ctx_t::term_tid, and zmq::command_t::type.

void zmq::object_t::send_hiccup	(	class pipe_t *	destination_,
		void *	pipe_
	)		`[protected]`

Definition at line 261 of file object.cpp.

References zmq::command_t::args, zmq::command_t::destination, zmq::command_t::hiccup, and zmq::command_t::type.

void zmq::object_t::send_own	(	class own_t *	destination_,
		class own_t *	object_
	)		`[protected]`

Definition at line 192 of file object.cpp.

References zmq::command_t::args, zmq::command_t::destination, zmq::own_t::inc_seqnum(), zmq::command_t::own, and zmq::command_t::type.

Here is the call graph for this function:

void zmq::object_t::send_pipe_term ( class pipe_t * destination_ ) [protected]

Definition at line 273 of file object.cpp.

References zmq::command_t::destination, zmq::command_t::pipe_term, and zmq::command_t::type.

void zmq::object_t::send_pipe_term_ack ( class pipe_t * destination_ ) [protected]

Definition at line 284 of file object.cpp.

References zmq::command_t::destination, zmq::command_t::pipe_term_ack, and zmq::command_t::type.

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

Definition at line 178 of file object.cpp.

References zmq::command_t::destination, zmq::own_t::inc_seqnum(), zmq::command_t::plug, and zmq::command_t::type.

Here is the call graph for this function:

void zmq::object_t::send_reap ( class socket_base_t * socket_ ) [protected]

Definition at line 331 of file object.cpp.

References zmq::command_t::args, zmq::command_t::destination, zmq::command_t::reap, and zmq::command_t::type.

void zmq::object_t::send_reaped ( ) [protected]

Definition at line 343 of file object.cpp.

References zmq::command_t::destination, zmq::command_t::reaped, and zmq::command_t::type.

void zmq::object_t::send_stop ( ) [protected]

Definition at line 165 of file object.cpp.

References zmq::command_t::destination, zmq::command_t::stop, and zmq::command_t::type.

void zmq::object_t::send_term	(	class own_t *	destination_,
		int	linger_
	)		`[protected]`

Definition at line 308 of file object.cpp.

References zmq::command_t::args, zmq::command_t::destination, zmq::command_t::term, and zmq::command_t::type.

void zmq::object_t::send_term_ack ( class own_t * destination_ ) [protected]

Definition at line 320 of file object.cpp.

References zmq::command_t::destination, zmq::command_t::term_ack, and zmq::command_t::type.

void zmq::object_t::send_term_req	(	class own_t *	destination_,
		class own_t *	object_
	)		`[protected]`

Definition at line 295 of file object.cpp.

References zmq::command_t::args, zmq::command_t::destination, zmq::command_t::term_req, and zmq::command_t::type.

void zmq::object_t::unregister_endpoints ( class socket_base_t * socket_ ) [protected]

Definition at line 137 of file object.cpp.

Member Data Documentation

class ctx_t* zmq::object_t::ctx [private]

Definition at line 110 of file object.hpp.

uint32_t zmq::object_t::tid [private]

Definition at line 113 of file object.hpp.

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

src/object.hpp
src/object.cpp

zmq::object_t Class Reference

Public Member Functions

Protected Member Functions

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation