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

[Ron Sigal]

  User: rsigal  
  Date: 07/02/22 22:34:54

  Modified:    src/main/org/jboss/remoting/transport/bisocket  Tag:
                        remoting_2_x BisocketClientInvoker.java
  Log:
  JBREM-650:  handleDisconnect() calls super.handleDisconnect() in all cases.
  
  Revision  Changes    Path
  No                   revision
  
  
  No                   revision
  
  
  1.1.2.8   +2 -13     JBossRemoting/src/main/org/jboss/remoting/transport/bisocket/BisocketClientInvoker.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: BisocketClientInvoker.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossRemoting/src/main/org/jboss/remoting/transport/bisocket/BisocketClientInvoker.java,v
  retrieving revision 1.1.2.7
  retrieving revision 1.1.2.8
  diff -u -b -r1.1.2.7 -r1.1.2.8
  --- BisocketClientInvoker.java	21 Feb 2007 10:35:16 -0000	1.1.2.7
  +++ BisocketClientInvoker.java	23 Feb 2007 03:34:54 -0000	1.1.2.8
  @@ -45,7 +45,6 @@
   import org.jboss.remoting.marshal.UnMarshaller;
   import org.jboss.remoting.transport.BidirectionalClientInvoker;
   import org.jboss.remoting.transport.socket.SocketClientInvoker;
  -import org.jboss.remoting.transport.socket.SocketWrapper;
   
   /**
    * The bisocket transport, an extension of the socket transport, is designed to allow
  @@ -214,28 +213,18 @@
            if (isCallbackInvoker)
            {
               listenerIdToCallbackClientInvokerMap.remove(listenerId);
  -            for (Iterator it = pool.iterator(); it.hasNext();)
  -            {
  -               SocketWrapper socketWrapper = (SocketWrapper) it.next();
  -               try
  -               {
  -                  socketWrapper.close();
  -               }
  -               catch (Exception ignored)
  -               {
  -               }
  -            }
            }
            else
            {
               listenerIdToClientInvokerMap.remove(listenerId);
  -            super.handleDisconnect();
            }
   
            listenerIdToSocketsMap.remove(listenerId);
            if (pingTimerTask != null)
               pingTimerTask.shutDown();
         }
  +      
  +      super.handleDisconnect();
      }