[jbosscache-commits] JBoss Cache SVN: r7910 - in core/branches/flat/src/test/java/org/horizon: api/mvcc and 9 other directories.
jbosscache-commits at lists.jboss.org
jbosscache-commits at lists.jboss.org
Wed Mar 18 10:02:03 EDT 2009
Author: manik.surtani at jboss.com
Date: 2009-03-18 10:02:03 -0400 (Wed, 18 Mar 2009)
New Revision: 7910
Added:
core/branches/flat/src/test/java/org/horizon/tx/TransactionsSpanningCaches.java
core/branches/flat/src/test/java/org/horizon/tx/TransactionsSpanningReplicatedCaches.java
Modified:
core/branches/flat/src/test/java/org/horizon/api/MixedModeTest.java
core/branches/flat/src/test/java/org/horizon/api/mvcc/PutForExternalReadTest.java
core/branches/flat/src/test/java/org/horizon/api/tree/NodeReplicatedMoveTest.java
core/branches/flat/src/test/java/org/horizon/api/tree/SyncReplTest.java
core/branches/flat/src/test/java/org/horizon/atomic/ClusteredAPITest.java
core/branches/flat/src/test/java/org/horizon/expiry/ReplicatedExpiryTest.java
core/branches/flat/src/test/java/org/horizon/invalidation/BaseInvalidationTest.java
core/branches/flat/src/test/java/org/horizon/loader/decorators/SingletonStoreTest.java
core/branches/flat/src/test/java/org/horizon/marshall/MarshalledValueTest.java
core/branches/flat/src/test/java/org/horizon/replication/AsyncReplTest.java
core/branches/flat/src/test/java/org/horizon/replication/BaseReplicatedAPITest.java
core/branches/flat/src/test/java/org/horizon/replication/ReplicationExceptionTest.java
core/branches/flat/src/test/java/org/horizon/replication/ReplicationQueueTest.java
core/branches/flat/src/test/java/org/horizon/replication/SyncCacheListenerTest.java
core/branches/flat/src/test/java/org/horizon/replication/SyncReplTest.java
core/branches/flat/src/test/java/org/horizon/test/MultipleCacheManagersTest.java
Log:
Added test to ensure transactions span caches on the same manager
Modified: core/branches/flat/src/test/java/org/horizon/api/MixedModeTest.java
===================================================================
--- core/branches/flat/src/test/java/org/horizon/api/MixedModeTest.java 2009-03-18 11:36:28 UTC (rev 7909)
+++ core/branches/flat/src/test/java/org/horizon/api/MixedModeTest.java 2009-03-18 14:02:03 UTC (rev 7910)
@@ -15,21 +15,12 @@
AdvancedCache localCache1, localCache2;
protected void createCacheManagers() throws Throwable {
- Configuration replSync = getDefaultConfig();
- replSync.setCacheMode(Configuration.CacheMode.REPL_SYNC);
+ Configuration replSync = getDefaultClusteredConfig(Configuration.CacheMode.REPL_SYNC);
+ Configuration replAsync = getDefaultClusteredConfig(Configuration.CacheMode.REPL_ASYNC);
+ Configuration invalSync = getDefaultClusteredConfig(Configuration.CacheMode.INVALIDATION_SYNC);
+ Configuration invalAsync = getDefaultClusteredConfig(Configuration.CacheMode.INVALIDATION_ASYNC);
+ Configuration local = getDefaultClusteredConfig(Configuration.CacheMode.LOCAL);
- Configuration replAsync = getDefaultConfig();
- replAsync.setCacheMode(Configuration.CacheMode.REPL_ASYNC);
-
- Configuration invalSync = getDefaultConfig();
- invalSync.setCacheMode(Configuration.CacheMode.INVALIDATION_SYNC);
-
- Configuration invalAsync = getDefaultConfig();
- invalAsync.setCacheMode(Configuration.CacheMode.INVALIDATION_ASYNC);
-
- Configuration local = getDefaultConfig();
- local.setCacheMode(Configuration.CacheMode.LOCAL);
-
createClusteredCaches(2, "replSync", replSync);
defineCacheOnAllManagers("replAsync", replAsync);
defineCacheOnAllManagers("invalSync", invalSync);
Modified: core/branches/flat/src/test/java/org/horizon/api/mvcc/PutForExternalReadTest.java
===================================================================
--- core/branches/flat/src/test/java/org/horizon/api/mvcc/PutForExternalReadTest.java 2009-03-18 11:36:28 UTC (rev 7909)
+++ core/branches/flat/src/test/java/org/horizon/api/mvcc/PutForExternalReadTest.java 2009-03-18 14:02:03 UTC (rev 7910)
@@ -35,8 +35,7 @@
ReplListener replListener1, replListener2;
protected void createCacheManagers() throws Throwable {
- Configuration c = getDefaultConfig();
- c.setCacheMode(Configuration.CacheMode.REPL_SYNC);
+ Configuration c = getDefaultClusteredConfig(Configuration.CacheMode.REPL_SYNC);
c.setTransactionManagerLookupClass(DummyTransactionManagerLookup.class.getName());
createClusteredCaches(2, "replSync", c);
Modified: core/branches/flat/src/test/java/org/horizon/api/tree/NodeReplicatedMoveTest.java
===================================================================
--- core/branches/flat/src/test/java/org/horizon/api/tree/NodeReplicatedMoveTest.java 2009-03-18 11:36:28 UTC (rev 7909)
+++ core/branches/flat/src/test/java/org/horizon/api/tree/NodeReplicatedMoveTest.java 2009-03-18 14:02:03 UTC (rev 7910)
@@ -31,9 +31,8 @@
TransactionManager tm1;
protected void createCacheManagers() throws Throwable {
- Configuration c = getDefaultConfig();
+ Configuration c = getDefaultClusteredConfig(Configuration.CacheMode.REPL_SYNC);
c.setInvocationBatchingEnabled(true);
- c.setCacheMode(Configuration.CacheMode.REPL_SYNC);
c.setTransactionManagerLookupClass(DummyTransactionManagerLookup.class.getName());
createClusteredCaches(2, "replSync", c);
Modified: core/branches/flat/src/test/java/org/horizon/api/tree/SyncReplTest.java
===================================================================
--- core/branches/flat/src/test/java/org/horizon/api/tree/SyncReplTest.java 2009-03-18 11:36:28 UTC (rev 7909)
+++ core/branches/flat/src/test/java/org/horizon/api/tree/SyncReplTest.java 2009-03-18 14:02:03 UTC (rev 7910)
@@ -29,10 +29,8 @@
private TreeCache<Object, Object> cache1, cache2;
protected void createCacheManagers() throws Throwable {
- Configuration c = getDefaultConfig();
- c.setCacheMode(Configuration.CacheMode.REPL_SYNC);
+ Configuration c = getDefaultClusteredConfig(Configuration.CacheMode.REPL_SYNC);
c.setInvocationBatchingEnabled(true);
- c.setFetchInMemoryState(false);
createClusteredCaches(2, "replSync", c);
Modified: core/branches/flat/src/test/java/org/horizon/atomic/ClusteredAPITest.java
===================================================================
--- core/branches/flat/src/test/java/org/horizon/atomic/ClusteredAPITest.java 2009-03-18 11:36:28 UTC (rev 7909)
+++ core/branches/flat/src/test/java/org/horizon/atomic/ClusteredAPITest.java 2009-03-18 14:02:03 UTC (rev 7910)
@@ -17,9 +17,8 @@
AtomicMapCache cache1, cache2;
protected void createCacheManagers() throws Throwable {
- Configuration c = getDefaultConfig();
+ Configuration c = getDefaultClusteredConfig(Configuration.CacheMode.REPL_SYNC);
c.setTransactionManagerLookupClass(DummyTransactionManagerLookup.class.getName());
- c.setCacheMode(Configuration.CacheMode.REPL_SYNC);
c.setInvocationBatchingEnabled(true);
List<Cache> caches = createClusteredCaches(2, "atomic", c);
Modified: core/branches/flat/src/test/java/org/horizon/expiry/ReplicatedExpiryTest.java
===================================================================
--- core/branches/flat/src/test/java/org/horizon/expiry/ReplicatedExpiryTest.java 2009-03-18 11:36:28 UTC (rev 7909)
+++ core/branches/flat/src/test/java/org/horizon/expiry/ReplicatedExpiryTest.java 2009-03-18 14:02:03 UTC (rev 7910)
@@ -14,8 +14,7 @@
Cache c1, c2;
protected void createCacheManagers() throws Throwable {
- Configuration cfg = getDefaultConfig();
- cfg.setCacheMode(Configuration.CacheMode.REPL_SYNC);
+ Configuration cfg = getDefaultClusteredConfig(Configuration.CacheMode.REPL_SYNC);
List<Cache> caches = createClusteredCaches(2, "cache", cfg);
c1 = caches.get(0);
c2 = caches.get(1);
Modified: core/branches/flat/src/test/java/org/horizon/invalidation/BaseInvalidationTest.java
===================================================================
--- core/branches/flat/src/test/java/org/horizon/invalidation/BaseInvalidationTest.java 2009-03-18 11:36:28 UTC (rev 7909)
+++ core/branches/flat/src/test/java/org/horizon/invalidation/BaseInvalidationTest.java 2009-03-18 14:02:03 UTC (rev 7910)
@@ -32,10 +32,8 @@
protected boolean isSync;
protected void createCacheManagers() throws Throwable {
- Configuration c = getDefaultConfig();
+ Configuration c = getDefaultClusteredConfig(isSync ? Configuration.CacheMode.INVALIDATION_SYNC : Configuration.CacheMode.INVALIDATION_ASYNC);
c.setStateRetrievalTimeout(1000);
- c.setFetchInMemoryState(false);
- c.setCacheMode(isSync ? Configuration.CacheMode.INVALIDATION_SYNC : Configuration.CacheMode.INVALIDATION_ASYNC);
c.setTransactionManagerLookupClass(DummyTransactionManagerLookup.class.getName());
List<Cache> caches = createClusteredCaches(2, "invalidation", c);
cache1 = caches.get(0).getAdvancedCache();
Modified: core/branches/flat/src/test/java/org/horizon/loader/decorators/SingletonStoreTest.java
===================================================================
--- core/branches/flat/src/test/java/org/horizon/loader/decorators/SingletonStoreTest.java 2009-03-18 11:36:28 UTC (rev 7909)
+++ core/branches/flat/src/test/java/org/horizon/loader/decorators/SingletonStoreTest.java 2009-03-18 14:02:03 UTC (rev 7910)
@@ -45,8 +45,7 @@
cm1 = addClusterEnabledCacheManager();
cm2 = addClusterEnabledCacheManager();
- Configuration conf = getDefaultConfig();
- conf.setCacheMode(Configuration.CacheMode.REPL_SYNC);
+ Configuration conf = getDefaultClusteredConfig(Configuration.CacheMode.REPL_SYNC);
DummyInMemoryCacheStore.Cfg cfg = new DummyInMemoryCacheStore.Cfg();
cfg.setStore("Store-" + storeCounter.getAndIncrement());
CacheLoaderManagerConfig pushingCfg = new CacheLoaderManagerConfig();
@@ -64,8 +63,7 @@
((DummyInMemoryCacheStore.Cfg) conf.getCacheLoaderManagerConfig().getFirstCacheLoaderConfig()).setStore("Store-" + storeCounter.getAndIncrement());
cm2.defineCache("pushing", conf);
- conf = getDefaultConfig();
- conf.setCacheMode(Configuration.CacheMode.REPL_SYNC);
+ conf = getDefaultClusteredConfig(Configuration.CacheMode.REPL_SYNC);
cfg = new DummyInMemoryCacheStore.Cfg();
cfg.setStore("Store-" + storeCounter.getAndIncrement());
CacheLoaderManagerConfig nonPushingCfg = new CacheLoaderManagerConfig();
Modified: core/branches/flat/src/test/java/org/horizon/marshall/MarshalledValueTest.java
===================================================================
--- core/branches/flat/src/test/java/org/horizon/marshall/MarshalledValueTest.java 2009-03-18 11:36:28 UTC (rev 7909)
+++ core/branches/flat/src/test/java/org/horizon/marshall/MarshalledValueTest.java 2009-03-18 14:02:03 UTC (rev 7910)
@@ -46,8 +46,7 @@
String k = "key", v = "value";
protected void createCacheManagers() throws Throwable {
- Configuration replSync = getDefaultConfig();
- replSync.setCacheMode(Configuration.CacheMode.REPL_SYNC);
+ Configuration replSync = getDefaultClusteredConfig(Configuration.CacheMode.REPL_SYNC);
replSync.setUseLazyDeserialization(true);
createClusteredCaches(2, "replSync", replSync);
@@ -249,8 +248,7 @@
public void testCacheLoaders() throws CloneNotSupportedException {
tearDown();
- Configuration cacheCofig = getDefaultConfig();
- cacheCofig.setCacheMode(Configuration.CacheMode.REPL_SYNC);
+ Configuration cacheCofig = getDefaultClusteredConfig(Configuration.CacheMode.REPL_SYNC);
cacheCofig.setUseLazyDeserialization(true);
CacheLoaderManagerConfig clmc = new CacheLoaderManagerConfig();
DummyInMemoryCacheStore.Cfg clc = new DummyInMemoryCacheStore.Cfg();
Modified: core/branches/flat/src/test/java/org/horizon/replication/AsyncReplTest.java
===================================================================
--- core/branches/flat/src/test/java/org/horizon/replication/AsyncReplTest.java 2009-03-18 11:36:28 UTC (rev 7909)
+++ core/branches/flat/src/test/java/org/horizon/replication/AsyncReplTest.java 2009-03-18 14:02:03 UTC (rev 7910)
@@ -26,10 +26,7 @@
Cache cache1, cache2;
protected void createCacheManagers() throws Throwable {
- Configuration asyncConfiguration = getDefaultConfig();
- asyncConfiguration.setCacheMode(Configuration.CacheMode.REPL_ASYNC);
- asyncConfiguration.setSyncCommitPhase(true);
- asyncConfiguration.setSyncRollbackPhase(true);
+ Configuration asyncConfiguration = getDefaultClusteredConfig(Configuration.CacheMode.REPL_ASYNC);
asyncConfiguration.setTransactionManagerLookupClass(DummyTransactionManagerLookup.class.getName());
List<Cache> caches = createClusteredCaches(2, "asyncRepl", asyncConfiguration);
cache1 = caches.get(0);
Modified: core/branches/flat/src/test/java/org/horizon/replication/BaseReplicatedAPITest.java
===================================================================
--- core/branches/flat/src/test/java/org/horizon/replication/BaseReplicatedAPITest.java 2009-03-18 11:36:28 UTC (rev 7909)
+++ core/branches/flat/src/test/java/org/horizon/replication/BaseReplicatedAPITest.java 2009-03-18 14:02:03 UTC (rev 7910)
@@ -22,10 +22,8 @@
protected boolean isSync;
protected void createCacheManagers() throws Throwable {
- Configuration c = getDefaultConfig();
+ Configuration c = getDefaultClusteredConfig(isSync ? Configuration.CacheMode.REPL_SYNC : Configuration.CacheMode.REPL_ASYNC);
c.setStateRetrievalTimeout(1000);
- c.setFetchInMemoryState(false);
- c.setCacheMode(isSync ? Configuration.CacheMode.REPL_SYNC : Configuration.CacheMode.REPL_ASYNC);
c.setTransactionManagerLookupClass(DummyTransactionManagerLookup.class.getName());
List<Cache> caches = createClusteredCaches(2, "replication", c);
cache1 = caches.get(0).getAdvancedCache();
Modified: core/branches/flat/src/test/java/org/horizon/replication/ReplicationExceptionTest.java
===================================================================
--- core/branches/flat/src/test/java/org/horizon/replication/ReplicationExceptionTest.java 2009-03-18 11:36:28 UTC (rev 7909)
+++ core/branches/flat/src/test/java/org/horizon/replication/ReplicationExceptionTest.java 2009-03-18 14:02:03 UTC (rev 7910)
@@ -35,9 +35,7 @@
private AdvancedCache cache1, cache2;
protected void createCacheManagers() throws Throwable {
- Configuration configuration = getDefaultConfig();
-
- configuration.setCacheMode(Configuration.CacheMode.REPL_SYNC);
+ Configuration configuration = getDefaultClusteredConfig(Configuration.CacheMode.REPL_SYNC);
configuration.setIsolationLevel(IsolationLevel.REPEATABLE_READ);
configuration.setTransactionManagerLookupClass(DummyTransactionManagerLookup.class.getName());
Modified: core/branches/flat/src/test/java/org/horizon/replication/ReplicationQueueTest.java
===================================================================
--- core/branches/flat/src/test/java/org/horizon/replication/ReplicationQueueTest.java 2009-03-18 11:36:28 UTC (rev 7909)
+++ core/branches/flat/src/test/java/org/horizon/replication/ReplicationQueueTest.java 2009-03-18 14:02:03 UTC (rev 7910)
@@ -13,11 +13,11 @@
import javax.transaction.TransactionManager;
import java.util.Properties;
+import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
-import java.util.concurrent.CountDownLatch;
/**
* Tests RepliationQueue functionality.
@@ -41,9 +41,8 @@
CacheManager second = TestingUtil.createClusteredCacheManager(globalConfiguration);
registerCacheManager(first, second);
- Configuration config = getDefaultConfig();
+ Configuration config = getDefaultClusteredConfig(Configuration.CacheMode.REPL_ASYNC);
config.setTransactionManagerLookupClass(DummyTransactionManagerLookup.class.getName());
- config.setCacheMode(Configuration.CacheMode.REPL_ASYNC);
config.setUseReplQueue(true);
config.setReplQueueInterval(REPL_QUEUE_INTERVAL);
config.setReplQueueMaxElements(REPL_QUEUE_MAX_ELEMENTS);
Modified: core/branches/flat/src/test/java/org/horizon/replication/SyncCacheListenerTest.java
===================================================================
--- core/branches/flat/src/test/java/org/horizon/replication/SyncCacheListenerTest.java 2009-03-18 11:36:28 UTC (rev 7909)
+++ core/branches/flat/src/test/java/org/horizon/replication/SyncCacheListenerTest.java 2009-03-18 14:02:03 UTC (rev 7910)
@@ -38,9 +38,7 @@
private final static Log log = LogFactory.getLog(SyncCacheListenerTest.class);
protected void createCacheManagers() throws Throwable {
- Configuration conf = getDefaultConfig();
- conf.setSyncCommitPhase(true);
- conf.setCacheMode(Configuration.CacheMode.REPL_SYNC);
+ Configuration conf = getDefaultClusteredConfig(Configuration.CacheMode.REPL_SYNC);
conf.setIsolationLevel(IsolationLevel.SERIALIZABLE);
conf.setTransactionManagerLookupClass(DummyTransactionManagerLookup.class.getName());
conf.setLockAcquisitionTimeout(5000);
Modified: core/branches/flat/src/test/java/org/horizon/replication/SyncReplTest.java
===================================================================
--- core/branches/flat/src/test/java/org/horizon/replication/SyncReplTest.java 2009-03-18 11:36:28 UTC (rev 7909)
+++ core/branches/flat/src/test/java/org/horizon/replication/SyncReplTest.java 2009-03-18 14:02:03 UTC (rev 7910)
@@ -35,8 +35,7 @@
String k = "key", v = "value";
protected void createCacheManagers() throws Throwable {
- Configuration replSync = getDefaultConfig();
- replSync.setCacheMode(Configuration.CacheMode.REPL_SYNC);
+ Configuration replSync = getDefaultClusteredConfig(Configuration.CacheMode.REPL_SYNC);
createClusteredCaches(2, "replSync", replSync);
cache1 = manager(0).getCache("replSync");
@@ -64,8 +63,7 @@
assert cache1.isEmpty();
assert cache2.isEmpty();
- Configuration newConf = getDefaultConfig();
- newConf.setCacheMode(Configuration.CacheMode.REPL_SYNC);
+ Configuration newConf = getDefaultClusteredConfig(Configuration.CacheMode.REPL_SYNC);
defineCacheOnAllManagers("newCache", newConf);
Cache altCache1 = manager(0).getCache("newCache");
Cache altCache2 = manager(1).getCache("newCache");
@@ -95,8 +93,7 @@
assert cache1.isEmpty();
assert cache2.isEmpty();
- Configuration newConf = getDefaultConfig();
- newConf.setCacheMode(Configuration.CacheMode.REPL_SYNC);
+ Configuration newConf = getDefaultClusteredConfig(Configuration.CacheMode.REPL_SYNC);
defineCacheOnAllManagers("newCache2", newConf);
Cache altCache1 = manager(0).getCache("newCache2");
@@ -123,8 +120,7 @@
Transport originalTransport = null;
RPCManagerImpl rpcManager = null;
try {
- Configuration asyncCache = getDefaultConfig();
- asyncCache.setCacheMode(Configuration.CacheMode.REPL_ASYNC);
+ Configuration asyncCache = getDefaultClusteredConfig(Configuration.CacheMode.REPL_ASYNC);
defineCacheOnAllManagers("asyncCache", asyncCache);
Cache asyncCache1 = manager(0).getCache("asyncCache");
Modified: core/branches/flat/src/test/java/org/horizon/test/MultipleCacheManagersTest.java
===================================================================
--- core/branches/flat/src/test/java/org/horizon/test/MultipleCacheManagersTest.java 2009-03-18 11:36:28 UTC (rev 7909)
+++ core/branches/flat/src/test/java/org/horizon/test/MultipleCacheManagersTest.java 2009-03-18 14:02:03 UTC (rev 7910)
@@ -90,7 +90,7 @@
}
/**
- * @see #getDefaultConfig()
+ * @see #getDefaultReplicatedConfig()
*/
private void assertSupportedConfig() {
for (CacheManager cm : cacheManagers) {
@@ -174,10 +174,13 @@
* make sure that an commit message will be dispatched in the same test method it was triggered and it will not
* interfere with further log messages.
*/
- protected Configuration getDefaultConfig() {
+ protected Configuration getDefaultClusteredConfig(Configuration.CacheMode mode) {
Configuration configuration = new Configuration();
- configuration.setSyncCommitPhase(true);
- configuration.setSyncRollbackPhase(true);
+ configuration.setCacheMode(mode);
+ if (mode.isSynchronous()) {
+ configuration.setSyncCommitPhase(true);
+ configuration.setSyncRollbackPhase(true);
+ }
configuration.setFetchInMemoryState(false);
return configuration;
}
Added: core/branches/flat/src/test/java/org/horizon/tx/TransactionsSpanningCaches.java
===================================================================
--- core/branches/flat/src/test/java/org/horizon/tx/TransactionsSpanningCaches.java (rev 0)
+++ core/branches/flat/src/test/java/org/horizon/tx/TransactionsSpanningCaches.java 2009-03-18 14:02:03 UTC (rev 7910)
@@ -0,0 +1,104 @@
+package org.horizon.tx;
+
+import org.horizon.Cache;
+import org.horizon.config.Configuration;
+import org.horizon.manager.CacheManager;
+import org.horizon.manager.DefaultCacheManager;
+import org.horizon.test.SingleCacheManagerTest;
+import org.horizon.test.TestingUtil;
+import org.horizon.transaction.DummyTransactionManagerLookup;
+import org.testng.annotations.Test;
+
+import javax.transaction.Transaction;
+import javax.transaction.TransactionManager;
+
+ at Test(groups = "functional", sequential = true, testName = "tx.TransactionsSpanningCaches")
+public class TransactionsSpanningCaches extends SingleCacheManagerTest {
+
+ protected CacheManager createCacheManager() throws Exception {
+ Configuration c = new Configuration();
+ c.setTransactionManagerLookupClass(DummyTransactionManagerLookup.class.getName());
+ CacheManager cm = new DefaultCacheManager(c);
+ cm.defineCache("c1", c);
+ cm.defineCache("c2", c);
+ return cm;
+ }
+
+ public void testCommitSpanningCaches() throws Exception {
+ Cache c1 = cacheManager.getCache("c1");
+ Cache c2 = cacheManager.getCache("c2");
+
+ assert c1.isEmpty();
+ assert c2.isEmpty();
+
+ c1.put("c1key", "c1value");
+ c2.put("c2key", "c2value");
+
+ assert !c1.isEmpty();
+ assert c1.size() == 1;
+ assert c1.get("c1key").equals("c1value");
+
+ assert !c2.isEmpty();
+ assert c2.size() == 1;
+ assert c2.get("c2key").equals("c2value");
+
+ TransactionManager tm = TestingUtil.getTransactionManager(c1);
+
+ tm.begin();
+ c1.put("c1key", "c1value_new");
+ c2.put("c2key", "c2value_new");
+
+ assert c1.get("c1key").equals("c1value_new");
+ assert c2.get("c2key").equals("c2value_new");
+
+ Transaction tx = tm.suspend();
+
+ assert c1.get("c1key").equals("c1value");
+ assert c2.get("c2key").equals("c2value");
+
+ tm.resume(tx);
+ tm.commit();
+
+ assert c1.get("c1key").equals("c1value_new");
+ assert c2.get("c2key").equals("c2value_new");
+ }
+
+ public void testRollbackSpanningCaches() throws Exception {
+ Cache c1 = cacheManager.getCache("c1");
+ Cache c2 = cacheManager.getCache("c2");
+
+ assert c1.isEmpty();
+ assert c2.isEmpty();
+
+ c1.put("c1key", "c1value");
+ c2.put("c2key", "c2value");
+
+ assert !c1.isEmpty();
+ assert c1.size() == 1;
+ assert c1.get("c1key").equals("c1value");
+
+ assert !c2.isEmpty();
+ assert c2.size() == 1;
+ assert c2.get("c2key").equals("c2value");
+
+ TransactionManager tm = TestingUtil.getTransactionManager(c1);
+
+ tm.begin();
+ c1.put("c1key", "c1value_new");
+ c2.put("c2key", "c2value_new");
+
+ assert c1.get("c1key").equals("c1value_new");
+ assert c2.get("c2key").equals("c2value_new");
+
+ Transaction tx = tm.suspend();
+
+ assert c1.get("c1key").equals("c1value");
+ assert c2.get("c2key").equals("c2value");
+
+ tm.resume(tx);
+ tm.rollback();
+
+ assert c1.get("c1key").equals("c1value");
+ assert c2.get("c2key").equals("c2value");
+ }
+}
Added: core/branches/flat/src/test/java/org/horizon/tx/TransactionsSpanningReplicatedCaches.java
===================================================================
--- core/branches/flat/src/test/java/org/horizon/tx/TransactionsSpanningReplicatedCaches.java (rev 0)
+++ core/branches/flat/src/test/java/org/horizon/tx/TransactionsSpanningReplicatedCaches.java 2009-03-18 14:02:03 UTC (rev 7910)
@@ -0,0 +1,140 @@
+package org.horizon.tx;
+
+import org.horizon.Cache;
+import org.horizon.config.Configuration;
+import org.horizon.manager.CacheManager;
+import org.horizon.test.MultipleCacheManagersTest;
+import org.horizon.test.TestingUtil;
+import org.horizon.transaction.DummyTransactionManagerLookup;
+import org.testng.annotations.Test;
+
+import javax.transaction.Transaction;
+import javax.transaction.TransactionManager;
+import java.util.Arrays;
+
+ at Test(groups = "functional", sequential = true, testName = "tx.TransactionsSpanningReplicatedCaches")
+public class TransactionsSpanningReplicatedCaches extends MultipleCacheManagersTest {
+
+ CacheManager cm1, cm2;
+
+ public TransactionsSpanningReplicatedCaches() {
+ cleanup = CleanupPhase.AFTER_METHOD;
+ }
+
+ protected void createCacheManagers() throws Exception {
+ cm1 = addClusterEnabledCacheManager();
+ cm2 = addClusterEnabledCacheManager();
+
+ Configuration c = getDefaultClusteredConfig(Configuration.CacheMode.REPL_SYNC);
+ c.setTransactionManagerLookupClass(DummyTransactionManagerLookup.class.getName());
+
+ defineCacheOnAllManagers("c1", c);
+ defineCacheOnAllManagers("c2", c);
+ }
+
+ public void testCommitSpanningCaches() throws Exception {
+ Cache c1 = cm1.getCache("c1");
+ Cache c1Replica = cm2.getCache("c1");
+ Cache c2 = cm1.getCache("c2");
+ Cache c2Replica = cm2.getCache("c2");
+
+ assert c1.isEmpty();
+ assert c2.isEmpty();
+ assert c1Replica.isEmpty();
+ assert c2Replica.isEmpty();
+
+ c1.put("c1key", "c1value");
+ c2.put("c2key", "c2value");
+
+ for (Cache c : Arrays.asList(c1, c1Replica)) {
+ assert !c.isEmpty();
+ assert c.size() == 1;
+ assert c.get("c1key").equals("c1value");
+ }
+
+ for (Cache c : Arrays.asList(c2, c2Replica)) {
+ assert !c.isEmpty();
+ assert c.size() == 1;
+ assert c.get("c2key").equals("c2value");
+ }
+
+ TransactionManager tm = TestingUtil.getTransactionManager(c1);
+
+ tm.begin();
+ c1.put("c1key", "c1value_new");
+ c2.put("c2key", "c2value_new");
+
+ assert c1.get("c1key").equals("c1value_new");
+ assert c1Replica.get("c1key").equals("c1value");
+ assert c2.get("c2key").equals("c2value_new");
+ assert c2Replica.get("c2key").equals("c2value");
+
+ Transaction tx = tm.suspend();
+
+ assert c1.get("c1key").equals("c1value");
+ assert c1Replica.get("c1key").equals("c1value");
+ assert c2.get("c2key").equals("c2value");
+ assert c2Replica.get("c2key").equals("c2value");
+
+ tm.resume(tx);
+ tm.commit();
+
+ assert c1.get("c1key").equals("c1value_new");
+ assert c1Replica.get("c1key").equals("c1value_new");
+ assert c2.get("c2key").equals("c2value_new");
+ assert c2Replica.get("c2key").equals("c2value_new");
+ }
+
+ public void testRollbackSpanningCaches() throws Exception {
+ Cache c1 = cm1.getCache("c1");
+ Cache c1Replica = cm2.getCache("c1");
+ Cache c2 = cm1.getCache("c2");
+ Cache c2Replica = cm2.getCache("c2");
+
+ assert c1.isEmpty();
+ assert c2.isEmpty();
+ assert c1Replica.isEmpty();
+ assert c2Replica.isEmpty();
+
+ c1.put("c1key", "c1value");
+ c2.put("c2key", "c2value");
+
+ for (Cache c : Arrays.asList(c1, c1Replica)) {
+ assert !c.isEmpty();
+ assert c.size() == 1;
+ assert c.get("c1key").equals("c1value");
+ }
+
+ for (Cache c : Arrays.asList(c2, c2Replica)) {
+ assert !c.isEmpty();
+ assert c.size() == 1;
+ assert c.get("c2key").equals("c2value");
+ }
+
+ TransactionManager tm = TestingUtil.getTransactionManager(c1);
+
+ tm.begin();
+ c1.put("c1key", "c1value_new");
+ c2.put("c2key", "c2value_new");
+
+ assert c1.get("c1key").equals("c1value_new");
+ assert c1Replica.get("c1key").equals("c1value");
+ assert c2.get("c2key").equals("c2value_new");
+ assert c2Replica.get("c2key").equals("c2value");
+
+ Transaction tx = tm.suspend();
+
+ assert c1.get("c1key").equals("c1value");
+ assert c1Replica.get("c1key").equals("c1value");
+ assert c2.get("c2key").equals("c2value");
+ assert c2Replica.get("c2key").equals("c2value");
+
+ tm.resume(tx);
+ tm.rollback();
+
+ assert c1.get("c1key").equals("c1value");
+ assert c1Replica.get("c1key").equals("c1value");
+ assert c2.get("c2key").equals("c2value");
+ assert c2Replica.get("c2key").equals("c2value");
+ }
+}
\ No newline at end of file
More information about the jbosscache-commits
mailing list