summaryrefslogtreecommitdiff
path: root/qpid/cpp
diff options
context:
space:
mode:
authorAndrew Stitcher <astitcher@apache.org>2009-06-11 14:24:43 +0000
committerAndrew Stitcher <astitcher@apache.org>2009-06-11 14:24:43 +0000
commit91f06a93d86eff2a597347dc2f15b2431eb0feae (patch)
tree8b6e70535c5e581759e3474534363981ae9a8b36 /qpid/cpp
parent6835c57ff0fcb1ad662f3bedd5e67a59fa9a1e50 (diff)
downloadqpid-python-91f06a93d86eff2a597347dc2f15b2431eb0feae.tar.gz
Avoid the case where we can receive bytes from the socket
after the heartbeat timer has disconnected it git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@783792 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp')
-rw-r--r--qpid/cpp/src/qpid/sys/AsynchIOHandler.cpp1
1 files changed, 1 insertions, 0 deletions
diff --git a/qpid/cpp/src/qpid/sys/AsynchIOHandler.cpp b/qpid/cpp/src/qpid/sys/AsynchIOHandler.cpp
index 9da4a68381..03543dc239 100644
--- a/qpid/cpp/src/qpid/sys/AsynchIOHandler.cpp
+++ b/qpid/cpp/src/qpid/sys/AsynchIOHandler.cpp
@@ -165,6 +165,7 @@ bool AsynchIOHandler::readbuff(AsynchIO& , AsynchIO::BufferBase* buff) {
void AsynchIOHandler::eof(AsynchIO&) {
QPID_LOG(debug, "DISCONNECTED [" << identifier << "]");
if (codec) codec->closed();
+ readError = true;
aio->queueWriteClose();
}