[jboss-remoting-commits] JBoss Remoting SVN: r6131 - remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote.

[jboss-remoting-commits at lists.jboss.org]

Author: ron.sigal at jboss.com
Date: 2010-11-11 22:34:38 -0500 (Thu, 11 Nov 2010)
New Revision: 6131

Modified:
   remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/InboundRequestTask.java
Log:
JBREM-1257: The appropriate InboundClient is retrieved by RemoteMessageHandler instead of in a separate thread running InboundRequestTask.

Modified: remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/InboundRequestTask.java
===================================================================
--- remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/InboundRequestTask.java	2010-11-12 03:29:58 UTC (rev 6130)
+++ remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/InboundRequestTask.java	2010-11-12 03:34:38 UTC (rev 6131)
@@ -35,17 +35,17 @@
 final class InboundRequestTask implements Runnable {
 
     private final InboundRequest inboundRequest;
+    private final InboundClient inboundClient;
     private final int rid;
-    private final int cid;
     private RemoteConnectionHandler remoteConnectionHandler;
 
     private static final Logger log = Loggers.main;
 
-    InboundRequestTask(final RemoteConnectionHandler remoteConnectionHandler, final InboundRequest inboundRequest, final int rid, final int cid) {
+    InboundRequestTask(final RemoteConnectionHandler remoteConnectionHandler, final InboundRequest inboundRequest, InboundClient inboundClient, final int rid) {
         this.remoteConnectionHandler = remoteConnectionHandler;
         this.inboundRequest = inboundRequest;
+        this.inboundClient = inboundClient;
         this.rid = rid;
-        this.cid = cid;
     }
 
     public void run() {
@@ -55,11 +55,6 @@
             inboundRequest.setReplyHandler(replyHandler = new OutboundReplyHandler(inboundRequest, rid));
         }
         final RemoteConnectionHandler connectionHandler = remoteConnectionHandler;
-        final IntKeyMap<InboundClient> inboundClients = connectionHandler.getInboundClients();
-        final InboundClient inboundClient;
-        synchronized (inboundClients) {
-            inboundClient = inboundClients.get(cid);
-        }
         final ClassLoader requestClassLoader = inboundClient.getHandler().getClassLoader();
         final Object request;
         try {