30 #ifndef __ZMQ_OBJECT_HPP_INCLUDED__ 31 #define __ZMQ_OBJECT_HPP_INCLUDED__ 41 struct pending_connection_t;
85 void log (
const char *format_, ...);
94 bool inc_seqnum_ =
true);
101 uint64_t msgs_read_);
void pend_connection(const std::string &addr_, const endpoint_t &endpoint, pipe_t **pipes_)
void process_command(zmq::command_t &cmd_)
void send_attach(zmq::session_base_t *destination_, zmq::i_engine *engine_, bool inc_seqnum_=true)
virtual void process_activate_write(uint64_t msgs_read_)
zmq::io_thread_t * choose_io_thread(uint64_t affinity_)
void send_command(command_t &cmd_)
virtual void process_term_ack()
void send_own(zmq::own_t *destination_, zmq::own_t *object_)
virtual void process_reap(zmq::socket_base_t *socket_)
virtual void process_activate_read()
void set_tid(uint32_t id)
virtual void process_reaped()
virtual void process_term_req(zmq::own_t *object_)
int unregister_endpoint(const std::string &addr_, socket_base_t *socket_)
virtual void process_bind(zmq::pipe_t *pipe_)
virtual void process_own(zmq::own_t *object_)
int register_endpoint(const char *addr_, const zmq::endpoint_t &endpoint_)
void destroy_socket(zmq::socket_base_t *socket_)
void send_pipe_term_ack(zmq::pipe_t *destination_)
void send_plug(zmq::own_t *destination_, bool inc_seqnum_=true)
virtual void process_pipe_term_ack()
virtual void process_pipe_term()
void unregister_endpoints(zmq::socket_base_t *socket_)
void connect_pending(const char *addr_, zmq::socket_base_t *bind_socket_)
const object_t & operator=(const object_t &)
void send_term_req(zmq::own_t *destination_, zmq::own_t *object_)
void send_term_ack(zmq::own_t *destination_)
void send_bind(zmq::own_t *destination_, zmq::pipe_t *pipe_, bool inc_seqnum_=true)
void send_term(zmq::own_t *destination_, int linger_)
void send_activate_write(zmq::pipe_t *destination_, uint64_t msgs_read_)
virtual void process_hiccup(void *pipe_)
virtual void process_seqnum()
void send_inproc_connected(zmq::socket_base_t *socket_)
virtual void process_stop()
virtual void process_term(int linger_)
void log(const char *format_,...)
void send_activate_read(zmq::pipe_t *destination_)
virtual void process_plug()
void send_reap(zmq::socket_base_t *socket_)
void send_pipe_term(zmq::pipe_t *destination_)
void send_hiccup(zmq::pipe_t *destination_, void *pipe_)
zmq::endpoint_t find_endpoint(const char *addr_)
object_t(zmq::ctx_t *ctx_, uint32_t tid_)
virtual void process_attach(zmq::i_engine *engine_)