From 770d0bc77cd1579a1cba33ba1eb3f06839c28c16 Mon Sep 17 00:00:00 2001 From: Martin Sustrik Date: Thu, 23 Jun 2011 08:51:48 +0200 Subject: Fix MSVC build Signed-off-by: Martin Sustrik --- src/dist.cpp | 3 ++- src/fq.cpp | 3 ++- src/lb.cpp | 5 +++-- src/pipe.cpp | 2 +- src/random.cpp | 1 + src/rep.cpp | 2 +- src/req.cpp | 2 +- src/router.cpp | 6 +++--- src/session.cpp | 3 ++- src/socket_base.cpp | 6 +++--- src/xpub.cpp | 3 ++- src/xrep.cpp | 6 +++--- src/xsub.cpp | 5 +++-- 13 files changed, 27 insertions(+), 20 deletions(-) (limited to 'src') diff --git a/src/dist.cpp b/src/dist.cpp index 6b95b2e..e088e5e 100644 --- a/src/dist.cpp +++ b/src/dist.cpp @@ -111,7 +111,8 @@ int zmq::dist_t::send_to_all (msg_t *msg_, int flags_) int zmq::dist_t::send_to_matching (msg_t *msg_, int flags_) { // Is this end of a multipart message? - bool msg_more = msg_->flags () & (msg_t::more | msg_t::label); + bool msg_more = + msg_->flags () & (msg_t::more | msg_t::label) ? true : false; // Push the message to matching pipes. distribute (msg_, flags_); diff --git a/src/fq.cpp b/src/fq.cpp index 1a2a0c0..abd4160 100644 --- a/src/fq.cpp +++ b/src/fq.cpp @@ -90,7 +90,8 @@ int zmq::fq_t::recvpipe (msg_t *msg_, int flags_, pipe_t **pipe_) if (fetched) { if (pipe_) *pipe_ = pipes [current]; - more = msg_->flags () & (msg_t::more | msg_t::label); + more = + msg_->flags () & (msg_t::more | msg_t::label) ? true : false; if (!more) { current++; if (current >= active) diff --git a/src/lb.cpp b/src/lb.cpp index 6101c69..da7cb9d 100644 --- a/src/lb.cpp +++ b/src/lb.cpp @@ -75,7 +75,7 @@ int zmq::lb_t::send (msg_t *msg_, int flags_) // switch back to non-dropping mode. if (dropping) { - more = msg_->flags () & (msg_t::more | msg_t::label); + more = msg_->flags () & (msg_t::more | msg_t::label) ? true : false; if (!more) dropping = false; @@ -88,7 +88,8 @@ int zmq::lb_t::send (msg_t *msg_, int flags_) while (active > 0) { if (pipes [current]->write (msg_)) { - more = msg_->flags () & (msg_t::more | msg_t::label); + more = + msg_->flags () & (msg_t::more | msg_t::label) ? true : false; break; } diff --git a/src/pipe.cpp b/src/pipe.cpp index c290bae..c52deb9 100644 --- a/src/pipe.cpp +++ b/src/pipe.cpp @@ -165,7 +165,7 @@ bool zmq::pipe_t::write (msg_t *msg_) if (unlikely (!check_write (msg_))) return false; - bool more = msg_->flags () & (msg_t::more | msg_t::label); + bool more = msg_->flags () & (msg_t::more | msg_t::label) ? true : false; outpipe->write (*msg_, more); if (!more) msgs_written++; diff --git a/src/random.cpp b/src/random.cpp index ee7a7fb..2a1d7d6 100644 --- a/src/random.cpp +++ b/src/random.cpp @@ -19,6 +19,7 @@ */ #include "random.hpp" +#include "stdint.hpp" #include "uuid.hpp" #include "err.hpp" diff --git a/src/rep.cpp b/src/rep.cpp index a5d1462..ee67186 100644 --- a/src/rep.cpp +++ b/src/rep.cpp @@ -42,7 +42,7 @@ int zmq::rep_t::xsend (msg_t *msg_, int flags_) return -1; } - bool more = msg_->flags () & (msg_t::more | msg_t::label); + bool more = msg_->flags () & (msg_t::more | msg_t::label) ? true : false; // Push message to the reply pipe. int rc = xrep_t::xsend (msg_, flags_); diff --git a/src/req.cpp b/src/req.cpp index e51b853..e0e3321 100644 --- a/src/req.cpp +++ b/src/req.cpp @@ -65,7 +65,7 @@ int zmq::req_t::xsend (msg_t *msg_, int flags_) message_begins = false; } - bool more = msg_->flags () & (msg_t::more | msg_t::label); + bool more = msg_->flags () & (msg_t::more | msg_t::label) ? true : false; int rc = xreq_t::xsend (msg_, flags_); if (rc != 0) diff --git a/src/router.cpp b/src/router.cpp index 2a19068..0d1b77e 100644 --- a/src/router.cpp +++ b/src/router.cpp @@ -159,7 +159,7 @@ int zmq::router_t::xsend (msg_t *msg_, int flags_) } // Check whether this is the last part of the message. - more_out = msg_->flags () & (msg_t::more | msg_t::label); + more_out = msg_->flags () & (msg_t::more | msg_t::label) ? true : false; // Push the message into the pipe. If there's no out pipe, just drop it. if (current_out) { @@ -188,7 +188,7 @@ int zmq::router_t::xrecv (msg_t *msg_, int flags_) if (prefetched) { int rc = msg_->move (prefetched_msg); errno_assert (rc == 0); - more_in = msg_->flags () & (msg_t::more | msg_t::label); + more_in = msg_->flags () & (msg_t::more | msg_t::label) ? true : false; prefetched = false; return 0; } @@ -202,7 +202,7 @@ int zmq::router_t::xrecv (msg_t *msg_, int flags_) zmq_assert (inpipes [current_in].active); bool fetched = inpipes [current_in].pipe->read (msg_); zmq_assert (fetched); - more_in = msg_->flags () & (msg_t::more | msg_t::label); + more_in = msg_->flags () & (msg_t::more | msg_t::label) ? true : false; if (!more_in) { current_in++; if (current_in >= inpipes.size ()) diff --git a/src/session.cpp b/src/session.cpp index 9286054..1ca69cf 100644 --- a/src/session.cpp +++ b/src/session.cpp @@ -71,7 +71,8 @@ bool zmq::session_t::read (msg_t *msg_) if (!pipe->read (msg_)) return false; - incomplete_in = msg_->flags () & (msg_t::more | msg_t::label); + incomplete_in = + msg_->flags () & (msg_t::more | msg_t::label) ? true : false; return true; } diff --git a/src/socket_base.cpp b/src/socket_base.cpp index 74a345b..6541661 100644 --- a/src/socket_base.cpp +++ b/src/socket_base.cpp @@ -582,7 +582,7 @@ int zmq::socket_base_t::recv (msg_t *msg_, int flags_) rcvlabel = msg_->flags () & msg_t::label; if (rcvlabel) msg_->reset_flags (msg_t::label); - rcvmore = msg_->flags () & msg_t::more; + rcvmore = msg_->flags () & msg_t::more ? true : false; if (rcvmore) msg_->reset_flags (msg_t::more); return 0; @@ -603,7 +603,7 @@ int zmq::socket_base_t::recv (msg_t *msg_, int flags_) rcvlabel = msg_->flags () & msg_t::label; if (rcvlabel) msg_->reset_flags (msg_t::label); - rcvmore = msg_->flags () & msg_t::more; + rcvmore = msg_->flags () & msg_t::more ? true : false; if (rcvmore) msg_->reset_flags (msg_t::more); return 0; @@ -642,7 +642,7 @@ int zmq::socket_base_t::recv (msg_t *msg_, int flags_) rcvlabel = msg_->flags () & msg_t::label; if (rcvlabel) msg_->reset_flags (msg_t::label); - rcvmore = msg_->flags () & msg_t::more; + rcvmore = msg_->flags () & msg_t::more ? true : false; if (rcvmore) msg_->reset_flags (msg_t::more); return 0; diff --git a/src/xpub.cpp b/src/xpub.cpp index f4fe7a1..7e4eecc 100644 --- a/src/xpub.cpp +++ b/src/xpub.cpp @@ -100,7 +100,8 @@ void zmq::xpub_t::mark_as_matching (pipe_t *pipe_, void *arg_) int zmq::xpub_t::xsend (msg_t *msg_, int flags_) { - bool msg_more = msg_->flags () & (msg_t::more | msg_t::label); + bool msg_more = + msg_->flags () & (msg_t::more | msg_t::label) ? true : false; // For the first part of multi-part message, find the matching pipes. if (!more) diff --git a/src/xrep.cpp b/src/xrep.cpp index fe9ab52..5d111f8 100644 --- a/src/xrep.cpp +++ b/src/xrep.cpp @@ -163,7 +163,7 @@ int zmq::xrep_t::xsend (msg_t *msg_, int flags_) } // Check whether this is the last part of the message. - more_out = msg_->flags () & (msg_t::more | msg_t::label); + more_out = msg_->flags () & (msg_t::more | msg_t::label) ? true : false; // Push the message into the pipe. If there's no out pipe, just drop it. if (current_out) { @@ -192,7 +192,7 @@ int zmq::xrep_t::xrecv (msg_t *msg_, int flags_) if (prefetched) { int rc = msg_->move (prefetched_msg); errno_assert (rc == 0); - more_in = msg_->flags () & (msg_t::more | msg_t::label); + more_in = msg_->flags () & (msg_t::more | msg_t::label) ? true : false; prefetched = false; return 0; } @@ -205,7 +205,7 @@ int zmq::xrep_t::xrecv (msg_t *msg_, int flags_) // If we are in the middle of reading a message, just return the next part. if (more_in) { - more_in = msg_->flags () & (msg_t::more | msg_t::label); + more_in = msg_->flags () & (msg_t::more | msg_t::label) ? true : false; return 0; } diff --git a/src/xsub.cpp b/src/xsub.cpp index bfe12a3..98abc87 100644 --- a/src/xsub.cpp +++ b/src/xsub.cpp @@ -116,7 +116,7 @@ int zmq::xsub_t::xrecv (msg_t *msg_, int flags_) int rc = msg_->move (message); errno_assert (rc == 0); has_message = false; - more = msg_->flags () & (msg_t::more | msg_t::label); + more = msg_->flags () & (msg_t::more | msg_t::label) ? true : false; return 0; } @@ -136,7 +136,8 @@ int zmq::xsub_t::xrecv (msg_t *msg_, int flags_) // Check whether the message matches at least one subscription. // Non-initial parts of the message are passed if (more || !options.filter || match (msg_)) { - more = msg_->flags () & (msg_t::more | msg_t::label); + more = + msg_->flags () & (msg_t::more | msg_t::label) ? true : false; return 0; } -- cgit v1.2.3