svn commit: r637828 - /incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/transport/TransportConnection.java

[ritchiem]

Author: ritchiem
Date: Mon Mar 17 03:36:13 2008
New Revision: 637828

URL: http://svn.apache.org/viewvc?rev=637828&view=rev
Log:
QPID-856 : Moved unbind out of the synchronized block as it doesn't need to be 
done there.

Modified:
    
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/transport/TransportConnection.java

Modified: 
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/transport/TransportConnection.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/transport/TransportConnection.java?rev=637828&r1=637827&r2=637828&view=diff
==============================================================================
--- 
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/transport/TransportConnection.java
 (original)
+++ 
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/transport/TransportConnection.java
 Mon Mar 17 03:36:13 2008
@@ -332,15 +332,20 @@
 
     public static void killVMBroker(int port)
     {
+        VmPipeAddress pipe;
         synchronized (_inVmPipeAddress)
         {
-            VmPipeAddress pipe = (VmPipeAddress) _inVmPipeAddress.get(port);
+            pipe = (VmPipeAddress) _inVmPipeAddress.get(port);
             if (pipe != null)
             {
                 _logger.info("Killing VM Broker:" + port);
                 _inVmPipeAddress.remove(port);
-                _acceptor.unbind(pipe);
             }
+        }
+        //This doesn't need to be sychronized
+        if (pipe != null)
+        {
+            _acceptor.unbind(pipe);
         }
     }