[jbosscache-commits] JBoss Cache SVN: r7132 - core/branches/flat/src/main/java/org/jboss/starobrno/config.

[jbosscache-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2008-11-13 13:08:44 -0500 (Thu, 13 Nov 2008)
New Revision: 7132

Modified:
   core/branches/flat/src/main/java/org/jboss/starobrno/config/Configuration.java
Log:
JBCACHE-1443:  Async marshalling, async cache loading and async notification handling use unbounded queues

Modified: core/branches/flat/src/main/java/org/jboss/starobrno/config/Configuration.java
===================================================================
--- core/branches/flat/src/main/java/org/jboss/starobrno/config/Configuration.java	2008-11-13 18:04:13 UTC (rev 7131)
+++ core/branches/flat/src/main/java/org/jboss/starobrno/config/Configuration.java	2008-11-13 18:08:44 UTC (rev 7132)
@@ -31,7 +31,11 @@
 import org.w3c.dom.Element;
 
 import java.net.URL;
-import java.util.*;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Locale;
+import java.util.Map;
 
 /**
  * Encapsulates the configuration of a Cache.
@@ -48,7 +52,7 @@
    private transient JGroupsStackParser jGroupsStackParser = new JGroupsStackParser();
    private boolean invocationBatchingEnabled;
 
-   private Map<String, EvictionCacheConfig> evictionCacheConfigs = new HashMap<String, EvictionCacheConfig>(4); 
+   private Map<String, EvictionCacheConfig> evictionCacheConfigs = new HashMap<String, EvictionCacheConfig>(4);
 
    public EvictionCacheConfig getEvictionCacheConfig(String cacheName)
    {
@@ -198,7 +202,10 @@
    private boolean writeSkewCheck = false;
    private int concurrencyLevel = 500;
    private int listenerAsyncPoolSize = 1;
-   private int serializationExecutorPoolSize = 25;
+   private int listenerAsyncQueueSize = 1000000;
+   private int serializationExecutorPoolSize = 0;
+   private int serializationExecutorQueueSize = 1000000;
+   private URL jgroupsConfigFile;
 
    @Start(priority = 1)
    private void correctIsolationLevels()
@@ -426,7 +433,7 @@
     */
    public void setListenerAsyncPoolSize(int listenerAsyncPoolSize)
    {
-      testImmutability("asyncListenerPoolSize");
+      testImmutability("listenerAsyncPoolSize");
       this.listenerAsyncPoolSize = listenerAsyncPoolSize;
    }
 
@@ -572,6 +579,24 @@
       this.serializationExecutorPoolSize = serializationExecutorPoolSize;
    }
 
+   public void setListenerAsyncQueueSize(int listenerAsyncQueueSize)
+   {
+      testImmutability("listenerAsyncQueueSize");
+      this.listenerAsyncQueueSize = listenerAsyncQueueSize;
+   }
+
+   public void setSerializationExecutorQueueSize(int serializationExecutorQueueSize)
+   {
+      testImmutability("serializationExecutorQueueSize");
+      this.serializationExecutorQueueSize = serializationExecutorQueueSize;
+   }
+
+   public void setJgroupsConfigFile(URL jgroupsConfigFile)
+   {
+      testImmutability("jgroupsConfigFile");
+      this.jgroupsConfigFile = jgroupsConfigFile;
+   }
+
    // ------------------------------------------------------------------------------------------------------------
    //   GETTERS
    // ------------------------------------------------------------------------------------------------------------
@@ -811,6 +836,21 @@
       return serializationExecutorPoolSize;
    }
 
+   public int getListenerAsyncQueueSize()
+   {
+      return listenerAsyncQueueSize;
+   }
+
+   public int getSerializationExecutorQueueSize()
+   {
+      return serializationExecutorQueueSize;
+   }
+
+   public URL getJgroupsConfigFile()
+   {
+      return jgroupsConfigFile;
+   }
+
    // ------------------------------------------------------------------------------------------------------------
    //   HELPERS
    // ------------------------------------------------------------------------------------------------------------
@@ -865,6 +905,9 @@
          return false;
       if (listenerAsyncPoolSize != that.listenerAsyncPoolSize) return false;
       if (serializationExecutorPoolSize != that.serializationExecutorPoolSize) return false;
+      if (jgroupsConfigFile != that.jgroupsConfigFile) return false;
+      if (listenerAsyncQueueSize != that.listenerAsyncQueueSize) return false;
+      if (serializationExecutorQueueSize != that.serializationExecutorQueueSize) return false;
 
       return true;
    }
@@ -905,6 +948,11 @@
       result = 31 * result + objectInputStreamPoolSize;
       result = 31 * result + objectOutputStreamPoolSize;
       result = 31 * result + serializationExecutorPoolSize;
+      result = 31 * result + listenerAsyncPoolSize;
+      result = 31 * result + serializationExecutorQueueSize;
+      result = 31 * result + listenerAsyncQueueSize;
+      result = 31 * result + (jgroupsConfigFile != null ? jgroupsConfigFile.hashCode() : 0);
+
       return result;
    }