![]() |
libzmq
master
ZeroMQ C++ Core Engine (LIBZMQ)
|
#include <xsub.hpp>
Public Member Functions | |
xsub_t (zmq::ctx_t *parent_, uint32_t tid_, int sid_) | |
~xsub_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_) |
![]() | |
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 () |
![]() | |
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) |
![]() | |
array_item_t () | |
virtual | ~array_item_t () |
int | get_array_index () |
void | set_array_index (int index_) |
![]() | |
virtual | ~i_poll_events () |
![]() | |
virtual | ~i_pipe_events () |
Protected Member Functions | |
blob_t | get_credential () const |
void | xattach_pipe (zmq::pipe_t *pipe_, bool subscribe_to_all_) |
bool | xhas_in () |
bool | xhas_out () |
void | xhiccuped (pipe_t *pipe_) |
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_) |
void | xwrite_activated (zmq::pipe_t *pipe_) |
![]() | |
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 int | xjoin (const char *group_) |
virtual int | xleave (const char *group_) |
virtual int | xsetsockopt (int option_, const void *optval_, size_t optvallen_) |
![]() | |
virtual | ~own_t () |
bool | is_terminating () |
void | launch_child (own_t *object_) |
void | term_child (own_t *object_) |
void | terminate () |
![]() | |
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_) |
Private Member Functions | |
xsub_t (const xsub_t &) | |
bool | match (zmq::msg_t *msg_) |
const xsub_t & | operator= (const xsub_t &) |
Static Private Member Functions | |
static void | send_subscription (unsigned char *data_, size_t size_, void *arg_) |
Private Attributes | |
dist_t | dist |
fq_t | fq |
bool | has_message |
msg_t | message |
bool | more |
trie_t | subscriptions |
Additional Inherited Members | |
![]() | |
static socket_base_t * | create (int type_, zmq::ctx_t *parent_, uint32_t tid_, int sid_) |
![]() | |
std::string | connect_rid |
![]() | |
options_t | options |
zmq::xsub_t::xsub_t | ( | zmq::ctx_t * | parent_, |
uint32_t | tid_, | ||
int | sid_ | ||
) |
Definition at line 37 of file xsub.cpp.
References errno_assert, zmq::msg_t::init(), zmq::options_t::linger, message, zmq::own_t::options, zmq::options_t::type, and ZMQ_XSUB.
zmq::xsub_t::~xsub_t | ( | ) |
Definition at line 52 of file xsub.cpp.
References zmq::msg_t::close(), errno_assert, and message.
|
private |
|
protectedvirtual |
Reimplemented from zmq::socket_base_t.
Definition at line 213 of file xsub.cpp.
References fq, and zmq::fq_t::get_credential().
|
private |
Definition at line 218 of file xsub.cpp.
References zmq::trie_t::check(), zmq::msg_t::data, zmq::options_t::invert_matching, zmq::own_t::options, zmq::msg_t::size, and subscriptions.
Referenced by xhas_in(), and xrecv().
|
staticprivate |
Definition at line 225 of file xsub.cpp.
References zmq::msg_t::close(), zmq::msg_t::data, errno_assert, zmq::msg_t::init_size(), and zmq::pipe_t::write().
Referenced by xattach_pipe(), and xhiccuped().
|
protectedvirtual |
Implements zmq::socket_base_t.
Definition at line 58 of file xsub.cpp.
References zmq::trie_t::apply(), zmq::fq_t::attach(), zmq::dist_t::attach(), dist, zmq::pipe_t::flush(), fq, LIBZMQ_UNUSED, send_subscription(), subscriptions, and zmq_assert.
|
protectedvirtual |
Reimplemented from zmq::socket_base_t.
Definition at line 173 of file xsub.cpp.
References errno_assert, zmq::options_t::filter, zmq::msg_t::flags, fq, has_message, match(), message, zmq::msg_t::more, more, zmq::own_t::options, and zmq::fq_t::recv().
|
protectedvirtual |
Reimplemented from zmq::socket_base_t.
|
protectedvirtual |
Reimplemented from zmq::socket_base_t.
Definition at line 87 of file xsub.cpp.
References zmq::trie_t::apply(), zmq::pipe_t::flush(), send_subscription(), and subscriptions.
|
protectedvirtual |
Implements zmq::socket_base_t.
Definition at line 81 of file xsub.cpp.
References dist, fq, zmq::fq_t::pipe_terminated(), and zmq::dist_t::pipe_terminated().
|
protectedvirtual |
Reimplemented from zmq::socket_base_t.
Definition at line 71 of file xsub.cpp.
References zmq::fq_t::activated(), and fq.
|
protectedvirtual |
Reimplemented from zmq::socket_base_t.
Definition at line 132 of file xsub.cpp.
References errno_assert, zmq::options_t::filter, zmq::msg_t::flags, fq, has_message, match(), message, zmq::msg_t::more, more, zmq::msg_t::move(), zmq::own_t::options, and zmq::fq_t::recv().
|
protectedvirtual |
Reimplemented from zmq::socket_base_t.
Definition at line 94 of file xsub.cpp.
References zmq::trie_t::add(), zmq::msg_t::close(), zmq::msg_t::data, dist, errno_assert, zmq::msg_t::init(), zmq::trie_t::rm(), zmq::dist_t::send_to_all(), zmq::msg_t::size, size, and subscriptions.
Referenced by zmq::sub_t::xsetsockopt().
|
protectedvirtual |
Reimplemented from zmq::socket_base_t.
Definition at line 76 of file xsub.cpp.
References zmq::dist_t::activated(), and dist.
|
private |
Definition at line 82 of file xsub.hpp.
Referenced by xattach_pipe(), xpipe_terminated(), xsend(), and xwrite_activated().
|
private |
Definition at line 79 of file xsub.hpp.
Referenced by get_credential(), xattach_pipe(), xhas_in(), xpipe_terminated(), xread_activated(), and xrecv().
|
private |
|
private |
|
private |
|
private |
Definition at line 85 of file xsub.hpp.
Referenced by match(), xattach_pipe(), xhiccuped(), and xsend().