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

[Ron Sigal]

  User: rsigal  
  Date: 06/12/19 01:06:06

  Modified:    src/main/org/jboss/remoting/transport/bisocket  Tag:
                        remoting_2_x BisocketClientInvoker.java
  Log:
  JBREM-650: Made listenerId protected.  Used 1000 for timeout waiting for new socket.
  
  Revision  Changes    Path
  No                   revision
  
  
  No                   revision
  
  
  1.1.2.2   +4 -3      JBossRemoting/src/main/org/jboss/remoting/transport/bisocket/Attic/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/Attic/BisocketClientInvoker.java,v
  retrieving revision 1.1.2.1
  retrieving revision 1.1.2.2
  diff -u -b -r1.1.2.1 -r1.1.2.2
  --- BisocketClientInvoker.java	14 Dec 2006 01:03:55 -0000	1.1.2.1
  +++ BisocketClientInvoker.java	19 Dec 2006 06:06:06 -0000	1.1.2.2
  @@ -61,7 +61,7 @@
      private static Map listenerIdToSocketsMap = new HashMap();
    
      private int pingFrequency = Bisocket.PING_FREQUENCY_DEFAULT;;
  -   private String listenerId;
  +   protected String listenerId;
      private InvokerLocator secondaryLocator;
      private Socket controlSocket;
      private OutputStream controlOutputStream;
  @@ -303,7 +303,8 @@
            {
               try
               {
  -               sockets.wait(getTimeout());
  +//               sockets.wait(getTimeout());
  +               sockets.wait(1000);
                  if (sockets.isEmpty())
                     throw new IOException("Timed out trying to create socket");
                  break;
  @@ -311,10 +312,10 @@
               catch (InterruptedException ignored) {}
            }
            
  -         log.info("got socket");
            it = sockets.iterator();
            socket = (Socket) it.next();
            it.remove();
  +         log.info("got socket: " + socket);
            return socket;
         }
      }