Namespaces | Classes | Typedefs | Enumerations | Functions | Variables
zmq Namespace Reference

Namespaces

 detail
 
 protocol_name
 

Classes

struct  address_t
 
class  array_item_t
 
class  array_t
 
class  atomic_counter_t
 
class  atomic_ptr_t
 
struct  atomic_value_t
 
struct  blob_t
 
class  c_single_allocator
 
class  clock_t
 
struct  command_t
 
class  context_t
 
class  dbuffer_t
 
class  dbuffer_t< msg_t >
 
class  dealer_t
 
class  decoder_base_t
 
class  dist_t
 
class  encoder_base_t
 
struct  endpoint_t
 
struct  endpoint_uri_pair_t
 
class  error_t
 
class  fast_vector_t
 
class  fq_t
 
struct  from_handle_t
 
class  generic_mtrie_t
 
class  i_decoder
 
struct  i_encoder
 
struct  i_engine
 
class  i_mailbox
 
struct  i_pipe_events
 
struct  i_poll_events
 
class  io_object_t
 
union  ip_addr_t
 
class  ip_resolver_options_t
 
class  ip_resolver_t
 
class  lb_t
 
class  mechanism_base_t
 
class  mechanism_t
 
class  message_t
 
class  metadata_t
 
class  monitor_t
 
class  msg_t
 
class  mutex_t
 
class  object_t
 
struct  options_t
 
class  own_t
 
class  poller_base_t
 
class  radix_tree_t
 
struct  reference_tag_t
 
class  resizable_fast_vector_t
 
class  router_t
 
class  routing_socket_base_t
 
struct  scoped_lock_t
 
struct  scoped_optional_lock_t
 
class  server_t
 
class  session_base_t
 
class  shared_message_memory_allocator
 
class  signaler_t
 
class  socket_base_t
 
class  socket_poller_t
 
class  socket_ref
 
class  socket_t
 
class  socks_auth_response_decoder_t
 
struct  socks_auth_response_t
 
class  socks_basic_auth_request_encoder_t
 
struct  socks_basic_auth_request_t
 
class  socks_choice_decoder_t
 
struct  socks_choice_t
 
class  socks_greeting_encoder_t
 
struct  socks_greeting_t
 
class  socks_request_encoder_t
 
struct  socks_request_t
 
class  socks_response_decoder_t
 
struct  socks_response_t
 
class  stream_connecter_base_t
 
class  stream_engine_base_t
 
class  stream_listener_base_t
 
class  tcp_address_mask_t
 
class  tcp_address_t
 
class  thread_ctx_t
 
class  thread_t
 
class  timers_t
 
class  trie_t
 
class  trie_with_size_t
 
class  udp_address_t
 
class  v2_protocol_t
 
class  worker_poller_base_t
 
class  ws_address_t
 
class  ws_engine_t
 
class  ws_protocol_t
 
class  wss_address_t
 
class  wss_engine_t
 
class  xpub_t
 
class  xsub_t
 
class  ypipe_base_t
 
class  yqueue_t
 
class  zap_client_common_handshake_t
 
class  zap_client_t
 
class  ZMQ_FINAL
 

Typedefs

typedef int fd_t
 
typedef zmq_free_fn free_fn
 
typedef generic_mtrie_t< pipe_t > mtrie_t
 
typedef zmq_pollitem_t pollitem_t
 
typedef void() thread_fn(void *)
 
typedef void() timers_timer_fn(int timer_id_, void *arg_)
 
typedef socklen_t zmq_socklen_t
 

Enumerations

enum  {
  message_pipe_granularity = 256, command_pipe_granularity = 16, inbound_poll_rate = 100, max_wm_delta = 1024,
  max_io_events = 256, proxy_burst_size = 1000, max_command_delay = 3000000, clock_precision = 1000000,
  signaler_port = 0
}
 
enum  { retired_fd = -1 }
 
enum  { ZMTP_1_0 = 0, ZMTP_2_0 = 1, ZMTP_3_x = 3 }
 
enum  endpoint_type_t { endpoint_type_none, endpoint_type_bind, endpoint_type_connect }
 
enum  socket_end_t { socket_end_local, socket_end_remote }
 
enum  ws_client_handshake_state_t {
  client_handshake_initial = 0, response_line_H, response_line_HT, response_line_HTT,
  response_line_HTTP, response_line_HTTP_slash, response_line_HTTP_slash_1, response_line_HTTP_slash_1_dot,
  response_line_HTTP_slash_1_dot_1, response_line_HTTP_slash_1_dot_1_space, response_line_status_1, response_line_status_10,
  response_line_status_101, response_line_status_101_space, response_line_s, response_line_sw,
  response_line_swi, response_line_swit, response_line_switc, response_line_switch,
  response_line_switchi, response_line_switchin, response_line_switching, response_line_switching_space,
  response_line_p, response_line_pr, response_line_pro, response_line_prot,
  response_line_proto, response_line_protoc, response_line_protoco, response_line_protocol,
  response_line_protocols, response_line_cr, client_header_field_begin_name, client_header_field_name,
  client_header_field_colon, client_header_field_value_trailing_space, client_header_field_value, client_header_field_cr,
  client_handshake_end_line_cr, client_handshake_complete, client_handshake_error = -1
}
 
enum  ws_server_handshake_state_t {
  handshake_initial = 0, request_line_G, request_line_GE, request_line_GET,
  request_line_GET_space, request_line_resource, request_line_resource_space, request_line_H,
  request_line_HT, request_line_HTT, request_line_HTTP, request_line_HTTP_slash,
  request_line_HTTP_slash_1, request_line_HTTP_slash_1_dot, request_line_HTTP_slash_1_dot_1, request_line_cr,
  header_field_begin_name, header_field_name, header_field_colon, header_field_value_trailing_space,
  header_field_value, header_field_cr, handshake_end_line_cr, handshake_complete,
  handshake_error = -1
}
 

Functions

void assert_success_or_recoverable (fd_t s_, int rc_)
 
void * atomic_cas (void *volatile *ptr_, void *cmp_, void *val_, mutex_t &_sync) ZMQ_NOEXCEPT
 
void * atomic_xchg_ptr (void **ptr_, void *const val_, mutex_t &_sync) ZMQ_NOEXCEPT
 
int bind_to_device (fd_t s_, const std::string &bound_device_)
 
int close_and_return (zmq::msg_t *msg_, int echo_)
 
int close_and_return (zmq::msg_t msg_[], int count_, int echo_)
 
template<typename T >
int do_getsockopt (void *const optval_, size_t *const optvallen_, T value_)
 
int do_getsockopt (void *optval_, size_t *optvallen_, const std::string &value_)
 
int do_getsockopt (void *optval_, size_t *optvallen_, const void *value_, size_t value_len_)
 
int do_setsockopt_int_as_bool_relaxed (const void *optval_, size_t optvallen_, bool *out_value_)
 
int do_setsockopt_int_as_bool_strict (const void *optval_, size_t optvallen_, bool *out_value_)
 
void enable_ipv4_mapping (fd_t s_)
 
const char * errno_to_string (int errno_)
 
uint32_t generate_random ()
 
bool get_effective_conflate_option (const options_t &options)
 
int get_peer_ip_address (fd_t sockfd_, std::string &ip_addr_)
 
zmq_socklen_t get_socket_address (fd_t fd_, socket_end_t socket_end_, sockaddr_storage *ss_)
 
template<typename T >
std::string get_socket_name (fd_t fd_, socket_end_t socket_end_)
 
uint16_t get_uint16 (const unsigned char *buffer_)
 
uint32_t get_uint32 (const unsigned char *buffer_)
 
uint64_t get_uint64 (const unsigned char *buffer_)
 
uint8_t get_uint8 (const unsigned char *buffer_)
 
bool initialize_network ()
 
int make_fdpair (fd_t *r_, fd_t *w_)
 
void make_socket_noninheritable (fd_t sock_)
 
endpoint_uri_pair_t make_unconnected_bind_endpoint_pair (const std::string &endpoint_)
 
endpoint_uri_pair_t make_unconnected_connect_endpoint_pair (const std::string &endpoint_)
 
fd_t open_socket (int domain_, int type_, int protocol_)
 
bool operator!= (const detail::socket_base &a, const detail::socket_base &b) ZMQ_NOTHROW
 
bool operator< (const detail::socket_base &a, const detail::socket_base &b) ZMQ_NOTHROW
 
std::ostream & operator<< (std::ostream &os, const message_t &msg)
 
bool operator<= (const detail::socket_base &a, const detail::socket_base &b) ZMQ_NOTHROW
 
bool operator== (const detail::socket_base &a, const detail::socket_base &b) ZMQ_NOTHROW
 
bool operator> (const detail::socket_base &a, const detail::socket_base &b) ZMQ_NOTHROW
 
bool operator>= (const detail::socket_base &a, const detail::socket_base &b) ZMQ_NOTHROW
 
int pipepair (zmq::object_t *parents_[2], zmq::pipe_t *pipes_[2], const int hwms_[2], const bool conflate_[2])
 
int poll (zmq_pollitem_t *items_, size_t nitems_, long timeout_=-1)
 
int poll (zmq_pollitem_t const *items_, size_t nitems_, long timeout_=-1)
 
void print_backtrace ()
 
int proxy (class socket_base_t *frontend_, class socket_base_t *backend_, class socket_base_t *capture_)
 
void proxy (socket_ref frontend, socket_ref backend, socket_ref capture=socket_ref())
 
void proxy (void *frontend, void *backend, void *capture)
 
int proxy_steerable (class socket_base_t *frontend_, class socket_base_t *backend_, class socket_base_t *capture_, class socket_base_t *control_)
 
void proxy_steerable (socket_ref frontend, socket_ref backend, socket_ref capture, socket_ref control)
 
void proxy_steerable (void *frontend, void *backend, void *capture, void *control)
 
void put_uint16 (unsigned char *buffer_, uint16_t value_)
 
void put_uint32 (unsigned char *buffer_, uint32_t value_)
 
void put_uint64 (unsigned char *buffer_, uint64_t value_)
 
void put_uint8 (unsigned char *buffer_, uint8_t value_)
 
void random_close ()
 
void random_open ()
 
void seed_random ()
 
void send_hello_msg (pipe_t *pipe_, const options_t &options_)
 
void send_routing_id (pipe_t *pipe_, const options_t &options_)
 
void set_ip_type_of_service (fd_t s_, int iptos_)
 
int set_nosigpipe (fd_t s_)
 
void set_socket_priority (fd_t s_, int priority_)
 
int set_tcp_receive_buffer (fd_t sockfd_, int bufsize_)
 
int set_tcp_send_buffer (fd_t sockfd_, int bufsize_)
 
void shutdown_network ()
 
void swap (context_t &a, context_t &b) ZMQ_NOTHROW
 
void swap (message_t &a, message_t &b) ZMQ_NOTHROW
 
void swap (socket_t &a, socket_t &b) ZMQ_NOTHROW
 
fd_t tcp_open_socket (const char *address_, const options_t &options_, bool local_, bool fallback_to_ipv4_, tcp_address_t *out_tcp_addr_)
 
int tcp_read (fd_t s_, void *data_, size_t size_)
 
void tcp_tune_loopback_fast_path (fd_t socket_)
 
int tcp_write (fd_t s_, const void *data_, size_t size_)
 
void tune_tcp_busy_poll (fd_t socket_, int busy_poll_)
 
int tune_tcp_keepalives (fd_t s_, int keepalive_, int keepalive_cnt_, int keepalive_idle_, int keepalive_intvl_)
 
int tune_tcp_maxrt (fd_t sockfd_, int timeout_)
 
int tune_tcp_socket (fd_t s_)
 
void unblock_socket (fd_t s_)
 
void version (int *major_, int *minor_, int *patch_)
 
void zmq_abort (const char *errmsg_)
 

Variables

const size_t brief_len_size = sizeof (char)
 
static const char cancel_cmd_name [] = "\6CANCEL"
 
const char error_prefix [] = "\x05ERROR"
 
const size_t error_prefix_len = sizeof (error_prefix) - 1
 
ZMQ_CONSTEXPR_VAR from_handle_t from_handle
 
const char hello_prefix [] = "\x05HELLO"
 
const size_t hello_prefix_len = sizeof (hello_prefix) - 1
 
const char id [] = "1"
 
const size_t id_len = sizeof (id) - 1
 
const char initiate_prefix [] = "\x08INITIATE"
 
const size_t initiate_prefix_len = sizeof (initiate_prefix) - 1
 
const char ready_prefix [] = "\x05READY"
 
const size_t ready_prefix_len = sizeof (ready_prefix) - 1
 
static const char sub_cmd_name [] = "\x9SUBSCRIBE"
 
const char welcome_prefix [] = "\x07WELCOME"
 
const size_t welcome_prefix_len = sizeof (welcome_prefix) - 1
 
const char zap_version [] = "1.0"
 
const size_t zap_version_len = sizeof (zap_version) - 1
 

Typedef Documentation

◆ fd_t

typedef zmq_fd_t zmq::fd_t

Definition at line 287 of file zmq.hpp.

◆ free_fn

typedef zmq_free_fn zmq::free_fn

Definition at line 276 of file zmq.hpp.

◆ mtrie_t

typedef generic_mtrie_t<pipe_t> zmq::mtrie_t

Definition at line 16 of file mtrie.hpp.

◆ pollitem_t

typedef zmq_pollitem_t zmq::pollitem_t

Definition at line 277 of file zmq.hpp.

◆ thread_fn

typedef void() zmq::thread_fn(void *)

Definition at line 17 of file thread.hpp.

◆ timers_timer_fn

typedef void() zmq::timers_timer_fn(int timer_id_, void *arg_)

Definition at line 14 of file timers.hpp.

◆ zmq_socklen_t

typedef socklen_t zmq::zmq_socklen_t

Definition at line 107 of file address.hpp.

Enumeration Type Documentation

◆ anonymous enum

anonymous enum
Enumerator
message_pipe_granularity 
command_pipe_granularity 
inbound_poll_rate 
max_wm_delta 
max_io_events 
proxy_burst_size 
max_command_delay 
clock_precision 
signaler_port 

Definition at line 10 of file config.hpp.

◆ anonymous enum

anonymous enum
Enumerator
retired_fd 

Definition at line 30 of file fd.hpp.

◆ anonymous enum

anonymous enum
Enumerator
ZMTP_1_0 
ZMTP_2_0 
ZMTP_3_x 

Definition at line 22 of file zmtp_engine.hpp.

◆ endpoint_type_t

enum zmq::endpoint_type_t
Enumerator
endpoint_type_none 
endpoint_type_bind 
endpoint_type_connect 

Definition at line 10 of file endpoint.hpp.

◆ socket_end_t

enum zmq::socket_end_t
Enumerator
socket_end_local 
socket_end_remote 

Definition at line 110 of file address.hpp.

◆ ws_client_handshake_state_t

enum zmq::ws_client_handshake_state_t
Enumerator
client_handshake_initial 
response_line_H 
response_line_HT 
response_line_HTT 
response_line_HTTP 
response_line_HTTP_slash 
response_line_HTTP_slash_1 
response_line_HTTP_slash_1_dot 
response_line_HTTP_slash_1_dot_1 
response_line_HTTP_slash_1_dot_1_space 
response_line_status_1 
response_line_status_10 
response_line_status_101 
response_line_status_101_space 
response_line_s 
response_line_sw 
response_line_swi 
response_line_swit 
response_line_switc 
response_line_switch 
response_line_switchi 
response_line_switchin 
response_line_switching 
response_line_switching_space 
response_line_p 
response_line_pr 
response_line_pro 
response_line_prot 
response_line_proto 
response_line_protoc 
response_line_protoco 
response_line_protocol 
response_line_protocols 
response_line_cr 
client_header_field_begin_name 
client_header_field_name 
client_header_field_colon 
client_header_field_value_trailing_space 
client_header_field_value 
client_header_field_cr 
client_handshake_end_line_cr 
client_handshake_complete 
client_handshake_error 

Definition at line 52 of file ws_engine.hpp.

◆ ws_server_handshake_state_t

enum zmq::ws_server_handshake_state_t
Enumerator
handshake_initial 
request_line_G 
request_line_GE 
request_line_GET 
request_line_GET_space 
request_line_resource 
request_line_resource_space 
request_line_H 
request_line_HT 
request_line_HTT 
request_line_HTTP 
request_line_HTTP_slash 
request_line_HTTP_slash_1 
request_line_HTTP_slash_1_dot 
request_line_HTTP_slash_1_dot_1 
request_line_cr 
header_field_begin_name 
header_field_name 
header_field_colon 
header_field_value_trailing_space 
header_field_value 
header_field_cr 
handshake_end_line_cr 
handshake_complete 
handshake_error 

Definition at line 21 of file ws_engine.hpp.

Function Documentation

◆ assert_success_or_recoverable()

void zmq::assert_success_or_recoverable ( zmq::fd_t  s_,
int  rc_ 
)

Definition at line 830 of file ip.cpp.

◆ atomic_cas()

void* zmq::atomic_cas ( void *volatile *  ptr_,
void *  cmp_,
void *  val_,
mutex_t &  _sync 
)
inline

Definition at line 91 of file atomic_ptr.hpp.

◆ atomic_xchg_ptr()

void* zmq::atomic_xchg_ptr ( void **  ptr_,
void *const  val_,
mutex_t &  _sync 
)
inline

Definition at line 45 of file atomic_ptr.hpp.

◆ bind_to_device()

int zmq::bind_to_device ( fd_t  s_,
const std::string &  bound_device_ 
)

Definition at line 244 of file ip.cpp.

◆ close_and_return() [1/2]

int zmq::close_and_return ( zmq::msg_t *  msg_,
int  echo_ 
)
inline

Definition at line 300 of file msg.hpp.

◆ close_and_return() [2/2]

int zmq::close_and_return ( zmq::msg_t  msg_[],
int  count_,
int  echo_ 
)
inline

Definition at line 310 of file msg.hpp.

◆ do_getsockopt() [1/3]

template<typename T >
int zmq::do_getsockopt ( void *const  optval_,
size_t *const  optvallen_,
T  value_ 
)

Definition at line 318 of file options.hpp.

◆ do_getsockopt() [2/3]

int zmq::do_getsockopt ( void *  optval_,
size_t *  optvallen_,
const std::string &  value_ 
)

Definition at line 31 of file options.cpp.

◆ do_getsockopt() [3/3]

int zmq::do_getsockopt ( void *  optval_,
size_t *  optvallen_,
const void *  value_,
size_t  value_len_ 
)

Definition at line 39 of file options.cpp.

◆ do_setsockopt_int_as_bool_relaxed()

int zmq::do_setsockopt_int_as_bool_relaxed ( const void *  optval_,
size_t  optvallen_,
bool *  out_value_ 
)

Definition at line 106 of file options.cpp.

◆ do_setsockopt_int_as_bool_strict()

int zmq::do_setsockopt_int_as_bool_strict ( const void *  optval_,
size_t  optvallen_,
bool *  out_value_ 
)

Definition at line 89 of file options.cpp.

◆ enable_ipv4_mapping()

void zmq::enable_ipv4_mapping ( fd_t  s_)

Definition at line 126 of file ip.cpp.

◆ errno_to_string()

const char * zmq::errno_to_string ( int  errno_)

Definition at line 7 of file err.cpp.

◆ generate_random()

uint32_t zmq::generate_random ( )

Definition at line 30 of file random.cpp.

◆ get_effective_conflate_option()

bool zmq::get_effective_conflate_option ( const options_t &  options)
inline

Definition at line 303 of file options.hpp.

◆ get_peer_ip_address()

int zmq::get_peer_ip_address ( fd_t  sockfd_,
std::string &  ip_addr_ 
)

Definition at line 147 of file ip.cpp.

◆ get_socket_address()

zmq::zmq_socklen_t zmq::get_socket_address ( fd_t  fd_,
socket_end_t  socket_end_,
sockaddr_storage *  ss_ 
)

Definition at line 102 of file address.cpp.

◆ get_socket_name()

template<typename T >
std::string zmq::get_socket_name ( fd_t  fd_,
socket_end_t  socket_end_ 
)

Definition at line 120 of file address.hpp.

◆ get_uint16()

uint16_t zmq::get_uint16 ( const unsigned char *  buffer_)
inline

Definition at line 29 of file wire.hpp.

◆ get_uint32()

uint32_t zmq::get_uint32 ( const unsigned char *  buffer_)
inline

Definition at line 43 of file wire.hpp.

◆ get_uint64()

uint64_t zmq::get_uint64 ( const unsigned char *  buffer_)
inline

Definition at line 63 of file wire.hpp.

◆ get_uint8()

uint8_t zmq::get_uint8 ( const unsigned char *  buffer_)
inline

Definition at line 18 of file wire.hpp.

◆ initialize_network()

bool zmq::initialize_network ( )

Definition at line 264 of file ip.cpp.

◆ make_fdpair()

int zmq::make_fdpair ( fd_t *  r_,
fd_t *  w_ 
)

Definition at line 532 of file ip.cpp.

◆ make_socket_noninheritable()

void zmq::make_socket_noninheritable ( fd_t  sock_)

Definition at line 810 of file ip.cpp.

◆ make_unconnected_bind_endpoint_pair()

zmq::endpoint_uri_pair_t zmq::make_unconnected_bind_endpoint_pair ( const std::string &  endpoint_)

Definition at line 14 of file endpoint.cpp.

◆ make_unconnected_connect_endpoint_pair()

zmq::endpoint_uri_pair_t zmq::make_unconnected_connect_endpoint_pair ( const std::string &  endpoint_)

Definition at line 7 of file endpoint.cpp.

◆ open_socket()

zmq::fd_t zmq::open_socket ( int  domain_,
int  type_,
int  protocol_ 
)

Definition at line 73 of file ip.cpp.

◆ operator!=()

bool zmq::operator!= ( const detail::socket_base &  a,
const detail::socket_base &  b 
)
inline

Definition at line 2150 of file zmq.hpp.

◆ operator<()

bool zmq::operator< ( const detail::socket_base &  a,
const detail::socket_base &  b 
)
inline

Definition at line 2154 of file zmq.hpp.

◆ operator<<()

std::ostream& zmq::operator<< ( std::ostream &  os,
const message_t &  msg 
)
inline

Definition at line 2792 of file zmq.hpp.

◆ operator<=()

bool zmq::operator<= ( const detail::socket_base &  a,
const detail::socket_base &  b 
)
inline

Definition at line 2162 of file zmq.hpp.

◆ operator==()

bool zmq::operator== ( const detail::socket_base &  a,
const detail::socket_base &  b 
)
inline

Definition at line 2146 of file zmq.hpp.

◆ operator>()

bool zmq::operator> ( const detail::socket_base &  a,
const detail::socket_base &  b 
)
inline

Definition at line 2158 of file zmq.hpp.

◆ operator>=()

bool zmq::operator>= ( const detail::socket_base &  a,
const detail::socket_base &  b 
)
inline

Definition at line 2166 of file zmq.hpp.

◆ pipepair()

int zmq::pipepair ( zmq::object_t *  parents_[2],
zmq::pipe_t *  pipes_[2],
const int  hwms_[2],
const bool  conflate_[2] 
)

◆ poll() [1/2]

int zmq::poll ( zmq_pollitem_t *  items_,
size_t  nitems_,
long  timeout_ = -1 
)
inline

Definition at line 319 of file zmq.hpp.

◆ poll() [2/2]

int zmq::poll ( zmq_pollitem_t const *  items_,
size_t  nitems_,
long  timeout_ = -1 
)
inline

Definition at line 326 of file zmq.hpp.

◆ print_backtrace()

void zmq::print_backtrace ( )

Definition at line 422 of file err.cpp.

◆ proxy() [1/3]

int zmq::proxy ( class socket_base_t *  frontend_,
class socket_base_t *  backend_,
class socket_base_t *  capture_ 
)

Definition at line 21 of file proxy.cpp.

◆ proxy() [2/3]

void zmq::proxy ( socket_ref  frontend,
socket_ref  backend,
socket_ref  capture = socket_ref() 
)
inline

Definition at line 2282 of file zmq.hpp.

◆ proxy() [3/3]

void zmq::proxy ( void *  frontend,
void *  backend,
void *  capture 
)
inline

Definition at line 2274 of file zmq.hpp.

◆ proxy_steerable() [1/3]

int zmq::proxy_steerable ( class socket_base_t *  frontend_,
class socket_base_t *  backend_,
class socket_base_t *  capture_,
class socket_base_t *  control_ 
)

Definition at line 215 of file proxy.cpp.

◆ proxy_steerable() [2/3]

void zmq::proxy_steerable ( socket_ref  frontend,
socket_ref  backend,
socket_ref  capture,
socket_ref  control 
)
inline

Definition at line 2299 of file zmq.hpp.

◆ proxy_steerable() [3/3]

void zmq::proxy_steerable ( void *  frontend,
void *  backend,
void *  capture,
void *  control 
)
inline

Definition at line 2292 of file zmq.hpp.

◆ put_uint16()

void zmq::put_uint16 ( unsigned char *  buffer_,
uint16_t  value_ 
)
inline

Definition at line 23 of file wire.hpp.

◆ put_uint32()

void zmq::put_uint32 ( unsigned char *  buffer_,
uint32_t  value_ 
)
inline

Definition at line 35 of file wire.hpp.

◆ put_uint64()

void zmq::put_uint64 ( unsigned char *  buffer_,
uint64_t  value_ 
)
inline

Definition at line 51 of file wire.hpp.

◆ put_uint8()

void zmq::put_uint8 ( unsigned char *  buffer_,
uint8_t  value_ 
)
inline

Definition at line 13 of file wire.hpp.

◆ random_close()

void zmq::random_close ( )

Definition at line 64 of file random.cpp.

◆ random_open()

void zmq::random_open ( )

Definition at line 59 of file random.cpp.

◆ seed_random()

void zmq::seed_random ( )

Definition at line 20 of file random.cpp.

◆ send_hello_msg()

void zmq::send_hello_msg ( pipe_t *  pipe_,
const options_t &  options_ 
)

Definition at line 64 of file pipe.cpp.

◆ send_routing_id()

void zmq::send_routing_id ( pipe_t *  pipe_,
const options_t &  options_ 
)

Definition at line 52 of file pipe.cpp.

◆ set_ip_type_of_service()

void zmq::set_ip_type_of_service ( fd_t  s_,
int  iptos_ 
)

Definition at line 187 of file ip.cpp.

◆ set_nosigpipe()

int zmq::set_nosigpipe ( fd_t  s_)

Definition at line 224 of file ip.cpp.

◆ set_socket_priority()

void zmq::set_socket_priority ( fd_t  s_,
int  priority_ 
)

Definition at line 211 of file ip.cpp.

◆ set_tcp_receive_buffer()

int zmq::set_tcp_receive_buffer ( fd_t  sockfd_,
int  bufsize_ 
)

Definition at line 62 of file tcp.cpp.

◆ set_tcp_send_buffer()

int zmq::set_tcp_send_buffer ( fd_t  sockfd_,
int  bufsize_ 
)

Definition at line 53 of file tcp.cpp.

◆ shutdown_network()

void zmq::shutdown_network ( )

Definition at line 305 of file ip.cpp.

◆ swap() [1/3]

void zmq::swap ( context_t &  a,
context_t &  b 
)
inline

Definition at line 913 of file zmq.hpp.

◆ swap() [2/3]

void zmq::swap ( message_t &  a,
message_t &  b 
)
inline

Definition at line 749 of file zmq.hpp.

◆ swap() [3/3]

void zmq::swap ( socket_t &  a,
socket_t &  b 
)
inline

Definition at line 2268 of file zmq.hpp.

◆ tcp_open_socket()

zmq::fd_t zmq::tcp_open_socket ( const char *  address_,
const options_t &  options_,
bool  local_,
bool  fallback_to_ipv4_,
zmq::tcp_address_t *  out_tcp_addr_ 
)

Definition at line 332 of file tcp.cpp.

◆ tcp_read()

int zmq::tcp_read ( fd_t  s_,
void *  data_,
size_t  size_ 
)

Definition at line 245 of file tcp.cpp.

◆ tcp_tune_loopback_fast_path()

void zmq::tcp_tune_loopback_fast_path ( fd_t  socket_)

Definition at line 293 of file tcp.cpp.

◆ tcp_write()

int zmq::tcp_write ( fd_t  s_,
const void *  data_,
size_t  size_ 
)

Definition at line 186 of file tcp.cpp.

◆ tune_tcp_busy_poll()

void zmq::tune_tcp_busy_poll ( fd_t  socket_,
int  busy_poll_ 
)

Definition at line 317 of file tcp.cpp.

◆ tune_tcp_keepalives()

int zmq::tune_tcp_keepalives ( fd_t  s_,
int  keepalive_,
int  keepalive_cnt_,
int  keepalive_idle_,
int  keepalive_intvl_ 
)

Definition at line 71 of file tcp.cpp.

◆ tune_tcp_maxrt()

int zmq::tune_tcp_maxrt ( fd_t  sockfd_,
int  timeout_ 
)

Definition at line 160 of file tcp.cpp.

◆ tune_tcp_socket()

int zmq::tune_tcp_socket ( fd_t  s_)

Definition at line 30 of file tcp.cpp.

◆ unblock_socket()

void zmq::unblock_socket ( fd_t  s_)

Definition at line 107 of file ip.cpp.

◆ version()

void zmq::version ( int *  major_,
int *  minor_,
int *  patch_ 
)
inline

Definition at line 381 of file zmq.hpp.

◆ zmq_abort()

void zmq::zmq_abort ( const char *  errmsg_)

Definition at line 50 of file err.cpp.

Variable Documentation

◆ brief_len_size

const size_t zmq::brief_len_size = sizeof (char)

Definition at line 23 of file plain_common.hpp.

◆ cancel_cmd_name

const char zmq::cancel_cmd_name[] = "\6CANCEL"
static

Definition at line 30 of file msg.hpp.

◆ error_prefix

const char zmq::error_prefix[] = "\x05ERROR"

Definition at line 20 of file plain_common.hpp.

◆ error_prefix_len

const size_t zmq::error_prefix_len = sizeof (error_prefix) - 1

Definition at line 21 of file plain_common.hpp.

◆ from_handle

ZMQ_CONSTEXPR_VAR from_handle_t zmq::from_handle
Initial value:
=
from_handle_t(from_handle_t::_private())

Definition at line 2109 of file zmq.hpp.

◆ hello_prefix

const char zmq::hello_prefix[] = "\x05HELLO"

Definition at line 8 of file plain_common.hpp.

◆ hello_prefix_len

const size_t zmq::hello_prefix_len = sizeof (hello_prefix) - 1

Definition at line 9 of file plain_common.hpp.

◆ id

const char zmq::id[] = "1"

Definition at line 14 of file zap_client.cpp.

◆ id_len

const size_t zmq::id_len = sizeof (id) - 1

Definition at line 15 of file zap_client.cpp.

◆ initiate_prefix

const char zmq::initiate_prefix[] = "\x08INITIATE"

Definition at line 14 of file plain_common.hpp.

◆ initiate_prefix_len

const size_t zmq::initiate_prefix_len = sizeof (initiate_prefix) - 1

Definition at line 15 of file plain_common.hpp.

◆ ready_prefix

const char zmq::ready_prefix[] = "\x05READY"

Definition at line 17 of file plain_common.hpp.

◆ ready_prefix_len

const size_t zmq::ready_prefix_len = sizeof (ready_prefix) - 1

Definition at line 18 of file plain_common.hpp.

◆ sub_cmd_name

const char zmq::sub_cmd_name[] = "\x9SUBSCRIBE"
static

Definition at line 31 of file msg.hpp.

◆ welcome_prefix

const char zmq::welcome_prefix[] = "\x07WELCOME"

Definition at line 11 of file plain_common.hpp.

◆ welcome_prefix_len

const size_t zmq::welcome_prefix_len = sizeof (welcome_prefix) - 1

Definition at line 12 of file plain_common.hpp.

◆ zap_version

const char zmq::zap_version[] = "1.0"

Definition at line 11 of file zap_client.cpp.

◆ zap_version_len

const size_t zmq::zap_version_len = sizeof (zap_version) - 1

Definition at line 12 of file zap_client.cpp.


libaditof
Author(s):
autogenerated on Wed May 21 2025 02:07:11