![]() |
libzmq
master
ZeroMQ C++ Core Engine (LIBZMQ)
|
#include "testutil.hpp"
Go to the source code of this file.
Functions | |
int | main (void) |
static void | pusher (void *ctx) |
static void | simult_bind (void *payload) |
static void | simult_conn (void *payload) |
void | test_bind_before_connect () |
void | test_connect_before_bind () |
void | test_connect_before_bind_pub_sub () |
void | test_connect_only () |
void | test_identity () |
void | test_multiple_connects () |
void | test_multiple_threads () |
void | test_shutdown_during_pend () |
void | test_simultaneous_connect_bind_threads () |
void | test_unbind () |
int main | ( | void | ) |
Definition at line 495 of file test_inproc_connect.cpp.
References setup_test_environment(), test_bind_before_connect(), test_connect_before_bind(), test_connect_before_bind_pub_sub(), test_connect_only(), test_identity(), test_multiple_connects(), test_multiple_threads(), test_shutdown_during_pend(), test_simultaneous_connect_bind_threads(), and test_unbind().
|
static |
Definition at line 32 of file test_inproc_connect.cpp.
References zmq_close(), zmq_connect(), ZMQ_PAIR, zmq_send_const(), and zmq_socket().
Referenced by test_multiple_threads().
|
static |
Definition at line 66 of file test_inproc_connect.cpp.
References zmq_bind(), zmq_close(), ZMQ_PUB, and zmq_socket().
Referenced by test_simultaneous_connect_bind_threads().
|
static |
Definition at line 49 of file test_inproc_connect.cpp.
References zmq_close(), zmq_connect(), zmq_socket(), and ZMQ_SUB.
Referenced by test_simultaneous_connect_bind_threads().
void test_bind_before_connect | ( | ) |
Definition at line 83 of file test_inproc_connect.cpp.
References zmq_bind(), zmq_close(), zmq_connect(), zmq_ctx_new(), zmq_ctx_term(), zmq_msg_data(), zmq_msg_init(), zmq_msg_recv(), ZMQ_PAIR, zmq_send_const(), and zmq_socket().
Referenced by main().
void test_connect_before_bind | ( | ) |
Definition at line 124 of file test_inproc_connect.cpp.
References zmq_bind(), zmq_close(), zmq_connect(), zmq_ctx_new(), zmq_ctx_term(), zmq_msg_data(), zmq_msg_init(), zmq_msg_recv(), ZMQ_PAIR, zmq_send_const(), and zmq_socket().
Referenced by main().
void test_connect_before_bind_pub_sub | ( | ) |
Definition at line 165 of file test_inproc_connect.cpp.
References msleep(), SETTLE_TIME, zmq_bind(), zmq_close(), zmq_connect(), zmq_ctx_new(), zmq_ctx_term(), zmq_msg_data(), zmq_msg_init(), zmq_msg_recv(), ZMQ_PUB, zmq_send_const(), zmq_setsockopt(), zmq_socket(), ZMQ_SUB, and ZMQ_SUBSCRIBE.
Referenced by main().
void test_connect_only | ( | ) |
Definition at line 407 of file test_inproc_connect.cpp.
References zmq_close(), zmq_connect(), zmq_ctx_new(), zmq_ctx_term(), ZMQ_PUSH, and zmq_socket().
Referenced by main().
void test_identity | ( | ) |
Definition at line 351 of file test_inproc_connect.cpp.
References zmq_bind(), zmq_close(), zmq_connect(), zmq_ctx_new(), zmq_ctx_term(), ZMQ_DEALER, zmq_msg_init(), zmq_msg_more(), zmq_msg_recv(), ZMQ_ROUTER, zmq_send(), ZMQ_SNDMORE, and zmq_socket().
Referenced by main().
void test_multiple_connects | ( | ) |
Definition at line 215 of file test_inproc_connect.cpp.
References zmq_bind(), zmq_close(), zmq_connect(), zmq_ctx_new(), zmq_ctx_term(), zmq_msg_data(), zmq_msg_init(), zmq_msg_recv(), ZMQ_PULL, ZMQ_PUSH, zmq_send_const(), and zmq_socket().
Referenced by main().
void test_multiple_threads | ( | ) |
Definition at line 269 of file test_inproc_connect.cpp.
References pusher(), zmq_bind(), zmq_close(), zmq_ctx_new(), zmq_ctx_term(), zmq_msg_data(), zmq_msg_init(), zmq_msg_recv(), ZMQ_PULL, zmq_socket(), zmq_threadclose(), and zmq_threadstart().
Referenced by main().
void test_shutdown_during_pend | ( | ) |
Definition at line 474 of file test_inproc_connect.cpp.
References zmq_close(), zmq_connect(), zmq_ctx_new(), zmq_ctx_shutdown(), zmq_ctx_term(), ZMQ_PAIR, and zmq_socket().
Referenced by main().
void test_simultaneous_connect_bind_threads | ( | ) |
Definition at line 315 of file test_inproc_connect.cpp.
References simult_bind(), simult_conn(), zmq_ctx_new(), zmq_ctx_term(), zmq_threadclose(), and zmq_threadstart().
Referenced by main().
void test_unbind | ( | ) |
Definition at line 425 of file test_inproc_connect.cpp.
References zmq_bind(), zmq_close(), zmq_connect(), zmq_ctx_new(), zmq_ctx_term(), zmq_msg_data(), zmq_msg_init(), zmq_msg_recv(), ZMQ_PAIR, zmq_send_const(), zmq_socket(), and zmq_unbind().
Referenced by main().