[jbosscache-commits] JBoss Cache SVN: r7489 - in core/branches/flat/src/main/java/org/horizon: factories/scopes and 2 other directories.

Author: manik.surtani(a)jboss.com Date: 2009-01-16 10:17:37 -0500 (Fri, 16 Jan 2009) New Revision: 7489 Removed: core/branches/flat/src/main/java/org/horizon/atomic/APITest.java core/branches/flat/src/main/java/org/horizon/atomic/AtomicHashMapTest.java core/branches/flat/src/main/java/org/horizon/factories/scopes/ScopeDetectorTest.java core/branches/flat/src/main/java/org/horizon/lock/LockContainerHashingTest.java core/branches/flat/src/main/java/org/horizon/manager/CacheManagerComponentRegistryTest.java core/branches/flat/src/main/java/org/horizon/manager/CacheManagerTest.java core/branches/flat/src/main/java/org/horizon/manager/CacheManagerXmlConfigurationTest.java Log: Deleted tests in the main src folder Deleted: core/branches/flat/src/main/java/org/horizon/atomic/APITest.java =================================================================== --- core/branches/flat/src/main/java/org/horizon/atomic/APITest.java 2009-01-16 15:14:23 UTC (rev 7488) +++ core/branches/flat/src/main/java/org/horizon/atomic/APITest.java 2009-01-16 15:17:37 UTC (rev 7489) @@ -1,254 +0,0 @@ -/* - * JBoss, Home of Professional Open Source - * Copyright 2008, Red Hat Middleware LLC, and individual contributors - * by the @authors tag. See the copyright.txt in the distribution for a - * full listing of individual contributors. - * - * This is free software; you can redistribute it and/or modify it - * under the terms of the GNU Lesser General Public License as - * published by the Free Software Foundation; either version 2.1 of - * the License, or (at your option) any later version. - * - * This software is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this software; if not, write to the Free - * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA - * 02110-1301 USA, or see the FSF site: http://www.fsf.org. - */ -package org.horizon.atomic; - -import org.horizon.config.Configuration; -import org.horizon.config.Configuration.CacheMode; -import org.horizon.manager.CacheManager; -import org.horizon.transaction.DummyTransactionManager; -import org.horizon.transaction.DummyTransactionManagerLookup; -import org.horizon.util.TestingUtil; -import org.testng.annotations.Test; - -import javax.transaction.Transaction; -import java.util.Map; - -@Test(groups = "functional") -public class APITest -{ - - private void assertIsEmpty(Map map) - { - assert map.size() == 0; - assert map.get("blah") == null; - assert !map.containsKey("blah"); - } - - private void assertIsEmptyMap(AtomicMapCache cache, Object key) - { - assertIsEmpty(cache.getAtomicMap(key)); - } - - public void testAtomicMap() - { - Configuration c = new Configuration(); - c.setInvocationBatchingEnabled(true); - AtomicMapCache cache = (AtomicMapCache) new CacheManager(c).getCache(); - try - { - AtomicMap map = cache.getAtomicMap("map"); - - assertIsEmpty(map); - assertIsEmptyMap(cache, "map"); - - map.put("blah", "blah"); - assert map.size() == 1; - assert map.get("blah").equals("blah"); - assert map.containsKey("blah"); - - map.clear(); - - assertIsEmpty(map); - assertIsEmptyMap(cache, "map"); - } - finally - { - cache.stop(); - } - } - - - public void testReadSafetyEmptyCache() throws Exception - { - Configuration c = new Configuration(); - c.setTransactionManagerLookupClass(DummyTransactionManagerLookup.class.getName()); - c.setInvocationBatchingEnabled(true); - AtomicMapCache cache = (AtomicMapCache) new CacheManager(c).getCache(); - try - { - AtomicMap map = cache.getAtomicMap("map"); - - assertIsEmpty(map); - assertIsEmptyMap(cache, "map"); - - DummyTransactionManager.getInstance().begin(); - map.put("blah", "blah"); - assert map.size() == 1; - assert map.get("blah").equals("blah"); - assert map.containsKey("blah"); - Transaction t = DummyTransactionManager.getInstance().suspend(); - - assertIsEmpty(map); - assertIsEmptyMap(cache, "map"); - - DummyTransactionManager.getInstance().resume(t); - DummyTransactionManager.getInstance().commit(); - - assert map.size() == 1; - assert map.get("blah").equals("blah"); - assert map.containsKey("blah"); - - map.clear(); - - assertIsEmpty(map); - assertIsEmptyMap(cache, "map"); - } - finally - { - cache.stop(); - } - } - - public void testReadSafetyNotEmptyCache() throws Exception - { - Configuration c = new Configuration(); - c.setTransactionManagerLookupClass(DummyTransactionManagerLookup.class.getName()); - c.setInvocationBatchingEnabled(true); - AtomicMapCache cache = (AtomicMapCache) new CacheManager(c).getCache(); - try - { - AtomicMap map = cache.getAtomicMap("map"); - - DummyTransactionManager.getInstance().begin(); - map.put("blah", "blah"); - assert map.size() == 1; - assert map.get("blah").equals("blah"); - assert map.containsKey("blah"); - Transaction t = DummyTransactionManager.getInstance().suspend(); - - assertIsEmpty(map); - assertIsEmptyMap(cache, "map"); - - DummyTransactionManager.getInstance().resume(t); - DummyTransactionManager.getInstance().commit(); - - assert map.size() == 1; - assert map.get("blah").equals("blah"); - assert map.containsKey("blah"); - - map.clear(); - - assertIsEmpty(map); - assertIsEmptyMap(cache, "map"); - } - finally - { - cache.stop(); - } - } - - public void testReadSafetyRollback() throws Exception - { - Configuration c = new Configuration(); - c.setTransactionManagerLookupClass(DummyTransactionManagerLookup.class.getName()); - c.setInvocationBatchingEnabled(true); - AtomicMapCache cache = (AtomicMapCache) new CacheManager(c).getCache(); - try - { - AtomicMap map = cache.getAtomicMap("map"); - - DummyTransactionManager.getInstance().begin(); - map.put("blah", "blah"); - assert map.size() == 1; - assert map.get("blah").equals("blah"); - assert map.containsKey("blah"); - Transaction t = DummyTransactionManager.getInstance().suspend(); - - assertIsEmpty(map); - assertIsEmptyMap(cache, "map"); - - DummyTransactionManager.getInstance().resume(t); - DummyTransactionManager.getInstance().rollback(); - - assertIsEmpty(map); - assertIsEmptyMap(cache, "map"); - } - finally - { - cache.stop(); - } - } - - public void testReplicationCommit() throws Exception - { - Configuration c = new Configuration(); - c.setTransactionManagerLookupClass(DummyTransactionManagerLookup.class.getName()); - c.setCacheMode(CacheMode.REPL_SYNC); - c.setInvocationBatchingEnabled(true); - AtomicMapCache cache1 = (AtomicMapCache) new CacheManager(c).getCache(); - AtomicMapCache cache2 = (AtomicMapCache) new CacheManager(c).getCache(); - - try - { - TestingUtil.blockUntilViewsReceived(20000, cache1, cache2); - AtomicMap map = cache1.getAtomicMap("map"); - - DummyTransactionManager.getInstance().begin(); - map.put("existing", "existing"); - map.put("blah", "blah"); - DummyTransactionManager.getInstance().commit(); - - assert map.size() == 2; - assert map.get("blah").equals("blah"); - assert map.containsKey("blah"); - - System.out.println("Map on cache 2 is " + cache2.getAtomicMap("map")); - - assert cache2.getAtomicMap("map").size() == 2; - assert cache2.getAtomicMap("map").get("blah").equals("blah"); - assert cache2.getAtomicMap("map").containsKey("blah"); - } - finally - { - TestingUtil.killCaches(cache1, cache2); - } - } - - public void testReplicationRollback() throws Exception - { - Configuration c = new Configuration(); - c.setTransactionManagerLookupClass(DummyTransactionManagerLookup.class.getName()); - c.setCacheMode(CacheMode.REPL_SYNC); - c.setInvocationBatchingEnabled(true); - AtomicMapCache cache1 = (AtomicMapCache) new CacheManager(c).getCache(); - AtomicMapCache cache2 = (AtomicMapCache) new CacheManager(c).getCache(); - - try - { - TestingUtil.blockUntilViewsReceived(20000, cache1, cache2); - AtomicMap map = cache1.getAtomicMap("map"); - - DummyTransactionManager.getInstance().begin(); - map.put("existing", "existing"); - map.put("blah", "blah"); - DummyTransactionManager.getInstance().rollback(); - - assertIsEmpty(map); - assertIsEmptyMap(cache1, "map"); - assertIsEmptyMap(cache2, "map"); - } - finally - { - TestingUtil.killCaches(cache1, cache2); - } - } -} Deleted: core/branches/flat/src/main/java/org/horizon/atomic/AtomicHashMapTest.java =================================================================== --- core/branches/flat/src/main/java/org/horizon/atomic/AtomicHashMapTest.java 2009-01-16 15:14:23 UTC (rev 7488) +++ core/branches/flat/src/main/java/org/horizon/atomic/AtomicHashMapTest.java 2009-01-16 15:17:37 UTC (rev 7489) @@ -1,105 +0,0 @@ -/* - * JBoss, Home of Professional Open Source - * Copyright 2008, Red Hat Middleware LLC, and individual contributors - * by the @authors tag. See the copyright.txt in the distribution for a - * full listing of individual contributors. - * - * This is free software; you can redistribute it and/or modify it - * under the terms of the GNU Lesser General Public License as - * published by the Free Software Foundation; either version 2.1 of - * the License, or (at your option) any later version. - * - * This software is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this software; if not, write to the Free - * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA - * 02110-1301 USA, or see the FSF site: http://www.fsf.org. - * - */ - -package org.horizon.atomic; - -import org.easymock.EasyMock; -import org.testng.annotations.Test; - -import java.io.IOException; -import java.io.ObjectOutput; - -@Test(groups = "unit") -public class AtomicHashMapTest -{ - public void testDeltasWithEmptyMap() throws IOException - { - AtomicHashMap m = new AtomicHashMap(); - Delta d = m.delta(); - assert d instanceof NullDelta; - ObjectOutput out = EasyMock.createMock(ObjectOutput.class); - EasyMock.replay(out); - d.writeExternal(out); - EasyMock.verify(out); - - AtomicHashMap newMap = new AtomicHashMap(); - newMap.initForWriting(); - newMap.put("k", "v"); - newMap = (AtomicHashMap) d.merge(newMap); - assert newMap.containsKey("k"); - assert newMap.size() == 1; - - newMap = (AtomicHashMap) d.merge(null); - assert newMap.isEmpty(); - } - - public void testDeltasWithNoChanges() throws IOException - { - AtomicHashMap m = new AtomicHashMap(); - m.initForWriting(); - m.put("k1", "v1"); - m.commit(); - assert m.size() == 1; - Delta d = m.delta(); - assert d instanceof NullDelta; - ObjectOutput out = EasyMock.createMock(ObjectOutput.class); - EasyMock.replay(out); - d.writeExternal(out); - EasyMock.verify(out); - - AtomicHashMap newMap = new AtomicHashMap(); - newMap.initForWriting(); - newMap.put("k", "v"); - newMap = (AtomicHashMap) d.merge(newMap); - assert newMap.containsKey("k"); - assert newMap.size() == 1; - - newMap = (AtomicHashMap) d.merge(null); - assert newMap.isEmpty(); - } - - public void testDeltasWithRepeatedChanges() - { - AtomicHashMap m = new AtomicHashMap(); - m.initForWriting(); - m.put("k1", "v1"); - m.put("k1", "v2"); - m.put("k1", "v3"); - assert m.size() == 1; - AtomicHashMapDelta d = (AtomicHashMapDelta) m.delta(); - assert d.getChangeLogSize() != 0; - - AtomicHashMap newMap = new AtomicHashMap(); - newMap.initForWriting(); - newMap.put("k1", "v4"); - newMap = (AtomicHashMap) d.merge(newMap); - assert newMap.containsKey("k1"); - assert newMap.get("k1").equals("v3"); - assert newMap.size() == 1; - - newMap = (AtomicHashMap) d.merge(null); - assert newMap.containsKey("k1"); - assert newMap.get("k1").equals("v3"); - assert newMap.size() == 1; - } -} Deleted: core/branches/flat/src/main/java/org/horizon/factories/scopes/ScopeDetectorTest.java =================================================================== --- core/branches/flat/src/main/java/org/horizon/factories/scopes/ScopeDetectorTest.java 2009-01-16 15:14:23 UTC (rev 7488) +++ core/branches/flat/src/main/java/org/horizon/factories/scopes/ScopeDetectorTest.java 2009-01-16 15:17:37 UTC (rev 7489) @@ -1,91 +0,0 @@ -package org.horizon.factories.scopes; - -import org.testng.annotations.Test; - -/** - * @author Manik Surtani - * @since 1.0 - */ -@Test(groups = "unit") -public class ScopeDetectorTest -{ - public void testScopeOnClass() - { - testScopes(Test1.class, Scopes.GLOBAL); - - } - - public void testScopeOnInterface() - { - testScopes(Test2.class, Scopes.GLOBAL); - } - - public void testScopeOnSuperClass() - { - testScopes(Test3.class, Scopes.GLOBAL); - } - - public void testScopeOnSuperInterface() - { - testScopes(Test4.class, Scopes.GLOBAL); - } - - public void testNoScopes() - { - testScopes(Test6.class, Scopes.NAMED_CACHE); - } - - private void testScopes(Class clazz, Scopes expected) - { - Scopes detected = ScopeDetector.detectScope(clazz); - assert detected == expected : "Expected " + expected + " but was " + detected; - } - - public static interface Unscoped - { - - } - - @Scope(Scopes.GLOBAL) - public static interface Scoped - { - - } - - @Scope(Scopes.GLOBAL) - public static class SuperScoped - { - - } - - public static class SuperUnScoped - { - - } - - @Scope(Scopes.GLOBAL) - public static class Test1 - { - - } - - public static class Test2 implements Scoped - { - - } - - public static class Test3 extends SuperScoped - { - - } - - public static class Test4 extends Test2 - { - - } - - public static class Test6 extends SuperUnScoped implements Unscoped - { - - } -} Deleted: core/branches/flat/src/main/java/org/horizon/lock/LockContainerHashingTest.java =================================================================== --- core/branches/flat/src/main/java/org/horizon/lock/LockContainerHashingTest.java 2009-01-16 15:14:23 UTC (rev 7488) +++ core/branches/flat/src/main/java/org/horizon/lock/LockContainerHashingTest.java 2009-01-16 15:17:37 UTC (rev 7489) @@ -1,88 +0,0 @@ -/* - * JBoss, Home of Professional Open Source - * Copyright 2008, Red Hat Middleware LLC, and individual contributors - * by the @authors tag. See the copyright.txt in the distribution for a - * full listing of individual contributors. - * - * This is free software; you can redistribute it and/or modify it - * under the terms of the GNU Lesser General Public License as - * published by the Free Software Foundation; either version 2.1 of - * the License, or (at your option) any later version. - * - * This software is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this software; if not, write to the Free - * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA - * 02110-1301 USA, or see the FSF site: http://www.fsf.org. - */ -package org.horizon.lock; - -import org.horizon.util.concurrent.locks.LockContainer; -import org.horizon.util.concurrent.locks.ReentrantLockContainer; -import org.testng.annotations.BeforeMethod; -import org.testng.annotations.Test; - -import java.util.*; -import java.util.concurrent.locks.Lock; - -@Test(groups = "unit") -public class LockContainerHashingTest -{ - private LockContainer<String> stripedLock; - - @BeforeMethod(alwaysRun = true) - public void setUp() - { - stripedLock = new ReentrantLockContainer<String>(500); - } - - public void testHashingDistribution() - { - // ensure even bucket distribution of lock stripes - List<String> keys = createRandomKeys(1000); - - Map<Lock, Integer> distribution = new HashMap<Lock, Integer>(); - - for (String s : keys) - { - Lock lock = stripedLock.getLock(s); - if (distribution.containsKey(lock)) - { - int count = distribution.get(lock) + 1; - distribution.put(lock, count); - } - else - { - distribution.put(lock, 1); - } - } - - System.out.println(distribution); - - // cannot be larger than the number of locks - System.out.println("dist size: " + distribution.size()); - System.out.println("num shared locks: " + stripedLock.size()); - assert distribution.size() <= stripedLock.size(); - // assume at least a 2/3rd spread - assert distribution.size() * 1.5 >= stripedLock.size(); - } - - private List<String> createRandomKeys(int number) - { - - List<String> f = new ArrayList<String>(number); - Random r = new Random(); - int i = number; - while (f.size() < number) - { - String s = i + "baseKey" + (10000 + i++); - f.add(s); - } - - return f; - } -} Deleted: core/branches/flat/src/main/java/org/horizon/manager/CacheManagerComponentRegistryTest.java =================================================================== --- core/branches/flat/src/main/java/org/horizon/manager/CacheManagerComponentRegistryTest.java 2009-01-16 15:14:23 UTC (rev 7488) +++ core/branches/flat/src/main/java/org/horizon/manager/CacheManagerComponentRegistryTest.java 2009-01-16 15:17:37 UTC (rev 7489) @@ -1,103 +0,0 @@ -package org.horizon.manager; - -import org.horizon.Cache; -import org.horizon.config.CacheLoaderConfig; -import org.horizon.config.Configuration; -import org.horizon.interceptors.BatchingInterceptor; -import org.horizon.interceptors.InterceptorChain; -import org.horizon.loader.CacheLoaderManager; -import org.horizon.loader.FileCacheLoaderConfig; -import org.horizon.remoting.RPCManager; -import org.horizon.transaction.DummyTransactionManager; -import org.horizon.transaction.DummyTransactionManagerLookup; -import org.horizon.util.TestingUtil; -import org.testng.annotations.AfterMethod; -import org.testng.annotations.Test; - -import javax.transaction.TransactionManager; - -/** - * @author Manik Surtani - * @since 1.0 - */ -@Test(groups = "functional", sequential = true) -public class CacheManagerComponentRegistryTest -{ - CacheManager cm; - - @AfterMethod - public void tearDown() - { - if (cm != null) cm.stop(); - } - - public void testForceSharedComponents() throws CacheNameExistsException, NamedCacheNotFoundException - { - Configuration defaultCfg = new Configuration(); - defaultCfg.setCacheMode(Configuration.CacheMode.REPL_SYNC); - // cache manager with default configuration - cm = new CacheManager(defaultCfg); - - // default cache with no overrides - Cache c = cm.getCache(); - - Configuration overrides = new Configuration(); - overrides.setTransactionManagerLookupClass(DummyTransactionManagerLookup.class.getName()); - cm.defineCache("transactional", overrides); - Cache transactional = cm.getCache("transactional"); - - // assert components. - assert TestingUtil.extractComponent(c, TransactionManager.class) == null; - assert TestingUtil.extractComponent(transactional, TransactionManager.class) instanceof DummyTransactionManager; - - // assert force-shared components - assert TestingUtil.extractComponent(c, RPCManager.class) != null; - assert TestingUtil.extractComponent(transactional, RPCManager.class) != null; - assert TestingUtil.extractComponent(c, RPCManager.class) == TestingUtil.extractComponent(transactional, RPCManager.class); - } - - public void testForceUnsharedComponents() throws CacheNameExistsException, NamedCacheNotFoundException - { - CacheLoaderConfig clc = new CacheLoaderConfig(); - FileCacheLoaderConfig fc = new FileCacheLoaderConfig(); - fc.setLocation("/tmp"); - clc.addIndividualCacheLoaderConfig(fc); - - Configuration defaultCfg = new Configuration(); - defaultCfg.setCacheMode(Configuration.CacheMode.REPL_SYNC); - defaultCfg.setCacheLoaderConfig(clc); - // cache manager with default configuration - cm = new CacheManager(defaultCfg); - - // default cache with no overrides - Cache c = cm.getCache(); - - Configuration overrides = new Configuration(); - overrides.setTransactionManagerLookupClass(DummyTransactionManagerLookup.class.getName()); - cm.defineCache("transactional", overrides); - Cache transactional = cm.getCache("transactional"); - - // assert components. - assert TestingUtil.extractComponent(c, CacheLoaderManager.class) != null; - assert TestingUtil.extractComponent(transactional, CacheLoaderManager.class) != null; - assert TestingUtil.extractComponent(c, CacheLoaderManager.class) != TestingUtil.extractComponent(transactional, CacheLoaderManager.class); - } - - public void testOverridingComponents() throws CacheNameExistsException, NamedCacheNotFoundException - { - Configuration defaultCfg = new Configuration(); - cm = new CacheManager(defaultCfg); - - // default cache with no overrides - Cache c = cm.getCache(); - - Configuration overrides = new Configuration(); - overrides.setInvocationBatchingEnabled(true); - cm.defineCache("overridden", overrides); - Cache overridden = cm.getCache("overridden"); - - // assert components. - assert !TestingUtil.extractComponent(c, InterceptorChain.class).containsInterceptorType(BatchingInterceptor.class); - assert TestingUtil.extractComponent(overridden, InterceptorChain.class).containsInterceptorType(BatchingInterceptor.class); - } -} Deleted: core/branches/flat/src/main/java/org/horizon/manager/CacheManagerTest.java =================================================================== --- core/branches/flat/src/main/java/org/horizon/manager/CacheManagerTest.java 2009-01-16 15:14:23 UTC (rev 7488) +++ core/branches/flat/src/main/java/org/horizon/manager/CacheManagerTest.java 2009-01-16 15:17:37 UTC (rev 7489) @@ -1,69 +0,0 @@ -package org.horizon.manager; - -import org.horizon.CacheStatus; -import org.horizon.Cache; -import org.horizon.config.Configuration; -import org.testng.annotations.Test; - -/** - * @author Manik Surtani - * @since 1.0 - */ -@Test(groups = "functional") -public class CacheManagerTest -{ - public void testDefaultCache() throws CacheNameExistsException - { - CacheManager cm = new CacheManager(); - - assert cm.getCache().getCacheStatus() == CacheStatus.STARTED; - assert cm.getCache().getName().equals(CacheManager.DEFAULT_CACHE_NAME); - - try - { - cm.defineCache(CacheManager.DEFAULT_CACHE_NAME, new Configuration()); - assert false : "Should fail"; - } - catch (IllegalArgumentException e) - { - // ok - assert true : "Allowed"; - } - } - - public void testClashingNames() throws CacheNameExistsException - { - CacheManager cm = new CacheManager(); - Configuration c = new Configuration(); - - cm.defineCache("aCache", c); - try - { - cm.defineCache("aCache", c); - assert false : "Should fail"; - } - catch (CacheNameExistsException cnee) - { - // expected - assert true : "Expected"; - } - } - - public void testStartAndStop() - { - CacheManager cm = new CacheManager(); - Cache c1 = cm.getCache("cache1"); - Cache c2 = cm.getCache("cache2"); - Cache c3 = cm.getCache("cache3"); - - assert c1.getCacheStatus() == CacheStatus.STARTED; - assert c2.getCacheStatus() == CacheStatus.STARTED; - assert c3.getCacheStatus() == CacheStatus.STARTED; - - cm.stop(); - - assert c1.getCacheStatus() == CacheStatus.STOPPED; - assert c2.getCacheStatus() == CacheStatus.STOPPED; - assert c3.getCacheStatus() == CacheStatus.STOPPED; - } -} Deleted: core/branches/flat/src/main/java/org/horizon/manager/CacheManagerXmlConfigurationTest.java =================================================================== --- core/branches/flat/src/main/java/org/horizon/manager/CacheManagerXmlConfigurationTest.java 2009-01-16 15:14:23 UTC (rev 7488) +++ core/branches/flat/src/main/java/org/horizon/manager/CacheManagerXmlConfigurationTest.java 2009-01-16 15:17:37 UTC (rev 7489) @@ -1,158 +0,0 @@ -package org.horizon.manager; - -import org.horizon.Cache; -import org.horizon.config.Configuration; -import org.horizon.config.ConfigurationException; -import org.testng.annotations.AfterMethod; -import org.testng.annotations.Test; - -import java.io.ByteArrayInputStream; -import java.io.IOException; - -/** - * @author Manik Surtani - * @since 1.0 - */ -@Test(groups = "functional", sequential = true) -public class CacheManagerXmlConfigurationTest -{ - CacheManager cm; - - @AfterMethod - public void tearDown() - { - if (cm != null) cm.stop(); - } - - public void testNamedCacheXML() throws IOException - { - String xml = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n" + - "<jbosscache xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xmlns=\"urn:jboss:starobrno-core:config:1.0\">\n" + - "\n" + - " <default>\n" + - " <locking concurrencyLevel=\"100\" lockAcquisitionTimeout=\"1000\" />\n" + - " </default>\n" + - "\n" + - " <namedCache name=\"transactional\">\n" + - " <transaction transactionManagerLookupClass=\"org.jboss.starobrno.transaction.GenericTransactionManagerLookup\"/>\n" + - " </namedCache>\n" + - "\n" + - " <namedCache name=\"syncRepl\">\n" + - " <clustering>\n" + - " <stateRetrieval fetchInMemoryState=\"true\" timeout=\"15000\"/>\n" + - " <jgroupsConfig configFile=\"udp.xml\"/>\n" + - " <sync replTimeout=\"15000\"/>\n" + - " </clustering>\n" + - " </namedCache>\n" + - "\n" + - " <namedCache name=\"txSyncRepl\">\n" + - " <transaction transactionManagerLookupClass=\"org.jboss.starobrno.transaction.GenericTransactionManagerLookup\"/>\n" + - " <clustering>\n" + - " <stateRetrieval fetchInMemoryState=\"true\" timeout=\"15000\"/>\n" + - " <jgroupsConfig configFile=\"udp.xml\"/>\n" + - " <sync replTimeout=\"15000\"/>\n" + - " </clustering>\n" + - " </namedCache>\n" + - " \n" + - "</jbosscache>"; - - ByteArrayInputStream bais = new ByteArrayInputStream(xml.getBytes()); - cm = new CacheManager(bais); - - // test default cache - Cache c = cm.getCache(); - assert c.getConfiguration().getConcurrencyLevel() == 100; - assert c.getConfiguration().getLockAcquisitionTimeout() == 1000; - assert c.getConfiguration().getRuntimeConfig().getTransactionManager() == null; - assert c.getConfiguration().getRuntimeConfig().getRPCManager() == null; - - // test the "transactional" cache - c = cm.getCache("transactional"); - assert c.getConfiguration().getConcurrencyLevel() == 100; - assert c.getConfiguration().getLockAcquisitionTimeout() == 1000; - assert c.getConfiguration().getRuntimeConfig().getTransactionManager() != null; - assert c.getConfiguration().getRuntimeConfig().getRPCManager() == null; - - // test the "replicated" cache - c = cm.getCache("syncRepl"); - assert c.getConfiguration().getConcurrencyLevel() == 100; - assert c.getConfiguration().getLockAcquisitionTimeout() == 1000; - assert c.getConfiguration().getRuntimeConfig().getTransactionManager() == null; - assert c.getConfiguration().getRuntimeConfig().getRPCManager() != null; - - // test the "txSyncRepl" cache - c = cm.getCache("txSyncRepl"); - assert c.getConfiguration().getConcurrencyLevel() == 100; - assert c.getConfiguration().getLockAcquisitionTimeout() == 1000; - assert c.getConfiguration().getRuntimeConfig().getTransactionManager() != null; - assert c.getConfiguration().getRuntimeConfig().getRPCManager() != null; - } - - public void testNamedCacheXMLClashingNames() throws IOException - { - String xml = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n" + - "<jbosscache xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xmlns=\"urn:jboss:starobrno-core:config:1.0\">\n" + - "\n" + - " <default>\n" + - " <locking concurrencyLevel=\"100\" lockAcquisitionTimeout=\"1000\" />\n" + - " </default>\n" + - "\n" + - " <namedCache name=\"c1\">\n" + - " <transaction transactionManagerLookupClass=\"org.jboss.starobrno.transaction.GenericTransactionManagerLookup\"/>\n" + - " </namedCache>\n" + - "\n" + - " <namedCache name=\"c1\">\n" + - " <clustering>\n" + - " <stateRetrieval fetchInMemoryState=\"true\" timeout=\"15000\"/>\n" + - " <jgroupsConfig configFile=\"udp.xml\"/>\n" + - " <sync replTimeout=\"15000\"/>\n" + - " </clustering>\n" + - " </namedCache>\n" + - " \n" + - "</jbosscache>"; - - ByteArrayInputStream bais = new ByteArrayInputStream(xml.getBytes()); - try - { - cm = new CacheManager(bais); - assert false : "Should fail"; - } - catch (ConfigurationException expected) - { - - } - } - - public void testNamedCacheXMLClashingNamesProgrammatic() throws IOException - { - String xml = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n" + - "<jbosscache xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xmlns=\"urn:jboss:starobrno-core:config:1.0\">\n" + - "\n" + - " <default>\n" + - " <locking concurrencyLevel=\"100\" lockAcquisitionTimeout=\"1000\" />\n" + - " </default>\n" + - "\n" + - " <namedCache name=\"c1\">\n" + - " <transaction transactionManagerLookupClass=\"org.jboss.starobrno.transaction.GenericTransactionManagerLookup\"/>\n" + - " </namedCache>\n" + - "\n" + - "</jbosscache>"; - - ByteArrayInputStream bais = new ByteArrayInputStream(xml.getBytes()); - cm = new CacheManager(bais); - - assert cm.getCache() != null; - assert cm.getCache("c1") != null; - try - { - cm.defineCache("c1", new Configuration()); - assert false : "Should fail"; - } - catch (CacheNameExistsException expected) - { - - } - } -} - -