47 uint16_t
event = *(uint16_t *) (data);
49 *value = *(uint32_t *) (data + 2);
60 *address = (
char *) malloc (size + 1);
61 memcpy (*address, data, size);
92 size_t vsize =
sizeof(val);
97 assert (vsize ==
sizeof(val));
98 assert (val == 30000);
106 assert (vsize ==
sizeof(val));
107 assert (val == tenth);
118 rc =
zmq_connect (dealer_mon,
"inproc://monitor-dealer");
122 rc =
zmq_bind (dealer,
"tcp://127.0.0.1:5557");
160 rc =
zmq_bind (stream,
"tcp://127.0.0.1:5556");
168 int val, tenth = 100;
169 size_t vsize =
sizeof(val);
174 assert (vsize ==
sizeof(val));
175 assert (val == 30000);
183 assert (vsize ==
sizeof(val));
184 assert (val == tenth);
195 rc =
zmq_connect (dealer_mon,
"inproc://monitor-dealer");
ZMQ_EXPORT int zmq_setsockopt(void *s, int option, const void *optval, size_t optvallen)
static void test_stream_handshake_timeout_connect(void)
#define ZMQ_EVENT_CONNECTED
ZMQ_EXPORT void * zmq_ctx_new(void)
void setup_test_environment(void)
ZMQ_EXPORT void * zmq_msg_data(zmq_msg_t *msg)
ZMQ_EXPORT void * zmq_socket(void *, int type)
ZMQ_EXPORT int zmq_socket_monitor(void *s, const char *addr, int events)
ZMQ_EXPORT int zmq_getsockopt(void *s, int option, void *optval, size_t *optvallen)
#define ZMQ_EVENT_DISCONNECTED
static void test_stream_handshake_timeout_accept(void)
ZMQ_EXPORT int zmq_connect(void *s, const char *addr)
ZMQ_EXPORT int zmq_close(void *s)
ZMQ_EXPORT int zmq_msg_recv(zmq_msg_t *msg, void *s, int flags)
ZMQ_EXPORT int zmq_msg_more(zmq_msg_t *msg)
#define ZMQ_EVENT_ACCEPTED
static int get_monitor_event(void *monitor, int *value, char **address)
ZMQ_EXPORT int zmq_bind(void *s, const char *addr)
ZMQ_EXPORT int zmq_ctx_term(void *context)
ZMQ_EXPORT size_t zmq_msg_size(zmq_msg_t *msg)
#define ZMQ_HANDSHAKE_IVL
ZMQ_EXPORT int zmq_msg_init(zmq_msg_t *msg)