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

[infinispan-commits at lists.jboss.org]

Author: galder.zamarreno at jboss.com
Date: 2009-06-24 09:07:04 -0400 (Wed, 24 Jun 2009)
New Revision: 497

Modified:
   trunk/core/src/main/java/org/infinispan/interceptors/CacheStoreInterceptor.java
Log:
[ISPN-115] (CacheStoreInterceptor hangs when concurrent access to txStores HashMap) Fixed.

Modified: trunk/core/src/main/java/org/infinispan/interceptors/CacheStoreInterceptor.java
===================================================================
--- trunk/core/src/main/java/org/infinispan/interceptors/CacheStoreInterceptor.java	2009-06-23 13:43:37 UTC (rev 496)
+++ trunk/core/src/main/java/org/infinispan/interceptors/CacheStoreInterceptor.java	2009-06-24 13:07:04 UTC (rev 497)
@@ -55,7 +55,6 @@
 import org.infinispan.util.logging.LogFactory;
 
 import java.util.ArrayList;
-import java.util.HashMap;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
@@ -73,7 +72,7 @@
 @MBean(objectName = "CacheStore", description = "Component that handles storing of entries to a CacheStore from memory.")
 public class CacheStoreInterceptor extends JmxStatsCommandInterceptor {
    private CacheLoaderManagerConfig loaderConfig = null;
-   private HashMap<GlobalTransaction, Integer> txStores = new HashMap<GlobalTransaction, Integer>();
+   private Map<GlobalTransaction, Integer> txStores = new ConcurrentHashMap<GlobalTransaction, Integer>();
    private Map<GlobalTransaction, Set<Object>> preparingTxs = new ConcurrentHashMap<GlobalTransaction, Set<Object>>();
    private final AtomicLong cacheStores = new AtomicLong(0);
    CacheStore store;