[jboss-cvs] JBossRemoting/src/main/org/jboss/remoting/transport/socket ...
Ron Sigal
ron_sigal at yahoo.com
Sat Oct 28 23:40:53 EDT 2006
User: rsigal
Date: 06/10/28 23:40:53
Modified: src/main/org/jboss/remoting/transport/socket
SocketServerInvoker.java
Log:
JBREM-619: Put ServerSocketRefresh thred in a finally clause.
Revision Changes Path
1.30 +33 -22 JBossRemoting/src/main/org/jboss/remoting/transport/socket/SocketServerInvoker.java
(In the diff below, changes in quantity of whitespace are not shown.)
Index: SocketServerInvoker.java
===================================================================
RCS file: /cvsroot/jboss/JBossRemoting/src/main/org/jboss/remoting/transport/socket/SocketServerInvoker.java,v
retrieving revision 1.29
retrieving revision 1.30
diff -u -b -r1.29 -r1.30
--- SocketServerInvoker.java 19 Jul 2006 16:39:17 -0000 1.29
+++ SocketServerInvoker.java 29 Oct 2006 03:40:53 -0000 1.30
@@ -43,7 +43,7 @@
*
* @author <a href="mailto:jhaynie at vocalocity.net">Jeff Haynie</a>
* @author <a href="mailto:tom.elrod at jboss.com">Tom Elrod</a>
- * @version $Revision: 1.29 $
+ * @version $Revision: 1.30 $
* @jmx:mbean
*/
public class SocketServerInvoker extends ServerInvoker implements Runnable, SocketServerInvokerMBean
@@ -432,6 +432,9 @@
ServerSocketRefresh thread=new ServerSocketRefresh();
thread.start();
+
+ try
+ {
while(running)
{
try
@@ -462,8 +465,12 @@
}
}
}
+ }
+ finally
+ {
thread.interrupt();
}
+ }
protected void processInvocation(Socket socket)
throws Exception
@@ -569,6 +576,10 @@
public class ServerSocketRefresh extends Thread{
boolean serverSocketLocked=false;
+ public ServerSocketRefresh()
+ {
+ super("ServerSocketRefresh");
+ }
public void run(){
while(true){
if(isInterrupted())break;
More information about the jboss-cvs-commits
mailing list