You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2014/08/21 11:08:46 UTC
svn commit: r1619318 - in /qpid/trunk/qpid/cpp/src/qpid/broker/amqp:
Connection.cpp Connection.h
Author: gsim
Date: Thu Aug 21 09:08:46 2014
New Revision: 1619318
URL: http://svn.apache.org/r1619318
Log:
QPID-6021: fix compile error on windows
Modified:
qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Connection.cpp
qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Connection.h
Modified: qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Connection.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Connection.cpp?rev=1619318&r1=1619317&r2=1619318&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Connection.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Connection.cpp Thu Aug 21 09:08:46 2014
@@ -168,9 +168,9 @@ size_t Connection::encode(char* buffer,
}
}
-void Connection::doOutput(ssize_t capacity)
+void Connection::doOutput(size_t capacity)
{
- for (ssize_t n = pn_transport_pending(transport); n > 0 && n < capacity; n = pn_transport_pending(transport)) {
+ for (ssize_t n = pn_transport_pending(transport); n > 0 && n < (ssize_t) capacity; n = pn_transport_pending(transport)) {
if (dispatch()) processDeliveries();
else break;
}
Modified: qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Connection.h
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Connection.h?rev=1619318&r1=1619317&r2=1619318&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Connection.h (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Connection.h Thu Aug 21 09:08:46 2014
@@ -72,7 +72,7 @@ class Connection : public BrokerContext,
bool closeRequested;
virtual void process();
- void doOutput(ssize_t);
+ void doOutput(size_t);
bool dispatch();
void processDeliveries();
std::string getError();
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org