summaryrefslogtreecommitdiff
path: root/cpp
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
commitc0ad16ca52695728e9912b908f84daf43395955d (patch)
treec3f630eed299fbf88044ff884d989c7f6b122de6 /cpp
parentfcc0a72b43e05ff5c975d305771ed902d7963550 (diff)
downloadqpid-python-c0ad16ca52695728e9912b908f84daf43395955d.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')
-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() {