30 #ifndef __ZMQ_STREAM_ENGINE_HPP_INCLUDED__ 31 #define __ZMQ_STREAM_ENGINE_HPP_INCLUDED__ 42 #include "../include/zmq.h" 123 const char *name,
const void *value,
size_t value_len);
static const size_t v3_greeting_size
int process_handshake_command(msg_t *msg)
unsigned char greeting_send[v3_greeting_size]
int produce_ping_message(msg_t *msg_)
int process_identity_msg(msg_t *msg_)
int pull_msg_from_session(msg_t *msg_)
int decode_and_push(msg_t *msg_)
int produce_pong_message(msg_t *msg_)
zmq::socket_base_t * socket
stream_engine_t(fd_t fd_, const options_t &options_, const std::string &endpoint)
void plug(zmq::io_thread_t *io_thread_, zmq::session_base_t *session_)
size_t add_property(unsigned char *ptr, const char *name, const void *value, size_t value_len)
int(stream_engine_t::* process_msg)(msg_t *msg_)
int(stream_engine_t::* next_msg)(msg_t *msg_)
void error(error_reason_t reason)
int write_credential(msg_t *msg_)
unsigned int greeting_bytes_read
const stream_engine_t & operator=(const stream_engine_t &)
metadata_t::dict_t properties_t
int next_handshake_command(msg_t *msg)
bool init_properties(properties_t &properties)
void set_handshake_timer()
int identity_msg(msg_t *msg_)
int push_raw_msg_to_session(msg_t *msg)
void timer_event(int id_)
static const size_t v2_greeting_size
unsigned char greeting_recv[v3_greeting_size]
int push_msg_to_session(msg_t *msg)
int process_heartbeat_message(msg_t *msg_)
zmq::session_base_t * session
bool subscription_required
int write_subscription_msg(msg_t *msg_)
int push_one_then_decode_and_push(msg_t *msg_)
static const size_t signature_size
int pull_and_encode(msg_t *msg_)
poller_t::handle_t handle_t