30 #include "../include/zmq.h" 34 int main (
int argc,
char *argv [])
45 unsigned long elapsed;
46 unsigned long throughput;
50 printf (
"usage: local_thr <bind-to> <message-size> <message-count>\n");
54 message_size = atoi (argv [2]);
55 message_count = atoi (argv [3]);
59 printf (
"error in zmq_init: %s\n",
zmq_strerror (errno));
65 printf (
"error in zmq_socket: %s\n",
zmq_strerror (errno));
74 printf (
"error in zmq_bind: %s\n",
zmq_strerror (errno));
80 printf (
"error in zmq_msg_init: %s\n",
zmq_strerror (errno));
86 printf (
"error in zmq_recvmsg: %s\n",
zmq_strerror (errno));
90 printf (
"message of incorrect size received\n");
96 for (i = 0; i != message_count - 1; i++) {
99 printf (
"error in zmq_recvmsg: %s\n",
zmq_strerror (errno));
103 printf (
"message of incorrect size received\n");
114 printf (
"error in zmq_msg_close: %s\n",
zmq_strerror (errno));
118 throughput = (
unsigned long)
119 ((
double) message_count / (double) elapsed * 1000000);
120 megabits = ((double) throughput * message_size * 8) / 1000000;
122 printf (
"message size: %d [B]\n", (
int) message_size);
123 printf (
"message count: %d\n", (
int) message_count);
124 printf (
"mean throughput: %d [msg/s]\n", (
int) throughput);
125 printf (
"mean throughput: %.3f [Mb/s]\n", (
double) megabits);
129 printf (
"error in zmq_close: %s\n",
zmq_strerror (errno));
135 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 unsigned long zmq_stopwatch_stop(void *watch_)
ZMQ_EXPORT void * zmq_socket(void *, int type)
ZMQ_EXPORT int zmq_close(void *s)
ZMQ_EXPORT const char * zmq_strerror(int errnum)
ZMQ_EXPORT int zmq_bind(void *s, const char *addr)
int main(int argc, char *argv[])
ZMQ_EXPORT int zmq_ctx_term(void *context)
ZMQ_EXPORT void * zmq_stopwatch_start(void)
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)