35 uint8_t metadata [] = {
36 5,
'H',
'e',
'l',
'l',
'o',
37 0, 0, 0, 5,
'W',
'o',
'r',
'l',
'd' 42 char *version =
s_recv (handler);
46 char *sequence =
s_recv (handler);
47 char *domain =
s_recv (handler);
49 char *identity =
s_recv (handler);
50 char *mechanism =
s_recv (handler);
52 assert (
streq (version,
"1.0"));
53 assert (
streq (mechanism,
"NULL"));
57 if (
streq (domain,
"DOMAIN")) {
61 zmq_send (handler, metadata,
sizeof (metadata), 0);
90 int rc =
zmq_bind (handler,
"inproc://zeromq.zap.01");
100 rc =
zmq_bind (server,
"tcp://127.0.0.1:9001");
105 s_send (client,
"This is a message");
ZMQ_EXPORT int zmq_setsockopt(void *s, int option, const void *optval, size_t optvallen)
int s_sendmore(void *socket, const char *string)
ZMQ_EXPORT void * zmq_ctx_new(void)
void setup_test_environment(void)
ZMQ_EXPORT int zmq_errno(void)
void handler(int timer_id, void *arg)
ZMQ_EXPORT void * zmq_socket(void *, int type)
ZMQ_EXPORT void zmq_threadclose(void *thread)
ZMQ_EXPORT int zmq_connect(void *s, const char *addr)
ZMQ_EXPORT int zmq_msg_recv(zmq_msg_t *msg, void *s, int flags)
char * s_recv(void *socket)
ZMQ_EXPORT const char * zmq_msg_gets(zmq_msg_t *msg, const char *property)
ZMQ_EXPORT int zmq_send(void *s, const void *buf, size_t len, int flags)
void close_zero_linger(void *socket)
ZMQ_EXPORT int zmq_bind(void *s, const char *addr)
ZMQ_EXPORT int zmq_ctx_term(void *context)
int s_send(void *socket, const char *string)
ZMQ_EXPORT int zmq_msg_close(zmq_msg_t *msg)
ZMQ_EXPORT void * zmq_threadstart(zmq_thread_fn *func, void *arg)
ZMQ_EXPORT int zmq_msg_init(zmq_msg_t *msg)