You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by lq...@apache.org on 2017/04/13 15:06:48 UTC
svn commit: r1791267 -
/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/transport/MultiVersionProtocolEngine.java
Author: lquack
Date: Thu Apr 13 15:06:48 2017
New Revision: 1791267
URL: http://svn.apache.org/viewvc?rev=1791267&view=rev
Log:
QPID-7743: [Java Broker] Propagate current IO thread when switching protocol engine
Modified:
qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/transport/MultiVersionProtocolEngine.java
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/transport/MultiVersionProtocolEngine.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/transport/MultiVersionProtocolEngine.java?rev=1791267&r1=1791266&r2=1791267&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/transport/MultiVersionProtocolEngine.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/transport/MultiVersionProtocolEngine.java Thu Apr 13 15:06:48 2017
@@ -68,6 +68,7 @@ public class MultiVersionProtocolEngine
private final Protocol _defaultSupportedReply;
private volatile ProtocolEngine _delegate = new SelfDelegateProtocolEngine();
+ private volatile Thread _ioThread;
private final AtomicReference<Action<ProtocolEngine>> _workListener = new AtomicReference<>();
private final AggregateTicker _aggregateTicker = new AggregateTicker();
@@ -132,6 +133,7 @@ public class MultiVersionProtocolEngine
@Override
public void setIOThread(final Thread ioThread)
{
+ _ioThread = ioThread;
_delegate.setIOThread(ioThread);
}
@@ -479,6 +481,7 @@ public class MultiVersionProtocolEngine
newDelegate.notifyWork();
}
_delegate = newDelegate;
+ _delegate.setIOThread(_ioThread);
_delegate.setWorkListener(_workListener.get());
_header.flip();
_delegate.received(_header);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org