![]() |
libzmq master
The Intelligent Transport Layer
|
#include <errno.h>#include <stddef.h>
Include dependency graph for zmq.h:
This graph shows which files directly or indirectly include this file:Go to the source code of this file.
Classes | |
| struct | zmq_msg_t |
| struct | zmq_pollitem_t |
Defines | |
| #define | EADDRINUSE (ZMQ_HAUSNUMERO + 5) |
| #define | EADDRNOTAVAIL (ZMQ_HAUSNUMERO + 6) |
| #define | EAFNOSUPPORT (ZMQ_HAUSNUMERO + 10) |
| #define | ECONNREFUSED (ZMQ_HAUSNUMERO + 7) |
| #define | EFSM (ZMQ_HAUSNUMERO + 51) |
| #define | EINPROGRESS (ZMQ_HAUSNUMERO + 8) |
| #define | EMTHREAD (ZMQ_HAUSNUMERO + 54) |
| #define | ENETDOWN (ZMQ_HAUSNUMERO + 4) |
| #define | ENOBUFS (ZMQ_HAUSNUMERO + 3) |
| #define | ENOCOMPATPROTO (ZMQ_HAUSNUMERO + 52) |
| #define | ENOTSOCK (ZMQ_HAUSNUMERO + 9) |
| #define | ENOTSUP (ZMQ_HAUSNUMERO + 1) |
| #define | EPROTONOSUPPORT (ZMQ_HAUSNUMERO + 2) |
| #define | ETERM (ZMQ_HAUSNUMERO + 53) |
| #define | ZMQ_AFFINITY 4 |
| #define | ZMQ_BACKLOG 19 |
| #define | ZMQ_DEALER ZMQ_XREQ |
| #define | ZMQ_DONTWAIT 1 |
| #define | ZMQ_EVENTS 15 |
| #define | ZMQ_EXPORT |
| #define | ZMQ_FD 14 |
| #define | ZMQ_HAUSNUMERO 156384712 |
| #define | ZMQ_IDENTITY 5 |
| #define | ZMQ_IPV4ONLY 31 |
| #define | ZMQ_LINGER 17 |
| #define | ZMQ_MAKE_VERSION(major, minor, patch) ((major) * 10000 + (minor) * 100 + (patch)) |
| #define | ZMQ_MAXMSGSIZE 22 |
| #define | ZMQ_MORE 1 |
| #define | ZMQ_MULTICAST_HOPS 25 |
| #define | ZMQ_PAIR 0 |
| #define | ZMQ_POLLERR 4 |
| #define | ZMQ_POLLIN 1 |
| #define | ZMQ_POLLOUT 2 |
| #define | ZMQ_PUB 1 |
| #define | ZMQ_PULL 7 |
| #define | ZMQ_PUSH 8 |
| #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_ROUTER ZMQ_XREP |
| #define | ZMQ_SNDBUF 11 |
| #define | ZMQ_SNDHWM 23 |
| #define | ZMQ_SNDMORE 2 |
| #define | ZMQ_SNDTIMEO 28 |
| #define | ZMQ_SUB 2 |
| #define | ZMQ_SUBSCRIBE 6 |
| #define | ZMQ_TYPE 16 |
| #define | ZMQ_UNSUBSCRIBE 7 |
| #define | ZMQ_VERSION ZMQ_MAKE_VERSION(ZMQ_VERSION_MAJOR, ZMQ_VERSION_MINOR, ZMQ_VERSION_PATCH) |
| #define | ZMQ_VERSION_MAJOR 3 |
| #define | ZMQ_VERSION_MINOR 1 |
| #define | ZMQ_VERSION_PATCH 0 |
| #define | ZMQ_XPUB 9 |
| #define | ZMQ_XREP 6 |
| #define | ZMQ_XREQ 5 |
| #define | ZMQ_XSUB 10 |
Typedefs | |
| typedef void( | zmq_free_fn )(void *data, void *hint) |
Functions | |
| 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_errno (void) |
| ZMQ_EXPORT int | zmq_getmsgopt (zmq_msg_t *msg, int option, void *optval, size_t *optvallen) |
| ZMQ_EXPORT int | zmq_getsockopt (void *s, int option, void *optval, size_t *optvallen) |
| 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_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_move (zmq_msg_t *dest, zmq_msg_t *src) |
| 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_recv (void *s, void *buf, size_t len, 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_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_socket (void *context, int type) |
| ZMQ_EXPORT const char * | zmq_strerror (int errnum) |
| ZMQ_EXPORT int | zmq_term (void *context) |
| ZMQ_EXPORT void | zmq_version (int *major, int *minor, int *patch) |
| #define EADDRINUSE (ZMQ_HAUSNUMERO + 5) |
Definition at line 92 of file zmq.h.
Referenced by zmq::ctx_t::register_endpoint().
| #define EAFNOSUPPORT (ZMQ_HAUSNUMERO + 10) |
Definition at line 107 of file zmq.h.
Referenced by zmq::tcp_listener_t::set_address().
| #define ECONNREFUSED (ZMQ_HAUSNUMERO + 7) |
Definition at line 98 of file zmq.h.
Referenced by zmq::tcp_connecter_t::connect(), zmq::ipc_connecter_t::connect(), zmq::ctx_t::find_endpoint(), and zmq::stream_engine_t::read().
| #define EFSM (ZMQ_HAUSNUMERO + 51) |
Definition at line 111 of file zmq.h.
Referenced by zmq::req_t::xrecv(), zmq::rep_t::xrecv(), zmq::req_t::xsend(), and zmq::rep_t::xsend().
| #define EINPROGRESS (ZMQ_HAUSNUMERO + 8) |
Definition at line 101 of file zmq.h.
Referenced by zmq::tcp_connecter_t::open().
| #define EMTHREAD (ZMQ_HAUSNUMERO + 54) |
Definition at line 114 of file zmq.h.
Referenced by zmq::socket_base_t::bind(), and zmq::socket_base_t::connect().
| #define ENETDOWN (ZMQ_HAUSNUMERO + 4) |
Definition at line 89 of file zmq.h.
Referenced by zmq::tcp_connecter_t::connect(), and zmq::ipc_connecter_t::connect().
| #define ENOBUFS (ZMQ_HAUSNUMERO + 3) |
Definition at line 86 of file zmq.h.
Referenced by zmq::tcp_listener_t::accept(), and zmq::ipc_listener_t::accept().
| #define ENOCOMPATPROTO (ZMQ_HAUSNUMERO + 52) |
Definition at line 112 of file zmq.h.
Referenced by zmq::socket_base_t::check_protocol().
| #define ENOTSOCK (ZMQ_HAUSNUMERO + 9) |
Definition at line 104 of file zmq.h.
Referenced by zmq_bind(), zmq_close(), zmq_connect(), zmq_getsockopt(), zmq_poll(), zmq_recvmsg(), zmq_sendmsg(), and zmq_setsockopt().
| #define ENOTSUP (ZMQ_HAUSNUMERO + 1) |
Definition at line 80 of file zmq.h.
Referenced by zmq::socket_base_t::xrecv(), zmq::pub_t::xrecv(), zmq::sub_t::xsend(), zmq::socket_base_t::xsend(), and zmq_poll().
| #define EPROTONOSUPPORT (ZMQ_HAUSNUMERO + 2) |
Definition at line 83 of file zmq.h.
Referenced by zmq::socket_base_t::check_protocol().
| #define ETERM (ZMQ_HAUSNUMERO + 53) |
Definition at line 113 of file zmq.h.
Referenced by zmq::socket_base_t::bind(), zmq::socket_base_t::connect(), zmq::ctx_t::create_socket(), zmq::socket_base_t::getsockopt(), zmq::socket_base_t::process_commands(), zmq::socket_base_t::recv(), zmq::socket_base_t::send(), and zmq::socket_base_t::setsockopt().
| #define ZMQ_AFFINITY 4 |
Definition at line 173 of file zmq.h.
Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().
| #define ZMQ_BACKLOG 19 |
Definition at line 187 of file zmq.h.
Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().
| #define ZMQ_DONTWAIT 1 |
Definition at line 201 of file zmq.h.
Referenced by main(), zmq::socket_base_t::recv(), zmq::socket_base_t::send(), zmq::xsub_t::xhas_in(), and zmq::xsub_t::xrecv().
| #define ZMQ_EVENTS 15 |
Definition at line 183 of file zmq.h.
Referenced by zmq::socket_base_t::getsockopt(), and zmq_poll().
| #define ZMQ_FD 14 |
Definition at line 182 of file zmq.h.
Referenced by zmq::socket_base_t::getsockopt(), and zmq_poll().
| #define ZMQ_IDENTITY 5 |
Definition at line 174 of file zmq.h.
Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().
| #define ZMQ_IPV4ONLY 31 |
Definition at line 195 of file zmq.h.
Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().
| #define ZMQ_LINGER 17 |
Definition at line 185 of file zmq.h.
Referenced by zmq::options_t::getsockopt(), main(), and zmq::options_t::setsockopt().
| #define ZMQ_MAKE_VERSION | ( | major, | |
| minor, | |||
| patch | |||
| ) | ((major) * 10000 + (minor) * 100 + (patch)) |
| #define ZMQ_MAXMSGSIZE 22 |
Definition at line 189 of file zmq.h.
Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().
| #define ZMQ_MORE 1 |
Definition at line 198 of file zmq.h.
Referenced by main(), and zmq_getmsgopt().
| #define ZMQ_MULTICAST_HOPS 25 |
Definition at line 192 of file zmq.h.
Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().
| #define ZMQ_PAIR 0 |
Definition at line 157 of file zmq.h.
Referenced by zmq::socket_base_t::create(), zmq::session_base_t::create(), main(), and zmq::pair_t::pair_t().
| #define ZMQ_POLLERR 4 |
Definition at line 223 of file zmq.h.
Referenced by zmq_poll().
| #define ZMQ_POLLIN 1 |
Definition at line 221 of file zmq.h.
Referenced by zmq::socket_base_t::getsockopt(), and zmq_poll().
| #define ZMQ_POLLOUT 2 |
Definition at line 222 of file zmq.h.
Referenced by zmq::socket_base_t::getsockopt(), and zmq_poll().
| #define ZMQ_PUB 1 |
Definition at line 158 of file zmq.h.
Referenced by zmq::socket_base_t::check_protocol(), zmq::socket_base_t::create(), zmq::session_base_t::create(), zmq::ctx_t::ctx_t(), main(), zmq::pub_t::pub_t(), zmq::xpub_t::send_unsubscription(), zmq::session_base_t::start_connecting(), and zmq::xpub_t::xread_activated().
| #define ZMQ_PULL 7 |
Definition at line 164 of file zmq.h.
Referenced by zmq::socket_base_t::create(), zmq::session_base_t::create(), main(), and zmq::pull_t::pull_t().
| #define ZMQ_PUSH 8 |
Definition at line 165 of file zmq.h.
Referenced by zmq::socket_base_t::create(), zmq::session_base_t::create(), main(), zmq::push_t::push_t(), and worker().
| #define ZMQ_RATE 8 |
Definition at line 177 of file zmq.h.
Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().
| #define ZMQ_RCVBUF 12 |
Definition at line 180 of file zmq.h.
Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().
| #define ZMQ_RCVHWM 24 |
Definition at line 191 of file zmq.h.
Referenced by zmq::options_t::getsockopt(), main(), and zmq::options_t::setsockopt().
| #define ZMQ_RCVMORE 13 |
Definition at line 181 of file zmq.h.
Referenced by bounce(), zmq::socket_base_t::getsockopt(), and main().
| #define ZMQ_RCVTIMEO 27 |
Definition at line 193 of file zmq.h.
Referenced by zmq::options_t::getsockopt(), main(), and zmq::options_t::setsockopt().
| #define ZMQ_RECONNECT_IVL 18 |
Definition at line 186 of file zmq.h.
Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().
| #define ZMQ_RECONNECT_IVL_MAX 21 |
Definition at line 188 of file zmq.h.
Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().
| #define ZMQ_RECOVERY_IVL 9 |
Definition at line 178 of file zmq.h.
Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().
| #define ZMQ_REP 4 |
Definition at line 161 of file zmq.h.
Referenced by zmq::socket_base_t::create(), zmq::session_base_t::create(), main(), zmq::rep_t::rep_t(), and worker().
| #define ZMQ_REQ 3 |
Definition at line 160 of file zmq.h.
Referenced by zmq::socket_base_t::create(), zmq::session_base_t::create(), main(), and zmq::req_t::req_t().
| #define ZMQ_SNDBUF 11 |
Definition at line 179 of file zmq.h.
Referenced by zmq::options_t::getsockopt(), and zmq::options_t::setsockopt().
| #define ZMQ_SNDHWM 23 |
Definition at line 190 of file zmq.h.
Referenced by zmq::options_t::getsockopt(), main(), and zmq::options_t::setsockopt().
| #define ZMQ_SNDMORE 2 |
Definition at line 202 of file zmq.h.
Referenced by bounce(), main(), zmq::socket_base_t::send(), and zmq::pair_t::xsend().
| #define ZMQ_SNDTIMEO 28 |
Definition at line 194 of file zmq.h.
Referenced by zmq::options_t::getsockopt(), main(), and zmq::options_t::setsockopt().
| #define ZMQ_SUB 2 |
Definition at line 159 of file zmq.h.
Referenced by zmq::socket_base_t::check_protocol(), zmq::socket_base_t::create(), zmq::session_base_t::create(), zmq::session_base_t::detached(), main(), zmq::session_base_t::start_connecting(), and zmq::sub_t::sub_t().
| #define ZMQ_SUBSCRIBE 6 |
Definition at line 175 of file zmq.h.
Referenced by main(), and zmq::sub_t::xsetsockopt().
| #define ZMQ_TYPE 16 |
Definition at line 184 of file zmq.h.
Referenced by zmq::options_t::getsockopt().
| #define ZMQ_UNSUBSCRIBE 7 |
Definition at line 176 of file zmq.h.
Referenced by zmq::sub_t::xsetsockopt().
| #define ZMQ_VERSION ZMQ_MAKE_VERSION(ZMQ_VERSION_MAJOR, ZMQ_VERSION_MINOR, ZMQ_VERSION_PATCH) |
| #define ZMQ_VERSION_MAJOR 3 |
Definition at line 58 of file zmq.h.
Referenced by zmq_version().
| #define ZMQ_VERSION_MINOR 1 |
Definition at line 59 of file zmq.h.
Referenced by zmq_version().
| #define ZMQ_VERSION_PATCH 0 |
Definition at line 60 of file zmq.h.
Referenced by zmq_version().
| #define ZMQ_XPUB 9 |
Definition at line 166 of file zmq.h.
Referenced by zmq::socket_base_t::check_protocol(), zmq::socket_base_t::create(), zmq::session_base_t::create(), main(), zmq::session_base_t::start_connecting(), and zmq::xpub_t::xpub_t().
| #define ZMQ_XREP 6 |
Definition at line 163 of file zmq.h.
Referenced by zmq::socket_base_t::create(), zmq::session_base_t::create(), main(), and zmq::xrep_t::xrep_t().
| #define ZMQ_XREQ 5 |
Definition at line 162 of file zmq.h.
Referenced by zmq::socket_base_t::create(), zmq::session_base_t::create(), main(), and zmq::xreq_t::xreq_t().
| #define ZMQ_XSUB 10 |
Definition at line 167 of file zmq.h.
Referenced by zmq::socket_base_t::check_protocol(), zmq::socket_base_t::create(), zmq::session_base_t::create(), zmq::session_base_t::detached(), main(), zmq::session_base_t::start_connecting(), and zmq::xsub_t::xsub_t().
| typedef void( zmq_free_fn)(void *data, void *hint) |
| 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_errno | ( | void | ) |
| ZMQ_EXPORT int zmq_getmsgopt | ( | zmq_msg_t * | msg, |
| int | option, | ||
| void * | optval, | ||
| size_t * | optvallen | ||
| ) |
Definition at line 343 of file zmq.cpp.
References zmq::msg_t::more, and ZMQ_MORE.
Referenced by main().
Here is the caller graph for this function:| ZMQ_EXPORT int zmq_getsockopt | ( | void * | s, |
| int | option, | ||
| void * | optval, | ||
| size_t * | optvallen | ||
| ) |
| ZMQ_EXPORT void* zmq_init | ( | int | io_threads | ) |
Definition at line 93 of file zmq.cpp.
References alloc_assert, and zmq_assert.
Referenced by main().
Here is the caller graph for this function:| ZMQ_EXPORT int zmq_msg_close | ( | zmq_msg_t * | msg | ) |
Definition at line 318 of file zmq.cpp.
Referenced by main(), worker(), zmq_recv(), and zmq_send().
Here is the caller graph for this function:| ZMQ_EXPORT void* zmq_msg_data | ( | zmq_msg_t * | msg | ) |
Definition at line 333 of file zmq.cpp.
Referenced by main(), worker(), zmq_recv(), and zmq_send().
Here is the caller graph for this function:| ZMQ_EXPORT int zmq_msg_init | ( | zmq_msg_t * | msg | ) |
Definition at line 302 of file zmq.cpp.
Referenced by main(), worker(), and zmq_recv().
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 | ||
| ) |
| ZMQ_EXPORT int zmq_msg_init_size | ( | zmq_msg_t * | msg, |
| size_t | size | ||
| ) |
Definition at line 307 of file zmq.cpp.
Referenced by main(), worker(), and zmq_send().
Here is the caller graph for this function:| ZMQ_EXPORT size_t zmq_msg_size | ( | zmq_msg_t * | msg | ) |
Definition at line 338 of file zmq.cpp.
Referenced by main(), zmq_recvmsg(), and zmq_sendmsg().
Here is the caller graph for this function:| ZMQ_EXPORT int zmq_poll | ( | zmq_pollitem_t * | items, |
| int | nitems, | ||
| long | timeout | ||
| ) |
Definition at line 362 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, and ZMQ_POLLOUT.
Here is the call graph for this function:| ZMQ_EXPORT int zmq_recv | ( | void * | s, |
| void * | buf, | ||
| size_t | len, | ||
| int | flags | ||
| ) |
Definition at line 251 of file zmq.cpp.
References errno_assert, unlikely, zmq_msg_close(), zmq_msg_data(), zmq_msg_init(), and zmq_recvmsg().
Referenced by bounce(), and main().
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 290 of file zmq.cpp.
References ENOTSOCK, unlikely, and zmq_msg_size().
Referenced by main(), worker(), and zmq_recv().
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 229 of file zmq.cpp.
References errno_assert, unlikely, zmq_msg_close(), zmq_msg_data(), zmq_msg_init_size(), and zmq_sendmsg().
Referenced by bounce(), and main().
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 277 of file zmq.cpp.
References ENOTSOCK, unlikely, and zmq_msg_size().
Referenced by main(), worker(), and zmq_send().
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 | ||
| ) |
| ZMQ_EXPORT void* zmq_socket | ( | void * | context, |
| int | type | ||
| ) |
| ZMQ_EXPORT const char* zmq_strerror | ( | int | errnum | ) |
| ZMQ_EXPORT int zmq_term | ( | void * | context | ) |
Definition at line 145 of file zmq.cpp.
References zmq_assert.
Referenced by main().
Here is the caller graph for this function:| ZMQ_EXPORT void zmq_version | ( | int * | major, |
| int * | minor, | ||
| int * | patch | ||
| ) |
Definition at line 81 of file zmq.cpp.
References ZMQ_VERSION_MAJOR, ZMQ_VERSION_MINOR, and ZMQ_VERSION_PATCH.
1.7.3