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/10/16 17:42:52 UTC
svn commit: r1709046 - in
/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/transport:
NetworkConnectionScheduler.java NonBlockingConnection.java
Author: rgodfrey
Date: Fri Oct 16 15:42:51 2015
New Revision: 1709046
URL: http://svn.apache.org/viewvc?rev=1709046&view=rev
Log:
QPID-6797 : Calculate the connection thread name once, rather than on every invocation
Modified:
qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/transport/NetworkConnectionScheduler.java
qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/transport/NetworkConnectionScheduler.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/transport/NetworkConnectionScheduler.java?rev=1709046&r1=1709045&r2=1709046&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/transport/NetworkConnectionScheduler.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/transport/NetworkConnectionScheduler.java Fri Oct 16 15:42:51 2015
@@ -102,8 +102,7 @@ public class NetworkConnectionScheduler
void processConnection(final NonBlockingConnection connection)
{
- Thread.currentThread().setName(
- SelectorThread.IO_THREAD_NAME_PREFIX + connection.getRemoteAddress().toString());
+ Thread.currentThread().setName( connection.getThreadName() );
try
{
_running.incrementAndGet();
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java?rev=1709046&r1=1709045&r2=1709046&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java Fri Oct 16 15:42:51 2015
@@ -67,6 +67,7 @@ public class NonBlockingConnection imple
private final AmqpPort _port;
private final AtomicBoolean _scheduled = new AtomicBoolean();
private volatile boolean _unexpectedByteBufferSizeReported;
+ private final String _threadName;
public NonBlockingConnection(SocketChannel socketChannel,
ProtocolEngine protocolEngine,
@@ -83,6 +84,7 @@ public class NonBlockingConnection imple
_remoteSocketAddress = _socketChannel.socket().getRemoteSocketAddress().toString();
_port = port;
+ _threadName = SelectorThread.IO_THREAD_NAME_PREFIX + _remoteSocketAddress.toString();
protocolEngine.setWorkListener(new Action<ProtocolEngine>()
{
@@ -104,6 +106,11 @@ public class NonBlockingConnection imple
}
+ String getThreadName()
+ {
+ return _threadName;
+ }
+
public boolean isPartialRead()
{
return _partialRead;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org