Author: manik.surtani(a)jboss.com
Date: 2008-10-03 09:27:23 -0400 (Fri, 03 Oct 2008)
New Revision: 6834
Modified:
core/trunk/src/main/java/org/jboss/cache/interceptors/DataGravitatorInterceptor.java
Log:
Fixed broken interceptors.
Modified:
core/trunk/src/main/java/org/jboss/cache/interceptors/DataGravitatorInterceptor.java
===================================================================
---
core/trunk/src/main/java/org/jboss/cache/interceptors/DataGravitatorInterceptor.java 2008-10-03
13:24:45 UTC (rev 6833)
+++
core/trunk/src/main/java/org/jboss/cache/interceptors/DataGravitatorInterceptor.java 2008-10-03
13:27:23 UTC (rev 6834)
@@ -25,6 +25,7 @@
import org.jboss.cache.InvocationContext;
import org.jboss.cache.factories.annotations.Inject;
import org.jboss.cache.mvcc.MVCCNodeHelper;
+import org.jboss.cache.mvcc.ReadCommittedNode;
/**
* MVCC specific version of the LegacyDataGravitatorInterceptor
@@ -45,7 +46,8 @@
@Override
protected boolean nodeDoesNotExist(InvocationContext ctx, Fqn fqn)
{
- return ctx.lookUpNode(fqn) == null;
+ ReadCommittedNode node = (ReadCommittedNode) ctx.lookUpNode(fqn);
+ return node == null || node.isNullNode();
}
Show replies by date