30 #include "../include/zmq.h" 34 int main (
int argc,
char *argv [])
46 printf (
"usage: local_lat <bind-to> <message-size> " 47 "<roundtrip-count>\n");
51 message_size = atoi (argv [2]);
52 roundtrip_count = atoi (argv [3]);
56 printf (
"error in zmq_init: %s\n",
zmq_strerror (errno));
62 printf (
"error in zmq_socket: %s\n",
zmq_strerror (errno));
68 printf (
"error in zmq_bind: %s\n",
zmq_strerror (errno));
74 printf (
"error in zmq_msg_init: %s\n",
zmq_strerror (errno));
81 printf (
"error in zmq_recvmsg: %s\n",
zmq_strerror (errno));
85 printf (
"message of incorrect size received\n");
90 printf (
"error in zmq_sendmsg: %s\n",
zmq_strerror (errno));
97 printf (
"error in zmq_msg_close: %s\n",
zmq_strerror (errno));
105 printf (
"error in zmq_close: %s\n",
zmq_strerror (errno));
111 printf (
"error in zmq_ctx_term: %s\n",
zmq_strerror (errno));
static size_t message_size
ZMQ_EXPORT void * zmq_init(int io_threads)
ZMQ_EXPORT int zmq_recvmsg(void *s, zmq_msg_t *msg, int flags)
ZMQ_EXPORT void * zmq_socket(void *, int type)
int main(int argc, char *argv[])
ZMQ_EXPORT int zmq_close(void *s)
ZMQ_EXPORT int zmq_sendmsg(void *s, zmq_msg_t *msg, int flags)
ZMQ_EXPORT const char * zmq_strerror(int errnum)
ZMQ_EXPORT void zmq_sleep(int seconds_)
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 size_t zmq_msg_size(zmq_msg_t *msg)
ZMQ_EXPORT int zmq_msg_init(zmq_msg_t *msg)
static int roundtrip_count