30 #ifndef __ZMQ_SESSION_BASE_HPP_INCLUDED__ 31 #define __ZMQ_SESSION_BASE_HPP_INCLUDED__ 67 virtual void reset ();
static session_base_t * create(zmq::io_thread_t *io_thread_, bool active_, zmq::socket_base_t *socket_, const options_t &options_, address_t *addr_)
void attach_pipe(zmq::pipe_t *pipe_)
virtual ~session_base_t()
virtual int push_msg(msg_t *msg_)
void start_connecting(bool wait_)
void engine_error(zmq::stream_engine_t::error_reason_t reason)
void process_attach(zmq::i_engine *engine_)
int write_zap_msg(msg_t *msg_)
socket_base_t * get_socket()
int read_zap_msg(msg_t *msg_)
void write_activated(zmq::pipe_t *pipe_)
virtual int pull_msg(msg_t *msg_)
void timer_event(int id_)
session_base_t(zmq::io_thread_t *io_thread_, bool active_, zmq::socket_base_t *socket_, const options_t &options_, address_t *addr_)
zmq::socket_base_t * socket
void process_term(int linger_)
void pipe_terminated(zmq::pipe_t *pipe_)
void read_activated(zmq::pipe_t *pipe_)
std::set< pipe_t * > terminating_pipes
const session_base_t & operator=(const session_base_t &)
void hiccuped(zmq::pipe_t *pipe_)
zmq::io_thread_t * io_thread