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

[Manik Surtani]

  User: msurtani
  Date: 07/05/23 11:22:05

  Modified:    src/org/jboss/cache/statetransfer 
                        DefaultStateTransferIntegrator.java
  Log:
  Performance enhancements, including a new invoke() signature for Interceptor
  
  Revision  Changes    Path
  1.25      +17 -16    JBossCache/src/org/jboss/cache/statetransfer/DefaultStateTransferIntegrator.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: DefaultStateTransferIntegrator.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossCache/src/org/jboss/cache/statetransfer/DefaultStateTransferIntegrator.java,v
  retrieving revision 1.24
  retrieving revision 1.25
  diff -u -b -r1.24 -r1.25
  --- DefaultStateTransferIntegrator.java	20 Apr 2007 17:18:47 -0000	1.24
  +++ DefaultStateTransferIntegrator.java	23 May 2007 15:22:05 -0000	1.25
  @@ -11,6 +11,7 @@
   import org.jboss.cache.CacheException;
   import org.jboss.cache.CacheImpl;
   import org.jboss.cache.Fqn;
  +import org.jboss.cache.InvocationContext;
   import org.jboss.cache.Node;
   import org.jboss.cache.NodeFactory;
   import org.jboss.cache.NodeSPI;
  @@ -84,7 +85,7 @@
               log.trace("transient state successfully integrated");
            }
   
  -         notifyAllNodesCreated(target);
  +         notifyAllNodesCreated(cache.getInvocationContext(), target);
         }
         catch (Exception e)
         {
  @@ -195,15 +196,15 @@
       * Generates NodeAdded notifications for all nodes of the tree. This is
       * called whenever the tree is initially retrieved (state transfer)
       */
  -   private void notifyAllNodesCreated(NodeSPI curr)
  +   private void notifyAllNodesCreated(InvocationContext ctx, NodeSPI curr)
      {
         if (curr == null) return;
  -      getCache().getNotifier().notifyNodeCreated(curr.getFqn(), true, true);
  -      getCache().getNotifier().notifyNodeCreated(curr.getFqn(), false, true);
  +      getCache().getNotifier().notifyNodeCreated(curr.getFqn(), true, ctx, true);
  +      getCache().getNotifier().notifyNodeCreated(curr.getFqn(), false, ctx, true);
         Set<NodeSPI> children = curr.getChildrenDirect();
         for (NodeSPI n : children)
         {
  -         notifyAllNodesCreated(n);
  +         notifyAllNodesCreated(ctx, n);
         }
      }