summaryrefslogtreecommitdiff
path: root/cpp
diff options
context:
space:
mode:
authorAndrew Stitcher <astitcher@apache.org>2010-01-22 21:24:52 +0000
committerAndrew Stitcher <astitcher@apache.org>2010-01-22 21:24:52 +0000
commit1b489dec1ea09cde9365602befb49eb958a62cdd (patch)
treef429ff95bf9f2a82f6bdf0455bfba1b468b35489 /cpp
parent20dba34f5764cde62d64241ff47cd5ee8a239cd9 (diff)
downloadqpid-python-1b489dec1ea09cde9365602befb49eb958a62cdd.tar.gz
If we've already closed Connection don't attempt to write to it
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@902278 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp')
-rw-r--r--cpp/src/qpid/client/TCPConnector.cpp4
1 files changed, 4 insertions, 0 deletions
diff --git a/cpp/src/qpid/client/TCPConnector.cpp b/cpp/src/qpid/client/TCPConnector.cpp
index 360d8c133c..00584d168e 100644
--- a/cpp/src/qpid/client/TCPConnector.cpp
+++ b/cpp/src/qpid/client/TCPConnector.cpp
@@ -200,6 +200,10 @@ void TCPConnector::handleClosed() {
void TCPConnector::writebuff(AsynchIO& /*aio*/)
{
+ // It's possible to be disconnected and be writable
+ if (closed)
+ return;
+
Codec* codec = securityLayer.get() ? (Codec*) securityLayer.get() : (Codec*) this;
if (codec->canEncode()) {
std::auto_ptr<AsynchIO::BufferBase> buffer = std::auto_ptr<AsynchIO::BufferBase>(aio->getQueuedBuffer());