[jboss-cvs] JBossCache/src/org/jboss/cache ...

[Manik Surtani]

  User: msurtani
  Date: 06/12/20 04:07:15

  Modified:    src/org/jboss/cache  TreeCache.java
  Log:
  Made _block and _unblock public
  
  Revision  Changes    Path
  1.296     +11 -13    JBossCache/src/org/jboss/cache/TreeCache.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: TreeCache.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossCache/src/org/jboss/cache/TreeCache.java,v
  retrieving revision 1.295
  retrieving revision 1.296
  diff -u -b -r1.295 -r1.296
  --- TreeCache.java	20 Dec 2006 04:02:09 -0000	1.295
  +++ TreeCache.java	20 Dec 2006 09:07:15 -0000	1.296
  @@ -95,7 +95,7 @@
    * @author <a href="mailto:manik at jboss.org">Manik Surtani (manik at jboss.org)</a>
    * @author Brian Stansberry
    * @author Daniel Huang (dhuang at jboss.org)
  - * @version $Id: TreeCache.java,v 1.295 2006/12/20 04:02:09 vblagojevic Exp $
  + * @version $Id: TreeCache.java,v 1.296 2006/12/20 09:07:15 msurtani Exp $
    *          <p/>
    * @see <a href="http://labs.jboss.com/portal/jbosscache/docs">JBossCache doc</a>
    */
  @@ -697,7 +697,7 @@
               // always use the InactiveRegionAwareRpcDispatcher - exceptions due to regions not being active should not propagate to remote
               // nodes as errors. - Manik
               disp = new InactiveRegionAwareRpcDispatcher(channel, ml, this, this);
  -//            disp = new RpcDispatcher(channel, ml, this, this);
  +            //            disp = new RpcDispatcher(channel, ml, this, this);
   
   
               disp.setMarshaller(getMarshaller());
  @@ -3182,12 +3182,12 @@
         }
      }
   
  -   private void _block()
  +   public void _block()
      {
         //intentionally empty, used only for reflection in MethodDeclarations.blockChannelLocal
      }
      
  -   private void _unblock()
  +   public void _unblock()
      {
         //intentionally empty, used only for reflection in MethodDeclarations.unblockChannelLocal
      }
  @@ -3580,13 +3580,13 @@
       */
      public void block()
      {
  -      if(log.isDebugEnabled())
  +      if (log.isDebugEnabled())
         {
            log.debug("Block received at " + getLocalAddress());
         }      
         MethodCall m = MethodCallFactory.create(MethodDeclarations.blockChannelLocal);
         invokeMethod(m);
  -      if(log.isDebugEnabled())
  +      if (log.isDebugEnabled())
         {
            log.debug("Block processed at " + getLocalAddress());
         }
  @@ -3594,18 +3594,16 @@
      
      /**
       * Indicates that a channel has received a UNBLOCK event from FLUSH protocol.
  -    * 
  -    * 
       */
      public void unblock()
      {
  -      if(log.isDebugEnabled())
  +      if (log.isDebugEnabled())
         {
            log.debug("UnBlock received at " + getLocalAddress());
         }
         MethodCall m = MethodCallFactory.create(MethodDeclarations.unblockChannelLocal);
         invokeMethod(m);
  -      if(log.isDebugEnabled())
  +      if (log.isDebugEnabled())
         {
            log.debug("UnBlock processed at " + getLocalAddress());
         }