You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rg...@apache.org on 2015/03/06 21:50:35 UTC
svn commit: r1664714 -
/qpid/trunk/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/ConnectionEndpoint.java
Author: rgodfrey
Date: Fri Mar 6 20:50:35 2015
New Revision: 1664714
URL: http://svn.apache.org/r1664714
Log:
QPID-6437 : ensure no locks are held when link endpoint listeners are notified
Modified:
qpid/trunk/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/ConnectionEndpoint.java
Modified: qpid/trunk/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/ConnectionEndpoint.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/ConnectionEndpoint.java?rev=1664714&r1=1664713&r2=1664714&view=diff
==============================================================================
--- qpid/trunk/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/ConnectionEndpoint.java (original)
+++ qpid/trunk/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/ConnectionEndpoint.java Fri Mar 6 20:50:35 2015
@@ -663,9 +663,14 @@ public class ConnectionEndpoint implemen
}
}
- public synchronized void receiveFlow(short channel, Flow flow)
+ public void receiveFlow(short channel, Flow flow)
{
- SessionEndpoint endPoint = getSession(channel);
+ SessionEndpoint endPoint;
+ synchronized (this)
+ {
+ endPoint = getSession(channel);
+ }
+
if (endPoint != null)
{
endPoint.receiveFlow(flow);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org