![]() |
libzmq master
The Intelligent Transport Layer
|
#include "platform.hpp"
#include <unistd.h>
#include <string.h>
#include <errno.h>
#include <stdlib.h>
#include <new>
#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"
Go to the source code of this file.
Typedefs | |
typedef char | check_msg_t_size [sizeof(zmq::msg_t)==sizeof(zmq_msg_t)?1:-1] |
Functions | |
int | zmq_bind (void *s_, const char *addr_) |
int | zmq_close (void *s_) |
int | zmq_connect (void *s_, const char *addr_) |
int | zmq_errno () |
int | zmq_getmsgopt (zmq_msg_t *msg_, int option_, void *optval_, size_t *optvallen_) |
int | zmq_getsockopt (void *s_, int option_, void *optval_, size_t *optvallen_) |
void * | zmq_init (int io_threads_) |
int | zmq_msg_close (zmq_msg_t *msg_) |
int | zmq_msg_copy (zmq_msg_t *dest_, zmq_msg_t *src_) |
void * | zmq_msg_data (zmq_msg_t *msg_) |
int | zmq_msg_init (zmq_msg_t *msg_) |
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_move (zmq_msg_t *dest_, zmq_msg_t *src_) |
size_t | zmq_msg_size (zmq_msg_t *msg_) |
int | zmq_poll (zmq_pollitem_t *items_, int nitems_, long timeout_) |
int | zmq_recv (void *s_, void *buf_, size_t len_, 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_sendmsg (void *s_, zmq_msg_t *msg_, int flags_) |
int | zmq_setsockopt (void *s_, int option_, const void *optval_, size_t optvallen_) |
void * | zmq_socket (void *ctx_, int type_) |
const char * | zmq_strerror (int errnum_) |
int | zmq_term (void *ctx_) |
void | zmq_version (int *major_, int *minor_, int *patch_) |
typedef char check_msg_t_size[sizeof(zmq::msg_t)==sizeof(zmq_msg_t)?1:-1] |
int zmq_bind | ( | void * | s_, |
const char * | addr_ | ||
) |
int zmq_close | ( | void * | s_ | ) |
int zmq_connect | ( | void * | s_, |
const char * | addr_ | ||
) |
int zmq_errno | ( | void | ) |
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().
int zmq_getsockopt | ( | void * | s_, |
int | option_, | ||
void * | optval_, | ||
size_t * | optvallen_ | ||
) |
void* zmq_init | ( | int | io_threads_ | ) |
Definition at line 93 of file zmq.cpp.
References alloc_assert, and zmq_assert.
Referenced by main().
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().
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().
int zmq_msg_init | ( | zmq_msg_t * | msg_ | ) |
Definition at line 302 of file zmq.cpp.
Referenced by main(), worker(), and zmq_recv().
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_ | ||
) |
Definition at line 307 of file zmq.cpp.
Referenced by main(), worker(), and zmq_send().
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().
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.
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().
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().
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().
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().
int zmq_setsockopt | ( | void * | s_, |
int | option_, | ||
const void * | optval_, | ||
size_t | optvallen_ | ||
) |
void* zmq_socket | ( | void * | ctx_, |
int | type_ | ||
) |
const char* zmq_strerror | ( | int | errnum_ | ) |
int zmq_term | ( | void * | ctx_ | ) |
Definition at line 145 of file zmq.cpp.
References zmq_assert.
Referenced by main().
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.