![]() |
libzmq
master
ZeroMQ C++ Core Engine (LIBZMQ)
|
#include "testutil.hpp"
Go to the source code of this file.
Functions | |
int | main (void) |
int | receive (void *socket) |
int | test_blocking (int send_hwm, int msgCnt) |
int | test_defaults (int send_hwm, int msgCnt) |
void | test_reset_hwm () |
int main | ( | void | ) |
Definition at line 230 of file test_hwm_pubsub.cpp.
References setup_test_environment(), test_blocking(), test_defaults(), and test_reset_hwm().
int receive | ( | void * | socket | ) |
Definition at line 83 of file test_hwm_pubsub.cpp.
References ZMQ_DONTWAIT, and zmq_recv().
Referenced by test_blocking().
Definition at line 97 of file test_hwm_pubsub.cpp.
References receive(), zmq_bind(), zmq_close(), zmq_connect(), zmq_ctx_new(), zmq_ctx_term(), ZMQ_DONTWAIT, ZMQ_PUB, zmq_send(), zmq_setsockopt(), ZMQ_SNDHWM, zmq_socket(), ZMQ_SUB, ZMQ_SUBSCRIBE, and ZMQ_XPUB_NODROP.
Referenced by main().
Definition at line 34 of file test_hwm_pubsub.cpp.
References zmq_bind(), zmq_close(), zmq_connect(), zmq_ctx_new(), zmq_ctx_term(), ZMQ_DONTWAIT, ZMQ_PUB, zmq_recv(), zmq_send(), zmq_setsockopt(), ZMQ_SNDHWM, zmq_socket(), ZMQ_SUB, and ZMQ_SUBSCRIBE.
Referenced by main().
void test_reset_hwm | ( | ) |
Definition at line 155 of file test_hwm_pubsub.cpp.
References msleep(), SETTLE_TIME, zmq_bind(), zmq_close(), zmq_connect(), zmq_ctx_new(), zmq_ctx_term(), ZMQ_DONTWAIT, ZMQ_PUB, ZMQ_RCVHWM, zmq_recv(), zmq_send(), zmq_setsockopt(), ZMQ_SNDHWM, zmq_socket(), ZMQ_SUB, and ZMQ_SUBSCRIBE.
Referenced by main().