[jboss-remoting-commits] JBoss Remoting SVN: r3735 - remoting2/branches/2.2/src/main/org/jboss/remoting/transport/bisocket.

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

Author: ron.sigal at jboss.com
Date: 2008-03-23 05:00:39 -0400 (Sun, 23 Mar 2008)
New Revision: 3735

Modified:
   remoting2/branches/2.2/src/main/org/jboss/remoting/transport/bisocket/BisocketServerInvoker.java
Log:
BREM-937: ControlConnectionThread.run() calls SocketServerInvoker.processInvocation().

Modified: remoting2/branches/2.2/src/main/org/jboss/remoting/transport/bisocket/BisocketServerInvoker.java
===================================================================
--- remoting2/branches/2.2/src/main/org/jboss/remoting/transport/bisocket/BisocketServerInvoker.java	2008-03-23 08:59:30 UTC (rev 3734)
+++ remoting2/branches/2.2/src/main/org/jboss/remoting/transport/bisocket/BisocketServerInvoker.java	2008-03-23 09:00:39 UTC (rev 3735)
@@ -832,33 +832,15 @@
                return;
             }
 
-            synchronized (clientpool)
-            {
-               if(clientpool.size() < maxPoolSize)
-               {
-                  Thread thread = null;
-                  try
-                  {
-                     thread = new ServerThread(socket, BisocketServerInvoker.this,
-                                               clientpool, threadpool,
-                                               getTimeout(), serverSocketClass);
-                     thread.start();
 
-                     if (log.isDebugEnabled())
-                        log.debug("created: " + thread);
-                  }
-                  catch (Exception e)
-                  {
-                     log.error("Unable to create new ServerThread: " + e.getMessage());
-                     e.printStackTrace();
-                  }
-
-                  synchronized (threadpool)
-                  {
-                     threadpool.add(thread);
-                  }
-               }
+            try
+            {
+               processInvocation(socket);
             }
+            catch (Exception e)
+            {
+               log.error("Unable to create new ServerThread: " + e.getMessage(), e);
+            }
          }
       }
    }