Author: manik.surtani(a)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)
{
Show replies by date