[infinispan-commits] Infinispan SVN: r885 - in trunk/core/src/main/java/org/infinispan/loaders: decorators and 1 other directory.

[infinispan-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2009-09-29 11:08:10 -0400 (Tue, 29 Sep 2009)
New Revision: 885

Modified:
   trunk/core/src/main/java/org/infinispan/loaders/AbstractCacheStore.java
   trunk/core/src/main/java/org/infinispan/loaders/decorators/AsyncStore.java
Log:
defaults to help unit tests

Modified: trunk/core/src/main/java/org/infinispan/loaders/AbstractCacheStore.java
===================================================================
--- trunk/core/src/main/java/org/infinispan/loaders/AbstractCacheStore.java	2009-09-29 15:03:35 UTC (rev 884)
+++ trunk/core/src/main/java/org/infinispan/loaders/AbstractCacheStore.java	2009-09-29 15:08:10 UTC (rev 885)
@@ -37,7 +37,8 @@
       this.config = (AbstractCacheStoreConfig) config;
       this.marshaller = m;
       if (config == null) throw new IllegalStateException("Null config!!!");
-      transactions = new ConcurrentHashMap<GlobalTransaction, List<? extends Modification>>(64, 0.75f, cache.getConfiguration().getConcurrencyLevel());
+      int concurrencyLevel = cache == null ? 16 : cache.getConfiguration().getConcurrencyLevel();
+      transactions = new ConcurrentHashMap<GlobalTransaction, List<? extends Modification>>(64, 0.75f, concurrencyLevel);
    }
 
    public void start() throws CacheLoaderException {

Modified: trunk/core/src/main/java/org/infinispan/loaders/decorators/AsyncStore.java
===================================================================
--- trunk/core/src/main/java/org/infinispan/loaders/decorators/AsyncStore.java	2009-09-29 15:03:35 UTC (rev 884)
+++ trunk/core/src/main/java/org/infinispan/loaders/decorators/AsyncStore.java	2009-09-29 15:08:10 UTC (rev 885)
@@ -86,7 +86,7 @@
    @Override
    public void init(CacheLoaderConfig config, Cache cache, Marshaller m) throws CacheLoaderException {
       super.init(config, cache, m);
-      concurrencyLevel = cache.getConfiguration().getConcurrencyLevel();
+      concurrencyLevel = cache == null ? 16 : cache.getConfiguration().getConcurrencyLevel();
    }
    
    public void store(InternalCacheEntry ed) {