30 #include "../include/zmq.h" 35 int main (
int argc,
char *argv [])
37 const char *connect_to;
47 printf (
"usage: remote_thr <connect-to> <message-size> " 51 connect_to = argv [1];
52 message_size = atoi (argv [2]);
53 message_count = atoi (argv [3]);
57 printf (
"error in zmq_init: %s\n",
zmq_strerror (errno));
63 printf (
"error in zmq_socket: %s\n",
zmq_strerror (errno));
72 printf (
"error in zmq_connect: %s\n",
zmq_strerror (errno));
79 printf (
"error in zmq_msg_init_size: %s\n",
zmq_strerror (errno));
84 printf (
"error in zmq_sendmsg: %s\n",
zmq_strerror (errno));
89 printf (
"error in zmq_msg_close: %s\n",
zmq_strerror (errno));
96 printf (
"error in zmq_close: %s\n",
zmq_strerror (errno));
102 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 void * zmq_socket(void *, int type)
ZMQ_EXPORT int zmq_connect(void *s, const char *addr)
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 int zmq_ctx_term(void *context)
ZMQ_EXPORT int zmq_msg_close(zmq_msg_t *msg)
int main(int argc, char *argv[])
ZMQ_EXPORT int zmq_msg_init_size(zmq_msg_t *msg, size_t size)