svn commit: r1709046 - in /qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/transport: NetworkConnectionScheduler.java NonBlockingConnection.java

[rgodfrey]

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-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org