[infinispan-commits] Infinispan SVN: r639 - in trunk/core/src/test/java/org/infinispan: test/fwk and 1 other directories.

[infinispan-commits at lists.jboss.org]

Author: mircea.markus
Date: 2009-08-06 16:41:37 -0400 (Thu, 06 Aug 2009)
New Revision: 639

Added:
   trunk/core/src/test/java/org/infinispan/tx/LargeTransactionTest.java
Modified:
   trunk/core/src/test/java/org/infinispan/test/MultipleCacheManagersTest.java
   trunk/core/src/test/java/org/infinispan/test/fwk/TestCacheManagerFactory.java
Log:
added ut for https://jira.jboss.org/jira/browse/ISPN-149

Modified: trunk/core/src/test/java/org/infinispan/test/MultipleCacheManagersTest.java
===================================================================
--- trunk/core/src/test/java/org/infinispan/test/MultipleCacheManagersTest.java	2009-08-06 19:42:33 UTC (rev 638)
+++ trunk/core/src/test/java/org/infinispan/test/MultipleCacheManagersTest.java	2009-08-06 20:41:37 UTC (rev 639)
@@ -88,7 +88,7 @@
       }
    }
 
-   private void assertSupportedConfig() {
+   protected void assertSupportedConfig() {
       for (CacheManager cm : cacheManagers) {
          for (Cache cache : getRunningCaches(cm)) {
             Configuration config = cache.getConfiguration();

Modified: trunk/core/src/test/java/org/infinispan/test/fwk/TestCacheManagerFactory.java
===================================================================
--- trunk/core/src/test/java/org/infinispan/test/fwk/TestCacheManagerFactory.java	2009-08-06 19:42:33 UTC (rev 638)
+++ trunk/core/src/test/java/org/infinispan/test/fwk/TestCacheManagerFactory.java	2009-08-06 20:41:37 UTC (rev 639)
@@ -29,6 +29,12 @@
       return new DefaultCacheManager(globalConfiguration);
    }
 
+   public static GlobalConfiguration getGlobalConfigurtion() {
+      GlobalConfiguration globalConfiguration = GlobalConfiguration.getNonClusteredDefault();
+      amendMarshaller(globalConfiguration);
+      return globalConfiguration;
+   }
+
    /**
     * Creates an cache manager that does support clustering.
     */

Added: trunk/core/src/test/java/org/infinispan/tx/LargeTransactionTest.java
===================================================================
--- trunk/core/src/test/java/org/infinispan/tx/LargeTransactionTest.java	                        (rev 0)
+++ trunk/core/src/test/java/org/infinispan/tx/LargeTransactionTest.java	2009-08-06 20:41:37 UTC (rev 639)
@@ -0,0 +1,59 @@
+package org.infinispan.tx;
+
+import org.infinispan.Cache;
+import org.infinispan.config.Configuration;
+import org.infinispan.manager.CacheManager;
+import org.infinispan.manager.DefaultCacheManager;
+import org.infinispan.test.TestingUtil;
+import org.infinispan.test.MultipleCacheManagersTest;
+import org.infinispan.test.fwk.TestCacheManagerFactory;
+import org.testng.annotations.Test;
+
+import javax.transaction.TransactionManager;
+
+/**
+ *  Test for: https://jira.jboss.org/jira/browse/ISPN-149.
+ *
+ * @author Mircea.Markus at jboss.com
+ */
+ at Test(testName = "tx.LargeTransactionTest", groups = "functional")
+public class LargeTransactionTest extends MultipleCacheManagersTest {
+   private Cache cache;
+
+   protected void createCacheManagers() throws Throwable {
+
+      Configuration c = new Configuration();
+      c.setInvocationBatchingEnabled(true);
+      c.setCacheMode(Configuration.CacheMode.REPL_SYNC);
+      c.setSyncReplTimeout(30000);
+      c.setLockAcquisitionTimeout(60000);
+      c.setUseLockStriping(false);
+
+      CacheManager manager = new DefaultCacheManager(TestCacheManagerFactory.getGlobalConfigurtion(), c);
+      registerCacheManager(manager);
+      cache = manager.getCache("TestCache");
+
+      manager = new DefaultCacheManager(TestCacheManagerFactory.getGlobalConfigurtion(), c);
+      registerCacheManager(manager);
+      manager.getCache("TestCache");
+   }
+
+   @Override
+   protected void assertSupportedConfig() {
+      //yep!
+   }
+
+   public void simpleTest() throws Exception {
+      TransactionManager tm = TestingUtil.getTransactionManager(cache);
+      tm.begin();
+      for (int i = 0; i < 200; i++)
+         cache.put("key" + i, "value" + i);
+      tm.commit();
+
+      Cache cache2 = cache(1, "TestCache");
+      for (int i = 0; i < 200; i++) {
+         assert cache2.get("key" + i).equals("value+i");
+      }
+
+   }
+}