[infinispan-commits] Infinispan SVN: r1415 - trunk/core/src/main/java/org/infinispan/loaders.

[infinispan-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2010-01-27 05:19:35 -0500 (Wed, 27 Jan 2010)
New Revision: 1415

Modified:
   trunk/core/src/main/java/org/infinispan/loaders/CacheLoaderManagerImpl.java
Log:
Preloads should be local only!

Modified: trunk/core/src/main/java/org/infinispan/loaders/CacheLoaderManagerImpl.java
===================================================================
--- trunk/core/src/main/java/org/infinispan/loaders/CacheLoaderManagerImpl.java	2010-01-27 10:00:11 UTC (rev 1414)
+++ trunk/core/src/main/java/org/infinispan/loaders/CacheLoaderManagerImpl.java	2010-01-27 10:19:35 UTC (rev 1415)
@@ -1,12 +1,17 @@
 package org.infinispan.loaders;
 
+import com.sun.tools.javac.code.Flags;
 import org.infinispan.Cache;
 import org.infinispan.CacheException;
 import org.infinispan.config.CacheLoaderManagerConfig;
 import org.infinispan.config.Configuration;
 import org.infinispan.config.ConfigurationException;
 import org.infinispan.container.entries.InternalCacheEntry;
+
+import static org.infinispan.context.Flag.CACHE_MODE_LOCAL;
 import static org.infinispan.context.Flag.SKIP_CACHE_STATUS_CHECK;
+
+import org.infinispan.context.Flag;
 import org.infinispan.factories.annotations.Inject;
 import org.infinispan.factories.annotations.Start;
 import org.infinispan.factories.annotations.Stop;
@@ -123,7 +128,7 @@
             }
 
             for (InternalCacheEntry e : state)
-               cache.getAdvancedCache().withFlags(SKIP_CACHE_STATUS_CHECK).put(e.getKey(), e.getValue(), e.getLifespan(), MILLISECONDS, e.getMaxIdle(), MILLISECONDS);
+               cache.getAdvancedCache().withFlags(SKIP_CACHE_STATUS_CHECK, CACHE_MODE_LOCAL).put(e.getKey(), e.getValue(), e.getLifespan(), MILLISECONDS, e.getMaxIdle(), MILLISECONDS);
 
             if (log.isDebugEnabled()) stop = System.currentTimeMillis();
             if (log.isDebugEnabled()) total = stop - start;