#include <pub.hpp>

Inheritance diagram for zmq::pub_t:

[legend]

Collaboration diagram for zmq::pub_t:

[legend]

Public Member Functions
	pub_t (zmq::ctx_t *parent_, uint32_t tid_, int sid_)

	~pub_t ()

void	xattach_pipe (zmq::pipe_t *pipe_, bool subscribe_to_all_=false)

bool	xhas_in ()

int	xrecv (zmq::msg_t *msg_)

Public Member Functions inherited from zmq::xpub_t
	xpub_t (zmq::ctx_t *parent_, uint32_t tid_, int sid_)

	~xpub_t ()

void	xattach_pipe (zmq::pipe_t *pipe_, bool subscribe_to_all_=false)

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
	pub_t (const pub_t &)

const pub_t &	operator= (const pub_t &)

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::socket_base_t
	socket_base_t (zmq::ctx_t *parent_, uint32_t tid_, int sid_, bool thread_safe_=false)

virtual	~socket_base_t ()

virtual blob_t	get_credential () const

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 pub.hpp.

Constructor & Destructor Documentation

zmq::pub_t::pub_t	(	zmq::ctx_t *	parent_,
		uint32_t	tid_,
		int	sid_
	)

Definition at line 36 of file pub.cpp.

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

zmq::pub_t::~pub_t ( )

Definition at line 42 of file pub.cpp.

zmq::pub_t::pub_t ( const pub_t & )

private

Member Function Documentation

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

private

void zmq::pub_t::xattach_pipe	(	zmq::pipe_t *	pipe_,
		bool	subscribe_to_all_ = `false`
	)

virtual

Implements zmq::socket_base_t.

Definition at line 46 of file pub.cpp.

References zmq::pipe_t::set_nodelay(), zmq::xpub_t::xattach_pipe(), and zmq_assert.

Here is the call graph for this function:

bool zmq::pub_t::xhas_in ( )

virtual

Reimplemented from zmq::socket_base_t.

Definition at line 64 of file pub.cpp.

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

virtual

Reimplemented from zmq::socket_base_t.

Definition at line 57 of file pub.cpp.

References ENOTSUP.

Public Member Functions

Private Member Functions

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation