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

[Ron Sigal]

  User: rsigal  
  Date: 06/08/20 04:54:30

  Modified:    src/main/org/jboss/remoting/transport/multiplex   
                        MultiplexServerInvoker.java InputMultiplexor.java
                        MultiplexingManager.java
  Log:
  JBREM-577:  Added more log output.
  
  Revision  Changes    Path
  1.57      +4 -1      JBossRemoting/src/main/org/jboss/remoting/transport/multiplex/MultiplexServerInvoker.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: MultiplexServerInvoker.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossRemoting/src/main/org/jboss/remoting/transport/multiplex/MultiplexServerInvoker.java,v
  retrieving revision 1.56
  retrieving revision 1.57
  diff -u -b -r1.56 -r1.57
  --- MultiplexServerInvoker.java	12 Aug 2006 23:26:00 -0000	1.56
  +++ MultiplexServerInvoker.java	20 Aug 2006 08:54:30 -0000	1.57
  @@ -195,7 +195,7 @@
      public MultiplexServerInvoker(InvokerLocator locator)
      {
         super(locator);
  -//      virtualServerInvokers = "stopped callback Connector"(new HashMap());
  +//      virtualServerInvokers = Collections.synchronizedMap(new HashMap());
         virtualServerInvokers = new HashMap();
      }
   
  @@ -757,11 +757,14 @@
               it = new HashMap(virtualServerInvokers).values().iterator();
            }
            
  +         log.info("copied virtualServerInvokers");
            while (it.hasNext())
            {
               ServerInvoker serverInvoker = ((ServerInvoker) it.next());
               it.remove();
  +            log.info("calling stop() on: " + serverInvoker.toString());
               serverInvoker.stop();
  +            log.info("called stop() on: " + serverInvoker.toString());
            }
         }
         
  
  
  
  1.27      +7 -0      JBossRemoting/src/main/org/jboss/remoting/transport/multiplex/InputMultiplexor.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: InputMultiplexor.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossRemoting/src/main/org/jboss/remoting/transport/multiplex/InputMultiplexor.java,v
  retrieving revision 1.26
  retrieving revision 1.27
  diff -u -b -r1.26 -r1.27
  --- InputMultiplexor.java	18 Aug 2006 13:50:14 -0000	1.26
  +++ InputMultiplexor.java	20 Aug 2006 08:54:30 -0000	1.27
  @@ -381,6 +381,11 @@
               {
                  handleChannelException(e, key, channel);
               }
  +            catch (Throwable t)
  +            {
  +               log.error("doRun()");
  +               log.error(t);
  +            }
            }
   
            public SelectionKey getKey()
  @@ -417,6 +422,8 @@
   
            private void handleChannelException(IOException e, SelectionKey key, SocketChannel channel)
            {
  +            log.error("handleChannelException()");
  +            log.error(e);
               try
               {
                  if (!channel.isOpen())
  
  
  
  1.56      +1 -1      JBossRemoting/src/main/org/jboss/remoting/transport/multiplex/MultiplexingManager.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: MultiplexingManager.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossRemoting/src/main/org/jboss/remoting/transport/multiplex/MultiplexingManager.java,v
  retrieving revision 1.55
  retrieving revision 1.56
  diff -u -b -r1.55 -r1.56
  --- MultiplexingManager.java	18 Aug 2006 16:37:35 -0000	1.55
  +++ MultiplexingManager.java	20 Aug 2006 08:54:30 -0000	1.56
  @@ -2156,7 +2156,7 @@
      protected void setEOF()
      {
         // Note.  See Note in setReadException().
  -      log.debug("setEOF()");
  +      log.info("setEOF()");
         HashSet tempSet;
         synchronized (inputStreamMap)
         {