33 #define ZMQ_PREPARE_STRING(msg, data, size) \ 34 zmq_msg_init(&msg) && printf("zmq_msg_init: %s\n", zmq_strerror(errno)); \ 35 zmq_msg_init_size (&msg, size + 1) && printf("zmq_msg_init_size: %s\n",zmq_strerror(errno)); \ 36 memcpy(zmq_msg_data(&msg), data, size + 1); 53 zmq_bind(pubSocket,
"inproc://someInProcDescriptor") && printf(
"zmq_bind: %s\n",
zmq_strerror(errno));
57 size_t more_size =
sizeof(more);
79 assert(!isSubscribed);
91 if (items[0].revents & ZMQ_POLLIN) {
100 publicationsReceived++;
105 if (iteration == 1) {
109 if (iteration == 4) {
112 if (iteration > 4 && rc == 0)
127 assert(publicationsReceived == 3);
128 assert(!isSubscribed);
void msleep(int milliseconds)
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)
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)
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)
ZMQ_EXPORT int zmq_msg_recv(zmq_msg_t *msg, void *s, int flags)
ZMQ_EXPORT const char * zmq_strerror(int errnum)
ZMQ_EXPORT int zmq_poll(zmq_pollitem_t *items, int nitems, long timeout)
ZMQ_EXPORT int zmq_bind(void *s, const char *addr)
#define ZMQ_PREPARE_STRING(msg, data, size)
Initialize a zeromq message with a given null-terminated string.
ZMQ_EXPORT int zmq_ctx_term(void *context)
ZMQ_EXPORT int zmq_msg_close(zmq_msg_t *msg)
ZMQ_EXPORT int zmq_disconnect(void *s, const char *addr)
ZMQ_EXPORT int zmq_msg_init(zmq_msg_t *msg)
static int publicationsReceived