Classes | Macros | Typedefs | Functions
zmq.cpp File Reference
#include "precompiled.hpp"
#include "macros.hpp"
#include "poller.hpp"
#include "peer.hpp"
#include <unistd.h>
#include <string.h>
#include <stdlib.h>
#include <new>
#include <climits>
#include "proxy.hpp"
#include "socket_base.hpp"
#include "stdint.hpp"
#include "config.hpp"
#include "likely.hpp"
#include "clock.hpp"
#include "ctx.hpp"
#include "err.hpp"
#include "msg.hpp"
#include "fd.hpp"
#include "metadata.hpp"
#include "socket_poller.hpp"
#include "timers.hpp"
#include "ip.hpp"
#include "address.hpp"
Include dependency graph for zmq.cpp:

Go to the source code of this file.

Classes

struct  iovec
 

Macros

#define ZMQ_TYPE_UNSAFE
 

Typedefs

typedef char check_msg_t_size[sizeof(zmq::msg_t)==sizeof(zmq_msg_t) ? 1 :-1]
 

Functions

static zmq::socket_base_tas_socket_base_t (void *s_)
 
static int check_events (const short events_)
 
static int check_poller (void *const poller_)
 
static int check_poller_fd_registration_args (void *const poller_, const zmq::fd_t fd_)
 
static int check_poller_registration_args (void *const poller_, void *const s_)
 
static int s_recvmsg (zmq::socket_base_t *s_, zmq_msg_t *msg_, int flags_)
 
static int s_sendmsg (zmq::socket_base_t *s_, zmq_msg_t *msg_, int flags_)
 
int zmq_bind (void *s_, const char *addr_)
 
int zmq_close (void *s_)
 
int zmq_connect (void *s_, const char *addr_)
 
uint32_t zmq_connect_peer (void *s_, const char *addr_)
 
int zmq_ctx_destroy (void *ctx_)
 
int zmq_ctx_get (void *ctx_, int option_)
 
int zmq_ctx_get_ext (void *ctx_, int option_, void *optval_, size_t *optvallen_)
 
voidzmq_ctx_new (void)
 
int zmq_ctx_set (void *ctx_, int option_, int optval_)
 
int zmq_ctx_set_ext (void *ctx_, int option_, const void *optval_, size_t optvallen_)
 
int zmq_ctx_shutdown (void *ctx_)
 
int zmq_ctx_term (void *ctx_)
 
int zmq_device (int, void *frontend_, void *backend_)
 
int zmq_disconnect (void *s_, const char *addr_)
 
int zmq_errno (void)
 
int zmq_getsockopt (void *s_, int option_, void *optval_, size_t *optvallen_)
 
int zmq_has (const char *capability_)
 
voidzmq_init (int io_threads_)
 
int zmq_join (void *s_, const char *group_)
 
int zmq_leave (void *s_, const char *group_)
 
int zmq_msg_close (zmq_msg_t *msg_)
 
int zmq_msg_copy (zmq_msg_t *dest_, zmq_msg_t *src_)
 
voidzmq_msg_data (zmq_msg_t *msg_)
 
int zmq_msg_get (const zmq_msg_t *msg_, int property_)
 
const char * zmq_msg_gets (const zmq_msg_t *msg_, const char *property_)
 
const char * zmq_msg_group (zmq_msg_t *msg_)
 
int zmq_msg_init (zmq_msg_t *msg_)
 
int zmq_msg_init_buffer (zmq_msg_t *msg_, const void *buf_, size_t size_)
 
int zmq_msg_init_data (zmq_msg_t *msg_, void *data_, size_t size_, zmq_free_fn *ffn_, void *hint_)
 
int zmq_msg_init_size (zmq_msg_t *msg_, size_t size_)
 
int zmq_msg_more (const zmq_msg_t *msg_)
 
int zmq_msg_move (zmq_msg_t *dest_, zmq_msg_t *src_)
 
int zmq_msg_recv (zmq_msg_t *msg_, void *s_, int flags_)
 
uint32_t zmq_msg_routing_id (zmq_msg_t *msg_)
 
int zmq_msg_send (zmq_msg_t *msg_, void *s_, int flags_)
 
int zmq_msg_set (zmq_msg_t *, int, int)
 
int zmq_msg_set_group (zmq_msg_t *msg_, const char *group_)
 
int zmq_msg_set_routing_id (zmq_msg_t *msg_, uint32_t routing_id_)
 
size_t zmq_msg_size (const zmq_msg_t *msg_)
 
int zmq_poll (zmq_pollitem_t *items_, int nitems_, long timeout_)
 
int zmq_poller_add (void *poller_, void *s_, void *user_data_, short events_)
 
int zmq_poller_add_fd (void *poller_, zmq::fd_t fd_, void *user_data_, short events_)
 
int zmq_poller_destroy (void **poller_p_)
 
int zmq_poller_fd (void *poller_, zmq_fd_t *fd_)
 
int zmq_poller_modify (void *poller_, void *s_, short events_)
 
int zmq_poller_modify_fd (void *poller_, zmq::fd_t fd_, short events_)
 
voidzmq_poller_new (void)
 
static int zmq_poller_poll (zmq_pollitem_t *items_, int nitems_, long timeout_)
 
int zmq_poller_remove (void *poller_, void *s_)
 
int zmq_poller_remove_fd (void *poller_, zmq::fd_t fd_)
 
int zmq_poller_size (void *poller_)
 
int zmq_poller_wait (void *poller_, zmq_poller_event_t *event_, long timeout_)
 
int zmq_poller_wait_all (void *poller_, zmq_poller_event_t *events_, int n_events_, long timeout_)
 
int zmq_ppoll (zmq_pollitem_t *items_, int nitems_, long timeout_, const sigset_t *sigmask_)
 
int zmq_proxy (void *frontend_, void *backend_, void *capture_)
 
int zmq_proxy_steerable (void *frontend_, void *backend_, void *capture_, void *control_)
 
int zmq_recv (void *s_, void *buf_, size_t len_, int flags_)
 
int zmq_recviov (void *s_, iovec *a_, size_t *count_, int flags_)
 
int zmq_recvmsg (void *s_, zmq_msg_t *msg_, int flags_)
 
int zmq_send (void *s_, const void *buf_, size_t len_, int flags_)
 
int zmq_send_const (void *s_, const void *buf_, size_t len_, int flags_)
 
int zmq_sendiov (void *s_, iovec *a_, size_t count_, int flags_)
 
int zmq_sendmsg (void *s_, zmq_msg_t *msg_, int flags_)
 
int zmq_setsockopt (void *s_, int option_, const void *optval_, size_t optvallen_)
 
voidzmq_socket (void *ctx_, int type_)
 
int zmq_socket_get_peer_state (void *s_, const void *routing_id_, size_t routing_id_size_)
 
int zmq_socket_monitor (void *s_, const char *addr_, int events_)
 
int zmq_socket_monitor_pipes_stats (void *s_)
 
int zmq_socket_monitor_versioned (void *s_, const char *addr_, uint64_t events_, int event_version_, int type_)
 
const char * zmq_strerror (int errnum_)
 
int zmq_term (void *ctx_)
 
int zmq_timers_add (void *timers_, size_t interval_, zmq_timer_fn handler_, void *arg_)
 
int zmq_timers_cancel (void *timers_, int timer_id_)
 
int zmq_timers_destroy (void **timers_p_)
 
int zmq_timers_execute (void *timers_)
 
voidzmq_timers_new (void)
 
int zmq_timers_reset (void *timers_, int timer_id_)
 
int zmq_timers_set_interval (void *timers_, int timer_id_, size_t interval_)
 
long zmq_timers_timeout (void *timers_)
 
int zmq_unbind (void *s_, const char *addr_)
 
void zmq_version (int *major_, int *minor_, int *patch_)
 

Macro Definition Documentation

◆ ZMQ_TYPE_UNSAFE

#define ZMQ_TYPE_UNSAFE

Definition at line 12 of file zmq.cpp.

Typedef Documentation

◆ check_msg_t_size

typedef char check_msg_t_size[sizeof(zmq::msg_t)==sizeof(zmq_msg_t) ? 1 :-1]

Definition at line 85 of file zmq.cpp.

Function Documentation

◆ as_socket_base_t()

static zmq::socket_base_t* as_socket_base_t ( void s_)
static

Definition at line 220 of file zmq.cpp.

◆ check_events()

static int check_events ( const short  events_)
static

Definition at line 1465 of file zmq.cpp.

◆ check_poller()

static int check_poller ( void *const  poller_)
static

Definition at line 1454 of file zmq.cpp.

◆ check_poller_fd_registration_args()

static int check_poller_fd_registration_args ( void *const  poller_,
const zmq::fd_t  fd_ 
)
static

Definition at line 1487 of file zmq.cpp.

◆ check_poller_registration_args()

static int check_poller_registration_args ( void *const  poller_,
void *const  s_ 
)
static

Definition at line 1474 of file zmq.cpp.

◆ s_recvmsg()

static int s_recvmsg ( zmq::socket_base_t s_,
zmq_msg_t msg_,
int  flags_ 
)
static

Definition at line 469 of file zmq.cpp.

◆ s_sendmsg()

static int s_sendmsg ( zmq::socket_base_t s_,
zmq_msg_t msg_,
int  flags_ 
)
inlinestatic

Definition at line 356 of file zmq.cpp.

◆ zmq_bind()

int zmq_bind ( void s_,
const char *  addr_ 
)

Definition at line 299 of file zmq.cpp.

◆ zmq_close()

int zmq_close ( void s_)

Definition at line 241 of file zmq.cpp.

◆ zmq_connect()

int zmq_connect ( void s_,
const char *  addr_ 
)

Definition at line 307 of file zmq.cpp.

◆ zmq_connect_peer()

uint32_t zmq_connect_peer ( void s_,
const char *  addr_ 
)

Definition at line 315 of file zmq.cpp.

◆ zmq_ctx_destroy()

int zmq_ctx_destroy ( void ctx_)

Definition at line 212 of file zmq.cpp.

◆ zmq_ctx_get()

int zmq_ctx_get ( void ctx_,
int  option_ 
)

Definition at line 174 of file zmq.cpp.

◆ zmq_ctx_get_ext()

int zmq_ctx_get_ext ( void ctx_,
int  option_,
void optval_,
size_t *  optvallen_ 
)

Definition at line 183 of file zmq.cpp.

◆ zmq_ctx_new()

void* zmq_ctx_new ( void  )

Definition at line 109 of file zmq.cpp.

◆ zmq_ctx_set()

int zmq_ctx_set ( void ctx_,
int  option_,
int  optval_ 
)

Definition at line 156 of file zmq.cpp.

◆ zmq_ctx_set_ext()

int zmq_ctx_set_ext ( void ctx_,
int  option_,
const void optval_,
size_t  optvallen_ 
)

Definition at line 161 of file zmq.cpp.

◆ zmq_ctx_shutdown()

int zmq_ctx_shutdown ( void ctx_)

Definition at line 147 of file zmq.cpp.

◆ zmq_ctx_term()

int zmq_ctx_term ( void ctx_)

Definition at line 128 of file zmq.cpp.

◆ zmq_device()

int zmq_device ( int  ,
void frontend_,
void backend_ 
)

Definition at line 1755 of file zmq.cpp.

◆ zmq_disconnect()

int zmq_disconnect ( void s_,
const char *  addr_ 
)

Definition at line 345 of file zmq.cpp.

◆ zmq_errno()

int zmq_errno ( void  )

Definition at line 101 of file zmq.cpp.

◆ zmq_getsockopt()

int zmq_getsockopt ( void s_,
int  option_,
void optval_,
size_t *  optvallen_ 
)

Definition at line 261 of file zmq.cpp.

◆ zmq_has()

int zmq_has ( const char *  capability_)

Definition at line 1763 of file zmq.cpp.

◆ zmq_init()

void* zmq_init ( int  io_threads_)

Definition at line 196 of file zmq.cpp.

◆ zmq_join()

int zmq_join ( void s_,
const char *  group_ 
)

Definition at line 283 of file zmq.cpp.

◆ zmq_leave()

int zmq_leave ( void s_,
const char *  group_ 
)

Definition at line 291 of file zmq.cpp.

◆ zmq_msg_close()

int zmq_msg_close ( zmq_msg_t msg_)

Definition at line 625 of file zmq.cpp.

◆ zmq_msg_copy()

int zmq_msg_copy ( zmq_msg_t dest_,
zmq_msg_t src_ 
)

Definition at line 636 of file zmq.cpp.

◆ zmq_msg_data()

void* zmq_msg_data ( zmq_msg_t msg_)

Definition at line 642 of file zmq.cpp.

◆ zmq_msg_get()

int zmq_msg_get ( const zmq_msg_t msg_,
int  property_ 
)

Definition at line 657 of file zmq.cpp.

◆ zmq_msg_gets()

const char* zmq_msg_gets ( const zmq_msg_t msg_,
const char *  property_ 
)

Definition at line 711 of file zmq.cpp.

◆ zmq_msg_group()

const char* zmq_msg_group ( zmq_msg_t msg_)

Definition at line 704 of file zmq.cpp.

◆ zmq_msg_init()

int zmq_msg_init ( zmq_msg_t msg_)

Definition at line 587 of file zmq.cpp.

◆ zmq_msg_init_buffer()

int zmq_msg_init_buffer ( zmq_msg_t msg_,
const void buf_,
size_t  size_ 
)

Definition at line 597 of file zmq.cpp.

◆ zmq_msg_init_data()

int zmq_msg_init_data ( zmq_msg_t msg_,
void data_,
size_t  size_,
zmq_free_fn ffn_,
void hint_ 
)

Definition at line 602 of file zmq.cpp.

◆ zmq_msg_init_size()

int zmq_msg_init_size ( zmq_msg_t msg_,
size_t  size_ 
)

Definition at line 592 of file zmq.cpp.

◆ zmq_msg_more()

int zmq_msg_more ( const zmq_msg_t msg_)

Definition at line 652 of file zmq.cpp.

◆ zmq_msg_move()

int zmq_msg_move ( zmq_msg_t dest_,
zmq_msg_t src_ 
)

Definition at line 630 of file zmq.cpp.

◆ zmq_msg_recv()

int zmq_msg_recv ( zmq_msg_t msg_,
void s_,
int  flags_ 
)

Definition at line 617 of file zmq.cpp.

◆ zmq_msg_routing_id()

uint32_t zmq_msg_routing_id ( zmq_msg_t msg_)

Definition at line 694 of file zmq.cpp.

◆ zmq_msg_send()

int zmq_msg_send ( zmq_msg_t msg_,
void s_,
int  flags_ 
)

Definition at line 609 of file zmq.cpp.

◆ zmq_msg_set()

int zmq_msg_set ( zmq_msg_t ,
int  ,
int   
)

Definition at line 681 of file zmq.cpp.

◆ zmq_msg_set_group()

int zmq_msg_set_group ( zmq_msg_t msg_,
const char *  group_ 
)

Definition at line 699 of file zmq.cpp.

◆ zmq_msg_set_routing_id()

int zmq_msg_set_routing_id ( zmq_msg_t msg_,
uint32_t  routing_id_ 
)

Definition at line 688 of file zmq.cpp.

◆ zmq_msg_size()

size_t zmq_msg_size ( const zmq_msg_t msg_)

Definition at line 647 of file zmq.cpp.

◆ zmq_poll()

int zmq_poll ( zmq_pollitem_t items_,
int  nitems_,
long  timeout_ 
)

Definition at line 827 of file zmq.cpp.

◆ zmq_poller_add()

int zmq_poller_add ( void poller_,
void s_,
void user_data_,
short  events_ 
)

Definition at line 1509 of file zmq.cpp.

◆ zmq_poller_add_fd()

int zmq_poller_add_fd ( void poller_,
zmq::fd_t  fd_,
void user_data_,
short  events_ 
)

Definition at line 1521 of file zmq.cpp.

◆ zmq_poller_destroy()

int zmq_poller_destroy ( void **  poller_p_)

Definition at line 1438 of file zmq.cpp.

◆ zmq_poller_fd()

int zmq_poller_fd ( void poller_,
zmq_fd_t fd_ 
)

Definition at line 1615 of file zmq.cpp.

◆ zmq_poller_modify()

int zmq_poller_modify ( void poller_,
void s_,
short  events_ 
)

Definition at line 1535 of file zmq.cpp.

◆ zmq_poller_modify_fd()

int zmq_poller_modify_fd ( void poller_,
zmq::fd_t  fd_,
short  events_ 
)

Definition at line 1548 of file zmq.cpp.

◆ zmq_poller_new()

void* zmq_poller_new ( void  )

Definition at line 1429 of file zmq.cpp.

◆ zmq_poller_poll()

static int zmq_poller_poll ( zmq_pollitem_t items_,
int  nitems_,
long  timeout_ 
)
static

Definition at line 728 of file zmq.cpp.

◆ zmq_poller_remove()

int zmq_poller_remove ( void poller_,
void s_ 
)

Definition at line 1558 of file zmq.cpp.

◆ zmq_poller_remove_fd()

int zmq_poller_remove_fd ( void poller_,
zmq::fd_t  fd_ 
)

Definition at line 1568 of file zmq.cpp.

◆ zmq_poller_size()

int zmq_poller_size ( void poller_)

Definition at line 1501 of file zmq.cpp.

◆ zmq_poller_wait()

int zmq_poller_wait ( void poller_,
zmq_poller_event_t event_,
long  timeout_ 
)

Definition at line 1576 of file zmq.cpp.

◆ zmq_poller_wait_all()

int zmq_poller_wait_all ( void poller_,
zmq_poller_event_t events_,
int  n_events_,
long  timeout_ 
)

Definition at line 1590 of file zmq.cpp.

◆ zmq_ppoll()

int zmq_ppoll ( zmq_pollitem_t items_,
int  nitems_,
long  timeout_,
const sigset_t *  sigmask_ 
)

Definition at line 1355 of file zmq.cpp.

◆ zmq_proxy()

int zmq_proxy ( void frontend_,
void backend_,
void capture_ 
)

Definition at line 1726 of file zmq.cpp.

◆ zmq_proxy_steerable()

int zmq_proxy_steerable ( void frontend_,
void backend_,
void capture_,
void control_ 
)

Definition at line 1738 of file zmq.cpp.

◆ zmq_recv()

int zmq_recv ( void s_,
void buf_,
size_t  len_,
int  flags_ 
)

Definition at line 487 of file zmq.cpp.

◆ zmq_recviov()

int zmq_recviov ( void s_,
iovec a_,
size_t *  count_,
int  flags_ 
)

Definition at line 535 of file zmq.cpp.

◆ zmq_recvmsg()

int zmq_recvmsg ( void s_,
zmq_msg_t msg_,
int  flags_ 
)

Definition at line 481 of file zmq.cpp.

◆ zmq_send()

int zmq_send ( void s_,
const void buf_,
size_t  len_,
int  flags_ 
)

Definition at line 377 of file zmq.cpp.

◆ zmq_send_const()

int zmq_send_const ( void s_,
const void buf_,
size_t  len_,
int  flags_ 
)

Definition at line 400 of file zmq.cpp.

◆ zmq_sendiov()

int zmq_sendiov ( void s_,
iovec a_,
size_t  count_,
int  flags_ 
)

Definition at line 432 of file zmq.cpp.

◆ zmq_sendmsg()

int zmq_sendmsg ( void s_,
zmq_msg_t msg_,
int  flags_ 
)

Definition at line 372 of file zmq.cpp.

◆ zmq_setsockopt()

int zmq_setsockopt ( void s_,
int  option_,
const void optval_,
size_t  optvallen_ 
)

Definition at line 250 of file zmq.cpp.

◆ zmq_socket()

void* zmq_socket ( void ctx_,
int  type_ 
)

Definition at line 230 of file zmq.cpp.

◆ zmq_socket_get_peer_state()

int zmq_socket_get_peer_state ( void s_,
const void routing_id_,
size_t  routing_id_size_ 
)

Definition at line 1627 of file zmq.cpp.

◆ zmq_socket_monitor()

int zmq_socket_monitor ( void s_,
const char *  addr_,
int  events_ 
)

Definition at line 278 of file zmq.cpp.

◆ zmq_socket_monitor_pipes_stats()

int zmq_socket_monitor_pipes_stats ( void s_)

Definition at line 1809 of file zmq.cpp.

◆ zmq_socket_monitor_versioned()

int zmq_socket_monitor_versioned ( void s_,
const char *  addr_,
uint64_t  events_,
int  event_version_,
int  type_ 
)

Definition at line 269 of file zmq.cpp.

◆ zmq_strerror()

const char* zmq_strerror ( int  errnum_)

Definition at line 96 of file zmq.cpp.

◆ zmq_term()

int zmq_term ( void ctx_)

Definition at line 207 of file zmq.cpp.

◆ zmq_timers_add()

int zmq_timers_add ( void timers_,
size_t  interval_,
zmq_timer_fn  handler_,
void arg_ 
)

Definition at line 1659 of file zmq.cpp.

◆ zmq_timers_cancel()

int zmq_timers_cancel ( void timers_,
int  timer_id_ 
)

Definition at line 1673 of file zmq.cpp.

◆ zmq_timers_destroy()

int zmq_timers_destroy ( void **  timers_p_)

Definition at line 1647 of file zmq.cpp.

◆ zmq_timers_execute()

int zmq_timers_execute ( void timers_)

Definition at line 1714 of file zmq.cpp.

◆ zmq_timers_new()

void* zmq_timers_new ( void  )

Definition at line 1640 of file zmq.cpp.

◆ zmq_timers_reset()

int zmq_timers_reset ( void timers_,
int  timer_id_ 
)

Definition at line 1694 of file zmq.cpp.

◆ zmq_timers_set_interval()

int zmq_timers_set_interval ( void timers_,
int  timer_id_,
size_t  interval_ 
)

Definition at line 1683 of file zmq.cpp.

◆ zmq_timers_timeout()

long zmq_timers_timeout ( void timers_)

Definition at line 1704 of file zmq.cpp.

◆ zmq_unbind()

int zmq_unbind ( void s_,
const char *  addr_ 
)

Definition at line 337 of file zmq.cpp.

◆ zmq_version()

void zmq_version ( int *  major_,
int *  minor_,
int *  patch_ 
)

Definition at line 88 of file zmq.cpp.



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