activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r547256 - in /activemq/activemq-cpp/trunk/src/decaf/src/main/decaf/net: SocketInputStream.cpp SocketOutputStream.cpp
Date Thu, 14 Jun 2007 14:34:28 GMT
Author: tabish
Date: Thu Jun 14 07:34:27 2007
New Revision: 547256

URL: http://svn.apache.org/viewvc?view=rev&rev=547256
Log:
http://issues.apache.org/activemq/browse/AMQCPP-103

Building Decaf lib

Modified:
    activemq/activemq-cpp/trunk/src/decaf/src/main/decaf/net/SocketInputStream.cpp
    activemq/activemq-cpp/trunk/src/decaf/src/main/decaf/net/SocketOutputStream.cpp

Modified: activemq/activemq-cpp/trunk/src/decaf/src/main/decaf/net/SocketInputStream.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/decaf/src/main/decaf/net/SocketInputStream.cpp?view=diff&rev=547256&r1=547255&r2=547256
==============================================================================
--- activemq/activemq-cpp/trunk/src/decaf/src/main/decaf/net/SocketInputStream.cpp (original)
+++ activemq/activemq-cpp/trunk/src/decaf/src/main/decaf/net/SocketInputStream.cpp Thu Jun
14 07:34:27 2007
@@ -146,7 +146,7 @@
         len = ::recv(socket, (char*)buffer, (int)bufferSize, 0);
 
         // Check for a closed socket.
-        if( len == 0 && !closed ){
+        if( len == 0 && closed ){
             throw IOException( __FILE__, __LINE__,
                 "activemq::io::SocketInputStream::read - The connection is broken" );
         }
@@ -155,7 +155,7 @@
              SocketError::getErrorCode() == SocketError::INTERRUPTED );
 
     // Check for error.
-    if( len == -1 && !closed ){
+    if( len == -1 ){
 
         // Otherwise, this was a bad error - throw an exception.
         throw IOException( __FILE__, __LINE__,

Modified: activemq/activemq-cpp/trunk/src/decaf/src/main/decaf/net/SocketOutputStream.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/decaf/src/main/decaf/net/SocketOutputStream.cpp?view=diff&rev=547256&r1=547255&r2=547256
==============================================================================
--- activemq/activemq-cpp/trunk/src/decaf/src/main/decaf/net/SocketOutputStream.cpp (original)
+++ activemq/activemq-cpp/trunk/src/decaf/src/main/decaf/net/SocketOutputStream.cpp Thu Jun
14 07:34:27 2007
@@ -78,7 +78,7 @@
     while( remaining > 0 && !closed )
     {
         int length = ::send( socket, (const char*)buffer, (int)remaining, sendOpts );
-        if( length == -1 && !closed ){
+        if( length == -1 && closed ){
             throw IOException( __FILE__, __LINE__,
                 "activemq::io::SocketOutputStream::write - %s", SocketError::getErrorString().c_str()
);
         }



Mime
View raw message