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

[Ron Sigal]

  User: rsigal  
  Date: 07/02/14 00:10:32

  Modified:    src/main/org/jboss/remoting/transport/bisocket  Tag:
                        remoting_2_x BisocketClientInvoker.java
  Log:
  JBREM-650:  getSecondaryLocator() tries 5 times.
  
  Revision  Changes    Path
  No                   revision
  
  
  No                   revision
  
  
  1.1.2.6   +17 -7     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.5
  retrieving revision 1.1.2.6
  diff -u -b -r1.1.2.5 -r1.1.2.6
  --- BisocketClientInvoker.java	13 Feb 2007 11:36:35 -0000	1.1.2.5
  +++ BisocketClientInvoker.java	14 Feb 2007 05:10:32 -0000	1.1.2.6
  @@ -85,9 +85,6 @@
   
   
      /**
  -    *
  -    * FIXME Comment this
  -    *
       * @param listenerId
       * @return
       */
  @@ -384,11 +381,24 @@
         InternalInvocation ii = new InternalInvocation(Bisocket.GET_SECONDARY_INVOKER_LOCATOR, null);
         InvocationRequest r = new InvocationRequest(null, null, ii, null, null, null);
         log.debug("getting secondary locator");
  +      
  +      for (int i = 0; i < 5; i++)
  +      {
  +         try
  +         {
         Object o = invoke(r);
         log.debug("secondary locator: " + o);
         secondaryLocator = (InvokerLocator) o;
         return secondaryLocator;
      }
  +         catch (IOException e)
  +         {
  +            log.warn("unable to get secondary locator: trying again");
  +         }
  +      }
  +      
  +      throw new IOException("unable to get secondary locator");
  +   }
   
      protected Object checkType(Object o, Class c) throws IOException
      {