#include <stream_connecter_base.hpp>

Inheritance diagram for zmq::stream_connecter_base_t:

[legend]

Public Member Functions
	stream_connecter_base_t (zmq::io_thread_t io_thread_, zmq::session_base_t session_, const options_t &options_, address_t *addr_, bool delayed_start_)

	~stream_connecter_base_t () ZMQ_OVERRIDE

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

Protected Member Functions
void	add_reconnect_timer ()

void	close ()

virtual void	create_engine (fd_t fd, const std::string &local_address_)

void	in_event () ZMQ_OVERRIDE

void	process_plug () ZMQ_FINAL

void	process_term (int linger_) ZMQ_OVERRIDE

void	rm_handle ()

void	timer_event (int id_) 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_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_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	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_)

Protected Attributes
address_t *const	_addr

std::string	_endpoint

handle_t	_handle

fd_t	_s

zmq::session_base_t *const	_session

zmq::socket_base_t *const	_socket

Protected Attributes inherited from zmq::own_t
options_t	options

Private Types
enum	{ reconnect_timer_id = 1 }

Private Member Functions
int	get_new_reconnect_ivl ()

virtual void	start_connecting ()=0

Private Attributes
int	_current_reconnect_ivl

const bool	_delayed_start

bool	_reconnect_timer_started

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

Detailed Description

Definition at line 16 of file stream_connecter_base.hpp.

Member Enumeration Documentation

◆ anonymous enum

anonymous enum

private

Enumerator
reconnect_timer_id

Definition at line 69 of file stream_connecter_base.hpp.

Constructor & Destructor Documentation

◆ stream_connecter_base_t()

zmq::stream_connecter_base_t::stream_connecter_base_t	(	zmq::io_thread_t *	io_thread_,
		zmq::session_base_t *	session_,
		const options_t &	options_,
		zmq::address_t *	addr_,
		bool	delayed_start_
	)

Definition at line 19 of file stream_connecter_base.cpp.

◆ ~stream_connecter_base_t()

zmq::stream_connecter_base_t::~stream_connecter_base_t ( )

Definition at line 43 of file stream_connecter_base.cpp.

Member Function Documentation

◆ add_reconnect_timer()

void zmq::stream_connecter_base_t::add_reconnect_timer ( )

protected

Definition at line 75 of file stream_connecter_base.cpp.

◆ close()

void zmq::stream_connecter_base_t::close ( )

protected

Definition at line 122 of file stream_connecter_base.cpp.

◆ create_engine()

void zmq::stream_connecter_base_t::create_engine	(	fd_t	fd,
		const std::string &	local_address_
	)

protectedvirtual

Definition at line 147 of file stream_connecter_base.cpp.

◆ get_new_reconnect_ivl()

int zmq::stream_connecter_base_t::get_new_reconnect_ivl ( )

private

Definition at line 86 of file stream_connecter_base.cpp.

◆ in_event()

void zmq::stream_connecter_base_t::in_event ( )

protectedvirtual

Reimplemented from zmq::io_object_t.

Definition at line 139 of file stream_connecter_base.cpp.

◆ process_plug()

void zmq::stream_connecter_base_t::process_plug ( )

protectedvirtual

Reimplemented from zmq::object_t.

Definition at line 50 of file stream_connecter_base.cpp.

◆ process_term()

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

protectedvirtual

Reimplemented from zmq::own_t.

Definition at line 58 of file stream_connecter_base.cpp.

◆ rm_handle()

void zmq::stream_connecter_base_t::rm_handle ( )

protected

Definition at line 116 of file stream_connecter_base.cpp.

◆ start_connecting()

virtual void zmq::stream_connecter_base_t::start_connecting ( )

privatepure virtual

◆ timer_event()

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

protectedvirtual

Reimplemented from zmq::io_object_t.

Definition at line 170 of file stream_connecter_base.cpp.

Member Data Documentation

◆ _addr

address_t* const zmq::stream_connecter_base_t::_addr

protected

Definition at line 52 of file stream_connecter_base.hpp.

◆ _current_reconnect_ivl

int zmq::stream_connecter_base_t::_current_reconnect_ivl

private

Definition at line 88 of file stream_connecter_base.hpp.

◆ _delayed_start

const bool zmq::stream_connecter_base_t::_delayed_start

private

Definition at line 82 of file stream_connecter_base.hpp.

◆ _endpoint

std::string zmq::stream_connecter_base_t::_endpoint

protected

Definition at line 62 of file stream_connecter_base.hpp.

◆ _handle

handle_t zmq::stream_connecter_base_t::_handle

protected

Definition at line 59 of file stream_connecter_base.hpp.

◆ _reconnect_timer_started

bool zmq::stream_connecter_base_t::_reconnect_timer_started

private

Definition at line 85 of file stream_connecter_base.hpp.

◆ _s

fd_t zmq::stream_connecter_base_t::_s

protected

Definition at line 55 of file stream_connecter_base.hpp.

◆ _session

zmq::session_base_t* const zmq::stream_connecter_base_t::_session

protected

Definition at line 94 of file stream_connecter_base.hpp.

◆ _socket

zmq::socket_base_t* const zmq::stream_connecter_base_t::_socket

protected

Definition at line 65 of file stream_connecter_base.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

Additional Inherited Members

Detailed Description

Member Enumeration Documentation

◆ anonymous enum

Constructor & Destructor Documentation

◆ stream_connecter_base_t()

◆ ~stream_connecter_base_t()

Member Function Documentation

◆ add_reconnect_timer()

◆ close()

◆ create_engine()

◆ get_new_reconnect_ivl()

◆ in_event()

◆ process_plug()

◆ process_term()

◆ rm_handle()

◆ start_connecting()

◆ timer_event()

Member Data Documentation

◆ _addr

◆ _current_reconnect_ivl

◆ _delayed_start

◆ _endpoint

◆ _handle

◆ _reconnect_timer_started

◆ _s

◆ _session

◆ _socket