Author: ron.sigal(a)jboss.com
Date: 2008-03-25 04:59:05 -0400 (Tue, 25 Mar 2008)
New Revision: 3744
Modified:
remoting2/branches/2.x/src/main/org/jboss/remoting/transport/bisocket/BisocketServerInvoker.java
Log:
BREM-937: ControlConnectionThread.run() calls SocketServerInvoker.processInvocation().
Modified:
remoting2/branches/2.x/src/main/org/jboss/remoting/transport/bisocket/BisocketServerInvoker.java
===================================================================
---
remoting2/branches/2.x/src/main/org/jboss/remoting/transport/bisocket/BisocketServerInvoker.java 2008-03-25
08:55:15 UTC (rev 3743)
+++
remoting2/branches/2.x/src/main/org/jboss/remoting/transport/bisocket/BisocketServerInvoker.java 2008-03-25
08:59:05 UTC (rev 3744)
@@ -58,7 +58,6 @@
import org.jboss.remoting.socketfactory.SocketCreationListener;
import org.jboss.remoting.transport.PortUtil;
import org.jboss.remoting.transport.socket.LRUPool;
-import org.jboss.remoting.transport.socket.ServerThread;
import org.jboss.remoting.transport.socket.SocketServerInvoker;
@@ -1061,33 +1060,14 @@
return;
}
- synchronized (clientpool)
+ try
{
- 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);
- }
- }
+ processInvocation(socket);
}
+ catch (Exception e)
+ {
+ log.error("Unable to create new ServerThread: " +
e.getMessage(), e);
+ }
}
}
}
Show replies by date