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

[Tom Elrod]

  User: telrod  
  Date: 06/11/06 10:21:51

  Modified:    src/main/org/jboss/remoting/transport/socket  Tag:
                        remoting_2_x ServerThread.java
  Log:
  JBREM-607 - updated doc to include idle timeout info
  
  Revision  Changes    Path
  No                   revision
  
  
  No                   revision
  
  
  1.29.2.3  +12 -1     JBossRemoting/src/main/org/jboss/remoting/transport/socket/ServerThread.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: ServerThread.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossRemoting/src/main/org/jboss/remoting/transport/socket/ServerThread.java,v
  retrieving revision 1.29.2.2
  retrieving revision 1.29.2.3
  diff -u -b -r1.29.2.2 -r1.29.2.3
  --- ServerThread.java	3 Nov 2006 15:56:32 -0000	1.29.2.2
  +++ ServerThread.java	6 Nov 2006 15:21:51 -0000	1.29.2.3
  @@ -58,7 +58,7 @@
    *
    * @author <a href="mailto:bill at jboss.org">Bill Burke</a>
    * @author <a href="mailto:tom at jboss.org">Tom Elrod</a>
  - * @version $Revision: 1.29.2.2 $
  + * @version $Revision: 1.29.2.3 $
    */
   public class ServerThread extends Thread
   {
  @@ -477,6 +477,9 @@
   
         Object obj = versionedRead(inputStream, invoker, this.getClass().getClassLoader(), version);
   
  +      // setting timestamp since about to start processing
  +      lastRequestHandledTimestamp = System.currentTimeMillis();
  +
         InvocationRequest req = null;
         boolean createdInvocationRequest = false;
         boolean isError = false;
  @@ -495,10 +498,18 @@
         Object resp = null;
         try
         {
  +         if(isTrace)
  +         {
  +            log.trace("About to call ServerInvoker.invoke()");
  +         }
            // Make absolutely sure thread interrupted is cleared.
            boolean interrupted = Thread.interrupted();
            // call transport on the subclass, get the result to handback
            resp = invoker.invoke(req);
  +         if(isTrace)
  +         {
  +            log.trace("ServerInvoker.invoke() returned");
  +         }
         }
         catch (Throwable ex)
         {