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 2008/08/05 14:27:30 UTC
svn commit: r682688 -
/incubator/qpid/branches/qpid.0-10/cpp/src/qpid/sys/posix/AsynchIO.cpp
Author: gsim
Date: Tue Aug 5 05:27:29 2008
New Revision: 682688
URL: http://svn.apache.org/viewvc?rev=682688&view=rev
Log:
Merged r682685: Modified error checking on TCP socket read so that it's no longer fatal
Modified:
incubator/qpid/branches/qpid.0-10/cpp/src/qpid/sys/posix/AsynchIO.cpp
Modified: incubator/qpid/branches/qpid.0-10/cpp/src/qpid/sys/posix/AsynchIO.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-10/cpp/src/qpid/sys/posix/AsynchIO.cpp?rev=682688&r1=682687&r2=682688&view=diff
==============================================================================
--- incubator/qpid/branches/qpid.0-10/cpp/src/qpid/sys/posix/AsynchIO.cpp (original)
+++ incubator/qpid/branches/qpid.0-10/cpp/src/qpid/sys/posix/AsynchIO.cpp Tue Aug 5 05:27:29 2008
@@ -300,7 +300,11 @@
// we can carry on watching for reads
break;
} else {
- QPID_POSIX_CHECK(rc);
+ // Report error then just treat as a socket disconnect
+ QPID_LOG(error, "Error reading socket: " << qpid::strError(rc) << "(" << rc << ")" );
+ eofCallback(*this);
+ h.unwatchRead();
+ break;
}
}
} else {