![]() |
libzmq
master
ZeroMQ C++ Core Engine (LIBZMQ)
|
#include <io_thread.hpp>
Public Member Functions | |
io_thread_t (zmq::ctx_t *ctx_, uint32_t tid_) | |
~io_thread_t () | |
int | get_load () |
mailbox_t * | get_mailbox () |
poller_t * | get_poller () |
void | in_event () |
void | out_event () |
void | process_stop () |
void | start () |
void | stop () |
void | timer_event (int id_) |
![]() | |
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) |
![]() | |
virtual | ~i_poll_events () |
Private Member Functions | |
io_thread_t (const io_thread_t &) | |
const io_thread_t & | operator= (const io_thread_t &) |
Private Attributes | |
mailbox_t | mailbox |
poller_t::handle_t | mailbox_handle |
poller_t * | poller |
Additional Inherited Members | |
![]() | |
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_bind (zmq::pipe_t *pipe_) |
virtual void | process_hiccup (void *pipe_) |
virtual void | process_own (zmq::own_t *object_) |
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 () |
virtual void | process_seqnum () |
virtual void | process_term (int linger_) |
virtual void | process_term_ack () |
virtual void | process_term_req (zmq::own_t *object_) |
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_) |
Definition at line 49 of file io_thread.hpp.
zmq::io_thread_t::io_thread_t | ( | zmq::ctx_t * | ctx_, |
uint32_t | tid_ | ||
) |
Definition at line 39 of file io_thread.cpp.
References alloc_assert, zmq::mailbox_t::get_fd(), mailbox, mailbox_handle, and poller.
zmq::io_thread_t::~io_thread_t | ( | ) |
Definition at line 49 of file io_thread.cpp.
References LIBZMQ_DELETE, and poller.
|
private |
int zmq::io_thread_t::get_load | ( | ) |
Definition at line 70 of file io_thread.cpp.
References poller.
zmq::mailbox_t * zmq::io_thread_t::get_mailbox | ( | ) |
Definition at line 65 of file io_thread.cpp.
References mailbox.
Referenced by zmq::ctx_t::create_socket().
zmq::poller_t * zmq::io_thread_t::get_poller | ( | ) |
Definition at line 104 of file io_thread.cpp.
References poller, and zmq_assert.
Referenced by zmq::io_object_t::plug().
|
virtual |
Implements zmq::i_poll_events.
Definition at line 75 of file io_thread.cpp.
References zmq::command_t::destination, errno_assert, mailbox, zmq::object_t::process_command(), and zmq::mailbox_t::recv().
|
private |
|
virtual |
|
virtual |
Reimplemented from zmq::object_t.
Definition at line 110 of file io_thread.cpp.
References mailbox_handle, and poller.
void zmq::io_thread_t::start | ( | ) |
Definition at line 54 of file io_thread.cpp.
References poller.
Referenced by zmq::ctx_t::create_socket().
void zmq::io_thread_t::stop | ( | ) |
Definition at line 60 of file io_thread.cpp.
References zmq::object_t::send_stop().
|
virtual |
|
private |
Definition at line 85 of file io_thread.hpp.
Referenced by get_mailbox(), in_event(), and io_thread_t().
|
private |
Definition at line 88 of file io_thread.hpp.
Referenced by io_thread_t(), and process_stop().
|
private |
Definition at line 91 of file io_thread.hpp.
Referenced by get_load(), get_poller(), io_thread_t(), process_stop(), start(), and ~io_thread_t().