![]() |
libzmq
master
ZeroMQ C++ Core Engine (LIBZMQ)
|
#include "testutil.hpp"
Go to the source code of this file.
Functions | |
int | main (void) |
void | test_block_on_send_no_peers (void *ctx) |
void | test_destroy_queue_on_disconnect (void *ctx) |
void | test_fair_queue_in (void *ctx) |
void | test_round_robin_out (void *ctx) |
Variables | |
const char * | bind_address = 0 |
const char * | connect_address = 0 |
int main | ( | void | ) |
Definition at line 224 of file test_spec_dealer.cpp.
References bind_address, connect_address, setup_test_environment(), test_block_on_send_no_peers(), test_fair_queue_in(), test_round_robin_out(), zmq_ctx_new(), and zmq_ctx_term().
void test_block_on_send_no_peers | ( | void * | ctx | ) |
Definition at line 203 of file test_spec_dealer.cpp.
References zmq_close(), ZMQ_DEALER, ZMQ_DONTWAIT, zmq_send(), zmq_setsockopt(), ZMQ_SNDTIMEO, and zmq_socket().
Referenced by main().
void test_destroy_queue_on_disconnect | ( | void * | ctx | ) |
Definition at line 141 of file test_spec_dealer.cpp.
References bind_address, close_zero_linger(), connect_address, msleep(), s_send_seq(), SEQ_END, SETTLE_TIME, zmq_bind(), zmq_connect(), ZMQ_DEALER, zmq_disconnect(), ZMQ_DONTWAIT, zmq_msg_close(), zmq_msg_init(), zmq_msg_recv(), zmq_poll(), zmq_send(), and zmq_socket().
void test_fair_queue_in | ( | void * | ctx | ) |
Definition at line 83 of file test_spec_dealer.cpp.
References bind_address, close_zero_linger(), connect_address, msleep(), receiver(), s_recv_seq(), s_send_seq(), SEQ_END, SETTLE_TIME, zmq_bind(), zmq_connect(), ZMQ_DEALER, zmq_msg_close(), zmq_msg_init(), ZMQ_RCVTIMEO, zmq_setsockopt(), and zmq_socket().
Referenced by main().
void test_round_robin_out | ( | void * | ctx | ) |
Definition at line 35 of file test_spec_dealer.cpp.
References bind_address, close_zero_linger(), connect_address, msleep(), s_recv_seq(), s_send_seq(), SEQ_END, SETTLE_TIME, zmq_bind(), zmq_connect(), ZMQ_DEALER, zmq_msg_close(), zmq_msg_init(), ZMQ_RCVTIMEO, ZMQ_REP, zmq_setsockopt(), and zmq_socket().
Referenced by main().
const char* bind_address = 0 |
Definition at line 32 of file test_spec_dealer.cpp.
Referenced by main(), test_destroy_queue_on_disconnect(), test_fair_queue_in(), and test_round_robin_out().
const char* connect_address = 0 |
Definition at line 33 of file test_spec_dealer.cpp.
Referenced by main(), test_destroy_queue_on_disconnect(), test_fair_queue_in(), and test_round_robin_out().