summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--doc/zmq_poll.txt2
-rw-r--r--src/zmq.cpp12
2 files changed, 7 insertions, 7 deletions
diff --git a/doc/zmq_poll.txt b/doc/zmq_poll.txt
index 9e3ecf7..72dcb4d 100644
--- a/doc/zmq_poll.txt
+++ b/doc/zmq_poll.txt
@@ -41,7 +41,7 @@ member, and then indicate any requested events that have occurred by setting the
bit corresponding to the event condition in the 'revents' member.
If none of the requested events have occurred on any *zmq_pollitem_t* item,
-_zmq_poll()_ shall wait 'timeout' microseconds for an event to occur on
+_zmq_poll()_ shall wait 'timeout' milliseconds for an event to occur on
any of the requested items. If the value of 'timeout' is `0`, _zmq_poll()_
shall return immediately. If the value of 'timeout' is `-1`, _zmq_poll()_ shall
block indefinitely until a requested event has occurred on at least one
diff --git a/src/zmq.cpp b/src/zmq.cpp
index 929e51c..5029734 100644
--- a/src/zmq.cpp
+++ b/src/zmq.cpp
@@ -387,10 +387,10 @@ int zmq_poll (zmq_pollitem_t *items_, int nitems_, long timeout_)
if (timeout_ == 0)
return 0;
#if defined ZMQ_HAVE_WINDOWS
- Sleep (timeout_ > 0 ? timeout_ / 1000 : INFINITE);
+ Sleep (timeout_ > 0 ? timeout_ : INFINITE);
return 0;
#else
- return usleep (timeout_);
+ return usleep (timeout_ * 1000);
#endif
}
@@ -514,7 +514,7 @@ int zmq_poll (zmq_pollitem_t *items_, int nitems_, long timeout_)
// when the polling should time out.
if (first_pass) {
now = clock.now_ms ();
- end = now + (timeout_ / 1000);
+ end = now + timeout_;
if (now == end)
break;
first_pass = false;
@@ -540,10 +540,10 @@ int zmq_poll (zmq_pollitem_t *items_, int nitems_, long timeout_)
if (timeout_ == 0)
return 0;
#if defined ZMQ_HAVE_WINDOWS
- Sleep (timeout_ > 0 ? timeout_ / 1000 : INFINITE);
+ Sleep (timeout_ > 0 ? timeout_ : INFINITE);
return 0;
#else
- return usleep (timeout_);
+ return usleep (timeout_ * 1000);
#endif
}
@@ -695,7 +695,7 @@ int zmq_poll (zmq_pollitem_t *items_, int nitems_, long timeout_)
// when the polling should time out.
if (first_pass) {
now = clock.now_ms ();
- end = now + (timeout_ / 1000);
+ end = now + timeout_;
if (now == end)
break;
first_pass = false;