zmq.h File Reference

#include <errno.h>
#include <stddef.h>
#include <stdio.h>
#include <stdint.h>

Include dependency graph for zmq.h:

Go to the source code of this file.

Classes
union	zmq_msg_t
struct	zmq_pollitem_t

Macros
#define	EADDRINUSE   (ZMQ_HAUSNUMERO + 5)
#define	EADDRNOTAVAIL   (ZMQ_HAUSNUMERO + 6)
#define	EAFNOSUPPORT   (ZMQ_HAUSNUMERO + 11)
#define	ECONNABORTED   (ZMQ_HAUSNUMERO + 13)
#define	ECONNREFUSED   (ZMQ_HAUSNUMERO + 7)
#define	ECONNRESET   (ZMQ_HAUSNUMERO + 14)
#define	EFSM   (ZMQ_HAUSNUMERO + 51)
#define	EHOSTUNREACH   (ZMQ_HAUSNUMERO + 17)
#define	EINPROGRESS   (ZMQ_HAUSNUMERO + 8)
#define	EMSGSIZE   (ZMQ_HAUSNUMERO + 10)
#define	EMTHREAD   (ZMQ_HAUSNUMERO + 54)
#define	ENETDOWN   (ZMQ_HAUSNUMERO + 4)
#define	ENETRESET   (ZMQ_HAUSNUMERO + 18)
#define	ENETUNREACH   (ZMQ_HAUSNUMERO + 12)
#define	ENOBUFS   (ZMQ_HAUSNUMERO + 3)
#define	ENOCOMPATPROTO   (ZMQ_HAUSNUMERO + 52)
#define	ENOTCONN   (ZMQ_HAUSNUMERO + 15)
#define	ENOTSOCK   (ZMQ_HAUSNUMERO + 9)
#define	ENOTSUP   (ZMQ_HAUSNUMERO + 1)
#define	EPROTONOSUPPORT   (ZMQ_HAUSNUMERO + 2)
#define	ETERM   (ZMQ_HAUSNUMERO + 53)
#define	ETIMEDOUT   (ZMQ_HAUSNUMERO + 16)
#define	ZMQ_AFFINITY   4
#define	ZMQ_BACKLOG   19
#define	ZMQ_BLOCKY   70
#define	ZMQ_CONFLATE   54
#define	ZMQ_CONNECT_RID   61
#define	ZMQ_CONNECT_TIMEOUT   79
#define	ZMQ_CURVE   2
#define	ZMQ_CURVE_PUBLICKEY   48
#define	ZMQ_CURVE_SECRETKEY   49
#define	ZMQ_CURVE_SERVER   47
#define	ZMQ_CURVE_SERVERKEY   50
#define	ZMQ_DEALER   5
#define	ZMQ_DEFINED_STDINT   1
#define	ZMQ_DELAY_ATTACH_ON_CONNECT   ZMQ_IMMEDIATE
#define	ZMQ_DONTWAIT   1
#define	ZMQ_EVENT_ACCEPT_FAILED   0x0040
#define	ZMQ_EVENT_ACCEPTED   0x0020
#define	ZMQ_EVENT_ALL   0xFFFF
#define	ZMQ_EVENT_BIND_FAILED   0x0010
#define	ZMQ_EVENT_CLOSE_FAILED   0x0100
#define	ZMQ_EVENT_CLOSED   0x0080
#define	ZMQ_EVENT_CONNECT_DELAYED   0x0002
#define	ZMQ_EVENT_CONNECT_RETRIED   0x0004
#define	ZMQ_EVENT_CONNECTED   0x0001
#define	ZMQ_EVENT_DISCONNECTED   0x0200
#define	ZMQ_EVENT_LISTENING   0x0008
#define	ZMQ_EVENT_MONITOR_STOPPED   0x0400
#define	ZMQ_EVENTS   15
#define	ZMQ_EXPORT
#define	ZMQ_FAIL_UNROUTABLE   ZMQ_ROUTER_MANDATORY
#define	ZMQ_FD   14
#define	ZMQ_FORWARDER   2
#define	ZMQ_GROUP_MAX_LENGTH   15
#define	ZMQ_GSSAPI   3
#define	ZMQ_GSSAPI_PLAINTEXT   65
#define	ZMQ_GSSAPI_PRINCIPAL   63
#define	ZMQ_GSSAPI_SERVER   62
#define	ZMQ_GSSAPI_SERVICE_PRINCIPAL   64
#define	ZMQ_HANDSHAKE_IVL   66
#define	ZMQ_HAS_CAPABILITIES   1
#define	ZMQ_HAUSNUMERO   156384712
#define	ZMQ_HEARTBEAT_IVL   75
#define	ZMQ_HEARTBEAT_TIMEOUT   77
#define	ZMQ_HEARTBEAT_TTL   76
#define	ZMQ_IDENTITY   5
#define	ZMQ_IMMEDIATE   39
#define	ZMQ_INVERT_MATCHING   74
#define	ZMQ_IO_THREADS   1
#define	ZMQ_IO_THREADS_DFLT   1
#define	ZMQ_IPC_FILTER_GID   60
#define	ZMQ_IPC_FILTER_PID   58
#define	ZMQ_IPC_FILTER_UID   59
#define	ZMQ_IPV4ONLY   31
#define	ZMQ_IPV6   42
#define	ZMQ_LAST_ENDPOINT   32
#define	ZMQ_LINGER   17
#define	ZMQ_MAKE_VERSION(major, minor, patch)   ((major) * 10000 + (minor) * 100 + (patch))
#define	ZMQ_MAX_MSGSZ   5
#define	ZMQ_MAX_SOCKETS   2
#define	ZMQ_MAX_SOCKETS_DFLT   1023
#define	ZMQ_MAXMSGSIZE   22
#define	ZMQ_MECHANISM   43
#define	ZMQ_MORE   1
#define	ZMQ_MULTICAST_HOPS   25
#define	ZMQ_MULTICAST_MAXTPDU   84
#define	ZMQ_NOBLOCK   ZMQ_DONTWAIT
#define	ZMQ_NULL   0
#define	ZMQ_PAIR   0
#define	ZMQ_PLAIN   1
#define	ZMQ_PLAIN_PASSWORD   46
#define	ZMQ_PLAIN_SERVER   44
#define	ZMQ_PLAIN_USERNAME   45
#define	ZMQ_POLLERR   4
#define	ZMQ_POLLIN   1
#define	ZMQ_POLLITEMS_DFLT   16
#define	ZMQ_POLLOUT   2
#define	ZMQ_POLLPRI   8
#define	ZMQ_PROBE_ROUTER   51
#define	ZMQ_PUB   1
#define	ZMQ_PULL   7
#define	ZMQ_PUSH   8
#define	ZMQ_QUEUE   3
#define	ZMQ_RATE   8
#define	ZMQ_RCVBUF   12
#define	ZMQ_RCVHWM   24
#define	ZMQ_RCVMORE   13
#define	ZMQ_RCVTIMEO   27
#define	ZMQ_RECONNECT_IVL   18
#define	ZMQ_RECONNECT_IVL_MAX   21
#define	ZMQ_RECOVERY_IVL   9
#define	ZMQ_REP   4
#define	ZMQ_REQ   3
#define	ZMQ_REQ_CORRELATE   52
#define	ZMQ_REQ_RELAXED   53
#define	ZMQ_ROUTER   6
#define	ZMQ_ROUTER_BEHAVIOR   ZMQ_ROUTER_MANDATORY
#define	ZMQ_ROUTER_HANDOVER   56
#define	ZMQ_ROUTER_MANDATORY   33
#define	ZMQ_ROUTER_RAW   41
#define	ZMQ_SHARED   3
#define	ZMQ_SNDBUF   11
#define	ZMQ_SNDHWM   23
#define	ZMQ_SNDMORE   2
#define	ZMQ_SNDTIMEO   28
#define	ZMQ_SOCKET_LIMIT   3
#define	ZMQ_SOCKS_PROXY   68
#define	ZMQ_SRCFD   2
#define	ZMQ_STREAM   11
#define	ZMQ_STREAM_NOTIFY   73
#define	ZMQ_STREAMER   1
#define	ZMQ_SUB   2
#define	ZMQ_SUBSCRIBE   6
#define	ZMQ_TCP_ACCEPT_FILTER   38
#define	ZMQ_TCP_KEEPALIVE   34
#define	ZMQ_TCP_KEEPALIVE_CNT   35
#define	ZMQ_TCP_KEEPALIVE_IDLE   36
#define	ZMQ_TCP_KEEPALIVE_INTVL   37
#define	ZMQ_TCP_MAXRT   80
#define	ZMQ_THREAD_PRIORITY   3
#define	ZMQ_THREAD_PRIORITY_DFLT   -1
#define	ZMQ_THREAD_SAFE   81
#define	ZMQ_THREAD_SCHED_POLICY   4
#define	ZMQ_THREAD_SCHED_POLICY_DFLT   -1
#define	ZMQ_TOS   57
#define	ZMQ_TYPE   16
#define	ZMQ_UNSUBSCRIBE   7
#define	ZMQ_USE_FD   89
#define	ZMQ_VERSION   ZMQ_MAKE_VERSION(ZMQ_VERSION_MAJOR, ZMQ_VERSION_MINOR, ZMQ_VERSION_PATCH)
#define	ZMQ_VERSION_MAJOR   4
#define	ZMQ_VERSION_MINOR   2
#define	ZMQ_VERSION_PATCH   0
#define	ZMQ_VMCI_BUFFER_MAX_SIZE   87
#define	ZMQ_VMCI_BUFFER_MIN_SIZE   86
#define	ZMQ_VMCI_BUFFER_SIZE   85
#define	ZMQ_VMCI_CONNECT_TIMEOUT   88
#define	ZMQ_XPUB   9
#define	ZMQ_XPUB_MANUAL   71
#define	ZMQ_XPUB_NODROP   69
#define	ZMQ_XPUB_VERBOSE   40
#define	ZMQ_XPUB_VERBOSER   78
#define	ZMQ_XPUB_WELCOME_MSG   72
#define	ZMQ_XREP   ZMQ_ROUTER
#define	ZMQ_XREQ   ZMQ_DEALER
#define	ZMQ_XSUB   10
#define	ZMQ_ZAP_DOMAIN   55

Typedefs
typedef void(	zmq_free_fn) (void *data, void *hint)
typedef union zmq_msg_t	zmq_msg_t
typedef struct zmq_pollitem_t	zmq_pollitem_t
typedef void(	zmq_thread_fn) (void *)

Functions
ZMQ_EXPORT int	zmq_atomic_counter_dec (void *counter)
ZMQ_EXPORT void	zmq_atomic_counter_destroy (void **counter_p)
ZMQ_EXPORT int	zmq_atomic_counter_inc (void *counter)
ZMQ_EXPORT void *	zmq_atomic_counter_new (void)
ZMQ_EXPORT void	zmq_atomic_counter_set (void *counter, int value)
ZMQ_EXPORT int	zmq_atomic_counter_value (void *counter)
ZMQ_EXPORT int	zmq_bind (void *s, const char *addr)
ZMQ_EXPORT int	zmq_close (void *s)
ZMQ_EXPORT int	zmq_connect (void *s, const char *addr)
ZMQ_EXPORT int	zmq_ctx_destroy (void *context)
ZMQ_EXPORT int	zmq_ctx_get (void *context, int option)
ZMQ_EXPORT void *	zmq_ctx_new (void)
ZMQ_EXPORT int	zmq_ctx_set (void *context, int option, int optval)
ZMQ_EXPORT int	zmq_ctx_shutdown (void *context)
ZMQ_EXPORT int	zmq_ctx_term (void *context)
ZMQ_EXPORT int	zmq_curve_keypair (char *z85_public_key, char *z85_secret_key)
ZMQ_EXPORT int	zmq_device (int type, void *frontend, void *backend)
ZMQ_EXPORT int	zmq_disconnect (void *s, const char *addr)
ZMQ_EXPORT int	zmq_errno (void)
ZMQ_EXPORT int	zmq_getsockopt (void *s, int option, void *optval, size_t *optvallen)
ZMQ_EXPORT int	zmq_has (const char *capability)
ZMQ_EXPORT void *	zmq_init (int io_threads)
ZMQ_EXPORT int	zmq_msg_close (zmq_msg_t *msg)
ZMQ_EXPORT int	zmq_msg_copy (zmq_msg_t *dest, zmq_msg_t *src)
ZMQ_EXPORT void *	zmq_msg_data (zmq_msg_t *msg)
ZMQ_EXPORT int	zmq_msg_get (zmq_msg_t *msg, int property)
ZMQ_EXPORT const char *	zmq_msg_gets (zmq_msg_t *msg, const char *property)
ZMQ_EXPORT int	zmq_msg_init (zmq_msg_t *msg)
ZMQ_EXPORT int	zmq_msg_init_data (zmq_msg_t *msg, void *data, size_t size, zmq_free_fn *ffn, void *hint)
ZMQ_EXPORT int	zmq_msg_init_size (zmq_msg_t *msg, size_t size)
ZMQ_EXPORT int	zmq_msg_more (zmq_msg_t *msg)
ZMQ_EXPORT int	zmq_msg_move (zmq_msg_t *dest, zmq_msg_t *src)
ZMQ_EXPORT int	zmq_msg_recv (zmq_msg_t *msg, void *s, int flags)
ZMQ_EXPORT int	zmq_msg_send (zmq_msg_t *msg, void *s, int flags)
ZMQ_EXPORT int	zmq_msg_set (zmq_msg_t *msg, int property, int optval)
ZMQ_EXPORT size_t	zmq_msg_size (zmq_msg_t *msg)
ZMQ_EXPORT int	zmq_poll (zmq_pollitem_t *items, int nitems, long timeout)
ZMQ_EXPORT int	zmq_proxy (void *frontend, void *backend, void *capture)
ZMQ_EXPORT int	zmq_proxy_steerable (void *frontend, void *backend, void *capture, void *control)
ZMQ_EXPORT int	zmq_recv (void *s, void *buf, size_t len, int flags)
ZMQ_EXPORT int	zmq_recviov (void *s, struct iovec *iov, size_t *count, int flags)
ZMQ_EXPORT int	zmq_recvmsg (void *s, zmq_msg_t *msg, int flags)
ZMQ_EXPORT int	zmq_send (void *s, const void *buf, size_t len, int flags)
ZMQ_EXPORT int	zmq_send_const (void *s, const void *buf, size_t len, int flags)
ZMQ_EXPORT int	zmq_sendiov (void *s, struct iovec *iov, size_t count, int flags)
ZMQ_EXPORT int	zmq_sendmsg (void *s, zmq_msg_t *msg, int flags)
ZMQ_EXPORT int	zmq_setsockopt (void *s, int option, const void *optval, size_t optvallen)
ZMQ_EXPORT void	zmq_sleep (int seconds_)
ZMQ_EXPORT void *	zmq_socket (void *, int type)
ZMQ_EXPORT int	zmq_socket_monitor (void *s, const char *addr, int events)
ZMQ_EXPORT void *	zmq_stopwatch_start (void)
ZMQ_EXPORT unsigned long	zmq_stopwatch_stop (void *watch_)
ZMQ_EXPORT const char *	zmq_strerror (int errnum)
ZMQ_EXPORT int	zmq_term (void *context)
ZMQ_EXPORT void	zmq_threadclose (void *thread)
ZMQ_EXPORT void *	zmq_threadstart (zmq_thread_fn *func, void *arg)
ZMQ_EXPORT int	zmq_unbind (void *s, const char *addr)
ZMQ_EXPORT void	zmq_version (int *major, int *minor, int *patch)
ZMQ_EXPORT uint8_t *	zmq_z85_decode (uint8_t *dest, const char *string)
ZMQ_EXPORT char *	zmq_z85_encode (char *dest, const uint8_t *data, size_t size)

Macro Definition Documentation

#define EADDRINUSE   (ZMQ_HAUSNUMERO + 5)

Definition at line 124 of file zmq.h.

Referenced by zmq::errno_to_string(), zmq::ctx_t::register_endpoint(), and zmq::zmq_abort().

#define EADDRNOTAVAIL   (ZMQ_HAUSNUMERO + 6)

Definition at line 127 of file zmq.h.

Referenced by zmq::errno_to_string(), and zmq::zmq_abort().

#define EAFNOSUPPORT   (ZMQ_HAUSNUMERO + 11)

Definition at line 142 of file zmq.h.

Referenced by zmq::tcp_connecter_t::open(), zmq::tcp_listener_t::set_address(), and zmq::zmq_abort().

#define ECONNABORTED   (ZMQ_HAUSNUMERO + 13)

Definition at line 148 of file zmq.h.

Referenced by zmq::tcp_listener_t::accept(), zmq::ipc_listener_t::accept(), and zmq::zmq_abort().

#define ECONNREFUSED   (ZMQ_HAUSNUMERO + 7)

Definition at line 130 of file zmq.h.

Referenced by zmq::socks_connecter_t::check_proxy_connection(), zmq::ipc_connecter_t::connect(), zmq::errno_to_string(), zmq::ctx_t::find_endpoint(), zmq::session_base_t::zap_connect(), and zmq::zmq_abort().

#define ECONNRESET   (ZMQ_HAUSNUMERO + 14)

Definition at line 151 of file zmq.h.

Referenced by zmq::socks_connecter_t::check_proxy_connection(), zmq::ipc_connecter_t::connect(), and zmq::zmq_abort().

#define EFSM   (ZMQ_HAUSNUMERO + 51)

Definition at line 167 of file zmq.h.

Referenced by zmq::errno_to_string(), zmq::rep_t::xrecv(), zmq::req_t::xrecv(), zmq::rep_t::xsend(), zmq::req_t::xsend(), zmq::plain_server_t::zap_msg_available(), and zmq::null_mechanism_t::zap_msg_available().

#define EHOSTUNREACH   (ZMQ_HAUSNUMERO + 17)

Definition at line 160 of file zmq.h.

Referenced by zmq::socks_connecter_t::check_proxy_connection(), zmq::ipc_connecter_t::connect(), main(), test_destroy_queue_on_disconnect(), zmq::stream_t::xsend(), zmq::server_t::xsend(), zmq::router_t::xsend(), and zmq::zmq_abort().

#define EINPROGRESS   (ZMQ_HAUSNUMERO + 8)

Definition at line 133 of file zmq.h.

Referenced by zmq::socks_connecter_t::connect_to_proxy(), zmq::errno_to_string(), zmq::socks_connecter_t::initiate_connect(), zmq::tcp_connecter_t::open(), zmq::ipc_connecter_t::open(), zmq::tcp_connecter_t::start_connecting(), and zmq::ipc_connecter_t::start_connecting().

#define EMSGSIZE   (ZMQ_HAUSNUMERO + 10)

Definition at line 139 of file zmq.h.

Referenced by zmq::v1_decoder_t::eight_byte_size_ready(), zmq::v1_decoder_t::one_byte_size_ready(), zmq::v2_decoder_t::size_ready(), zmq::tcp_write(), and zmq::zmq_abort().

#define EMTHREAD   (ZMQ_HAUSNUMERO + 54)

Definition at line 170 of file zmq.h.

Referenced by zmq::socket_base_t::bind(), zmq::socket_base_t::connect(), and zmq::errno_to_string().

#define ENETDOWN   (ZMQ_HAUSNUMERO + 4)

Definition at line 121 of file zmq.h.

Referenced by zmq::socks_connecter_t::check_proxy_connection(), zmq::ipc_connecter_t::connect(), zmq::errno_to_string(), and zmq::zmq_abort().

#define ENETRESET   (ZMQ_HAUSNUMERO + 18)

Definition at line 163 of file zmq.h.

Referenced by zmq::zmq_abort().

#define ENETUNREACH   (ZMQ_HAUSNUMERO + 12)

Definition at line 145 of file zmq.h.

Referenced by zmq::socks_connecter_t::check_proxy_connection(), zmq::ipc_connecter_t::connect(), and zmq::zmq_abort().

#define ENOBUFS   (ZMQ_HAUSNUMERO + 3)

Definition at line 118 of file zmq.h.

Referenced by zmq::tcp_listener_t::accept(), zmq::tcp_connecter_t::connect(), zmq::errno_to_string(), and zmq::zmq_abort().

#define ENOCOMPATPROTO   (ZMQ_HAUSNUMERO + 52)

Definition at line 168 of file zmq.h.

Referenced by zmq::socket_base_t::check_protocol(), and zmq::errno_to_string().

#define ENOTCONN   (ZMQ_HAUSNUMERO + 15)

Definition at line 154 of file zmq.h.

Referenced by zmq::session_base_t::read_zap_msg(), zmq::session_base_t::write_zap_msg(), and zmq::zmq_abort().

#define ENOTSOCK   (ZMQ_HAUSNUMERO + 9)

Definition at line 136 of file zmq.h.

Referenced by zmq::tcp_connecter_t::connect(), do_check(), zmq::get_peer_ip_address(), zmq::udp_engine_t::in_event(), zmq::tcp_read(), zmq::tcp_write(), zmq::socket_poller_t::wait(), zmq::zmq_abort(), zmq_bind(), zmq_close(), zmq_connect(), zmq_disconnect(), zmq_getsockopt(), zmq_join(), zmq_leave(), zmq_msg_recv(), zmq_msg_send(), zmq_poll(), zmq_poller_add(), zmq_poller_modify(), zmq_poller_remove(), zmq_recv(), zmq_recviov(), zmq_send(), zmq_send_const(), zmq_sendiov(), zmq_setsockopt(), zmq_socket_monitor(), and zmq_unbind().

#define ENOTSUP   (ZMQ_HAUSNUMERO + 1)

Definition at line 112 of file zmq.h.

Referenced by zmq::errno_to_string(), zmq::socket_poller_t::wait(), zmq::socket_base_t::xjoin(), zmq::socket_base_t::xleave(), zmq::pub_t::xrecv(), zmq::radio_t::xrecv(), zmq::socket_base_t::xrecv(), zmq::sub_t::xsend(), zmq::dish_t::xsend(), zmq::socket_base_t::xsend(), zmq_curve_keypair(), and zmq_poll().

#define EPROTONOSUPPORT   (ZMQ_HAUSNUMERO + 2)

Definition at line 115 of file zmq.h.

Referenced by zmq::socket_base_t::check_protocol(), zmq::errno_to_string(), main(), zmq::socket_base_t::monitor(), and zmq::zmq_abort().

#define ETERM   (ZMQ_HAUSNUMERO + 53)

Definition at line 169 of file zmq.h.

Referenced by zmq::socket_base_t::bind(), close_zero_linger(), zmq::socket_base_t::connect(), zmq::ctx_t::create_socket(), zmq::errno_to_string(), zmq::socket_base_t::getsockopt(), zmq::socket_base_t::monitor(), zmq::socket_base_t::process_commands(), zmq::socket_base_t::recv(), zmq::socket_base_t::send(), zmq::socket_base_t::setsockopt(), and zmq::socket_base_t::term_endpoint().

#define ETIMEDOUT   (ZMQ_HAUSNUMERO + 16)

Definition at line 157 of file zmq.h.

Referenced by zmq::socks_connecter_t::check_proxy_connection(), zmq::ipc_connecter_t::connect(), main(), zmq::socket_poller_t::wait(), zmq::condition_variable_t::wait(), and zmq::zmq_abort().

#define ZMQ_AFFINITY   4

Definition at line 264 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().

#define ZMQ_BACKLOG   19

Definition at line 278 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().

#define ZMQ_BLOCKY   70

Definition at line 321 of file zmq.h.

Referenced by zmq::ctx_t::get(), main(), zmq::ctx_t::set(), and zmq::socket_base_t::socket_base_t().

#define ZMQ_CONFLATE   54

Definition at line 307 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), main(), and zmq::options_t::setsockopt().

#define ZMQ_CONNECT_RID   61

Definition at line 311 of file zmq.h.

Referenced by test_router_2_router(), test_stream_2_stream(), zmq::router_t::xsetsockopt(), and zmq::stream_t::xsetsockopt().

#define ZMQ_CONNECT_TIMEOUT   79

Definition at line 330 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().

#define ZMQ_CURVE   2

Definition at line 351 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), zmq::stream_engine_t::handshake(), and zmq::options_t::setsockopt().

#define ZMQ_CURVE_PUBLICKEY   48

Definition at line 301 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), main(), zmq::options_t::setsockopt(), and setup_curve().

#define ZMQ_CURVE_SECRETKEY   49

Definition at line 302 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), main(), zmq::options_t::setsockopt(), and setup_curve().

#define ZMQ_CURVE_SERVER   47

Definition at line 300 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), main(), zmq::options_t::setsockopt(), and setup_curve().

#define ZMQ_CURVE_SERVERKEY   50

Definition at line 303 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), main(), zmq::options_t::setsockopt(), and setup_curve().

#define ZMQ_DEALER   5

Definition at line 251 of file zmq.h.

Referenced by zmq::mechanism_t::check_socket_type(), client_task(), zmq::socket_base_t::connect(), zmq::ctx_t::connect_inproc_sockets(), zmq::session_base_t::create(), zmq::socket_base_t::create(), zmq::dealer_t::dealer_t(), main(), zmq::null_mechanism_t::next_handshake_command(), zmq::session_base_t::process_attach(), zmq::plain_client_t::produce_initiate(), zmq::plain_server_t::produce_ready(), run_test(), server_task(), server_worker(), test_block_on_send_no_peers(), test_destroy_queue_on_disconnect(), test_envelope(), test_fair_queue_in(), test_heartbeat_notimeout(), test_heartbeat_ttl(), test_identity(), test_round_robin_out(), test_stream_handshake_timeout_accept(), test_stream_handshake_timeout_connect(), and test_stream_to_dealer().

#define ZMQ_DEFINED_STDINT   1

Definition at line 84 of file zmq.h.

#define ZMQ_DELAY_ATTACH_ON_CONNECT   ZMQ_IMMEDIATE

Definition at line 363 of file zmq.h.

Referenced by main().

#define ZMQ_DONTWAIT   1

Definition at line 345 of file zmq.h.

Referenced by count_msg(), get_monitor_event(), main(), receive(), zmq::socket_base_t::recv(), zmq::socket_base_t::send(), server_worker(), test_basic(), test_block_on_send_no_peers(), test_blocking(), test_change_after_connected(), test_change_before_connected(), test_decrease_when_full(), test_defaults(), test_destroy_queue_on_disconnect(), test_inproc_bind_and_close_first(), test_inproc_connect_and_close_first(), test_missing_subscriptions(), test_push_block_on_send_no_peers(), test_reset_hwm(), and test_xpub_proxy_unsubscribe_on_disconnect().

#define ZMQ_EVENT_ACCEPT_FAILED   0x0040

Definition at line 383 of file zmq.h.

Referenced by zmq::socket_base_t::event_accept_failed().

#define ZMQ_EVENT_ACCEPTED   0x0020

Definition at line 382 of file zmq.h.

Referenced by zmq::socket_base_t::event_accepted(), main(), prep_server_socket(), test_heartbeat_notimeout(), test_heartbeat_timeout(), test_heartbeat_ttl(), test_stream_handshake_timeout_accept(), and test_stream_handshake_timeout_connect().

#define ZMQ_EVENT_ALL   0xFFFF

Definition at line 388 of file zmq.h.

Referenced by main().

#define ZMQ_EVENT_BIND_FAILED   0x0010

Definition at line 381 of file zmq.h.

Referenced by zmq::socket_base_t::event_bind_failed().

#define ZMQ_EVENT_CLOSE_FAILED   0x0100

Definition at line 385 of file zmq.h.

Referenced by zmq::socket_base_t::event_close_failed().

#define ZMQ_EVENT_CLOSED   0x0080

Definition at line 384 of file zmq.h.

Referenced by zmq::socket_base_t::event_closed(), and main().

#define ZMQ_EVENT_CONNECT_DELAYED   0x0002

Definition at line 378 of file zmq.h.

Referenced by zmq::socket_base_t::event_connect_delayed(), and main().

#define ZMQ_EVENT_CONNECT_RETRIED   0x0004

Definition at line 379 of file zmq.h.

Referenced by zmq::socket_base_t::event_connect_retried().

#define ZMQ_EVENT_CONNECTED   0x0001

Definition at line 377 of file zmq.h.

Referenced by zmq::socket_base_t::event_connected(), main(), prep_server_socket(), test_stream_handshake_timeout_accept(), and test_stream_handshake_timeout_connect().

#define ZMQ_EVENT_DISCONNECTED   0x0200

Definition at line 386 of file zmq.h.

Referenced by zmq::socket_base_t::event_disconnected(), main(), prep_server_socket(), test_heartbeat_timeout(), test_heartbeat_ttl(), test_stream_handshake_timeout_accept(), and test_stream_handshake_timeout_connect().

#define ZMQ_EVENT_LISTENING   0x0008

Definition at line 380 of file zmq.h.

Referenced by zmq::socket_base_t::event_listening(), and main().

#define ZMQ_EVENT_MONITOR_STOPPED   0x0400

Definition at line 387 of file zmq.h.

Referenced by main(), and zmq::socket_base_t::stop_monitor().

#define ZMQ_EVENTS   15

Definition at line 274 of file zmq.h.

Referenced by zmq::socket_base_t::getsockopt(), zmq::socket_poller_t::wait(), and zmq_poll().

#define ZMQ_EXPORT

Definition at line 79 of file zmq.h.

#define ZMQ_FAIL_UNROUTABLE   ZMQ_ROUTER_MANDATORY

Definition at line 365 of file zmq.h.

#define ZMQ_FD   14

Definition at line 273 of file zmq.h.

Referenced by zmq::socket_base_t::getsockopt(), main(), zmq::socket_poller_t::rebuild(), and zmq_poll().

#define ZMQ_FORWARDER   2

Definition at line 447 of file zmq.h.

#define ZMQ_GROUP_MAX_LENGTH   15

Definition at line 355 of file zmq.h.

Referenced by main(), zmq::dish_session_t::push_msg(), zmq::msg_t::set_group(), zmq::dish_t::xjoin(), and zmq::dish_t::xleave().

#define ZMQ_GSSAPI   3

Definition at line 352 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), zmq::stream_engine_t::handshake(), and zmq::options_t::setsockopt().

#define ZMQ_GSSAPI_PLAINTEXT   65

Definition at line 315 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().

#define ZMQ_GSSAPI_PRINCIPAL   63

Definition at line 313 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().

#define ZMQ_GSSAPI_SERVER   62

Definition at line 312 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().

#define ZMQ_GSSAPI_SERVICE_PRINCIPAL   64

Definition at line 314 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().

#define ZMQ_HANDSHAKE_IVL   66

Definition at line 316 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), zmq::options_t::setsockopt(), test_stream_handshake_timeout_accept(), and test_stream_handshake_timeout_connect().

#define ZMQ_HAS_CAPABILITIES   1

Definition at line 442 of file zmq.h.

#define ZMQ_HAUSNUMERO   156384712

Definition at line 108 of file zmq.h.

#define ZMQ_HEARTBEAT_IVL   75

Definition at line 326 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), prep_server_socket(), zmq::options_t::setsockopt(), and test_heartbeat_ttl().

#define ZMQ_HEARTBEAT_TIMEOUT   77

Definition at line 328 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().

#define ZMQ_HEARTBEAT_TTL   76

Definition at line 327 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), zmq::options_t::setsockopt(), and test_heartbeat_ttl().

#define ZMQ_IDENTITY   5

Definition at line 265 of file zmq.h.

Referenced by client_task(), get_identity(), zmq::options_t::getsockopt(), main(), zmq::options_t::setsockopt(), test_destroy_queue_on_disconnect(), test_fair_queue_in(), test_req_only_listens_to_current_peer(), test_router_2_router(), and test_stream_to_stream().

#define ZMQ_IMMEDIATE   39

Definition at line 292 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), main(), and zmq::options_t::setsockopt().

#define ZMQ_INVERT_MATCHING   74

Definition at line 325 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), main(), and zmq::options_t::setsockopt().

#define ZMQ_IO_THREADS   1

Definition at line 189 of file zmq.h.

Referenced by zmq::ctx_t::get(), main(), zmq::ctx_t::set(), and zmq_init().

#define ZMQ_IO_THREADS_DFLT   1

Definition at line 197 of file zmq.h.

Referenced by main().

#define ZMQ_IPC_FILTER_GID   60

Definition at line 361 of file zmq.h.

Referenced by main(), and zmq::options_t::setsockopt().

#define ZMQ_IPC_FILTER_PID   58

Definition at line 359 of file zmq.h.

Referenced by main(), and zmq::options_t::setsockopt().

#define ZMQ_IPC_FILTER_UID   59

Definition at line 360 of file zmq.h.

Referenced by main(), and zmq::options_t::setsockopt().

#define ZMQ_IPV4ONLY   31

Definition at line 362 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().

#define ZMQ_IPV6   42

Definition at line 295 of file zmq.h.

Referenced by zmq::ctx_t::get(), zmq::options_t::getsockopt(), main(), zmq::ctx_t::set(), zmq::options_t::setsockopt(), and zmq::socket_base_t::socket_base_t().

#define ZMQ_LAST_ENDPOINT   32

Definition at line 286 of file zmq.h.

Referenced by do_bind_and_verify(), zmq::socket_base_t::getsockopt(), and main().

#define ZMQ_LINGER   17

Definition at line 276 of file zmq.h.

Referenced by client_task(), close_zero_linger(), zmq::options_t::getsockopt(), main(), zmq::socket_base_t::monitor(), prep_server_socket(), server_task(), server_worker(), zmq::options_t::setsockopt(), test_router_2_router(), test_stream_2_stream(), test_stream_handshake_timeout_accept(), test_stream_handshake_timeout_connect(), and test_stream_to_dealer().

#define ZMQ_MAKE_VERSION	(		major,
			minor,
			patch
	)		((major) * 10000 + (minor) * 100 + (patch))

Definition at line 46 of file zmq.h.

#define ZMQ_MAX_MSGSZ   5

Definition at line 194 of file zmq.h.

Referenced by zmq::ctx_t::get(), and zmq::ctx_t::set().

#define ZMQ_MAX_SOCKETS   2

Definition at line 190 of file zmq.h.

Referenced by zmq::ctx_t::get(), main(), zmq::ctx_t::set(), and test_system_max().

#define ZMQ_MAX_SOCKETS_DFLT   1023

Definition at line 198 of file zmq.h.

Referenced by main(), and test_zmq_default_max().

#define ZMQ_MAXMSGSIZE   22

Definition at line 280 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().

#define ZMQ_MECHANISM   43

Definition at line 296 of file zmq.h.

Referenced by zmq::options_t::getsockopt().

#define ZMQ_MORE   1

Definition at line 341 of file zmq.h.

Referenced by zmq_msg_get(), and zmq_msg_more().

#define ZMQ_MULTICAST_HOPS   25

Definition at line 283 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().

#define ZMQ_MULTICAST_MAXTPDU   84

Definition at line 333 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().

#define ZMQ_NOBLOCK   ZMQ_DONTWAIT

Definition at line 364 of file zmq.h.

Referenced by main().

#define ZMQ_NULL   0

Definition at line 349 of file zmq.h.

Referenced by zmq::stream_engine_t::handshake(), zmq::options_t::setsockopt(), and zmq::session_base_t::zap_enabled().

#define ZMQ_PAIR   0

Definition at line 246 of file zmq.h.

Referenced by zmq::mechanism_t::check_socket_type(), zmq::session_base_t::create(), zmq::socket_base_t::create(), main(), zmq::socket_base_t::monitor(), zmq::pair_t::pair_t(), prep_server_socket(), pusher(), zmq::ctx_t::terminate(), test_bind_before_connect(), test_connect_before_bind(), test_pair(), test_shutdown_during_pend(), test_stream_handshake_timeout_accept(), test_stream_handshake_timeout_connect(), test_system_max(), test_unbind(), and test_zmq_default_max().

#define ZMQ_PLAIN   1

Definition at line 350 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), zmq::stream_engine_t::handshake(), and zmq::options_t::setsockopt().

#define ZMQ_PLAIN_PASSWORD   46

Definition at line 299 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), main(), and zmq::options_t::setsockopt().

#define ZMQ_PLAIN_SERVER   44

Definition at line 297 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), main(), and zmq::options_t::setsockopt().

#define ZMQ_PLAIN_USERNAME   45

Definition at line 298 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), main(), and zmq::options_t::setsockopt().

#define ZMQ_POLLERR   4

Definition at line 412 of file zmq.h.

Referenced by zmq::socket_poller_t::rebuild(), zmq::socket_poller_t::wait(), and zmq_poll().

#define ZMQ_POLLIN   1

Definition at line 410 of file zmq.h.

Referenced by client_task(), zmq::socket_base_t::getsockopt(), main(), zmq::proxy(), zmq::socket_poller_t::rebuild(), zmq::socket_poller_t::wait(), and zmq_poll().

#define ZMQ_POLLITEMS_DFLT   16

Definition at line 427 of file zmq.h.

Referenced by zmq_poll().

#define ZMQ_POLLOUT   2

Definition at line 411 of file zmq.h.

Referenced by zmq::socket_base_t::getsockopt(), main(), zmq::proxy(), zmq::socket_poller_t::rebuild(), zmq::socket_poller_t::wait(), and zmq_poll().

#define ZMQ_POLLPRI   8

Definition at line 413 of file zmq.h.

Referenced by zmq::socket_poller_t::rebuild(), zmq::socket_poller_t::wait(), and zmq_poll().

#define ZMQ_PROBE_ROUTER   51

Definition at line 304 of file zmq.h.

Referenced by main(), zmq::dealer_t::xsetsockopt(), and zmq::router_t::xsetsockopt().

#define ZMQ_PUB   1

Definition at line 247 of file zmq.h.

Referenced by zmq::socket_base_t::check_protocol(), zmq::mechanism_t::check_socket_type(), zmq::socket_base_t::connect(), zmq::ctx_t::connect_inproc_sockets(), zmq::session_base_t::create(), zmq::socket_base_t::create(), zmq::stream_engine_t::handshake(), main(), zmq::session_base_t::process_attach(), zmq::pub_t::pub_t(), zmq::xpub_t::send_unsubscription(), simult_bind(), zmq::session_base_t::start_connecting(), test_blocking(), test_connect_before_bind_pub_sub(), test_defaults(), test_missing_subscriptions(), test_reset_hwm(), and test_xpub_proxy_unsubscribe_on_disconnect().

#define ZMQ_PULL   7

Definition at line 253 of file zmq.h.

Referenced by zmq::mechanism_t::check_socket_type(), zmq::socket_base_t::connect(), zmq::ctx_t::connect_inproc_sockets(), count_msg(), zmq::session_base_t::create(), zmq::socket_base_t::create(), main(), zmq::session_base_t::process_attach(), zmq::pull_t::pull_t(), test_change_after_connected(), test_change_before_connected(), test_ctx_destroy(), test_ctx_shutdown(), test_decrease_when_full(), test_defaults(), test_destroy_queue_on_disconnect(), test_inproc_connect_and_close_first(), test_multiple_connects(), test_multiple_threads(), test_pull_fair_queue_in(), and test_push_round_robin_out().

#define ZMQ_PUSH   8

Definition at line 254 of file zmq.h.

Referenced by zmq::mechanism_t::check_socket_type(), zmq::socket_base_t::connect(), zmq::ctx_t::connect_inproc_sockets(), count_msg(), zmq::session_base_t::create(), zmq::socket_base_t::create(), main(), zmq::session_base_t::process_attach(), zmq::push_t::push_t(), server_task(), test_change_after_connected(), test_change_before_connected(), test_connect_only(), test_decrease_when_full(), test_defaults(), test_destroy_queue_on_disconnect(), test_inproc_bind_and_close_first(), test_inproc_connect_and_close_first(), test_multiple_connects(), test_pull_fair_queue_in(), test_push_block_on_send_no_peers(), test_push_round_robin_out(), test_setsockopt_tcp_recv_buffer(), test_setsockopt_tcp_send_buffer(), test_setsockopt_use_fd(), and worker().

#define ZMQ_QUEUE   3

Definition at line 448 of file zmq.h.

#define ZMQ_RATE   8

Definition at line 268 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().

#define ZMQ_RCVBUF   12

Definition at line 271 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), zmq::options_t::setsockopt(), and test_setsockopt_tcp_recv_buffer().

#define ZMQ_RCVHWM   24

Definition at line 282 of file zmq.h.

Referenced by count_msg(), zmq::options_t::getsockopt(), main(), zmq::options_t::setsockopt(), test_change_after_connected(), test_change_before_connected(), test_decrease_when_full(), test_destroy_queue_on_disconnect(), test_inproc_connect_and_close_first(), test_reset_hwm(), and zmq::socket_base_t::update_pipe_options().

#define ZMQ_RCVMORE   13

Definition at line 272 of file zmq.h.

Referenced by bounce(), client_task(), forward(), zmq::socket_base_t::getsockopt(), has_more(), main(), zmq::proxy(), s_recv_seq(), and test_req_message_format().

#define ZMQ_RCVTIMEO   27

Definition at line 284 of file zmq.h.

Referenced by bounce_fail(), expect_bounce_fail(), zmq::options_t::getsockopt(), main(), run_test(), zmq::options_t::setsockopt(), test_fair_queue_in(), test_push_round_robin_out(), test_req_only_listens_to_current_peer(), and test_round_robin_out().

#define ZMQ_RECONNECT_IVL   18

Definition at line 277 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), run_test(), and zmq::options_t::setsockopt().

#define ZMQ_RECONNECT_IVL_MAX   21

Definition at line 279 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().

#define ZMQ_RECOVERY_IVL   9

Definition at line 269 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().

#define ZMQ_REP   4

Definition at line 250 of file zmq.h.

Referenced by zmq::mechanism_t::check_socket_type(), zmq::session_base_t::create(), zmq::socket_base_t::create(), main(), zmq::rep_t::rep_t(), server_task(), test_envelope(), test_fair_queue_in(), test_req_rep(), test_round_robin_out(), worker(), zmq::session_base_t::zap_connect(), and zap_handler().

#define ZMQ_REQ   3

Definition at line 249 of file zmq.h.

Referenced by zmq::mechanism_t::check_socket_type(), zmq::socket_base_t::connect(), zmq::session_base_t::create(), zmq::socket_base_t::create(), main(), zmq::null_mechanism_t::next_handshake_command(), zmq::plain_client_t::produce_initiate(), zmq::plain_server_t::produce_ready(), zmq::req_t::req_t(), test_block_on_send_no_peers(), test_fair_queue_in(), test_req_message_format(), test_req_only_listens_to_current_peer(), test_req_rep(), and test_round_robin_out().

#define ZMQ_REQ_CORRELATE   52

Definition at line 305 of file zmq.h.

Referenced by main(), and zmq::req_t::xsetsockopt().

#define ZMQ_REQ_RELAXED   53

Definition at line 306 of file zmq.h.

Referenced by main(), and zmq::req_t::xsetsockopt().

#define ZMQ_ROUTER   6

Definition at line 252 of file zmq.h.

Referenced by zmq::mechanism_t::check_socket_type(), zmq::session_base_t::create(), zmq::socket_base_t::create(), main(), zmq::null_mechanism_t::next_handshake_command(), prep_server_socket(), zmq::plain_client_t::produce_initiate(), zmq::plain_server_t::produce_ready(), zmq::router_t::router_t(), server_task(), test_destroy_queue_on_disconnect(), test_fair_queue_in(), test_identity(), test_req_message_format(), test_req_only_listens_to_current_peer(), test_router_2_router(), and zmq::session_base_t::zap_connect().

#define ZMQ_ROUTER_BEHAVIOR   ZMQ_ROUTER_MANDATORY

Definition at line 366 of file zmq.h.

#define ZMQ_ROUTER_HANDOVER   56

Definition at line 309 of file zmq.h.

Referenced by main(), and zmq::router_t::xsetsockopt().

#define ZMQ_ROUTER_MANDATORY   33

Definition at line 287 of file zmq.h.

Referenced by main(), test_destroy_queue_on_disconnect(), test_req_only_listens_to_current_peer(), and zmq::router_t::xsetsockopt().

#define ZMQ_ROUTER_RAW   41

Definition at line 294 of file zmq.h.

Referenced by zmq::router_t::xsetsockopt().

#define ZMQ_SHARED   3

Definition at line 342 of file zmq.h.

Referenced by main(), and zmq_msg_get().

#define ZMQ_SNDBUF   11

Definition at line 270 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), zmq::options_t::setsockopt(), and test_setsockopt_tcp_send_buffer().

#define ZMQ_SNDHWM   23

Definition at line 281 of file zmq.h.

Referenced by count_msg(), zmq::options_t::getsockopt(), main(), zmq::options_t::setsockopt(), test_blocking(), test_change_after_connected(), test_change_before_connected(), test_decrease_when_full(), test_defaults(), test_destroy_queue_on_disconnect(), test_inproc_bind_and_close_first(), test_inproc_connect_and_close_first(), test_reset_hwm(), and zmq::socket_base_t::update_pipe_options().

#define ZMQ_SNDMORE   2

Definition at line 346 of file zmq.h.

Referenced by bounce(), bounce_fail(), capture(), do_check(), expect_bounce_fail(), forward(), main(), zmq::socket_base_t::monitor_event(), s_send_seq(), s_sendmore(), zmq::socket_base_t::send(), server_worker(), test_client_server(), test_destroy_queue_on_disconnect(), test_identity(), test_missing_subscriptions(), test_req_message_format(), test_router_2_router(), test_stream_2_stream(), test_stream_to_dealer(), test_stream_to_stream(), test_xpub_proxy_unsubscribe_on_disconnect(), and zmq_sendiov().

#define ZMQ_SNDTIMEO   28

Definition at line 285 of file zmq.h.

Referenced by bounce_fail(), expect_bounce_fail(), zmq::options_t::getsockopt(), main(), run_test(), zmq::options_t::setsockopt(), test_block_on_send_no_peers(), and test_push_block_on_send_no_peers().

#define ZMQ_SOCKET_LIMIT   3

Definition at line 191 of file zmq.h.

Referenced by zmq::ctx_t::get(), and main().

#define ZMQ_SOCKS_PROXY   68

Definition at line 317 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().

#define ZMQ_SRCFD   2

Definition at line 369 of file zmq.h.

Referenced by main(), and zmq_msg_get().

#define ZMQ_STREAM   11

Definition at line 257 of file zmq.h.

Referenced by zmq::session_base_t::create(), zmq::socket_base_t::create(), main(), zmq::stream_t::stream_t(), test_stream_2_stream(), test_stream_handshake_timeout_accept(), test_stream_handshake_timeout_connect(), test_stream_to_dealer(), and test_stream_to_stream().

#define ZMQ_STREAM_NOTIFY   73

Definition at line 324 of file zmq.h.

Referenced by main(), test_stream_2_stream(), test_stream_to_dealer(), test_stream_to_stream(), and zmq::stream_t::xsetsockopt().

#define ZMQ_STREAMER   1

Definition at line 446 of file zmq.h.

#define ZMQ_SUB   2

Definition at line 248 of file zmq.h.

Referenced by zmq::socket_base_t::check_protocol(), zmq::mechanism_t::check_socket_type(), client_task(), zmq::socket_base_t::connect(), zmq::ctx_t::connect_inproc_sockets(), zmq::session_base_t::create(), zmq::socket_base_t::create(), main(), zmq::session_base_t::process_attach(), zmq::session_base_t::reconnect(), server_task(), server_worker(), simult_conn(), zmq::session_base_t::start_connecting(), zmq::sub_t::sub_t(), test_blocking(), test_connect_before_bind_pub_sub(), test_defaults(), test_missing_subscriptions(), test_reset_hwm(), and test_xpub_proxy_unsubscribe_on_disconnect().

#define ZMQ_SUBSCRIBE   6

Definition at line 266 of file zmq.h.

Referenced by client_task(), main(), server_task(), server_worker(), test_basic(), test_blocking(), test_connect_before_bind_pub_sub(), test_defaults(), test_missing_subscriptions(), test_reset_hwm(), test_xpub_proxy_unsubscribe_on_disconnect(), zmq::sub_t::xsetsockopt(), and zmq::xpub_t::xsetsockopt().

#define ZMQ_TCP_ACCEPT_FILTER   38

Definition at line 358 of file zmq.h.

Referenced by zmq::options_t::setsockopt().

#define ZMQ_TCP_KEEPALIVE   34

Definition at line 288 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().

#define ZMQ_TCP_KEEPALIVE_CNT   35

Definition at line 289 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().

#define ZMQ_TCP_KEEPALIVE_IDLE   36

Definition at line 290 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().

#define ZMQ_TCP_KEEPALIVE_INTVL   37

Definition at line 291 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().

#define ZMQ_TCP_MAXRT   80

Definition at line 331 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().

#define ZMQ_THREAD_PRIORITY   3

Definition at line 192 of file zmq.h.

Referenced by zmq::ctx_t::set().

#define ZMQ_THREAD_PRIORITY_DFLT   -1

Definition at line 199 of file zmq.h.

#define ZMQ_THREAD_SAFE   81

Definition at line 332 of file zmq.h.

Referenced by zmq::socket_poller_t::add(), zmq::socket_base_t::getsockopt(), main(), zmq::socket_poller_t::rebuild(), zmq::socket_poller_t::remove(), and zmq::socket_poller_t::~socket_poller_t().

#define ZMQ_THREAD_SCHED_POLICY   4

Definition at line 193 of file zmq.h.

Referenced by zmq::ctx_t::set().

#define ZMQ_THREAD_SCHED_POLICY_DFLT   -1

Definition at line 200 of file zmq.h.

#define ZMQ_TOS   57

Definition at line 310 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), main(), and zmq::options_t::setsockopt().

#define ZMQ_TYPE   16

Definition at line 275 of file zmq.h.

Referenced by zmq::options_t::getsockopt().

#define ZMQ_UNSUBSCRIBE   7

Definition at line 267 of file zmq.h.

Referenced by test_xpub_proxy_unsubscribe_on_disconnect(), zmq::sub_t::xsetsockopt(), and zmq::xpub_t::xsetsockopt().

#define ZMQ_USE_FD   89

Definition at line 338 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), pre_allocate_sock(), zmq::options_t::setsockopt(), and test_setsockopt_use_fd().

#define ZMQ_VERSION   ZMQ_MAKE_VERSION(ZMQ_VERSION_MAJOR, ZMQ_VERSION_MINOR, ZMQ_VERSION_PATCH)

Definition at line 48 of file zmq.h.

#define ZMQ_VERSION_MAJOR   4

Definition at line 42 of file zmq.h.

Referenced by main(), and zmq_version().

#define ZMQ_VERSION_MINOR   2

Definition at line 43 of file zmq.h.

Referenced by main(), and zmq_version().

#define ZMQ_VERSION_PATCH   0

Definition at line 44 of file zmq.h.

Referenced by main(), and zmq_version().

#define ZMQ_VMCI_BUFFER_MAX_SIZE   87

Definition at line 336 of file zmq.h.

Referenced by zmq::options_t::setsockopt().

#define ZMQ_VMCI_BUFFER_MIN_SIZE   86

Definition at line 335 of file zmq.h.

Referenced by zmq::options_t::setsockopt().

#define ZMQ_VMCI_BUFFER_SIZE   85

Definition at line 334 of file zmq.h.

Referenced by zmq::options_t::setsockopt().

#define ZMQ_VMCI_CONNECT_TIMEOUT   88

Definition at line 337 of file zmq.h.

Referenced by zmq::options_t::setsockopt().

#define ZMQ_XPUB   9

Definition at line 255 of file zmq.h.

Referenced by zmq::socket_base_t::check_protocol(), zmq::mechanism_t::check_socket_type(), zmq::session_base_t::create(), zmq::socket_base_t::create(), zmq::stream_engine_t::handshake(), main(), zmq::session_base_t::start_connecting(), test_basic(), test_missing_subscriptions(), test_xpub_proxy_unsubscribe_on_disconnect(), zmq::xpub_t::xpub_t(), and zmq::xpub_t::xread_activated().

#define ZMQ_XPUB_MANUAL   71

Definition at line 322 of file zmq.h.

Referenced by test_basic(), test_missing_subscriptions(), test_xpub_proxy_unsubscribe_on_disconnect(), and zmq::xpub_t::xsetsockopt().

#define ZMQ_XPUB_NODROP   69

Definition at line 318 of file zmq.h.

Referenced by main(), test_blocking(), and zmq::xpub_t::xsetsockopt().

#define ZMQ_XPUB_VERBOSE   40

Definition at line 293 of file zmq.h.

Referenced by zmq::xpub_t::xsetsockopt().

#define ZMQ_XPUB_VERBOSER   78

Definition at line 329 of file zmq.h.

Referenced by zmq::xpub_t::xsetsockopt().

#define ZMQ_XPUB_WELCOME_MSG   72

Definition at line 323 of file zmq.h.

Referenced by main(), and zmq::xpub_t::xsetsockopt().

#define ZMQ_XREP   ZMQ_ROUTER

Definition at line 261 of file zmq.h.

#define ZMQ_XREQ   ZMQ_DEALER

Definition at line 260 of file zmq.h.

#define ZMQ_XSUB   10

Definition at line 256 of file zmq.h.

Referenced by zmq::socket_base_t::check_protocol(), zmq::mechanism_t::check_socket_type(), zmq::session_base_t::create(), zmq::socket_base_t::create(), main(), zmq::session_base_t::reconnect(), zmq::session_base_t::start_connecting(), test_basic(), test_missing_subscriptions(), test_xpub_proxy_unsubscribe_on_disconnect(), and zmq::xsub_t::xsub_t().

#define ZMQ_ZAP_DOMAIN   55

Definition at line 308 of file zmq.h.

Referenced by zmq::options_t::getsockopt(), main(), and zmq::options_t::setsockopt().

Typedef Documentation

typedef void( zmq_free_fn) (void *data, void *hint)

Definition at line 223 of file zmq.h.

typedef union zmq_msg_t zmq_msg_t

typedef struct zmq_pollitem_t zmq_pollitem_t

typedef void( zmq_thread_fn) (void *)

Definition at line 503 of file zmq.h.

Function Documentation

ZMQ_EXPORT int zmq_atomic_counter_dec

(

void *

counter

)

Definition at line 246 of file zmq_utils.cpp.

Referenced by main().

Here is the caller graph for this function:

ZMQ_EXPORT void zmq_atomic_counter_destroy

(

void **

counter_p

)

Definition at line 260 of file zmq_utils.cpp.

Referenced by main().

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_atomic_counter_inc

(

void *

counter

)

Definition at line 238 of file zmq_utils.cpp.

Referenced by main().

Here is the caller graph for this function:

ZMQ_EXPORT void* zmq_atomic_counter_new

(

void

)

Definition at line 222 of file zmq_utils.cpp.

References alloc_assert.

Referenced by main().

Here is the caller graph for this function:

ZMQ_EXPORT void zmq_atomic_counter_set	(	void *	counter,
		int	value
	)

Definition at line 231 of file zmq_utils.cpp.

Referenced by main().

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_atomic_counter_value

(

void *

counter

)

Definition at line 253 of file zmq_utils.cpp.

Referenced by main().

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_bind	(	void *	s,
		const char *	addr
	)

Definition at line 321 of file zmq.cpp.

References zmq::socket_base_t::bind(), and ENOTSOCK.

Referenced by count_msg(), do_bind_and_verify(), main(), zmq::socket_base_t::monitor(), prep_server_socket(), run_test(), server_task(), simult_bind(), test_basic(), test_bind_before_connect(), test_blocking(), test_change_after_connected(), test_change_before_connected(), test_client_server(), test_connect_before_bind(), test_connect_before_bind_pub_sub(), test_decrease_when_full(), test_defaults(), test_destroy_queue_on_disconnect(), test_envelope(), test_fair_queue_in(), test_identity(), test_inproc_bind_and_close_first(), test_inproc_connect_and_close_first(), test_missing_subscriptions(), test_multiple_connects(), test_multiple_threads(), test_pair(), test_pull_fair_queue_in(), test_push_round_robin_out(), test_req_message_format(), test_req_only_listens_to_current_peer(), test_req_rep(), test_reset_hwm(), test_round_robin_out(), test_router_2_router(), test_stream_2_stream(), test_stream_handshake_timeout_accept(), test_stream_handshake_timeout_connect(), test_stream_to_dealer(), test_stream_to_stream(), test_unbind(), test_xpub_proxy_unsubscribe_on_disconnect(), and zap_handler().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_close

(

void *

s

)

Definition at line 255 of file zmq.cpp.

References ENOTSOCK.

Referenced by client_task(), close_zero_linger(), count_msg(), main(), pusher(), server_task(), server_worker(), simult_bind(), simult_conn(), zmq::socket_base_t::stop_monitor(), test_basic(), test_bind_before_connect(), test_block_on_send_no_peers(), test_blocking(), test_change_after_connected(), test_change_before_connected(), test_client_server(), test_connect_before_bind(), test_connect_before_bind_pub_sub(), test_connect_only(), test_ctx_destroy(), test_ctx_shutdown(), test_decrease_when_full(), test_defaults(), test_heartbeat_notimeout(), test_heartbeat_timeout(), test_heartbeat_ttl(), test_identity(), test_inproc_bind_and_close_first(), test_inproc_connect_and_close_first(), test_missing_subscriptions(), test_multiple_connects(), test_multiple_threads(), test_pair(), test_push_block_on_send_no_peers(), test_req_rep(), test_reset_hwm(), test_router_2_router(), test_setsockopt_tcp_recv_buffer(), test_setsockopt_tcp_send_buffer(), test_setsockopt_use_fd(), test_shutdown_during_pend(), test_stream_2_stream(), test_stream_handshake_timeout_accept(), test_stream_handshake_timeout_connect(), test_stream_to_dealer(), test_stream_to_stream(), test_system_max(), test_unbind(), test_xpub_proxy_unsubscribe_on_disconnect(), test_zmq_default_max(), worker(), and zap_handler().

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_connect	(	void *	s,
		const char *	addr
	)

Definition at line 332 of file zmq.cpp.

References zmq::socket_base_t::connect(), and ENOTSOCK.

Referenced by client_task(), count_msg(), main(), prep_server_socket(), pusher(), run_test(), server_task(), server_worker(), simult_conn(), test_basic(), test_bind_before_connect(), test_blocking(), test_change_after_connected(), test_change_before_connected(), test_client_server(), test_connect_before_bind(), test_connect_before_bind_pub_sub(), test_connect_only(), test_decrease_when_full(), test_defaults(), test_destroy_queue_on_disconnect(), test_envelope(), test_fair_queue_in(), test_heartbeat_notimeout(), test_heartbeat_ttl(), test_identity(), test_inproc_connect_and_close_first(), test_missing_subscriptions(), test_multiple_connects(), test_pair(), test_pull_fair_queue_in(), test_push_round_robin_out(), test_req_message_format(), test_req_only_listens_to_current_peer(), test_req_rep(), test_reset_hwm(), test_round_robin_out(), test_router_2_router(), test_shutdown_during_pend(), test_stream_2_stream(), test_stream_handshake_timeout_accept(), test_stream_handshake_timeout_connect(), test_stream_to_dealer(), test_stream_to_stream(), test_unbind(), test_xpub_proxy_unsubscribe_on_disconnect(), and worker().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_ctx_destroy

(

void *

context

)

Definition at line 236 of file zmq.cpp.

References zmq_ctx_term().

Referenced by main(), test_ctx_destroy(), test_ctx_shutdown(), test_router_2_router(), test_stream_2_stream(), test_system_max(), and test_zmq_default_max().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_ctx_get	(	void *	context,
		int	option
	)

Definition at line 209 of file zmq.cpp.

Referenced by main().

Here is the caller graph for this function:

ZMQ_EXPORT void* zmq_ctx_new

(

void

)

Definition at line 115 of file zmq.cpp.

References alloc_assert, and zmq_assert.

Referenced by count_msg(), main(), run_test(), test_basic(), test_bind_before_connect(), test_blocking(), test_change_after_connected(), test_change_before_connected(), test_client_server(), test_connect_before_bind(), test_connect_before_bind_pub_sub(), test_connect_only(), test_ctx_destroy(), test_ctx_shutdown(), test_decrease_when_full(), test_defaults(), test_heartbeat_notimeout(), test_heartbeat_timeout(), test_heartbeat_ttl(), test_identity(), test_inproc_bind_and_close_first(), test_inproc_connect_and_close_first(), test_missing_subscriptions(), test_multiple_connects(), test_multiple_threads(), test_pair(), test_req_rep(), test_reset_hwm(), test_router_2_router(), test_setsockopt_tcp_recv_buffer(), test_setsockopt_tcp_send_buffer(), test_setsockopt_use_fd(), test_shutdown_during_pend(), test_simultaneous_connect_bind_threads(), test_stream_2_stream(), test_stream_handshake_timeout_accept(), test_stream_handshake_timeout_connect(), test_stream_to_dealer(), test_stream_to_stream(), test_system_max(), test_unbind(), test_xpub_proxy_unsubscribe_on_disconnect(), test_zmq_default_max(), and zmq_init().

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_ctx_set	(	void *	context,
		int	option,
		int	optval
	)

Definition at line 200 of file zmq.cpp.

Referenced by main(), test_system_max(), and zmq_init().

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_ctx_shutdown

(

void *

context

)

Definition at line 191 of file zmq.cpp.

Referenced by test_ctx_shutdown(), and test_shutdown_during_pend().

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_ctx_term

(

void *

context

)

Definition at line 162 of file zmq.cpp.

References zmq_assert.

Referenced by count_msg(), main(), run_test(), test_basic(), test_bind_before_connect(), test_blocking(), test_change_after_connected(), test_change_before_connected(), test_client_server(), test_connect_before_bind(), test_connect_before_bind_pub_sub(), test_connect_only(), test_decrease_when_full(), test_defaults(), test_heartbeat_notimeout(), test_heartbeat_timeout(), test_heartbeat_ttl(), test_identity(), test_inproc_bind_and_close_first(), test_inproc_connect_and_close_first(), test_missing_subscriptions(), test_multiple_connects(), test_multiple_threads(), test_pair(), test_req_rep(), test_reset_hwm(), test_setsockopt_tcp_recv_buffer(), test_setsockopt_tcp_send_buffer(), test_setsockopt_use_fd(), test_shutdown_during_pend(), test_simultaneous_connect_bind_threads(), test_stream_handshake_timeout_accept(), test_stream_handshake_timeout_connect(), test_stream_to_dealer(), test_stream_to_stream(), test_unbind(), test_xpub_proxy_unsubscribe_on_disconnect(), zmq_ctx_destroy(), and zmq_term().

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_curve_keypair	(	char *	z85_public_key,
		char *	z85_secret_key
	)

Definition at line 191 of file zmq_utils.cpp.

References ENOTSUP, and zmq_z85_encode().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_device	(	int	type,
		void *	frontend,
		void *	backend
	)

Definition at line 1350 of file zmq.cpp.

References zmq::proxy().

Here is the call graph for this function:

ZMQ_EXPORT int zmq_disconnect	(	void *	s,
		const char *	addr
	)

Definition at line 353 of file zmq.cpp.

References ENOTSOCK, and zmq::socket_base_t::term_endpoint().

Referenced by main(), and test_destroy_queue_on_disconnect().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_errno

(

void

)

Definition at line 107 of file zmq.cpp.

Referenced by zmq::socket_base_t::bind(), bounce_fail(), zmq::ipc_listener_t::close(), expect_bounce_fail(), zmq::tcp_listener_t::in_event(), zmq::ipc_listener_t::in_event(), zmq::socks_connecter_t::initiate_connect(), main(), run_test(), zmq::tcp_connecter_t::start_connecting(), and zmq::ipc_connecter_t::start_connecting().

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_getsockopt	(	void *	s,
		int	option,
		void *	optval,
		size_t *	optvallen
	)

Definition at line 277 of file zmq.cpp.

References ENOTSOCK, and zmq::socket_base_t::getsockopt().

Referenced by bounce(), client_task(), do_bind_and_verify(), get_identity(), has_more(), main(), s_recv_seq(), test_change_after_connected(), test_change_before_connected(), test_decrease_when_full(), test_req_message_format(), test_setsockopt_tcp_recv_buffer(), test_setsockopt_tcp_send_buffer(), test_setsockopt_use_fd(), test_stream_handshake_timeout_accept(), test_stream_handshake_timeout_connect(), test_stream_to_stream(), and zmq_poll().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_has

(

const char *

capability

)

Definition at line 1359 of file zmq.cpp.

Referenced by main().

Here is the caller graph for this function:

ZMQ_EXPORT void* zmq_init

(

int

io_threads

)

Definition at line 220 of file zmq.cpp.

References zmq_ctx_new(), zmq_ctx_set(), and ZMQ_IO_THREADS.

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_msg_close

(

zmq_msg_t *

msg

)

Definition at line 651 of file zmq.cpp.

Referenced by bounce(), main(), msg_recv_cmp(), msg_send(), s_recv_seq(), test_client_server(), test_destroy_queue_on_disconnect(), test_fair_queue_in(), test_pull_fair_queue_in(), test_req_message_format(), test_round_robin_out(), worker(), zmq_recv(), zmq_recviov(), zmq_send(), zmq_send_const(), and zmq_sendiov().

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_msg_copy	(	zmq_msg_t *	dest,
		zmq_msg_t *	src
	)

Definition at line 661 of file zmq.cpp.

Referenced by bounce(), main(), and test_req_message_format().

Here is the caller graph for this function:

ZMQ_EXPORT void* zmq_msg_data

(

zmq_msg_t *

msg

)

Definition at line 666 of file zmq.cpp.

Referenced by get_monitor_event(), main(), zmq::socket_base_t::monitor_event(), msg_recv_cmp(), msg_send(), s_recv_seq(), test_bind_before_connect(), test_client_server(), test_connect_before_bind(), test_connect_before_bind_pub_sub(), test_fair_queue_in(), test_multiple_connects(), test_multiple_threads(), test_pull_fair_queue_in(), test_unbind(), worker(), zmq_recv(), zmq_recviov(), zmq_send(), and zmq_sendiov().

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_msg_get	(	zmq_msg_t *	msg,
		int	property
	)

Definition at line 681 of file zmq.cpp.

References zmq::msg_t::more, zmq::msg_t::shared, ZMQ_MORE, zmq_msg_gets(), ZMQ_SHARED, and ZMQ_SRCFD.

Referenced by main(), and zmq_msg_more().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT const char* zmq_msg_gets	(	zmq_msg_t *	msg,
		const char *	property
	)

Definition at line 732 of file zmq.cpp.

References zmq::metadata_t::get().

Referenced by main(), test_stream_to_dealer(), and zmq_msg_get().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_msg_init

(

zmq_msg_t *

msg

)

Definition at line 613 of file zmq.cpp.

Referenced by bounce(), get_monitor_event(), main(), msg_recv_cmp(), s_recv_seq(), test_bind_before_connect(), test_client_server(), test_connect_before_bind(), test_connect_before_bind_pub_sub(), test_destroy_queue_on_disconnect(), test_fair_queue_in(), test_identity(), test_multiple_connects(), test_multiple_threads(), test_pull_fair_queue_in(), test_req_message_format(), test_round_robin_out(), test_stream_to_dealer(), test_unbind(), worker(), zmq_recv(), and zmq_recviov().

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_msg_init_data	(	zmq_msg_t *	msg,
		void *	data,
		size_t	size,
		zmq_free_fn *	ffn,
		void *	hint
	)

Definition at line 623 of file zmq.cpp.

Referenced by main(), and zmq_send_const().

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_msg_init_size	(	zmq_msg_t *	msg,
		size_t	size
	)

Definition at line 618 of file zmq.cpp.

Referenced by main(), zmq::socket_base_t::monitor_event(), msg_send(), test_client_server(), worker(), zmq_send(), and zmq_sendiov().

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_msg_more

(

zmq_msg_t *

msg

)

Definition at line 676 of file zmq.cpp.

References ZMQ_MORE, and zmq_msg_get().

Referenced by get_monitor_event(), main(), test_identity(), and test_stream_to_dealer().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_msg_move	(	zmq_msg_t *	dest,
		zmq_msg_t *	src
	)

Definition at line 656 of file zmq.cpp.

ZMQ_EXPORT int zmq_msg_recv	(	zmq_msg_t *	msg,
		void *	s,
		int	flags
	)

Definition at line 640 of file zmq.cpp.

References ENOTSOCK, and s_recvmsg().

Referenced by bounce(), get_monitor_event(), main(), msg_recv_cmp(), s_recv_seq(), test_bind_before_connect(), test_client_server(), test_connect_before_bind(), test_connect_before_bind_pub_sub(), test_destroy_queue_on_disconnect(), test_fair_queue_in(), test_identity(), test_multiple_connects(), test_multiple_threads(), test_pull_fair_queue_in(), test_req_message_format(), test_stream_to_dealer(), test_unbind(), and zmq_recvmsg().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_msg_send	(	zmq_msg_t *	msg,
		void *	s,
		int	flags
	)

Definition at line 629 of file zmq.cpp.

References ENOTSOCK, and s_sendmsg().

Referenced by bounce(), main(), msg_send(), test_client_server(), test_req_message_format(), test_stream_to_dealer(), and zmq_sendmsg().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_msg_set	(	zmq_msg_t *	msg,
		int	property,
		int	optval
	)

Definition at line 703 of file zmq.cpp.

ZMQ_EXPORT size_t zmq_msg_size

(

zmq_msg_t *

msg

)

Definition at line 671 of file zmq.cpp.

Referenced by get_monitor_event(), main(), msg_recv_cmp(), s_recv_seq(), s_recvmsg(), s_sendmsg(), test_req_message_format(), and zmq_recviov().

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_poll	(	zmq_pollitem_t *	items,
		int	nitems,
		long	timeout
	)

Definition at line 748 of file zmq.cpp.

References alloc_assert, ENOTSOCK, ENOTSUP, errno_assert, zmq_pollitem_t::events, zmq_pollitem_t::fd, zmq::clock_t::now_ms(), zmq_pollitem_t::revents, unlikely, zmq_assert, ZMQ_EVENTS, ZMQ_FD, zmq_getsockopt(), ZMQ_POLLERR, ZMQ_POLLIN, ZMQ_POLLITEMS_DFLT, ZMQ_POLLOUT, and ZMQ_POLLPRI.

Referenced by client_task(), main(), zmq::proxy(), test_destroy_queue_on_disconnect(), and test_req_only_listens_to_current_peer().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_proxy	(	void *	frontend,
		void *	backend,
		void *	capture
	)

Definition at line 1323 of file zmq.cpp.

References zmq::proxy().

Here is the call graph for this function:

ZMQ_EXPORT int zmq_proxy_steerable	(	void *	frontend,
		void *	backend,
		void *	capture,
		void *	control
	)

Definition at line 1335 of file zmq.cpp.

References zmq::proxy().

Referenced by server_task().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_recv	(	void *	s,
		void *	buf,
		size_t	len,
		int	flags
	)

Definition at line 507 of file zmq.cpp.

References ENOTSOCK, errno_assert, s_recvmsg(), unlikely, zmq_msg_close(), zmq_msg_data(), and zmq_msg_init().

Referenced by bounce(), bounce_fail(), client_task(), count_msg(), expect_bounce_fail(), main(), receive(), receiver(), s_recv(), server_worker(), test_basic(), test_decrease_when_full(), test_defaults(), test_inproc_connect_and_close_first(), test_missing_subscriptions(), test_reset_hwm(), test_router_2_router(), test_stream_2_stream(), test_stream_to_dealer(), test_stream_to_stream(), test_xpub_proxy_unsubscribe_on_disconnect(), and zap_handler().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_recviov	(	void *	s,
		struct iovec *	iov,
		size_t *	count,
		int	flags
	)

Definition at line 557 of file zmq.cpp.

References ENOTSOCK, errno_assert, zmq::msg_t::flags, iovec::iov_base, iovec::iov_len, zmq::msg_t::more, s_recvmsg(), unlikely, zmq_msg_close(), zmq_msg_data(), zmq_msg_init(), and zmq_msg_size().

Referenced by do_check().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_recvmsg	(	void *	s,
		zmq_msg_t *	msg,
		int	flags
	)

Definition at line 501 of file zmq.cpp.

References zmq_msg_recv().

Referenced by main(), and worker().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_send	(	void *	s,
		const void *	buf,
		size_t	len,
		int	flags
	)

Definition at line 387 of file zmq.cpp.

References ENOTSOCK, errno_assert, s_sendmsg(), unlikely, zmq_msg_close(), zmq_msg_data(), and zmq_msg_init_size().

Referenced by bounce(), bounce_fail(), client_task(), client_thread(), count_msg(), expect_bounce_fail(), main(), s_send(), s_send_seq(), s_sendmore(), server_worker(), test_block_on_send_no_peers(), test_blocking(), test_change_after_connected(), test_change_before_connected(), test_decrease_when_full(), test_defaults(), test_destroy_queue_on_disconnect(), test_identity(), test_inproc_bind_and_close_first(), test_inproc_connect_and_close_first(), test_missing_subscriptions(), test_push_block_on_send_no_peers(), test_reset_hwm(), test_router_2_router(), test_stream_2_stream(), test_stream_to_dealer(), test_stream_to_stream(), test_xpub_proxy_unsubscribe_on_disconnect(), and zap_handler().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_send_const	(	void *	s,
		const void *	buf,
		size_t	len,
		int	flags
	)

Definition at line 416 of file zmq.cpp.

References ENOTSOCK, errno_assert, s_sendmsg(), unlikely, zmq_msg_close(), and zmq_msg_init_data().

Referenced by main(), pusher(), test_basic(), test_bind_before_connect(), test_connect_before_bind(), test_connect_before_bind_pub_sub(), test_multiple_connects(), test_router_2_router(), and test_unbind().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_sendiov	(	void *	s,
		struct iovec *	iov,
		size_t	count,
		int	flags
	)

Definition at line 449 of file zmq.cpp.

References ENOTSOCK, errno_assert, iovec::iov_base, iovec::iov_len, s_sendmsg(), unlikely, zmq_msg_close(), zmq_msg_data(), zmq_msg_init_size(), and ZMQ_SNDMORE.

Referenced by do_check().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_sendmsg	(	void *	s,
		zmq_msg_t *	msg,
		int	flags
	)

Definition at line 382 of file zmq.cpp.

References zmq_msg_send().

Referenced by main(), zmq::socket_base_t::monitor_event(), and worker().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_setsockopt	(	void *	s,
		int	option,
		const void *	optval,
		size_t	optvallen
	)

Definition at line 265 of file zmq.cpp.

References ENOTSOCK, and zmq::socket_base_t::setsockopt().

Referenced by bounce_fail(), client_task(), close_zero_linger(), count_msg(), expect_bounce_fail(), main(), zmq::socket_base_t::monitor(), pre_allocate_sock(), prep_server_socket(), run_test(), server_task(), server_worker(), setup_curve(), test_basic(), test_block_on_send_no_peers(), test_blocking(), test_change_after_connected(), test_change_before_connected(), test_connect_before_bind_pub_sub(), test_decrease_when_full(), test_defaults(), test_destroy_queue_on_disconnect(), test_fair_queue_in(), test_heartbeat_ttl(), test_inproc_bind_and_close_first(), test_inproc_connect_and_close_first(), test_missing_subscriptions(), test_push_block_on_send_no_peers(), test_push_round_robin_out(), test_req_only_listens_to_current_peer(), test_reset_hwm(), test_round_robin_out(), test_router_2_router(), test_setsockopt_tcp_recv_buffer(), test_setsockopt_tcp_send_buffer(), test_setsockopt_use_fd(), test_stream_2_stream(), test_stream_handshake_timeout_accept(), test_stream_handshake_timeout_connect(), test_stream_to_dealer(), test_stream_to_stream(), and test_xpub_proxy_unsubscribe_on_disconnect().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT void zmq_sleep

(

int

seconds_

)

Definition at line 53 of file zmq_utils.cpp.

Referenced by main().

Here is the caller graph for this function:

ZMQ_EXPORT void* zmq_socket	(	void *	,
		int	type
	)

Definition at line 244 of file zmq.cpp.

References zmq::ctx_t::create_socket().

Referenced by client_task(), count_msg(), main(), zmq::socket_base_t::monitor(), prep_server_socket(), pusher(), run_test(), server_task(), server_worker(), simult_bind(), simult_conn(), test_basic(), test_bind_before_connect(), test_block_on_send_no_peers(), test_blocking(), test_change_after_connected(), test_change_before_connected(), test_client_server(), test_connect_before_bind(), test_connect_before_bind_pub_sub(), test_connect_only(), test_ctx_destroy(), test_ctx_shutdown(), test_decrease_when_full(), test_defaults(), test_destroy_queue_on_disconnect(), test_envelope(), test_fair_queue_in(), test_heartbeat_notimeout(), test_heartbeat_ttl(), test_identity(), test_inproc_bind_and_close_first(), test_inproc_connect_and_close_first(), test_missing_subscriptions(), test_multiple_connects(), test_multiple_threads(), test_pair(), test_pull_fair_queue_in(), test_push_block_on_send_no_peers(), test_push_round_robin_out(), test_req_message_format(), test_req_only_listens_to_current_peer(), test_req_rep(), test_reset_hwm(), test_round_robin_out(), test_router_2_router(), test_setsockopt_tcp_recv_buffer(), test_setsockopt_tcp_send_buffer(), test_setsockopt_use_fd(), test_shutdown_during_pend(), test_stream_2_stream(), test_stream_handshake_timeout_accept(), test_stream_handshake_timeout_connect(), test_stream_to_dealer(), test_stream_to_stream(), test_system_max(), test_unbind(), test_xpub_proxy_unsubscribe_on_disconnect(), test_zmq_default_max(), worker(), and zap_handler().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_socket_monitor	(	void *	s,
		const char *	addr,
		int	events
	)

Definition at line 288 of file zmq.cpp.

References ENOTSOCK, and zmq::socket_base_t::monitor().

Referenced by main(), prep_server_socket(), test_stream_handshake_timeout_accept(), and test_stream_handshake_timeout_connect().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT void* zmq_stopwatch_start

(

void

)

Definition at line 62 of file zmq_utils.cpp.

References alloc_assert, and zmq::clock_t::now_us().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT unsigned long zmq_stopwatch_stop

(

void *

watch_

)

Definition at line 70 of file zmq_utils.cpp.

References zmq::clock_t::now_us().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT const char* zmq_strerror

(

int

errnum

)

Definition at line 102 of file zmq.cpp.

References zmq::errno_to_string().

Referenced by main(), and worker().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_term

(

void *

context

)

Definition at line 231 of file zmq.cpp.

References zmq_ctx_term().

Here is the call graph for this function:

ZMQ_EXPORT void zmq_threadclose

(

void *

thread

)

Definition at line 85 of file zmq_utils.cpp.

References LIBZMQ_DELETE, and zmq::thread_t::stop().

Referenced by main(), server_task(), test_ctx_shutdown(), test_multiple_threads(), and test_simultaneous_connect_bind_threads().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT void* zmq_threadstart	(	zmq_thread_fn *	func,
		void *	arg
	)

Definition at line 78 of file zmq_utils.cpp.

References zmq::thread_t::start().

Referenced by main(), server_task(), test_ctx_shutdown(), test_multiple_threads(), and test_simultaneous_connect_bind_threads().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT int zmq_unbind	(	void *	s,
		const char *	addr
	)

Definition at line 343 of file zmq.cpp.

References ENOTSOCK, and zmq::socket_base_t::term_endpoint().

Referenced by main(), test_router_2_router(), test_stream_2_stream(), and test_unbind().

Here is the call graph for this function:

Here is the caller graph for this function:

ZMQ_EXPORT void zmq_version	(	int *	major,
		int *	minor,
		int *	patch
	)

Definition at line 94 of file zmq.cpp.

References ZMQ_VERSION_MAJOR, ZMQ_VERSION_MINOR, and ZMQ_VERSION_PATCH.

Referenced by main().

Here is the caller graph for this function:

ZMQ_EXPORT uint8_t* zmq_z85_decode	(	uint8_t *	dest,
		const char *	string
	)

Definition at line 158 of file zmq_utils.cpp.

References decoder.

Referenced by zmq::options_t::setsockopt().

Here is the caller graph for this function:

ZMQ_EXPORT char* zmq_z85_encode	(	char *	dest,
		const uint8_t *	data,
		size_t	size
	)

Definition at line 124 of file zmq_utils.cpp.

References encoder.

Referenced by zmq::options_t::getsockopt(), zap_handler(), and zmq_curve_keypair().

Here is the caller graph for this function: