zmq::radio_session_t Class Reference

#include <radio.hpp>

Inheritance diagram for zmq::radio_session_t:

Collaboration diagram for zmq::radio_session_t:

Public Member Functions
	radio_session_t (zmq::io_thread_t *io_thread_, bool connect_, zmq::socket_base_t *socket_, const options_t &options_, address_t *addr_)
	~radio_session_t ()
int	pull_msg (msg_t *msg_)
int	push_msg (msg_t *msg_)
void	reset ()
Public Member Functions inherited from zmq::session_base_t
void	attach_pipe (zmq::pipe_t *pipe_)
void	engine_error (zmq::stream_engine_t::error_reason_t reason)
void	flush ()
socket_base_t *	get_socket ()
void	hiccuped (zmq::pipe_t *pipe_)
void	pipe_terminated (zmq::pipe_t *pipe_)
void	read_activated (zmq::pipe_t *pipe_)
int	read_zap_msg (msg_t *msg_)
void	write_activated (zmq::pipe_t *pipe_)
int	write_zap_msg (msg_t *msg_)
int	zap_connect ()
bool	zap_enabled ()
Public Member Functions inherited from zmq::own_t
	own_t (zmq::ctx_t *parent_, uint32_t tid_)
	own_t (zmq::io_thread_t *io_thread_, const options_t &options_)
void	inc_seqnum ()
void	register_term_acks (int count_)
void	unregister_term_ack ()
Public Member Functions inherited from zmq::object_t
	object_t (zmq::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 (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)
Public Member Functions inherited from zmq::io_object_t
	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 ()
Public Member Functions inherited from zmq::i_pipe_events
virtual	~i_pipe_events ()

Private Types
enum	{ group, body }

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

Private Attributes
msg_t	pending_msg
enum zmq::radio_session_t:: { ... }	state

Additional Inherited Members
Static Public Member Functions inherited from zmq::session_base_t
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 Types inherited from zmq::io_object_t
typedef poller_t::handle_t	handle_t
Protected Member Functions inherited from 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_)
virtual	~session_base_t ()
Protected Member Functions inherited from zmq::own_t
virtual	~own_t ()
bool	is_terminating ()
void	launch_child (own_t *object_)
virtual void	process_destroy ()
void	term_child (own_t *object_)
void	terminate ()
Protected Member Functions inherited from zmq::object_t
zmq::io_thread_t *	choose_io_thread (uint64_t affinity_)
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_)
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_term ()
virtual void	process_pipe_term_ack ()
virtual void	process_reap (zmq::socket_base_t *socket_)
virtual void	process_reaped ()
virtual void	process_stop ()
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_done ()
void	send_hiccup (zmq::pipe_t *destination_, void *pipe_)
void	send_own (zmq::own_t *destination_, zmq::own_t *object_)
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_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 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_)
Protected Attributes inherited from zmq::own_t
options_t	options

Detailed Description

Definition at line 85 of file radio.hpp.

Member Enumeration Documentation

anonymous enum

private

Enumerator
group
body

Definition at line 100 of file radio.hpp.

Constructor & Destructor Documentation

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

Definition at line 161 of file radio.cpp.

zmq::radio_session_t::~radio_session_t

(

)

Definition at line 169 of file radio.cpp.

zmq::radio_session_t::radio_session_t ( const radio_session_t &  )

private

Member Function Documentation

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

private

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

virtual

Reimplemented from zmq::session_base_t.

Definition at line 219 of file radio.cpp.

References body, zmq::msg_t::data, errno_assert, group, zmq::msg_t::group, zmq::msg_t::init_size(), zmq::msg_t::more, pending_msg, zmq::session_base_t::pull_msg(), zmq::msg_t::set_flags(), and state.

Here is the call graph for this function:

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

virtual

Reimplemented from zmq::session_base_t.

Definition at line 173 of file radio.cpp.

References zmq::msg_t::close(), zmq::msg_t::command, zmq::msg_t::data, errno_assert, zmq::msg_t::flags, group, zmq::msg_t::init_join(), zmq::msg_t::init_leave(), zmq::session_base_t::push_msg(), zmq::msg_t::set_group(), and zmq::msg_t::size.

Here is the call graph for this function:

void zmq::radio_session_t::reset ( )

virtual

Reimplemented from zmq::session_base_t.

Definition at line 246 of file radio.cpp.

References group, zmq::session_base_t::reset(), and state.

Here is the call graph for this function:

Member Data Documentation

msg_t zmq::radio_session_t::pending_msg

private

Definition at line 105 of file radio.hpp.

Referenced by pull_msg().

enum { ... } zmq::radio_session_t::state

Referenced by pull_msg(), and reset().