From 0dd1a458772496dbdb51068b1f7456ce30d6e296 Mon Sep 17 00:00:00 2001 From: Michael Goulish Date: Wed, 17 Mar 2010 05:52:12 +0000 Subject: workaround for BZ 570168 ( see comment in code ) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@924169 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/cpp/src/qpid/client/TCPConnector.cpp | 13 ++++++++++++- 1 file changed, 12 insertions(+), 1 deletion(-) (limited to 'qpid/cpp/src') diff --git a/qpid/cpp/src/qpid/client/TCPConnector.cpp b/qpid/cpp/src/qpid/client/TCPConnector.cpp index 78c9b32069..1a245fe2c8 100644 --- a/qpid/cpp/src/qpid/client/TCPConnector.cpp +++ b/qpid/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() { -- cgit v1.2.1