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/04 22:46:37 UTC
svn commit: r1664160 -
/qpid/trunk/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/SessionEndpoint.java
Author: rgodfrey
Date: Wed Mar 4 21:46:36 2015
New Revision: 1664160
URL: http://svn.apache.org/r1664160
Log:
QPID-6433 : notify link listeners of flow state change outside of the connection endpoint lock
Modified:
qpid/trunk/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/SessionEndpoint.java
Modified: qpid/trunk/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/SessionEndpoint.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/SessionEndpoint.java?rev=1664160&r1=1664159&r2=1664160&view=diff
==============================================================================
--- qpid/trunk/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/SessionEndpoint.java (original)
+++ qpid/trunk/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/SessionEndpoint.java Wed Mar 4 21:46:36 2015
@@ -456,7 +456,7 @@ public class SessionEndpoint
public void receiveFlow(final Flow flow)
{
-
+ Collection<LinkEndpoint> endpoints = new ArrayList<>();
synchronized(getLock())
{
UnsignedInteger handle = flow.getHandle();
@@ -472,15 +472,17 @@ public class SessionEndpoint
}
else
{
- for(LinkEndpoint le : _remoteLinkEndpoints.values())
- {
- le.flowStateChanged();
- }
+ endpoints.addAll(_remoteLinkEndpoints.values());
}
getLock().notifyAll();
}
+ for(LinkEndpoint le : endpoints)
+ {
+ le.flowStateChanged();
+ }
+
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org