[jbosscache-commits] JBoss Cache SVN: r8168 - in core/trunk/src/main/java/org/jboss/cache: lock and 1 other directory.

[jbosscache-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2009-08-07 07:50:17 -0400 (Fri, 07 Aug 2009)
New Revision: 8168

Modified:
   core/trunk/src/main/java/org/jboss/cache/PessimisticUnversionedNode.java
   core/trunk/src/main/java/org/jboss/cache/lock/PessimisticNodeBasedLockManager.java
Log:
Fixed notification suppression

Modified: core/trunk/src/main/java/org/jboss/cache/PessimisticUnversionedNode.java
===================================================================
--- core/trunk/src/main/java/org/jboss/cache/PessimisticUnversionedNode.java	2009-08-07 10:59:23 UTC (rev 8167)
+++ core/trunk/src/main/java/org/jboss/cache/PessimisticUnversionedNode.java	2009-08-07 11:50:17 UTC (rev 8168)
@@ -233,10 +233,10 @@
       return getOrCreateChild(o, gtx, true, notify, null);
    }
 
-   public NodeSPI<K, V> addChildAndAcquireLock(Object o, PessimisticNodeBasedLockManager.LockAcquirer la)
+   public NodeSPI<K, V> addChildAndAcquireLock(Object o, boolean notify, PessimisticNodeBasedLockManager.LockAcquirer la)
    {
       GlobalTransaction gtx = cache.getInvocationContext().getGlobalTransaction();
-      return getOrCreateChild(o, gtx, true, false, la);
+      return getOrCreateChild(o, gtx, true, notify, la);
    }
 
    @Override

Modified: core/trunk/src/main/java/org/jboss/cache/lock/PessimisticNodeBasedLockManager.java
===================================================================
--- core/trunk/src/main/java/org/jboss/cache/lock/PessimisticNodeBasedLockManager.java	2009-08-07 10:59:23 UTC (rev 8167)
+++ core/trunk/src/main/java/org/jboss/cache/lock/PessimisticNodeBasedLockManager.java	2009-08-07 11:50:17 UTC (rev 8168)
@@ -145,7 +145,7 @@
             {
                // if the new node is to be marked as deleted, do not notify!
                PessimisticUnversionedNode parentInternalNode = (PessimisticUnversionedNode) parent.getDelegationTarget();
-               currentNode = parentInternalNode.addChildAndAcquireLock(childName, new LockAcquirer(ctx, WRITE, timeout, owner));
+               currentNode = parentInternalNode.addChildAndAcquireLock(childName, !skipNotification, new LockAcquirer(ctx, WRITE, timeout, owner));
                skipLockAcquire = true;
                if (!created)
                {