69 char * body = (
char*) malloc (
sizeof(
char) * (
zmq_msg_size (msg_) + 1));
73 if (strcmp (body, body_) != 0)
93 int rc =
zmq_bind (radio,
"tcp://127.0.0.1:5556");
103 too_long_group[index] =
'A';
104 too_long_group[ZMQ_GROUP_MAX_LENGTH + 1] =
'\0';
105 rc =
zmq_join (dish, too_long_group);
125 rc =
msg_send (&msg, radio,
"TV",
"Friends");
129 rc =
msg_send (&msg, radio,
"Movies",
"Godfather");
143 rc =
msg_send (&msg, radio,
"TV",
"Friends");
157 rc =
msg_send (&msg, radio,
"TV",
"Friends");
161 rc =
msg_send (&msg, radio,
"Movies",
"Godfather");
int msg_send(zmq_msg_t *msg_, void *s_, const char *group_, const char *body_)
void msleep(int milliseconds)
ZMQ_EXPORT void * zmq_ctx_new(void)
void setup_test_environment(void)
int msg_recv_cmp(zmq_msg_t *msg_, void *s_, const char *group_, const char *body_)
#define ZMQ_GROUP_MAX_LENGTH
ZMQ_EXPORT void * zmq_msg_data(zmq_msg_t *msg)
ZMQ_EXPORT void * zmq_socket(void *, int type)
ZMQ_EXPORT int zmq_msg_send(zmq_msg_t *msg, void *s, int flags)
ZMQ_EXPORT int zmq_connect(void *s, const char *addr)
int zmq_join(void *s, const char *group)
ZMQ_EXPORT int zmq_close(void *s)
ZMQ_EXPORT int zmq_msg_recv(zmq_msg_t *msg, void *s, int flags)
ZMQ_EXPORT void zmq_sleep(int seconds_)
const char * zmq_msg_group(zmq_msg_t *msg)
int zmq_leave(void *s, const char *group)
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)
int zmq_msg_set_group(zmq_msg_t *msg, const char *group)
ZMQ_EXPORT int zmq_msg_init(zmq_msg_t *msg)