summaryrefslogtreecommitdiff
path: root/cpp/src
diff options
context:
space:
mode:
authorMichael Goulish <mgoulish@apache.org>2010-03-17 05:52:12 +0000
committerMichael Goulish <mgoulish@apache.org>2010-03-17 05:52:12 +0000
commit06015c91dd9037d102f9feeea76c81561b82002e (patch)
treec3f630eed299fbf88044ff884d989c7f6b122de6 /cpp/src
parenta821ed09ad5d11860c8d502e7175173b51b0fe09 (diff)
downloadqpid-python-06015c91dd9037d102f9feeea76c81561b82002e.tar.gz
workaround for BZ 570168 ( see comment in code )
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@924169 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src')
-rw-r--r--cpp/src/qpid/client/TCPConnector.cpp13
1 files changed, 12 insertions, 1 deletions
diff --git a/cpp/src/qpid/client/TCPConnector.cpp b/cpp/src/qpid/client/TCPConnector.cpp
index 78c9b32069..1a245fe2c8 100644
--- a/cpp/src/qpid/client/TCPConnector.cpp
+++ b/cpp/src/qpid/client/TCPConnector.cpp
@@ -199,8 +199,19 @@ void TCPConnector::send(AMQFrame& frame) {
} else {
notifyWrite = (currentSize >= maxFrameSize);
}
- }
+ /*
+ NOTE: Moving the following line into this mutex block
+ is a workaround for BZ 570168, in which the test
+ testConcurrentSenders causes a hang about 1.5%
+ of the time. ( To see the hang much more frequently
+ leave this line out of the mutex block, and put a
+ small usleep just before it.)
+
+ TODO mgoulish - fix the underlying cause and then
+ move this call back outside the mutex.
+ */
if (notifyWrite && !closed) aio->notifyPendingWrite();
+ }
}
void TCPConnector::handleClosed() {