#include <session_base.hpp>

Inheritance diagram for zmq::session_base_t:

[legend]

Public Member Functions
void	attach_pipe (zmq::pipe_t *pipe_)

void	engine_error (bool handshaked_, zmq::i_engine::error_reason_t reason_)

void	engine_ready ()

void	flush ()

const endpoint_uri_pair_t &	get_endpoint () const

socket_base_t *	get_socket () const

void	hiccuped (zmq::pipe_t *pipe_) ZMQ_FINAL

void	pipe_terminated (zmq::pipe_t *pipe_) ZMQ_FINAL

virtual int	pull_msg (msg_t *msg_)

virtual int	push_msg (msg_t *msg_)

void	read_activated (zmq::pipe_t *pipe_) ZMQ_FINAL

int	read_zap_msg (msg_t *msg_)

virtual void	reset ()

void	rollback ()

void	write_activated (zmq::pipe_t *pipe_) ZMQ_FINAL

int	write_zap_msg (msg_t *msg_)

int	zap_connect ()

bool	zap_enabled () const

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::io_object_t
	io_object_t (zmq::io_thread_t *io_thread_=NULL)

void	plug (zmq::io_thread_t *io_thread_)

void	unplug ()

	~io_object_t () ZMQ_OVERRIDE

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	~i_pipe_events () ZMQ_DEFAULT

Static Public Member Functions
static session_base_t *	create (zmq::io_thread_t io_thread_, bool active_, zmq::socket_base_t socket_, const options_t &options_, address_t *addr_)

Protected Member Functions
	session_base_t (zmq::io_thread_t io_thread_, bool active_, zmq::socket_base_t socket_, const options_t &options_, address_t *addr_)

	~session_base_t () ZMQ_OVERRIDE

Protected Member Functions inherited from zmq::own_t
bool	is_terminating () const

void	launch_child (own_t *object_)

virtual void	process_destroy ()

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

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_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 Member Functions inherited from zmq::io_object_t
handle_t	add_fd (fd_t fd_)

void	add_timer (int timeout_, int id_)

void	cancel_timer (int id_)

void	in_event () ZMQ_OVERRIDE

void	out_event () ZMQ_OVERRIDE

void	reset_pollin (handle_t handle_)

void	reset_pollout (handle_t handle_)

void	rm_fd (handle_t handle_)

void	set_pollin (handle_t handle_)

void	set_pollout (handle_t handle_)

Private Types
enum	{ linger_timer_id = 0x20 }

Private Member Functions
void	clean_pipes ()

void	process_attach (zmq::i_engine *engine_) ZMQ_FINAL

void	process_conn_failed () ZMQ_OVERRIDE

void	process_plug () ZMQ_FINAL

void	process_term (int linger_) ZMQ_FINAL

void	reconnect ()

void	start_connecting (bool wait_)

void	timer_event (int id_) ZMQ_FINAL

Private Attributes
const bool	_active

address_t *	_addr

zmq::i_engine *	_engine

bool	_has_linger_timer

bool	_incomplete_in

zmq::io_thread_t *	_io_thread

bool	_pending

zmq::pipe_t *	_pipe

zmq::socket_base_t *	_socket

std::set< pipe_t * >	_terminating_pipes

zmq::pipe_t *	_zap_pipe

Additional Inherited Members
Protected Types inherited from zmq::io_object_t
typedef poller_t::handle_t	handle_t

Protected Attributes inherited from zmq::own_t
options_t	options

Detailed Description

Definition at line 21 of file session_base.hpp.

Member Enumeration Documentation

◆ anonymous enum

anonymous enum

private

Enumerator
linger_timer_id

Definition at line 130 of file session_base.hpp.

Constructor & Destructor Documentation

◆ session_base_t()

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

protected

Definition at line 88 of file session_base.cpp.

◆ ~session_base_t()

zmq::session_base_t::~session_base_t ( )

protected

Definition at line 117 of file session_base.cpp.

Member Function Documentation

◆ attach_pipe()

void zmq::session_base_t::attach_pipe ( zmq::pipe_t * pipe_ )

Definition at line 135 of file session_base.cpp.

◆ clean_pipes()

void zmq::session_base_t::clean_pipes ( )

private

Definition at line 218 of file session_base.cpp.

◆ create()

zmq::session_base_t * zmq::session_base_t::create	(	zmq::io_thread_t *	io_thread_,
		bool	active_,
		zmq::socket_base_t *	socket_,
		const options_t &	options_,
		address_t *	addr_
	)

static

Definition at line 27 of file session_base.cpp.

◆ engine_error()

void zmq::session_base_t::engine_error	(	bool	handshaked_,
		zmq::i_engine::error_reason_t	reason_
	)

Definition at line 426 of file session_base.cpp.

◆ engine_ready()

void zmq::session_base_t::engine_ready ( )

Definition at line 394 of file session_base.cpp.

◆ flush()

void zmq::session_base_t::flush ( )

Definition at line 206 of file session_base.cpp.

◆ get_endpoint()

const zmq::endpoint_uri_pair_t & zmq::session_base_t::get_endpoint ( ) const

Definition at line 112 of file session_base.cpp.

◆ get_socket()

zmq::socket_base_t * zmq::session_base_t::get_socket ( ) const

Definition at line 316 of file session_base.cpp.

◆ hiccuped()

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

virtual

Implements zmq::i_pipe_events.

Definition at line 309 of file session_base.cpp.

◆ pipe_terminated()

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

virtual

Implements zmq::i_pipe_events.

Definition at line 239 of file session_base.cpp.

◆ process_attach()

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

privatevirtual

Reimplemented from zmq::object_t.

Definition at line 381 of file session_base.cpp.

◆ process_conn_failed()

void zmq::session_base_t::process_conn_failed ( )

privatevirtual

Reimplemented from zmq::object_t.

Definition at line 534 of file session_base.cpp.

◆ process_plug()

void zmq::session_base_t::process_plug ( )

privatevirtual

Reimplemented from zmq::object_t.

Definition at line 321 of file session_base.cpp.

◆ process_term()

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

privatevirtual

Reimplemented from zmq::own_t.

Definition at line 483 of file session_base.cpp.

◆ pull_msg()

int zmq::session_base_t::pull_msg ( msg_t * msg_ )

virtual

Definition at line 144 of file session_base.cpp.

◆ push_msg()

int zmq::session_base_t::push_msg ( msg_t * msg_ )

virtual

Definition at line 156 of file session_base.cpp.

◆ read_activated()

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

virtual

Implements zmq::i_pipe_events.

Definition at line 275 of file session_base.cpp.

◆ read_zap_msg()

int zmq::session_base_t::read_zap_msg ( msg_t * msg_ )

Definition at line 172 of file session_base.cpp.

◆ reconnect()

void zmq::session_base_t::reconnect ( )

private

Definition at line 541 of file session_base.cpp.

◆ reset()

void zmq::session_base_t::reset ( )

virtual

Definition at line 202 of file session_base.cpp.

◆ rollback()

void zmq::session_base_t::rollback ( )

Definition at line 212 of file session_base.cpp.

◆ start_connecting()

void zmq::session_base_t::start_connecting ( bool wait_ )

private

Definition at line 584 of file session_base.cpp.

◆ timer_event()

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

privatevirtual

Reimplemented from zmq::io_object_t.

Definition at line 522 of file session_base.cpp.

◆ write_activated()

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

virtual

Implements zmq::i_pipe_events.

Definition at line 297 of file session_base.cpp.

◆ write_zap_msg()

int zmq::session_base_t::write_zap_msg ( msg_t * msg_ )

Definition at line 187 of file session_base.cpp.

◆ zap_connect()

int zmq::session_base_t::zap_connect ( )

Definition at line 333 of file session_base.cpp.

◆ zap_enabled()

bool zmq::session_base_t::zap_enabled ( ) const

Definition at line 376 of file session_base.cpp.

Member Data Documentation

◆ _active

const bool zmq::session_base_t::_active

private

Definition at line 100 of file session_base.hpp.

◆ _addr

address_t* zmq::session_base_t::_addr

private

Definition at line 139 of file session_base.hpp.

◆ _engine

zmq::i_engine* zmq::session_base_t::_engine

private

Definition at line 120 of file session_base.hpp.

◆ _has_linger_timer

bool zmq::session_base_t::_has_linger_timer

private

Definition at line 136 of file session_base.hpp.

◆ _incomplete_in

bool zmq::session_base_t::_incomplete_in

private

Definition at line 113 of file session_base.hpp.

◆ _io_thread

zmq::io_thread_t* zmq::session_base_t::_io_thread

private

Definition at line 127 of file session_base.hpp.

◆ _pending

bool zmq::session_base_t::_pending

private

Definition at line 117 of file session_base.hpp.

◆ _pipe

zmq::pipe_t* zmq::session_base_t::_pipe

private

Definition at line 103 of file session_base.hpp.

◆ _socket

zmq::socket_base_t* zmq::session_base_t::_socket

private

Definition at line 123 of file session_base.hpp.

◆ _terminating_pipes

std::set<pipe_t *> zmq::session_base_t::_terminating_pipes

private

Definition at line 109 of file session_base.hpp.

◆ _zap_pipe

zmq::pipe_t* zmq::session_base_t::_zap_pipe

private

Definition at line 106 of file session_base.hpp.

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

Public Member Functions

Static Public Member Functions

Protected Member Functions

Private Types

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Member Enumeration Documentation

◆ anonymous enum

Constructor & Destructor Documentation

◆ session_base_t()

◆ ~session_base_t()

Member Function Documentation

◆ attach_pipe()

◆ clean_pipes()

◆ create()

◆ engine_error()

◆ engine_ready()

◆ flush()

◆ get_endpoint()

◆ get_socket()

◆ hiccuped()

◆ pipe_terminated()

◆ process_attach()

◆ process_conn_failed()

◆ process_plug()

◆ process_term()

◆ pull_msg()

◆ push_msg()

◆ read_activated()

◆ read_zap_msg()

◆ reconnect()

◆ reset()

◆ rollback()

◆ start_connecting()

◆ timer_event()

◆ write_activated()

◆ write_zap_msg()

◆ zap_connect()

◆ zap_enabled()

Member Data Documentation

◆ _active

◆ _addr

◆ _engine

◆ _has_linger_timer

◆ _incomplete_in

◆ _io_thread

◆ _pending

◆ _pipe

◆ _socket

◆ _terminating_pipes

◆ _zap_pipe