libzmq
master
ZeroMQ C++ Core Engine (LIBZMQ)
Main Page
Classes
Files
Class List
Class Index
Class Hierarchy
Class Members
zmq::stream_engine_t Member List
This is the complete list of members for
zmq::stream_engine_t
, including all inherited members.
add_fd
(fd_t fd_)
zmq::io_object_t
protected
add_property
(unsigned char *ptr, const char *name, const void *value, size_t value_len)
zmq::stream_engine_t
private
add_timer
(int timout_, int id_)
zmq::io_object_t
protected
as_server
zmq::stream_engine_t
private
cancel_timer
(int id_)
zmq::io_object_t
protected
connection_error
enum value
zmq::stream_engine_t
decode_and_push
(msg_t *msg_)
zmq::stream_engine_t
private
decoder
zmq::stream_engine_t
private
encoder
zmq::stream_engine_t
private
endpoint
zmq::stream_engine_t
private
error
(error_reason_t reason)
zmq::stream_engine_t
private
error_reason_t
enum name
zmq::stream_engine_t
greeting_bytes_read
zmq::stream_engine_t
private
greeting_recv
zmq::stream_engine_t
private
greeting_send
zmq::stream_engine_t
private
greeting_size
zmq::stream_engine_t
private
handle
zmq::stream_engine_t
private
handle_t
typedef
zmq::io_object_t
protected
handshake
()
zmq::stream_engine_t
private
handshake_timer_id
enum value
zmq::stream_engine_t
private
handshaking
zmq::stream_engine_t
private
has_handshake_timer
zmq::stream_engine_t
private
has_heartbeat_timer
zmq::stream_engine_t
private
has_timeout_timer
zmq::stream_engine_t
private
has_ttl_timer
zmq::stream_engine_t
private
heartbeat_ivl_timer_id
enum value
zmq::stream_engine_t
private
heartbeat_timeout
zmq::stream_engine_t
private
heartbeat_timeout_timer_id
enum value
zmq::stream_engine_t
private
heartbeat_ttl_timer_id
enum value
zmq::stream_engine_t
private
identity_msg
(msg_t *msg_)
zmq::stream_engine_t
private
in_event
()
zmq::stream_engine_t
virtual
init_properties
(properties_t &properties)
zmq::stream_engine_t
private
inpos
zmq::stream_engine_t
private
input_stopped
zmq::stream_engine_t
private
insize
zmq::stream_engine_t
private
io_error
zmq::stream_engine_t
private
io_object_t
(zmq::io_thread_t *io_thread_=NULL)
zmq::io_object_t
mechanism
zmq::stream_engine_t
private
mechanism_ready
()
zmq::stream_engine_t
private
metadata
zmq::stream_engine_t
private
next_handshake_command
(msg_t *msg)
zmq::stream_engine_t
private
next_msg
zmq::stream_engine_t
private
operator=
(const stream_engine_t &)
zmq::stream_engine_t
private
options
zmq::stream_engine_t
private
out_event
()
zmq::stream_engine_t
virtual
outpos
zmq::stream_engine_t
private
output_stopped
zmq::stream_engine_t
private
outsize
zmq::stream_engine_t
private
peer_address
zmq::stream_engine_t
private
plug
(zmq::io_thread_t *io_thread_, zmq::session_base_t *session_)
zmq::stream_engine_t
virtual
zmq::io_object_t::plug
(zmq::io_thread_t *io_thread_)
zmq::io_object_t
plugged
zmq::stream_engine_t
private
process_handshake_command
(msg_t *msg)
zmq::stream_engine_t
private
process_heartbeat_message
(msg_t *msg_)
zmq::stream_engine_t
private
process_identity_msg
(msg_t *msg_)
zmq::stream_engine_t
private
process_msg
zmq::stream_engine_t
private
produce_ping_message
(msg_t *msg_)
zmq::stream_engine_t
private
produce_pong_message
(msg_t *msg_)
zmq::stream_engine_t
private
properties_t
typedef
zmq::stream_engine_t
private
protocol_error
enum value
zmq::stream_engine_t
pull_and_encode
(msg_t *msg_)
zmq::stream_engine_t
private
pull_msg_from_session
(msg_t *msg_)
zmq::stream_engine_t
private
push_msg_to_session
(msg_t *msg)
zmq::stream_engine_t
private
push_one_then_decode_and_push
(msg_t *msg_)
zmq::stream_engine_t
private
push_raw_msg_to_session
(msg_t *msg)
zmq::stream_engine_t
private
receive_greeting
()
zmq::stream_engine_t
private
reset_pollin
(handle_t handle_)
zmq::io_object_t
protected
reset_pollout
(handle_t handle_)
zmq::io_object_t
protected
restart_input
()
zmq::stream_engine_t
virtual
restart_output
()
zmq::stream_engine_t
virtual
rm_fd
(handle_t handle_)
zmq::io_object_t
protected
s
zmq::stream_engine_t
private
session
zmq::stream_engine_t
private
set_handshake_timer
()
zmq::stream_engine_t
private
set_pollin
(handle_t handle_)
zmq::io_object_t
protected
set_pollout
(handle_t handle_)
zmq::io_object_t
protected
signature_size
zmq::stream_engine_t
private
static
socket
zmq::stream_engine_t
private
stream_engine_t
(fd_t fd_, const options_t &options_, const std::string &endpoint)
zmq::stream_engine_t
stream_engine_t
(const stream_engine_t &)
zmq::stream_engine_t
private
subscription_required
zmq::stream_engine_t
private
terminate
()
zmq::stream_engine_t
virtual
timeout_error
enum value
zmq::stream_engine_t
timer_event
(int id_)
zmq::stream_engine_t
virtual
tx_msg
zmq::stream_engine_t
private
unplug
()
zmq::stream_engine_t
private
v2_greeting_size
zmq::stream_engine_t
private
static
v3_greeting_size
zmq::stream_engine_t
private
static
write_credential
(msg_t *msg_)
zmq::stream_engine_t
private
write_subscription_msg
(msg_t *msg_)
zmq::stream_engine_t
private
zap_msg_available
()
zmq::stream_engine_t
virtual
~i_engine
()
zmq::i_engine
inline
virtual
~i_poll_events
()
zmq::i_poll_events
inline
virtual
~io_object_t
()
zmq::io_object_t
~stream_engine_t
()
zmq::stream_engine_t
Generated by
1.8.11