[infinispan-commits] Infinispan SVN: r1591 - trunk/core/src/main/java/org/infinispan/commands/write.

[infinispan-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2010-03-10 12:34:18 -0500 (Wed, 10 Mar 2010)
New Revision: 1591

Modified:
   trunk/core/src/main/java/org/infinispan/commands/write/InvalidateL1Command.java
Log:
[ISPN-369] (InvalidateL1Command should not be invoked if the keys are local)

Modified: trunk/core/src/main/java/org/infinispan/commands/write/InvalidateL1Command.java
===================================================================
--- trunk/core/src/main/java/org/infinispan/commands/write/InvalidateL1Command.java	2010-03-10 17:28:06 UTC (rev 1590)
+++ trunk/core/src/main/java/org/infinispan/commands/write/InvalidateL1Command.java	2010-03-10 17:34:18 UTC (rev 1591)
@@ -65,6 +65,17 @@
    }
 
    @Override
+   public boolean shouldInvoke(InvocationContext ctx) {
+      if (ctx.isOriginLocal() || (forRehash && config.isL1OnRehash())) return true;
+      boolean invoke = false;
+      for (Object k: getKeys()) {
+         invoke = invoke || !dm.isLocal(k);
+         if (invoke) return true;
+      }
+      return invoke;
+   }
+
+   @Override
    public boolean equals(Object o) {
       if (this == o) return true;
       if (o == null || getClass() != o.getClass()) return false;