42 {
CLIENT,
"i can haz cheez burger?"},
43 {
SERVER,
"y u no disonnect?"},
51 size_t more_size =
sizeof(more);
76 rc =
zmq_bind (sockets [SERVER],
"tcp://0.0.0.0:6666");
82 rc =
zmq_connect (sockets [CLIENT],
"tcp://localhost:6666");
93 assert (
has_more (sockets [SERVER]));
113 assert (
has_more (sockets [CLIENT]));
127 char blob_data [256];
128 size_t blob_size =
sizeof(blob_data);
131 assert(blob_size > 0);
142 memcpy (
zmq_msg_data (&msg), dialog [0].text, strlen(dialog [0].text));
152 while (step < steps) {
163 assert (dialog [step].turn == CLIENT);
172 assert (
has_more (sockets [SERVER]));
182 const char *
const data = (
const char*)
zmq_msg_data (&data_frame);
188 assert (step == steps);
191 assert ((
size_t) size == strlen (dialog [step].text));
192 int cmp = memcmp (dialog [step].text, data, size);
197 assert (step < steps);
203 strlen (dialog [step].text));
223 if (items [CLIENT].revents & ZMQ_POLLIN) {
224 assert (dialog [step].turn == SERVER);
233 assert (
has_more (sockets [CLIENT]));
244 const char *
const data = (
const char*)
zmq_msg_data (&data_frame);
246 assert ((
size_t)size == strlen(dialog [step].text));
247 int cmp = memcmp(dialog [step].text, data, size);
253 assert (step < steps);
273 assert (step == steps);
ZMQ_EXPORT int zmq_setsockopt(void *s, int option, const void *optval, size_t optvallen)
ZMQ_EXPORT void * zmq_ctx_new(void)
void setup_test_environment(void)
bool get_identity(void *socket, char *data, size_t *size)
#define ZMQ_STREAM_NOTIFY
ZMQ_EXPORT void * zmq_msg_data(zmq_msg_t *msg)
ZMQ_EXPORT void * zmq_socket(void *, int type)
ZMQ_EXPORT int zmq_getsockopt(void *s, int option, void *optval, size_t *optvallen)
bool has_more(void *socket)
ZMQ_EXPORT int zmq_msg_send(zmq_msg_t *msg, void *s, int flags)
ZMQ_EXPORT int zmq_connect(void *s, const char *addr)
ZMQ_EXPORT int zmq_close(void *s)
const test_message_t dialog[]
ZMQ_EXPORT int zmq_msg_recv(zmq_msg_t *msg, void *s, int flags)
ZMQ_EXPORT int zmq_poll(zmq_pollitem_t *items, int nitems, long timeout)
ZMQ_EXPORT int zmq_bind(void *s, const char *addr)
ZMQ_EXPORT int zmq_ctx_term(void *context)
ZMQ_EXPORT int zmq_msg_close(zmq_msg_t *msg)
ZMQ_EXPORT int zmq_msg_init_size(zmq_msg_t *msg, size_t size)
ZMQ_EXPORT size_t zmq_msg_size(zmq_msg_t *msg)
ZMQ_EXPORT int zmq_msg_init(zmq_msg_t *msg)