summaryrefslogtreecommitdiff
path: root/src/fq.cpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@250bpm.com>2011-05-15 13:12:09 +0200
committerMartin Sustrik <sustrik@250bpm.com>2011-05-15 13:12:09 +0200
commit49df2f416cd43e9e18f3dbd964271c5cca835729 (patch)
tree815d659e54170a47fd812bc55bbda6b9f0ec7581 /src/fq.cpp
parent49387874efe790713f4a090e03a97212f4889163 (diff)
Fixes warning when compiling with MSVC on Win64
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
Diffstat (limited to 'src/fq.cpp')
-rw-r--r--src/fq.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/fq.cpp b/src/fq.cpp
index ef68016..392e554 100644
--- a/src/fq.cpp
+++ b/src/fq.cpp
@@ -81,7 +81,7 @@ void zmq::fq_t::terminate ()
zmq_assert (!terminating);
terminating = true;
- sink->register_term_acks (pipes.size ());
+ sink->register_term_acks ((int) pipes.size ());
for (pipes_t::size_type i = 0; i != pipes.size (); i++)
pipes [i]->terminate ();
}
@@ -100,7 +100,7 @@ int zmq::fq_t::recv (msg_t *msg_, int flags_)
errno_assert (rc == 0);
// Round-robin over the pipes to get the next message.
- for (int count = active; count != 0; count--) {
+ for (pipes_t::size_type count = active; count != 0; count--) {
// Try to fetch new message. If we've already read part of the message
// subsequent part should be immediately available.
@@ -149,7 +149,7 @@ bool zmq::fq_t::has_in ()
// queueing algorithm. If there are no messages available current will
// get back to its original value. Otherwise it'll point to the first
// pipe holding messages, skipping only pipes with no messages available.
- for (int count = active; count != 0; count--) {
+ for (pipes_t::size_type count = active; count != 0; count--) {
if (pipes [current]->check_read ())
return true;