libzmq  master
ZeroMQ C++ Core Engine (LIBZMQ)
test_inproc_connect.cpp File Reference
#include "testutil.hpp"
Include dependency graph for test_inproc_connect.cpp:

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 ()
 

Function Documentation

static void pusher ( void *  ctx)
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().

Here is the call graph for this function:

Here is the caller graph for this function:

static void simult_bind ( void *  payload)
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().

Here is the call graph for this function:

Here is the caller graph for this function:

static void simult_conn ( void *  payload)
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().

Here is the call graph for this function:

Here is the caller graph for this function:

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().

Here is the call graph for this function:

Here is the caller graph for this function:

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().

Here is the call graph for this function:

Here is the caller graph for this function:

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().

Here is the call graph for this function:

Here is the caller graph for this function:

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().

Here is the call graph for this function:

Here is the caller graph for this function:

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().

Here is the call graph for this function:

Here is the caller graph for this function:

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().

Here is the call graph for this function:

Here is the caller graph for this function:

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().

Here is the call graph for this function:

Here is the caller graph for this function:

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().

Here is the call graph for this function:

Here is the caller graph for this function:

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().

Here is the call graph for this function:

Here is the caller graph for this function:

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().

Here is the call graph for this function:

Here is the caller graph for this function: