zmq::rep_t Class Reference

#include <rep.hpp>

Inheritance diagram for zmq::rep_t:

Collaboration diagram for zmq::rep_t:

Public Member Functions
	rep_t (zmq::ctx_t *parent_, uint32_t tid_, int sid)
	~rep_t ()
bool	xhas_in ()
bool	xhas_out ()
int	xrecv (zmq::msg_t *msg_)
int	xsend (zmq::msg_t *msg_)
Public Member Functions inherited from zmq::router_t
	router_t (zmq::ctx_t *parent_, uint32_t tid_, int sid)
	~router_t ()
void	xattach_pipe (zmq::pipe_t *pipe_, bool subscribe_to_all_)
bool	xhas_in ()
bool	xhas_out ()
void	xpipe_terminated (zmq::pipe_t *pipe_)
void	xread_activated (zmq::pipe_t *pipe_)
int	xrecv (zmq::msg_t *msg_)
int	xsend (zmq::msg_t *msg_)
int	xsetsockopt (int option_, const void *optval_, size_t optvallen_)
void	xwrite_activated (zmq::pipe_t *pipe_)
Public Member Functions inherited from zmq::socket_base_t
int	add_signaler (signaler_t *s)
int	bind (const char *addr_)
bool	check_tag ()
int	close ()
int	connect (const char *addr_)
void	event_accept_failed (const std::string &addr_, int err_)
void	event_accepted (const std::string &addr_, int fd_)
void	event_bind_failed (const std::string &addr_, int err_)
void	event_close_failed (const std::string &addr_, int fd_)
void	event_closed (const std::string &addr_, int fd_)
void	event_connect_delayed (const std::string &addr_, int err_)
void	event_connect_retried (const std::string &addr_, int interval_)
void	event_connected (const std::string &addr_, int fd_)
void	event_disconnected (const std::string &addr_, int fd_)
void	event_listening (const std::string &addr_, int fd_)
i_mailbox *	get_mailbox ()
int	getsockopt (int option_, void *optval_, size_t *optvallen_)
bool	has_in ()
bool	has_out ()
void	hiccuped (pipe_t *pipe_)
void	in_event ()
int	join (const char *group)
int	leave (const char *group)
void	lock ()
int	monitor (const char *endpoint_, int events_)
void	out_event ()
void	pipe_terminated (pipe_t *pipe_)
void	read_activated (pipe_t *pipe_)
int	recv (zmq::msg_t *msg_, int flags_)
int	remove_signaler (signaler_t *s)
int	send (zmq::msg_t *msg_, int flags_)
int	setsockopt (int option_, const void *optval_, size_t optvallen_)
void	start_reaping (poller_t *poller_)
void	stop ()
int	term_endpoint (const char *addr_)
void	timer_event (int id_)
void	unlock ()
void	write_activated (pipe_t *pipe_)
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::array_item_t<>
	array_item_t ()
virtual	~array_item_t ()
int	get_array_index ()
void	set_array_index (int index_)
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 Member Functions
	rep_t (const rep_t &)
const rep_t &	operator= (const rep_t &)

Private Attributes
bool	request_begins
bool	sending_reply

Additional Inherited Members
Static Public Member Functions inherited from zmq::socket_base_t
static socket_base_t *	create (int type_, zmq::ctx_t *parent_, uint32_t tid_, int sid_)
Protected Member Functions inherited from zmq::router_t
blob_t	get_credential () const
int	rollback ()
Protected Member Functions inherited from zmq::socket_base_t
	socket_base_t (zmq::ctx_t *parent_, uint32_t tid_, int sid_, bool thread_safe_=false)
virtual	~socket_base_t ()
void	monitor_event (int event_, int value_, const std::string &addr_)
void	process_destroy ()
void	stop_monitor (bool send_monitor_stopped_event_=true)
virtual void	xhiccuped (pipe_t *pipe_)
virtual int	xjoin (const char *group_)
virtual int	xleave (const char *group_)
Protected Member Functions inherited from zmq::own_t
virtual	~own_t ()
bool	is_terminating ()
void	launch_child (own_t *object_)
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_attach (zmq::i_engine *engine_)
virtual void	process_hiccup (void *pipe_)
virtual void	process_pipe_term ()
virtual void	process_pipe_term_ack ()
virtual void	process_plug ()
virtual void	process_reap (zmq::socket_base_t *socket_)
virtual void	process_reaped ()
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 Attributes inherited from zmq::socket_base_t
std::string	connect_rid
Protected Attributes inherited from zmq::own_t
options_t	options

Detailed Description

Definition at line 43 of file rep.hpp.

Constructor & Destructor Documentation

zmq::rep_t::rep_t	(	zmq::ctx_t *	parent_,
		uint32_t	tid_,
		int	sid
	)

Definition at line 35 of file rep.cpp.

References zmq::own_t::options, zmq::options_t::type, and ZMQ_REP.

zmq::rep_t::~rep_t

(

)

Definition at line 43 of file rep.cpp.

zmq::rep_t::rep_t ( const rep_t &  )

private

Member Function Documentation

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

private

bool zmq::rep_t::xhas_in ( )

virtual

Reimplemented from zmq::socket_base_t.

Definition at line 120 of file rep.cpp.

References sending_reply, and zmq::router_t::xhas_in().

Here is the call graph for this function:

bool zmq::rep_t::xhas_out ( )

virtual

Reimplemented from zmq::socket_base_t.

Definition at line 128 of file rep.cpp.

References sending_reply, and zmq::router_t::xhas_out().

Here is the call graph for this function:

int zmq::rep_t::xrecv ( zmq::msg_t *  msg_ )

virtual

Reimplemented from zmq::socket_base_t.

Definition at line 69 of file rep.cpp.

References EFSM, errno_assert, zmq::msg_t::flags, zmq::msg_t::more, request_begins, zmq::router_t::rollback(), sending_reply, zmq::msg_t::size, zmq::router_t::xrecv(), and zmq::router_t::xsend().

Here is the call graph for this function:

int zmq::rep_t::xsend ( zmq::msg_t *  msg_ )

virtual

Reimplemented from zmq::socket_base_t.

Definition at line 47 of file rep.cpp.

References EFSM, zmq::msg_t::flags, zmq::msg_t::more, sending_reply, and zmq::router_t::xsend().

Here is the call graph for this function:

Member Data Documentation

bool zmq::rep_t::request_begins

private

Definition at line 64 of file rep.hpp.

Referenced by xrecv().

bool zmq::rep_t::sending_reply

private

Definition at line 60 of file rep.hpp.

Referenced by xhas_in(), xhas_out(), xrecv(), and xsend().