[jboss-cvs] JBossRemoting/src/main/org/jboss/remoting/transport/socket ...

[Ron Sigal]

  User: rsigal  
  Date: 07/11/27 19:59:14

  Modified:    src/main/org/jboss/remoting/transport/socket  Tag:
                        remoting_2_x SocketServerInvoker.java
  Log:
  JBREM-807, JBREM-821: Moved some log statements.
  
  Revision  Changes    Path
  No                   revision
  
  
  No                   revision
  
  
  1.30.2.16 +5 -3      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.30.2.15
  retrieving revision 1.30.2.16
  diff -u -b -r1.30.2.15 -r1.30.2.16
  --- SocketServerInvoker.java	13 Nov 2007 09:00:23 -0000	1.30.2.15
  +++ SocketServerInvoker.java	28 Nov 2007 00:59:14 -0000	1.30.2.16
  @@ -50,7 +50,7 @@
    * @author <a href="mailto:tom.elrod at jboss.com">Tom Elrod</a>
    * @author <a href="mailto:ovidiu at jboss.org">Ovidiu Feodorov</a>
    *
  - * @version $Revision: 1.30.2.15 $
  + * @version $Revision: 1.30.2.16 $
    * @jmx:mbean
    */
   public class SocketServerInvoker extends ServerInvoker implements Runnable, SocketServerInvokerMBean
  @@ -326,8 +326,6 @@
            }
         }
   
  -      log.debug(this + " stopped threads in threadpool");
  -      
         // The following code has been changed to avoid a race condition with ServerThread.run() which
         // can result in leaving ServerThreads alive, which causes a memory leak.
         if (clientpool != null)
  @@ -347,6 +345,8 @@
               clientpool.flush();
               clientpool.stop();
   
  +            log.debug(this + " stopped threads in clientpool");
  +
               if (threadpool != null)
               {
                  int threadsToShutdown = threadpool.size();
  @@ -355,6 +355,8 @@
                     ServerThread thread = (ServerThread) threadpool.removeFirst();
                     thread.shutdown();
                  }
  +               
  +               log.debug(this + " stopped threads in threadpool");
               }
            }
         }