![]() |
libzmq
master
ZeroMQ C++ Core Engine (LIBZMQ)
|
#include "testutil.hpp"
Go to the source code of this file.
Classes | |
struct | zmtp_greeting_t |
Macros | |
#define | size 64000 |
#define | ZMTP_DEALER 5 |
Typedefs | |
typedef unsigned char | byte |
Functions | |
int | main (void) |
static void | test_stream_to_dealer (void) |
static void | test_stream_to_stream (void) |
Variables | |
static zmtp_greeting_t | greeting |
#define size 64000 |
Referenced by zmq::ipc_listener_t::close(), do_bind_and_verify(), get_monitor_event(), main(), zmq::v1_encoder_t::message_ready(), zmq::v2_encoder_t::message_ready(), zmq::udp_engine_t::out_event(), zmq::dish_session_t::push_msg(), zmq::null_mechanism_t::receive_and_process_zap_reply(), zmq::plain_server_t::receive_and_process_zap_reply(), s_recv(), s_send(), s_sendmore(), zmq::stream_engine_t::stream_engine_t(), test_stream_to_dealer(), zmq::xpub_t::xread_activated(), zmq::xsub_t::xsend(), zap_handler(), zmq::mechanism_t::zap_msg_available(), and zmq::i_encoder::~i_encoder().
#define ZMTP_DEALER 5 |
Definition at line 43 of file test_stream.cpp.
typedef unsigned char byte |
Definition at line 34 of file test_stream.cpp.
int main | ( | void | ) |
Definition at line 328 of file test_stream.cpp.
References setup_test_environment(), test_stream_to_dealer(), and test_stream_to_stream().
|
static |
Definition at line 57 of file test_stream.cpp.
References greeting, zmtp_greeting_t::signature, size, streq, zmq_bind(), zmq_close(), zmq_connect(), zmq_ctx_new(), zmq_ctx_term(), ZMQ_DEALER, ZMQ_LINGER, zmq_msg_gets(), zmq_msg_init(), zmq_msg_more(), zmq_msg_recv(), zmq_msg_send(), zmq_recv(), zmq_send(), zmq_setsockopt(), ZMQ_SNDMORE, zmq_socket(), ZMQ_STREAM, and ZMQ_STREAM_NOTIFY.
Referenced by main().
|
static |
Definition at line 232 of file test_stream.cpp.
References zmq_bind(), zmq_close(), zmq_connect(), zmq_ctx_new(), zmq_ctx_term(), zmq_getsockopt(), ZMQ_IDENTITY, zmq_recv(), zmq_send(), zmq_setsockopt(), ZMQ_SNDMORE, zmq_socket(), ZMQ_STREAM, and ZMQ_STREAM_NOTIFY.
Referenced by main().
|
static |
Definition at line 49 of file test_stream.cpp.
Referenced by test_stream_to_dealer().