zmq::io_object_t Class Reference

#include <io_object.hpp>

Inheritance diagram for zmq::io_object_t:

Collaboration diagram for zmq::io_object_t:

Public Member Functions
	io_object_t (zmq::io_thread_t *io_thread_=NULL)
	~io_object_t ()
void	plug (zmq::io_thread_t *io_thread_)
void	unplug ()
Public Member Functions inherited from zmq::i_poll_events
virtual	~i_poll_events ()

Protected Types
typedef poller_t::handle_t	handle_t

Protected Member Functions
handle_t	add_fd (fd_t fd_)
void	add_timer (int timout_, int id_)
void	cancel_timer (int id_)
void	in_event ()
void	out_event ()
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_)
void	timer_event (int id_)

Private Member Functions
	io_object_t (const io_object_t &)
const io_object_t &	operator= (const io_object_t &)

Private Attributes
poller_t *	poller

Detailed Description

Definition at line 48 of file io_object.hpp.

Member Typedef Documentation

typedef poller_t::handle_t zmq::io_object_t::handle_t

protected

Definition at line 62 of file io_object.hpp.

Constructor & Destructor Documentation

zmq::io_object_t::io_object_t

(

zmq::io_thread_t *

io_thread_ = NULL

)

Definition at line 35 of file io_object.cpp.

References plug().

Here is the call graph for this function:

zmq::io_object_t::~io_object_t

(

)

Definition at line 42 of file io_object.cpp.

zmq::io_object_t::io_object_t ( const io_object_t &  )

private

Member Function Documentation

zmq::io_object_t::handle_t zmq::io_object_t::add_fd ( fd_t  fd_ )

protected

Definition at line 64 of file io_object.cpp.

References poller.

Referenced by zmq::socks_connecter_t::initiate_connect(), zmq::udp_engine_t::plug(), zmq::stream_engine_t::plug(), zmq::tcp_listener_t::process_plug(), zmq::ipc_listener_t::process_plug(), zmq::tcp_connecter_t::start_connecting(), and zmq::ipc_connecter_t::start_connecting().

Here is the caller graph for this function:

void zmq::io_object_t::add_timer ( int  timout_, int  id_  )

protected

Definition at line 94 of file io_object.cpp.

References poller.

Referenced by zmq::tcp_connecter_t::add_connect_timer(), zmq::ipc_connecter_t::add_reconnect_timer(), zmq::tcp_connecter_t::add_reconnect_timer(), zmq::stream_engine_t::mechanism_ready(), zmq::stream_engine_t::process_heartbeat_message(), zmq::session_base_t::process_term(), zmq::stream_engine_t::produce_ping_message(), zmq::stream_engine_t::set_handshake_timer(), zmq::socks_connecter_t::start_timer(), and zmq::stream_engine_t::timer_event().

Here is the caller graph for this function:

void zmq::io_object_t::cancel_timer ( int  id_ )

protected

Definition at line 99 of file io_object.cpp.

References poller.

Referenced by zmq::stream_engine_t::decode_and_push(), zmq::stream_engine_t::handshake(), zmq::tcp_connecter_t::out_event(), zmq::session_base_t::pipe_terminated(), zmq::tcp_connecter_t::process_term(), zmq::ipc_connecter_t::process_term(), zmq::socks_connecter_t::process_term(), zmq::stream_engine_t::unplug(), and zmq::session_base_t::~session_base_t().

Here is the caller graph for this function:

void zmq::io_object_t::in_event ( )

protectedvirtual

Implements zmq::i_poll_events.

Reimplemented in zmq::stream_engine_t, zmq::socks_connecter_t, zmq::ipc_listener_t, zmq::ipc_connecter_t, zmq::tcp_connecter_t, zmq::tcp_listener_t, and zmq::udp_engine_t.

Definition at line 104 of file io_object.cpp.

References zmq_assert.

const io_object_t& zmq::io_object_t::operator= ( const io_object_t &  )

private

void zmq::io_object_t::out_event ( )

protectedvirtual

Implements zmq::i_poll_events.

Reimplemented in zmq::stream_engine_t, zmq::socks_connecter_t, zmq::ipc_connecter_t, zmq::tcp_connecter_t, and zmq::udp_engine_t.

Definition at line 109 of file io_object.cpp.

References zmq_assert.

void zmq::io_object_t::plug

(

zmq::io_thread_t *

io_thread_

)

Definition at line 46 of file io_object.cpp.

References zmq::io_thread_t::get_poller(), poller, and zmq_assert.

Referenced by io_object_t(), zmq::udp_engine_t::plug(), and zmq::stream_engine_t::plug().

Here is the call graph for this function:

Here is the caller graph for this function:

void zmq::io_object_t::reset_pollin ( handle_t  handle_ )

protected

Definition at line 79 of file io_object.cpp.

References poller.

Referenced by zmq::udp_engine_t::in_event(), zmq::socks_connecter_t::in_event(), and zmq::stream_engine_t::in_event().

Here is the caller graph for this function:

void zmq::io_object_t::reset_pollout ( handle_t  handle_ )

protected

Definition at line 89 of file io_object.cpp.

References poller.

Referenced by zmq::udp_engine_t::out_event(), zmq::socks_connecter_t::out_event(), and zmq::stream_engine_t::out_event().

Here is the caller graph for this function:

void zmq::io_object_t::rm_fd ( handle_t  handle_ )

protected

Definition at line 69 of file io_object.cpp.

References poller.

Referenced by zmq::socks_connecter_t::error(), zmq::socks_connecter_t::in_event(), zmq::stream_engine_t::in_event(), zmq::tcp_connecter_t::out_event(), zmq::ipc_connecter_t::out_event(), zmq::tcp_connecter_t::process_term(), zmq::tcp_listener_t::process_term(), zmq::ipc_connecter_t::process_term(), zmq::ipc_listener_t::process_term(), zmq::socks_connecter_t::process_term(), zmq::udp_engine_t::terminate(), zmq::tcp_connecter_t::timer_event(), and zmq::stream_engine_t::unplug().

Here is the caller graph for this function:

void zmq::io_object_t::set_pollin ( handle_t  handle_ )

protected

Definition at line 74 of file io_object.cpp.

References poller.

Referenced by zmq::socks_connecter_t::out_event(), zmq::udp_engine_t::plug(), zmq::stream_engine_t::plug(), zmq::tcp_listener_t::process_plug(), zmq::ipc_listener_t::process_plug(), zmq::udp_engine_t::restart_input(), and zmq::stream_engine_t::restart_input().

Here is the caller graph for this function:

void zmq::io_object_t::set_pollout ( handle_t  handle_ )

protected

Definition at line 84 of file io_object.cpp.

References poller.

Referenced by zmq::stream_engine_t::handshake(), zmq::socks_connecter_t::in_event(), zmq::socks_connecter_t::initiate_connect(), zmq::udp_engine_t::plug(), zmq::stream_engine_t::plug(), zmq::udp_engine_t::restart_output(), zmq::stream_engine_t::restart_output(), zmq::tcp_connecter_t::start_connecting(), and zmq::ipc_connecter_t::start_connecting().

Here is the caller graph for this function:

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

protectedvirtual

Implements zmq::i_poll_events.

Reimplemented in zmq::session_base_t, zmq::stream_engine_t, zmq::socks_connecter_t, zmq::ipc_connecter_t, and zmq::tcp_connecter_t.

Definition at line 114 of file io_object.cpp.

References zmq_assert.

void zmq::io_object_t::unplug

(

)

Definition at line 55 of file io_object.cpp.

References poller, and zmq_assert.

Referenced by zmq::udp_engine_t::terminate(), and zmq::stream_engine_t::unplug().

Here is the caller graph for this function:

Member Data Documentation

poller_t* zmq::io_object_t::poller

private

Definition at line 81 of file io_object.hpp.

Referenced by add_fd(), add_timer(), cancel_timer(), plug(), reset_pollin(), reset_pollout(), rm_fd(), set_pollin(), set_pollout(), and unplug().