You are viewing a plain text version of this content. The canonical link for it is here.
Posted to cvs@avalon.apache.org by le...@apache.org on 2002/08/16 09:25:25 UTC
cvs commit: jakarta-avalon-excalibur/altrmi/src/java/org/apache/excalibur/altrmi/server/impl/socket AbstractCompleteSocketStreamServer.java
leif 2002/08/16 00:25:25
Modified: altrmi/src/java/org/apache/excalibur/altrmi/server/impl/socket
AbstractCompleteSocketStreamServer.java
Log:
Close the server socket so that thread will end.
Name the server thread so that it is clear what it is on a thread dump.
Revision Changes Path
1.4 +12 -4 jakarta-avalon-excalibur/altrmi/src/java/org/apache/excalibur/altrmi/server/impl/socket/AbstractCompleteSocketStreamServer.java
Index: AbstractCompleteSocketStreamServer.java
===================================================================
RCS file: /home/cvs/jakarta-avalon-excalibur/altrmi/src/java/org/apache/excalibur/altrmi/server/impl/socket/AbstractCompleteSocketStreamServer.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- AbstractCompleteSocketStreamServer.java 23 Jun 2002 17:02:50 -0000 1.3
+++ AbstractCompleteSocketStreamServer.java 16 Aug 2002 07:25:25 -0000 1.4
@@ -107,7 +107,7 @@
sssc.enableLogging( getLogger() );
- Thread thread = new Thread( sssc,"SocketStreamServerConnection Thread" );
+ Thread thread = new Thread( sssc, "SocketStreamServerConnection Thread" );
thread.start();
}
@@ -138,7 +138,15 @@
{
mState = SHUTTINGDOWN;
-
+
+ try
+ {
+ mServerSocket.close();
+ }
+ catch ( IOException e )
+ {
+ System.out.println( "Unable to close the server socket." );
+ }
killAllConnections();
getThread().interrupt();
@@ -150,7 +158,7 @@
if( mThread == null )
{
- mThread = new Thread( this );
+ mThread = new Thread( this, "AltrmiSocketStreamServer" );
}
return mThread;
--
To unsubscribe, e-mail: <ma...@jakarta.apache.org>
For additional commands, e-mail: <ma...@jakarta.apache.org>