January 2009 - jbosscache-commits

JBoss Cache SVN: r7385 - core/trunk/src/main/java/org/jboss/cache/buddyreplication.

by jbosscache-commits＠lists.jboss.org

Author: mircea.markus Date: 2009-01-07 12:42:29 -0500 (Wed, 07 Jan 2009) New Revision: 7385 Modified: core/trunk/src/main/java/org/jboss/cache/buddyreplication/GravitateResult.java Log: upgraded to string Modified: core/trunk/src/main/java/org/jboss/cache/buddyreplication/GravitateResult.java =================================================================== --- core/trunk/src/main/java/org/jboss/cache/buddyreplication/GravitateResult.java 2009-01-07 09:32:46 UTC (rev 7384) +++ core/trunk/src/main/java/org/jboss/cache/buddyreplication/GravitateResult.java 2009-01-07 17:42:29 UTC (rev 7385) @@ -97,7 +97,7 @@ @Override public String toString() { - return "Result dataFound=" + dataFound + + return "GravitateResult dataFound=" + dataFound + " nodeData=" + nodeData + " fqn=" + buddyBackupFqn; }

16 years

1
0
0 / 0

Hudson build is unstable: jboss-cache-core-trunk-jdk1.5 » JBoss Cache - Core Edition #685

by jboss-qa-internal＠redhat.com

See http://hudson.qa.jboss.com/hudson/job/jboss-cache-core-trunk-jdk1.5/org.j...

16 years

1
7
0 / 0

JBoss Cache SVN: r7384 - core/trunk/src/test/java/org/jboss/cache/eviction.

by jbosscache-commits＠lists.jboss.org

Author: mircea.markus Date: 2009-01-07 04:32:46 -0500 (Wed, 07 Jan 2009) New Revision: 7384 Modified: core/trunk/src/test/java/org/jboss/cache/eviction/ProgrammaticLRUPolicyTest.java Log: more reliable evction checking Modified: core/trunk/src/test/java/org/jboss/cache/eviction/ProgrammaticLRUPolicyTest.java =================================================================== --- core/trunk/src/test/java/org/jboss/cache/eviction/ProgrammaticLRUPolicyTest.java 2009-01-06 11:18:51 UTC (rev 7383) +++ core/trunk/src/test/java/org/jboss/cache/eviction/ProgrammaticLRUPolicyTest.java 2009-01-07 09:32:46 UTC (rev 7384) @@ -23,7 +23,6 @@ package org.jboss.cache.eviction; -import org.jboss.cache.CacheFactory; import org.jboss.cache.CacheSPI; import org.jboss.cache.Fqn; import org.jboss.cache.RegionManager; @@ -41,6 +40,7 @@ import java.util.concurrent.TimeUnit; import org.jboss.cache.UnitTestCacheFactory; import org.jboss.cache.util.TestingUtil; +import org.jboss.cache.util.internals.EvictionController; /** * Unit tests for programmatic configuration of LRU policy @@ -52,26 +52,23 @@ public class ProgrammaticLRUPolicyTest extends EvictionTestsBase { CacheSPI<Object, Object> cache; + EvictionController evController; long wakeupIntervalMillis = 0; @BeforeMethod(alwaysRun = true) public void setUp() throws Exception { - initCaches(); + initCache(); wakeupIntervalMillis = cache.getConfiguration().getEvictionConfig().getWakeupInterval(); - if (wakeupIntervalMillis < 0) - { - fail("testEviction(): eviction thread wake up interval is illegal " + wakeupIntervalMillis); - } - + evController = new EvictionController(cache); } - private void initCaches() + private void initCache() { Configuration conf = UnitTestCacheConfigurationFactory.createConfiguration(Configuration.CacheMode.LOCAL, true); UnitTestCacheFactory<Object, Object> instance = new UnitTestCacheFactory<Object, Object>(); cache = (CacheSPI<Object, Object>) instance.createCache(conf, false, getClass()); - EvictionConfig erc = new EvictionConfig(new EvictionRegionConfig(Fqn.ROOT, new LRUAlgorithmConfig(0, 0, 10)), 200); + EvictionConfig erc = new EvictionConfig(new EvictionRegionConfig(Fqn.ROOT, new LRUAlgorithmConfig(0, 0, 10)), -1); conf.setEvictionConfig(erc); cache.getConfiguration().setTransactionManagerLookupClass(DummyTransactionManagerLookup.class.getName()); cache.getConfiguration().setIsolationLevel(IsolationLevel.SERIALIZABLE); @@ -115,7 +112,8 @@ String val = (String) cache.get(rootStr + "3", rootStr + "3"); assertNotNull("DataNode should be empty ", val); - assert waitForEviction(cache, 30, TimeUnit.SECONDS, Fqn.fromString(rootStr + 3)); + evController.startEviction(); + val = (String) cache.get(rootStr + "3", rootStr + "3"); assertNull("DataNode should be empty ", val); } @@ -166,7 +164,7 @@ fail("Failed to get" + e); } - assert waitForEviction(cache, 30, TimeUnit.SECONDS, fqn); + evController.startEviction(); try { @@ -184,8 +182,7 @@ { addObjectBasedRegion(); - Integer ii = 1; - Fqn rootfqn = Fqn.fromElements(ii); + Fqn rootfqn = Fqn.fromElements((Integer) 1); for (int i = 0; i < 10; i++) { Fqn fqn = Fqn.fromRelativeElements(rootfqn, i); @@ -205,7 +202,7 @@ Integer in = 3; Fqn fqn = Fqn.fromRelativeElements(rootfqn, in); Object val = cache.get(fqn, in); - assertNotNull("DataNode should be empty ", val); + assertNotNull("DataNode should not be empty ", val); } catch (Exception e) { @@ -215,7 +212,8 @@ Integer in = 3; Fqn fqn = Fqn.fromRelativeElements(rootfqn, in); - assert waitForEviction(cache, 30, TimeUnit.SECONDS, fqn); + Thread.sleep(1500);//max age is 1000, so this should expire + evController.startEviction(); try {

16 years

1
0
0 / 0

JBoss Cache SVN: r7383 - core/trunk/src/test/java/org/jboss/cache/loader.

by jbosscache-commits＠lists.jboss.org

Author: manik.surtani(a)jboss.com Date: 2009-01-06 06:18:51 -0500 (Tue, 06 Jan 2009) New Revision: 7383 Modified: core/trunk/src/test/java/org/jboss/cache/loader/CacheLoaderTestsBase.java Log: Removed setData() from public interface for micro releases. Modified: core/trunk/src/test/java/org/jboss/cache/loader/CacheLoaderTestsBase.java =================================================================== --- core/trunk/src/test/java/org/jboss/cache/loader/CacheLoaderTestsBase.java 2009-01-06 11:15:59 UTC (rev 7382) +++ core/trunk/src/test/java/org/jboss/cache/loader/CacheLoaderTestsBase.java 2009-01-06 11:18:51 UTC (rev 7383) @@ -2422,27 +2422,29 @@ return cache.getConfiguration().getRuntimeConfig().getTransactionManager(); } - public void testSetData() throws Exception - { - log.info("testSetData"); - Fqn key = Fqn.fromElements("key"); - Map<Object, Object> map = new HashMap<Object, Object>(); - Map<Object, Object> loaderMap; - map.put("a", "a"); - map.put("c", "c"); - log.info("PUT"); - cache.put(key, "x", "x"); - cache.setData(key, map); - assertEquals(map, cache.getData(key)); - log.info("GET"); - loaderMap = loader.get(key); - assertEquals(map, loaderMap); + // TODO: re-enable once we have setData() implemented in 3.1.0 - assertNull(cache.get(key, "x")); - assertEquals("c", cache.get(key, "c")); - assertEquals("a", cache.get(key, "a")); - loaderMap = loader.get(key); - assertEquals(map, loaderMap); - } +// public void testSetData() throws Exception +// { +// log.info("testSetData"); +// Fqn key = Fqn.fromElements("key"); +// Map<Object, Object> map = new HashMap<Object, Object>(); +// Map<Object, Object> loaderMap; +// map.put("a", "a"); +// map.put("c", "c"); +// log.info("PUT"); +// cache.put(key, "x", "x"); +// cache.setData(key, map); +// assertEquals(map, cache.getData(key)); +// log.info("GET"); +// loaderMap = loader.get(key); +// assertEquals(map, loaderMap); +// +// assertNull(cache.get(key, "x")); +// assertEquals("c", cache.get(key, "c")); +// assertEquals("a", cache.get(key, "a")); +// loaderMap = loader.get(key); +// assertEquals(map, loaderMap); +// } }

16 years

1
0
0 / 0

JBoss Cache SVN: r7382 - in core/trunk/src: main/java/org/jboss/cache/invocation and 1 other directories.

by jbosscache-commits＠lists.jboss.org

Author: manik.surtani(a)jboss.com Date: 2009-01-06 06:15:59 -0500 (Tue, 06 Jan 2009) New Revision: 7382 Modified: core/trunk/src/main/java/org/jboss/cache/Cache.java core/trunk/src/main/java/org/jboss/cache/invocation/CacheInvocationDelegate.java core/trunk/src/test/java/org/jboss/cache/loader/UnnecessaryLoadingSetDataTest.java Log: Removed setData() from public interface for micro releases. Modified: core/trunk/src/main/java/org/jboss/cache/Cache.java =================================================================== --- core/trunk/src/main/java/org/jboss/cache/Cache.java 2009-01-06 11:08:41 UTC (rev 7381) +++ core/trunk/src/main/java/org/jboss/cache/Cache.java 2009-01-06 11:15:59 UTC (rev 7382) @@ -543,7 +543,6 @@ * * @param i the interceptor to add * @param position the position to add the interceptor - * * @since 3.0 */ void addInterceptor(CommandInterceptor i, int position); @@ -554,7 +553,6 @@ * * @param i interceptor to add * @param afterInterceptor interceptor type after which to place custom interceptor - * * @since 3.0 */ void addInterceptor(CommandInterceptor i, Class<? extends CommandInterceptor> afterInterceptor); @@ -575,30 +573,4 @@ * @since 3.0 */ void removeInterceptor(Class<? extends CommandInterceptor> interceptorType); - - /** - * Sets all of the mappings from the specified map in a {@link Node}, replacing the - * existing data of that node, or creates a new node with the data. - * The operation is essentially the inverse of {@link #getData(Fqn)}. - * <p/> - * For caches that write to a cache loader, this operation is the most efficient, - * as the existing data need not be loaded to be merged. - * - * @param fqn <b><i>absolute</i></b> {@link Fqn} to the {@link Node} to set the data for - * @param data mappings to copy - * @throws IllegalStateException if the cache is not in a started state - * @since 3.1 - */ - void setData(Fqn fqn, Map<? extends K, ? extends V> data); - - /** - * Convenience method that takes a string representation of an Fqn. Otherwise identical to {@link #replace(Fqn, java.util.Map)} - * - * @param fqn String representation of the Fqn - * @param data data map to insert - * @throws IllegalStateException if the cache is not in a started state - * @since 3.1 - */ - void setData(String fqn, Map<? extends K, ? extends V> data); - } Modified: core/trunk/src/main/java/org/jboss/cache/invocation/CacheInvocationDelegate.java =================================================================== --- core/trunk/src/main/java/org/jboss/cache/invocation/CacheInvocationDelegate.java 2009-01-06 11:08:41 UTC (rev 7381) +++ core/trunk/src/main/java/org/jboss/cache/invocation/CacheInvocationDelegate.java 2009-01-06 11:15:59 UTC (rev 7382) @@ -23,18 +23,7 @@ import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; -import org.jboss.cache.CacheException; -import org.jboss.cache.CacheSPI; -import org.jboss.cache.CacheStatus; -import org.jboss.cache.DataContainer; -import org.jboss.cache.Fqn; -import org.jboss.cache.InvocationContext; -import org.jboss.cache.NodeNotExistsException; -import org.jboss.cache.NodeSPI; -import org.jboss.cache.RPCManager; -import org.jboss.cache.Region; -import org.jboss.cache.RegionManager; -import org.jboss.cache.Version; +import org.jboss.cache.*; import org.jboss.cache.batch.BatchContainer; import org.jboss.cache.buddyreplication.BuddyManager; import org.jboss.cache.buddyreplication.GravitateResult; @@ -381,8 +370,14 @@ { assertIsConstructed(); // assume a null ctx is meant to "un-set" the context? - if (ctx == null) invocationContextContainer.remove(); - else invocationContextContainer.set(ctx); + if (ctx == null) + { + invocationContextContainer.remove(); + } + else + { + invocationContextContainer.set(ctx); + } } public Address getLocalAddress() @@ -543,7 +538,9 @@ else { if (log.isDebugEnabled()) + { log.debug("putForExternalRead() called with Fqn " + fqn + " and this node already exists. This method is hence a no op."); + } } } @@ -608,14 +605,18 @@ public void startBatch() { if (!configuration.isInvocationBatchingEnabled()) + { throw new ConfigurationException("Invocation batching not enabled in current configuration! Please use the <invocationBatching /> element."); + } batchContainer.startBatch(); } public void endBatch(boolean successful) { if (!configuration.isInvocationBatchingEnabled()) + { throw new ConfigurationException("Invocation batching not enabled in current configuration! Please use the <invocationBatching /> element."); + } batchContainer.endBatch(successful); } @@ -627,9 +628,13 @@ GetChildrenNamesCommand command = commandsFactory.buildGetChildrenNamesCommand(fqn); Set<Object> retval = (Set<Object>) invoker.invoke(ctx, command); if (retval != null) + { retval = Immutables.immutableSetWrap(retval); // this is already copied in the command + } else + { retval = Collections.emptySet(); + } return retval; } @@ -657,8 +662,9 @@ throw new IllegalStateException("Cache not in STARTED state!"); } } - - private void invokePut(Fqn fqn, Map<? extends K, ? extends V> data, boolean erase) { + + private void invokePut(Fqn fqn, Map<? extends K, ? extends V> data, boolean erase) + { InvocationContext ctx = invocationContextContainer.get(); cacheStatusCheck(ctx); PutDataMapCommand command = commandsFactory.buildPutDataMapCommand(null, fqn, data); @@ -666,6 +672,8 @@ invoker.invoke(ctx, command); } + + // TODO: Add these to the public interface in 3.1.0. public void setData(Fqn fqn, Map<? extends K, ? extends V> data) { invokePut(fqn, data, true); Modified: core/trunk/src/test/java/org/jboss/cache/loader/UnnecessaryLoadingSetDataTest.java =================================================================== --- core/trunk/src/test/java/org/jboss/cache/loader/UnnecessaryLoadingSetDataTest.java 2009-01-06 11:08:41 UTC (rev 7381) +++ core/trunk/src/test/java/org/jboss/cache/loader/UnnecessaryLoadingSetDataTest.java 2009-01-06 11:15:59 UTC (rev 7382) @@ -1,13 +1,6 @@ package org.jboss.cache.loader; import static org.easymock.EasyMock.*; -import static org.testng.AssertJUnit.assertFalse; -import static org.testng.AssertJUnit.assertTrue; -import static org.testng.AssertJUnit.assertEquals; - -import java.util.HashMap; -import java.util.Map; - import org.jboss.cache.CacheSPI; import org.jboss.cache.Fqn; import org.jboss.cache.NodeSPI; @@ -16,16 +9,23 @@ import org.jboss.cache.config.Configuration.NodeLockingScheme; import org.jboss.cache.util.CachePrinter; import org.jboss.cache.util.TestingUtil; +import static org.testng.AssertJUnit.assertEquals; +import static org.testng.AssertJUnit.assertFalse; +import static org.testng.AssertJUnit.assertTrue; import org.testng.annotations.AfterMethod; import org.testng.annotations.DataProvider; import org.testng.annotations.Test; +import java.util.HashMap; +import java.util.Map; + /** * TODO merge with {@link UnnecessaryLoadingTest}. + * * @author Elias Ross * @since 3.0.0 */ -@Test(groups = {"functional", "mvcc"}) +@Test(groups = {"functional", "mvcc"}, enabled = false, description = "To do with the setData() method on Cache, which will only be valid in 3.1.0.GA.") public class UnnecessaryLoadingSetDataTest { private CacheSPI<Object, Object> cache; @@ -33,12 +33,13 @@ private Fqn parent = Fqn.fromString("/parent"); @DataProvider(name = "locking") - public Object[][] createData1() { - return new Object[][] { - // TODO - // { NodeLockingScheme.PESSIMISTIC }, - { NodeLockingScheme.MVCC }, - }; + public Object[][] createData1() + { + return new Object[][]{ + // TODO + // { NodeLockingScheme.PESSIMISTIC }, + {NodeLockingScheme.MVCC}, + }; } private void setUp(NodeLockingScheme locking) throws Exception @@ -56,8 +57,9 @@ reset(mockCacheLoader); } - - public static CacheLoader createMockCacheLoader() throws Exception { + + public static CacheLoader createMockCacheLoader() throws Exception + { CacheLoader mockCacheLoader = createMock(CacheLoader.class); expect(mockCacheLoader.getConfig()).andReturn(null).anyTimes(); @@ -76,7 +78,7 @@ replay(mockCacheLoader); return mockCacheLoader; } - + @AfterMethod(alwaysRun = true) public void tearDown() throws Exception { @@ -97,7 +99,7 @@ replay(mockCacheLoader); TestingUtil.killCaches(cache); - cache = null; + cache = null; } protected void assertDataLoaded(Fqn f) @@ -111,18 +113,18 @@ assertFalse("Data should not be loaded for node " + f, n != null && n.isDataLoaded()); } - @Test(dataProvider="locking") + @Test(dataProvider = "locking") public void testDontLoadWithSetData(NodeLockingScheme locking) throws Exception { System.err.println(locking); System.err.println(locking); setUp(locking); - + Map<Object, Object> m0 = new HashMap<Object, Object>(); m0.put("replace", "replace"); Map<Object, Object> m1 = new HashMap<Object, Object>(); m1.put("new", "new"); - + mockCacheLoader.put(eq(parent), eq(m0)); mockCacheLoader.put(eq(parent), eq(m1)); mockCacheLoader.put(eq(parent), eq(m0)); @@ -131,19 +133,19 @@ mockCacheLoader.exists(parent); expectLastCall().andStubThrow(new IllegalStateException("no need to call exists()")); replay(mockCacheLoader); - + assertDataNotLoaded(parent); - cache.setData(parent, m0); +// cache.setData(parent, m0); assertDataLoaded(parent); - cache.setData(parent, m1); +// cache.setData(parent, m1); assertEquals(m1, cache.peek(parent, false).getData()); - + // force removal, see if load happens cache.evict(parent); - cache.setData(parent, m0); +// cache.setData(parent, m0); // assertDataLoaded(parent); assertEquals(m0, cache.peek(parent, false).getData()); - + verify(mockCacheLoader); CachePrinter.printCacheDetails(cache); cache.toString();

16 years

1
0
0 / 0

JBoss Cache SVN: r7381 - in core/trunk/src: main/resources/config-samples and 1 other directories.

by jbosscache-commits＠lists.jboss.org

Author: manik.surtani(a)jboss.com Date: 2009-01-06 06:08:41 -0500 (Tue, 06 Jan 2009) New Revision: 7381 Modified: core/trunk/src/main/docbook/userguide/en/modules/cache_loaders.xml core/trunk/src/main/resources/config-samples/all.xml core/trunk/src/main/resources/config-samples/cacheloader-enabled.xml core/trunk/src/test/java/org/jboss/cache/config/parsing/SampleConfigFilesCorrectnessTest.java Log: Fixed broken test and updated docs Modified: core/trunk/src/main/docbook/userguide/en/modules/cache_loaders.xml =================================================================== --- core/trunk/src/main/docbook/userguide/en/modules/cache_loaders.xml 2009-01-05 17:54:59 UTC (rev 7380) +++ core/trunk/src/main/docbook/userguide/en/modules/cache_loaders.xml 2009-01-06 11:08:41 UTC (rev 7381) @@ -1,152 +1,152 @@ <chapter id="cache_loaders"> - <title>Cache Loaders</title> - <para>JBoss Cache can use a - <literal>CacheLoader</literal> - to back up the in-memory cache to a backend datastore. - If JBoss Cache is configured with a cache loader, then the following features are provided: - <itemizedlist> - <listitem>Whenever a cache element is accessed, and that element is not in - the cache (e.g. due to eviction or due to server restart), then the cache loader transparently - loads the element into the cache if found in the backend - store. - </listitem> + <title>Cache Loaders</title> + <para>JBoss Cache can use a + <literal>CacheLoader</literal> + to back up the in-memory cache to a backend datastore. + If JBoss Cache is configured with a cache loader, then the following features are provided: + <itemizedlist> + <listitem>Whenever a cache element is accessed, and that element is not in + the cache (e.g. due to eviction or due to server restart), then the cache loader transparently + loads the element into the cache if found in the backend + store. + </listitem> - <listitem>Whenever an element is modified, added or removed, then that - modification is persisted in the backend store via the cache loader. If - transactions are used, all modifications created within a transaction - are persisted. To this end, the - <literal>CacheLoader</literal> - takes part in the two - phase commit protocol run by the transaction manager, although it does not do so explicitly. - </listitem> - </itemizedlist> - </para> + <listitem>Whenever an element is modified, added or removed, then that + modification is persisted in the backend store via the cache loader. If + transactions are used, all modifications created within a transaction + are persisted. To this end, the + <literal>CacheLoader</literal> + takes part in the two + phase commit protocol run by the transaction manager, although it does not do so explicitly. + </listitem> + </itemizedlist> + </para> - <section> - <title>The CacheLoader Interface and Lifecycle</title> + <section> + <title>The CacheLoader Interface and Lifecycle</title> - <figure> - <title>The CacheLoader interface</title> + <figure> + <title>The CacheLoader interface</title> - <mediaobject> - <imageobject> - <imagedata fileref="CacheLoader.png"/> - </imageobject> - </mediaobject> - </figure> + <mediaobject> + <imageobject> + <imagedata fileref="CacheLoader.png"/> + </imageobject> + </mediaobject> + </figure> - <para>The interaction between JBoss Cache and a - <literal>CacheLoader</literal> - implementation is as follows. When - <literal>CacheLoaderConfiguration</literal> - (see below) is non-null, an - instance of each configured - <literal>CacheLoader</literal> - is created when the cache is created, and started when the cache is started. - </para> + <para>The interaction between JBoss Cache and a + <literal>CacheLoader</literal> + implementation is as follows. When + <literal>CacheLoaderConfiguration</literal> + (see below) is non-null, an + instance of each configured + <literal>CacheLoader</literal> + is created when the cache is created, and started when the cache is started. + </para> - <para> - <literal>CacheLoader.create()</literal> - and - <literal>CacheLoader.start()</literal> - are called when the cache is - started. Correspondingly, - <literal>stop()</literal> - and - <literal>destroy()</literal> - are called when the cache is - stopped. - </para> + <para> + <literal>CacheLoader.create()</literal> + and + <literal>CacheLoader.start()</literal> + are called when the cache is + started. Correspondingly, + <literal>stop()</literal> + and + <literal>destroy()</literal> + are called when the cache is + stopped. + </para> - <para>Next, - <literal>setConfig()</literal> - and - <literal>setCache()</literal> - are called. The latter can be used to - store a reference to the cache, the former is used to configure this - instance of the - <literal>CacheLoader</literal> - . For example, here a database cache loader - could establish a connection to the database. - </para> + <para>Next, + <literal>setConfig()</literal> + and + <literal>setCache()</literal> + are called. The latter can be used to + store a reference to the cache, the former is used to configure this + instance of the + <literal>CacheLoader</literal> + . For example, here a database cache loader + could establish a connection to the database. + </para> - <para>The - <literal>CacheLoader</literal> - interface has a set of methods that are called - when no transactions are used: - <literal>get()</literal> - , - <literal>put()</literal> - , - <literal>remove()</literal> - and - <literal>removeData()</literal> - : they get/set/remove the value - immediately. These methods are described as javadoc comments in the - interface. - </para> + <para>The + <literal>CacheLoader</literal> + interface has a set of methods that are called + when no transactions are used: + <literal>get()</literal> + , + <literal>put()</literal> + , + <literal>remove()</literal> + and + <literal>removeData()</literal> + : they get/set/remove the value + immediately. These methods are described as javadoc comments in the + interface. + </para> - <para>Then there are three methods that are used with transactions: - <literal>prepare()</literal> - , - <literal>commit()</literal> - and - <literal>rollback()</literal> - . The - <literal>prepare()</literal> - method - is called when a transaction is to be committed. It has a transaction - object and a list of modfications as argument. The transaction object - can be used as a key into a hashmap of transactions, where the values - are the lists of modifications. Each modification list has a number of - <literal>Modification</literal> - elements, which represent the changes - made to a cache for a given transaction. When - <literal>prepare()</literal> - returns successfully, then the cache loader - <emphasis>must</emphasis> - be able to commit (or rollback) the - transaction successfully. - </para> + <para>Then there are three methods that are used with transactions: + <literal>prepare()</literal> + , + <literal>commit()</literal> + and + <literal>rollback()</literal> + . The + <literal>prepare()</literal> + method + is called when a transaction is to be committed. It has a transaction + object and a list of modfications as argument. The transaction object + can be used as a key into a hashmap of transactions, where the values + are the lists of modifications. Each modification list has a number of + <literal>Modification</literal> + elements, which represent the changes + made to a cache for a given transaction. When + <literal>prepare()</literal> + returns successfully, then the cache loader + <emphasis>must</emphasis> + be able to commit (or rollback) the + transaction successfully. + </para> - <para> - JBoss Cache takes care of calling prepare(), commit() - and rollback() on the cache loaders at the right time. - </para> + <para> + JBoss Cache takes care of calling prepare(), commit() + and rollback() on the cache loaders at the right time. + </para> - <para>The - <literal>commit()</literal> - method tells the cache loader to - commit the transaction, and the - <literal>rollback()</literal> - method - tells the cache loader to discard the changes associated with that - transaction. - </para> + <para>The + <literal>commit()</literal> + method tells the cache loader to + commit the transaction, and the + <literal>rollback()</literal> + method + tells the cache loader to discard the changes associated with that + transaction. + </para> - <para>See the javadocs on this interface for a detailed explanation on each method and the contract - implementations would need to fulfill. - </para> + <para>See the javadocs on this interface for a detailed explanation on each method and the contract + implementations would need to fulfill. + </para> - </section> + </section> - <section> - <title>Configuration</title> + <section> + <title>Configuration</title> - <para>Cache loaders are configured as follows in the JBoss Cache XML - file. Note that you can define several cache loaders, in - a chain. The impact is that the cache will look at all of the cache - loaders in the order they've been configured, until it finds a valid, - non-null element of data. When performing writes, all cache loaders are - written to (except if the - <literal>ignoreModifications</literal> - element has been set to - <literal>true</literal> - for a specific cache loader. See the configuration section below for - details. - </para> + <para>Cache loaders are configured as follows in the JBoss Cache XML + file. Note that you can define several cache loaders, in + a chain. The impact is that the cache will look at all of the cache + loaders in the order they've been configured, until it finds a valid, + non-null element of data. When performing writes, all cache loaders are + written to (except if the + <literal>ignoreModifications</literal> + element has been set to + <literal>true</literal> + for a specific cache loader. See the configuration section below for + details. + </para> - <programlisting role="XML"><![CDATA[ + <programlisting role="XML"><![CDATA[ ...  @@ -170,138 +170,139 @@ </loaders> ]]></programlisting> - <para>The - <literal>class</literal> - element defines the - class of the cache loader implementation. (Note that, because of a bug in - the properties editor in JBoss AS, backslashes in variables for Windows - filenames might not get expanded correctly, so replace="false" may be - necessary). Note that an implementation of cache loader has to have an empty - constructor. - </para> + <para>The + <literal>class</literal> + element defines the + class of the cache loader implementation. (Note that, because of a bug in + the properties editor in JBoss AS, backslashes in variables for Windows + filenames might not get expanded correctly, so replace="false" may be + necessary). Note that an implementation of cache loader has to have an empty + constructor. + </para> - <para>The - <literal>properties</literal> - element defines a configuration - specific to the given implementation. The filesystem-based - implementation for example defines the root directory to be used, - whereas a database implementation might define the database URL, name - and password to establish a database connection. This configuration is - passed to the cache loader implementation via - <literal>CacheLoader.setConfig(Properties)</literal> - . Note that - backspaces may have to be escaped. - </para> + <para>The + <literal>properties</literal> + element defines a configuration + specific to the given implementation. The filesystem-based + implementation for example defines the root directory to be used, + whereas a database implementation might define the database URL, name + and password to establish a database connection. This configuration is + passed to the cache loader implementation via + <literal>CacheLoader.setConfig(Properties)</literal> + . Note that + backspaces may have to be escaped. + </para> - <para> - <literal>preload</literal> - allows us to define a list of nodes, or - even entire subtrees, that are visited by the cache on startup, in order - to preload the data associated with those nodes. The default ("/") loads - the entire data available in the backend store into the cache, which is - probably not a good idea given that the data in the backend store might - be large. As an example, - <literal>/a, - /product/catalogue - </literal> - loads the subtrees - <literal>/a</literal> - and - <literal>/product/catalogue</literal> - into the cache, but nothing - else. Anything else is loaded lazily when accessed. Preloading makes - sense when one anticipates using elements under a given subtree - frequently. - . - </para> + <para> + <literal>preload</literal> + allows us to define a list of nodes, or + even entire subtrees, that are visited by the cache on startup, in order + to preload the data associated with those nodes. The default ("/") loads + the entire data available in the backend store into the cache, which is + probably not a good idea given that the data in the backend store might + be large. As an example, + <literal>/a, + /product/catalogue + </literal> + loads the subtrees + <literal>/a</literal> + and + <literal>/product/catalogue</literal> + into the cache, but nothing + else. Anything else is loaded lazily when accessed. Preloading makes + sense when one anticipates using elements under a given subtree + frequently. + . + </para> - <para> - <literal>fetchPersistentState</literal> - determines whether or not - to fetch the persistent state of a cache when joining a cluster. Only - one configured cache loader may set this property to true; if more than - one cache loader does so, a configuration exception will be thrown when - starting your cache service. - </para> + <para> + <literal>fetchPersistentState</literal> + determines whether or not + to fetch the persistent state of a cache when joining a cluster. Only + one configured cache loader may set this property to true; if more than + one cache loader does so, a configuration exception will be thrown when + starting your cache service. + </para> - <para> - <literal>async</literal> - determines whether writes to the cache - loader block until completed, or are run on a separate thread so writes - return immediately. If this is set to true, an instance of - <literal>org.jboss.cache.loader.AsyncCacheLoader</literal> - is - constructed with an instance of the actual cache loader to be used. The - <literal>AsyncCacheLoader</literal> - then delegates all requests to the - underlying cache loader, using a separate thread if necessary. See the - Javadocs on - <literal>AsyncCacheLoader</literal> - for more details. If unspecified, the - <literal>async</literal> - element - defaults to - <literal>false</literal> - . - </para> + <para> + <literal>async</literal> + determines whether writes to the cache + loader block until completed, or are run on a separate thread so writes + return immediately. If this is set to true, an instance of + <literal>org.jboss.cache.loader.AsyncCacheLoader</literal> + is + constructed with an instance of the actual cache loader to be used. The + <literal>AsyncCacheLoader</literal> + then delegates all requests to the + underlying cache loader, using a separate thread if necessary. See the + Javadocs on + <literal>AsyncCacheLoader</literal> + for more details. If unspecified, the + <literal>async</literal> + element + defaults to + <literal>false</literal> + . + </para> - <para> - <emphasis role="bold">Note on using the + <para> + <emphasis role="bold">Note on using the + <literal>async</literal> + element: + </emphasis> + there is always the possibility of dirty reads since + all writes are performed asynchronously, and it is thus impossible to + guarantee when (and even if) a write succeeds. This needs to be kept in + mind when setting the <literal>async</literal> - element: - </emphasis> - there is always the possibility of dirty reads since - all writes are performed asynchronously, and it is thus impossible to - guarantee when (and even if) a write succeeds. This needs to be kept in - mind when setting the - <literal>async</literal> - element to true. - </para> + element to true. + </para> - <para> - <literal>ignoreModifications</literal> - determines whether write - methods are pushed down to the specific cache loader. Situations may - arise where transient application data should only reside in a file - based cache loader on the same server as the in-memory cache, for - example, with a further shared - <literal>JDBCCacheLoader</literal> - used by all servers in - the network. This feature allows you to write to the 'local' file cache - loader but not the shared - <literal>JDBCCacheLoader</literal> - . This property defaults to - <literal>false</literal> - , so writes are propagated to all cache loaders - configured. - </para> + <para> + <literal>ignoreModifications</literal> + determines whether write + methods are pushed down to the specific cache loader. Situations may + arise where transient application data should only reside in a file + based cache loader on the same server as the in-memory cache, for + example, with a further shared + <literal>JDBCCacheLoader</literal> + used by all servers in + the network. This feature allows you to write to the 'local' file cache + loader but not the shared + <literal>JDBCCacheLoader</literal> + . This property defaults to + <literal>false</literal> + , so writes are propagated to all cache loaders + configured. + </para> - <para> - <literal>purgeOnStatup</literal> - empties the specified cache loader - (if - <literal>ignoreModifications</literal> - is - <literal>false</literal> - ) - when the cache loader starts up. - </para> + <para> + <literal>purgeOnStatup</literal> + empties the specified cache loader + (if + <literal>ignoreModifications</literal> + is + <literal>false</literal> + ) + when the cache loader starts up. + </para> - <para> - <literal>shared</literal> - indicates that the cache loader is shared among different cache instances, for example where all instances in a - cluster use the same JDBC settings t talk to the same remote, shared database. Setting this to - <literal>true</literal> - prevents repeated and unnecessary writes of the same data to the cache loader by different cache instances. - Default value is - <literal>false</literal> - . - </para> + <para> + <literal>shared</literal> + indicates that the cache loader is shared among different cache instances, for example where all instances + in a + cluster use the same JDBC settings t talk to the same remote, shared database. Setting this to + <literal>true</literal> + prevents repeated and unnecessary writes of the same data to the cache loader by different cache instances. + Default value is + <literal>false</literal> + . + </para> - <section id="sscl"> - <title>Singleton Store Configuration</title> + <section id="sscl"> + <title>Singleton Store Configuration</title> - <programlisting role="XML"><![CDATA[ + <programlisting role="XML"><![CDATA[ <loaders passivation="false" shared="true"> <preload> <node fqn="/a/b/c"/> @@ -322,458 +323,468 @@ </singletonStore> </loader> </loaders> - ]]></programlisting> - <para> - <literal>singletonStore</literal> - element enables modifications to be stored by only one node in the cluster, - the coordinator. Essentially, whenever any data comes in to some node - it is always replicated so as to keep the caches' in-memory states in - sync; the coordinator, though, has the sole responsibility of pushing - that state to disk. This functionality can be activated setting the - <literal>enabled</literal> - subelement to true in all nodes, but - again only the coordinator of the cluster will store the modifications - in the underlying cache loader as defined in - <literal>loader</literal> - element. You cannot define a cache loader as - <literal>shared</literal> - and with - <literal>singletonStore</literal> - enabled at the same time. - Default value for - <literal>enabled</literal> - is - <literal>false</literal> - . - </para> + ]]></programlisting> + <para> + <literal>singletonStore</literal> + element enables modifications to be stored by only one node in the cluster, + the coordinator. Essentially, whenever any data comes in to some node + it is always replicated so as to keep the caches' in-memory states in + sync; the coordinator, though, has the sole responsibility of pushing + that state to disk. This functionality can be activated setting the + <literal>enabled</literal> + subelement to true in all nodes, but + again only the coordinator of the cluster will store the modifications + in the underlying cache loader as defined in + <literal>loader</literal> + element. You cannot define a cache loader as + <literal>shared</literal> + and with + <literal>singletonStore</literal> + enabled at the same time. + Default value for + <literal>enabled</literal> + is + <literal>false</literal> + . + </para> - <para> - Optionally, within the - <literal>singletonStore</literal> - element, you can define a - <literal>class</literal> - element that specifies the implementation class that provides the - singleton store functionality. This class must extend - <literal>org.jboss.cache.loader.AbstractDelegatingCacheLoader</literal> - , and if absent, it defaults to - <literal>org.jboss.cache.loader.SingletonStoreCacheLoader</literal> - . - </para> + <para> + Optionally, within the + <literal>singletonStore</literal> + element, you can define a + <literal>class</literal> + element that specifies the implementation class that provides the + singleton store functionality. This class must extend + <literal>org.jboss.cache.loader.AbstractDelegatingCacheLoader</literal> + , and if absent, it defaults to + <literal>org.jboss.cache.loader.SingletonStoreCacheLoader</literal> + . + </para> - <para> - The - <literal>properties</literal> - subelement defines properties that allow changing the behavior of the - class providing the singleton store functionality. By default, - <literal>pushStateWhenCoordinator</literal> - and - <literal>pushStateWhenCoordinatorTimeout</literal> - properties have been defined, but more could be added as - required by the user-defined class providing singleton store - functionality. - </para> + <para> + The + <literal>properties</literal> + subelement defines properties that allow changing the behavior of the + class providing the singleton store functionality. By default, + <literal>pushStateWhenCoordinator</literal> + and + <literal>pushStateWhenCoordinatorTimeout</literal> + properties have been defined, but more could be added as + required by the user-defined class providing singleton store + functionality. + </para> - <para> - <literal>pushStateWhenCoordinator</literal> - allows the in-memory - state to be pushed to the cache store when a node becomes the - coordinator, as a result of the new election of coordinator due to a - cluster topology change. This can be very useful in situations where the - coordinator crashes and there's a gap in time until the new coordinator - is elected. During this time, if this property was set to - <literal>false</literal> - and the - cache was updated, these changes would never be persisted. Setting this - property to - <literal>true</literal> - would ensure that any changes during this process also - get stored in the cache loader. You would also want to set this property - to - <literal>true</literal> - if each node's cache loader is configured with a different - location. Default value is - <literal>true</literal> - . - </para> + <para> + <literal>pushStateWhenCoordinator</literal> + allows the in-memory + state to be pushed to the cache store when a node becomes the + coordinator, as a result of the new election of coordinator due to a + cluster topology change. This can be very useful in situations where the + coordinator crashes and there's a gap in time until the new coordinator + is elected. During this time, if this property was set to + <literal>false</literal> + and the + cache was updated, these changes would never be persisted. Setting this + property to + <literal>true</literal> + would ensure that any changes during this process also + get stored in the cache loader. You would also want to set this property + to + <literal>true</literal> + if each node's cache loader is configured with a different + location. Default value is + <literal>true</literal> + . + </para> - <para> - <literal>pushStateWhenCoordinatorTimeout</literal> - is only relevant if - <literal>pushStateWhenCoordinator</literal> - is - <literal>true</literal> - in which case, sets the maximum number of milliseconds that the process - of pushing the in-memory state to the underlying cache loader should take, - reporting a - <literal>PushStateException</literal> - if exceeded. Default value is 20000. - </para> + <para> + <literal>pushStateWhenCoordinatorTimeout</literal> + is only relevant if + <literal>pushStateWhenCoordinator</literal> + is + <literal>true</literal> + in which case, sets the maximum number of milliseconds that the process + of pushing the in-memory state to the underlying cache loader should take, + reporting a + <literal>PushStateException</literal> + if exceeded. Default value is 20000. + </para> - <para> - <emphasis role="bold">Note on using the - <literal>singletonStore</literal> - element: - </emphasis> - setting - up a cache loader as a singleton and using cache passivation (via - evictions) can lead to undesired effects. If a node is to be passivated - as a result of an eviction, while the cluster is in the process of - electing a new coordinator, the data will be lost. This is because no - coordinator is active at that time and therefore, none of the nodes in - the cluster will store the passivated node. A new coordinator is elected - in the cluster when either, the coordinator leaves the cluster, the - coordinator crashes or stops responding. - </para> - </section> + <para> + <emphasis role="bold">Note on using the + <literal>singletonStore</literal> + element: + </emphasis> + setting + up a cache loader as a singleton and using cache passivation (via + evictions) can lead to undesired effects. If a node is to be passivated + as a result of an eviction, while the cluster is in the process of + electing a new coordinator, the data will be lost. This is because no + coordinator is active at that time and therefore, none of the nodes in + the cluster will store the passivated node. A new coordinator is elected + in the cluster when either, the coordinator leaves the cluster, the + coordinator crashes or stops responding. + </para> + </section> - </section> + </section> - <section id="cl.impls"> + <section id="cl.impls"> - <title>Shipped Implementations</title> + <title>Shipped Implementations</title> - <para>The currently available implementations shipped with JBoss Cache are as follows.</para> + <para>The currently available implementations shipped with JBoss Cache are as follows.</para> - <section> - <title>File system based cache loaders</title> - <para> - JBoss Cache ships with several cache loaders that utilize the file system as a data store. They all require - that the - <literal><![CDATA[<loader><properties>]]></literal> - configuration element - contains a - <literal>location</literal> - property, which maps to a directory to be used as a persistent store. - (e.g., - <literal>location=/tmp/myDataStore</literal> - ). Used mainly for testing and not recommended for production use. - </para> - <itemizedlist> - <listitem> - <para> - <literal>FileCacheLoader</literal> - , which is a simple filesystem-based implementation. By default, this cache - loader checks for any potential character portability issues in the - location or tree node names, for example invalid characters, producing - warning messages. These checks can be disabled adding - <literal>check.character.portability</literal> - property to the - <literal><![CDATA[<properties>]]></literal> - element and setting it to - <literal>false</literal> - (e.g., - <literal>check.character.portability=false</literal> - ). - </para> - <para> - The FileCacheLoader has some severe limitations which restrict its use in a production - environment, or if used in such an environment, it should be used with due care and sufficient - understanding of these limitations. - <itemizedlist> - <listitem>Due to the way the FileCacheLoader represents a tree structure on disk (directories and - files) traversal is inefficient for deep trees. - </listitem> - <listitem>Usage on shared filesystems like NFS, Windows shares, etc. should be avoided as these do - not implement proper file locking and can cause data corruption. - </listitem> - <listitem>Usage with an isolation level of NONE can cause corrupt writes as multiple threads - attempt to write to the same file. - </listitem> - <listitem>File systems are inherently not transactional, so when attempting to use your cache in a - transactional context, failures when writing to the file (which happens during the commit phase) - cannot be recovered. - </listitem> - </itemizedlist> + <section> + <title>File system based cache loaders</title> + <para> + JBoss Cache ships with several cache loaders that utilize the file system as a data store. They all + require + that the + <literal><![CDATA[<loader><properties>]]></literal> + configuration element + contains a + <literal>location</literal> + property, which maps to a directory to be used as a persistent store. + (e.g., + <literal>location=/tmp/myDataStore</literal> + ). Used mainly for testing and not recommended for production use. + </para> + <itemizedlist> + <listitem> + <para> + <literal>FileCacheLoader</literal> + , which is a simple filesystem-based implementation. By default, this cache + loader checks for any potential character portability issues in the + location or tree node names, for example invalid characters, producing + warning messages. These checks can be disabled adding + <literal>check.character.portability</literal> + property to the + <literal><![CDATA[<properties>]]></literal> + element and setting it to + <literal>false</literal> + (e.g., + <literal>check.character.portability=false</literal> + ). + </para> + <para> + The FileCacheLoader has some severe limitations which restrict its use in a production + environment, or if used in such an environment, it should be used with due care and sufficient + understanding of these limitations. + <itemizedlist> + <listitem>Due to the way the FileCacheLoader represents a tree structure on disk + (directories and + files) traversal is inefficient for deep trees. + </listitem> + <listitem>Usage on shared filesystems like NFS, Windows shares, etc. should be avoided as + these do + not implement proper file locking and can cause data corruption. + </listitem> + <listitem>Usage with an isolation level of NONE can cause corrupt writes as multiple threads + attempt to write to the same file. + </listitem> + <listitem>File systems are inherently not transactional, so when attempting to use your + cache in a + transactional context, failures when writing to the file (which happens during the + commit phase) + cannot be recovered. + </listitem> + </itemizedlist> - As a rule of thumb, it is recommended that the FileCacheLoader not be used in a highly concurrent, - transactional or stressful environment, and its use is restricted to testing. - </para> - </listitem> + As a rule of thumb, it is recommended that the FileCacheLoader not be used in a highly + concurrent, + transactional or stressful environment, and its use is restricted to testing. + </para> + </listitem> - <listitem> - <para> - <literal>BdbjeCacheLoader</literal> - , which is a cache loader implementation based on the Oracle/Sleepycat's - <ulink url="http://www.oracle.com/database/berkeley-db/index.html">BerkeleyDB Java Edition</ulink> - . - </para> - </listitem> + <listitem> + <para> + <literal>BdbjeCacheLoader</literal> + , which is a cache loader implementation based on the Oracle/Sleepycat's + <ulink url="http://www.oracle.com/database/berkeley-db/index.html">BerkeleyDB Java Edition + </ulink> + . + </para> + </listitem> - <listitem> - <para> - <literal>JdbmCacheLoader</literal> - , which is a cache loader - implementation based on the - <ulink url="http://jdbm.sourceforge.net/">JDBM engine</ulink> - , a fast and free alternative to - BerkeleyDB. - </para> - </listitem> - </itemizedlist> + <listitem> + <para> + <literal>JdbmCacheLoader</literal> + , which is a cache loader + implementation based on the + <ulink url="http://jdbm.sourceforge.net/">JDBM engine</ulink> + , a fast and free alternative to + BerkeleyDB. + </para> + </listitem> + </itemizedlist> - <para>Note that the BerkeleyDB implementation is much more efficient than - the filesystem-based implementation, and provides transactional - guarantees, but requires a commercial license if distributed with an - application (see http://www.oracle.com/database/berkeley-db/index.html for - details). - </para> + <para>Note that the BerkeleyDB implementation is much more efficient than + the filesystem-based implementation, and provides transactional + guarantees, but requires a commercial license if distributed with an + application (see http://www.oracle.com/database/berkeley-db/index.html for + details). + </para> - </section> + </section> - <section> - <title>Cache loaders that delegate to other caches</title> - <itemizedlist> - <listitem> - <para> - <literal>LocalDelegatingCacheLoader</literal> - , which enables - loading from and storing to another local (same JVM) cache. - </para> - </listitem> - <listitem> - <para> - <literal>ClusteredCacheLoader</literal> - , which allows querying - of other caches in the same cluster for in-memory data via the same - clustering protocols used to replicate data. Writes are - <emphasis>not</emphasis> - 'stored' though, as replication would - take care of any updates needed. You need to specify a property - called - <literal>timeout</literal> - , a long value telling the cache - loader how many milliseconds to wait for responses from the cluster - before assuming a null value. For example, - <literal>timeout = 3000</literal> - would use a timeout value of 3 seconds. - </para> - </listitem> - </itemizedlist> - </section> + <section> + <title>Cache loaders that delegate to other caches</title> + <itemizedlist> + <listitem> + <para> + <literal>LocalDelegatingCacheLoader</literal> + , which enables + loading from and storing to another local (same JVM) cache. + </para> + </listitem> + <listitem> + <para> + <literal>ClusteredCacheLoader</literal> + , which allows querying + of other caches in the same cluster for in-memory data via the same + clustering protocols used to replicate data. Writes are + <emphasis>not</emphasis> + 'stored' though, as replication would + take care of any updates needed. You need to specify a property + called + <literal>timeout</literal> + , a long value telling the cache + loader how many milliseconds to wait for responses from the cluster + before assuming a null value. For example, + <literal>timeout = 3000</literal> + would use a timeout value of 3 seconds. + </para> + </listitem> + </itemizedlist> + </section> - <section id="cl.jdbc"> - <title>JDBCCacheLoader</title> + <section id="cl.jdbc"> + <title>JDBCCacheLoader</title> - <para>JBossCache is distributed with a JDBC-based cache loader - implementation that stores/loads nodes' state into a relational database. - The implementing class is - <literal>org.jboss.cache.loader.JDBCCacheLoader</literal> - . - </para> + <para>JBossCache is distributed with a JDBC-based cache loader + implementation that stores/loads nodes' state into a relational database. + The implementing class is + <literal>org.jboss.cache.loader.JDBCCacheLoader</literal> + . + </para> - <para>The current implementation uses just one table. Each row in the table - represents one node and contains three columns: - <itemizedlist> - <listitem>column for - <literal>Fqn</literal> - (which is also a primary key - column) - </listitem> + <para>The current implementation uses just one table. Each row in the table + represents one node and contains three columns: + <itemizedlist> + <listitem>column for + <literal>Fqn</literal> + (which is also a primary key + column) + </listitem> - <listitem>column for node contents (attribute/value - pairs) - </listitem> + <listitem>column for node contents (attribute/value + pairs) + </listitem> - <listitem>column for parent - <literal>Fqn</literal> - </listitem> - </itemizedlist> - </para> + <listitem>column for parent + <literal>Fqn</literal> + </listitem> + </itemizedlist> + </para> - <para> - <literal>Fqn</literal>s are stored as strings. Node content is stored - as a BLOB. - <emphasis>WARNING:</emphasis> - JBoss Cache does not impose any - limitations on the types of objects used in - <literal>Fqn</literal> - but this implementation of - cache loader requires - <literal>Fqn</literal> - to contain only objects of type - <literal>java.lang.String</literal> - . Another limitation for - <literal>Fqn</literal> - is its - length. Since - <literal>Fqn</literal> - is a primary key, its default column type is - <literal>VARCHAR</literal> - which can store text values up to some - maximum length determined by the database in use. - </para> + <para> + <literal>Fqn</literal>s are stored as strings. Node content is stored + as a BLOB. + <emphasis>WARNING:</emphasis> + JBoss Cache does not impose any + limitations on the types of objects used in + <literal>Fqn</literal> + but this implementation of + cache loader requires + <literal>Fqn</literal> + to contain only objects of type + <literal>java.lang.String</literal> + . Another limitation for + <literal>Fqn</literal> + is its + length. Since + <literal>Fqn</literal> + is a primary key, its default column type is + <literal>VARCHAR</literal> + which can store text values up to some + maximum length determined by the database in use. + </para> - <para>See - <ulink url="http://www.jboss.org/community/docs/DOC-10864">this wiki page</ulink> - for configuration tips with specific database systems. - </para> + <para>See + <ulink url="http://www.jboss.org/community/docs/DOC-10864">this wiki page</ulink> + for configuration tips with specific database systems. + </para> - <section> - <title>JDBCCacheLoader configuration</title> - <section> - <title>Table configuration</title> + <title>JDBCCacheLoader configuration</title> - <para>Table and column names as well as column types are - configurable with the following properties. - <itemizedlist> - <listitem> - <emphasis>cache.jdbc.table.name</emphasis> - - the name - of the table. Can be prepended with schema name for the given table: - <literal>{schema_name}.{table_name}</literal>. - The default value is 'jbosscache'. - </listitem> + <section> + <title>Table configuration</title> - <listitem> - <emphasis>cache.jdbc.table.primarykey</emphasis> - - the - name of the primary key for the table. The default value is - 'jbosscache_pk'. - </listitem> + <para>Table and column names as well as column types are + configurable with the following properties. + <itemizedlist> + <listitem> + <emphasis>cache.jdbc.table.name</emphasis> + - the name + of the table. Can be prepended with schema name for the given table: + <literal>{schema_name}.{table_name}</literal>. + The default value is 'jbosscache'. + </listitem> - <listitem> - <emphasis>cache.jdbc.table.create</emphasis> - - can be - true or false. Indicates whether to create the table during startup. - If true, the table is created if it doesn't already exist. The - default value is true. - </listitem> + <listitem> + <emphasis>cache.jdbc.table.primarykey</emphasis> + - the + name of the primary key for the table. The default value is + 'jbosscache_pk'. + </listitem> - <listitem> - <emphasis>cache.jdbc.table.drop</emphasis> - - can be - true or false. Indicates whether to drop the table during shutdown. The - default value is true. - </listitem> + <listitem> + <emphasis>cache.jdbc.table.create</emphasis> + - can be + true or false. Indicates whether to create the table during startup. + If true, the table is created if it doesn't already exist. The + default value is true. + </listitem> - <listitem> - <emphasis>cache.jdbc.fqn.column</emphasis> - - FQN - column name. The default value is 'fqn'. - </listitem> + <listitem> + <emphasis>cache.jdbc.table.drop</emphasis> + - can be + true or false. Indicates whether to drop the table during shutdown. The + default value is true. + </listitem> - <listitem> - <emphasis>cache.jdbc.fqn.type</emphasis> - - FQN column - type. The default value is 'varchar(255)'. - </listitem> + <listitem> + <emphasis>cache.jdbc.fqn.column</emphasis> + - FQN + column name. The default value is 'fqn'. + </listitem> - <listitem> - <emphasis>cache.jdbc.node.column</emphasis> - - node - contents column name. The default value is 'node'. - </listitem> + <listitem> + <emphasis>cache.jdbc.fqn.type</emphasis> + - FQN column + type. The default value is 'varchar(255)'. + </listitem> - <listitem> - <emphasis>cache.jdbc.node.type</emphasis> - - node - contents column type. The default value is 'blob'. This type must specify - a valid binary data type for the database being used. - </listitem> - </itemizedlist> - </para> - </section> + <listitem> + <emphasis>cache.jdbc.node.column</emphasis> + - node + contents column name. The default value is 'node'. + </listitem> - <section> - <title>DataSource</title> + <listitem> + <emphasis>cache.jdbc.node.type</emphasis> + - node + contents column type. The default value is 'blob'. This type must specify + a valid binary data type for the database being used. + </listitem> + </itemizedlist> + </para> + </section> - <para>If you are using JBossCache in a managed environment (e.g., an - application server) you can specify the JNDI name of the DataSource - you want to use. - <itemizedlist> - <listitem> - <emphasis>cache.jdbc.datasource</emphasis> - - JNDI name - of the DataSource. The default value is - <literal>java:/DefaultDS</literal> - . - </listitem> - </itemizedlist> - </para> - </section> + <section> + <title>DataSource</title> - <section> - <title>JDBC driver</title> + <para>If you are using JBossCache in a managed environment (e.g., an + application server) you can specify the JNDI name of the DataSource + you want to use. + <itemizedlist> + <listitem> + <emphasis>cache.jdbc.datasource</emphasis> + - JNDI name + of the DataSource. The default value is + <literal>java:/DefaultDS</literal> + . + </listitem> + </itemizedlist> + </para> + </section> - <para>If you are - <emphasis>not</emphasis> - using DataSource you have - the following properties to configure database access using a JDBC - driver. - <itemizedlist> - <listitem> - <emphasis>cache.jdbc.driver</emphasis> - - fully - qualified JDBC driver name. - </listitem> + <section> + <title>JDBC driver</title> - <listitem> - <emphasis>cache.jdbc.url</emphasis> - - URL to connect - to the database. - </listitem> + <para>If you are + <emphasis>not</emphasis> + using DataSource you have + the following properties to configure database access using a JDBC + driver. + <itemizedlist> + <listitem> + <emphasis>cache.jdbc.driver</emphasis> + - fully + qualified JDBC driver name. + </listitem> - <listitem> - <emphasis>cache.jdbc.user</emphasis> - - user name to - connect to the database. - </listitem> + <listitem> + <emphasis>cache.jdbc.url</emphasis> + - URL to connect + to the database. + </listitem> - <listitem> - <emphasis>cache.jdbc.password</emphasis> - - password to - connect to the database. - </listitem> - </itemizedlist> - </para> - </section> + <listitem> + <emphasis>cache.jdbc.user</emphasis> + - user name to + connect to the database. + </listitem> - <section> - <title>c3p0 connection pooling</title> + <listitem> + <emphasis>cache.jdbc.password</emphasis> + - password to + connect to the database. + </listitem> + </itemizedlist> + </para> + </section> - <para>JBoss Cache implements JDBC connection pooling when running outside of an application server - standalone using - the c3p0:JDBC DataSources/Resource Pools library. In order to enable it, just edit the following - property: - <itemizedlist> - <listitem> - <emphasis>cache.jdbc.connection.factory</emphasis> - - Connection factory class name. - If not set, it defaults to standard non-pooled implementation. To enable c3p0 pooling, just set - the - connection factory class for c3p0. See example below. - </listitem> - </itemizedlist> - </para> + <section> + <title>c3p0 connection pooling</title> - <para>You can also set any c3p0 parameters in the same cache loader properties section but don't forget - to - start the property name with 'c3p0.'. To find a list of available properties, please check the - c3p0 documentation for the c3p0 library version distributed in - <ulink url="http://sourceforge.net/projects/c3p0">c3p0:JDBC DataSources/Resource Pools</ulink> - . - Also, in order to provide quick and easy way to try out different pooling - parameters, any of these properties can be set via a System property overriding any values these - properties might have in the JBoss Cache XML configuration file, for example: - <literal>-Dc3p0.maxPoolSize=20</literal> - . - If a c3p0 property is not defined in either the configuration file or as a System property, default - value, as indicated in the c3p0 documentation, will apply. - </para> - </section> + <para>JBoss Cache implements JDBC connection pooling when running outside of an application server + standalone using + the c3p0:JDBC DataSources/Resource Pools library. In order to enable it, just edit the following + property: + <itemizedlist> + <listitem> + <emphasis>cache.jdbc.connection.factory</emphasis> + - Connection factory class name. + If not set, it defaults to standard non-pooled implementation. To enable c3p0 pooling, + just set + the + connection factory class for c3p0. See example below. + </listitem> + </itemizedlist> + </para> - <section> - <title>Configuration example</title> + <para>You can also set any c3p0 parameters in the same cache loader properties section but don't + forget + to + start the property name with 'c3p0.'. To find a list of available properties, please check the + c3p0 documentation for the c3p0 library version distributed in + <ulink url="http://sourceforge.net/projects/c3p0">c3p0:JDBC DataSources/Resource Pools</ulink> + . + Also, in order to provide quick and easy way to try out different pooling + parameters, any of these properties can be set via a System property overriding any values these + properties might have in the JBoss Cache XML configuration file, for example: + <literal>-Dc3p0.maxPoolSize=20</literal> + . + If a c3p0 property is not defined in either the configuration file or as a System property, + default + value, as indicated in the c3p0 documentation, will apply. + </para> + </section> - <para>Below is an example of a JDBCCacheLoader using Oracle as - database. The CacheLoaderConfiguration XML element contains an - arbitrary set of properties which define the database-related - configuration. - </para> + <section> + <title>Configuration example</title> - <programlisting role="XML"><![CDATA[ + <para>Below is an example of a JDBCCacheLoader using Oracle as + database. The CacheLoaderConfiguration XML element contains an + arbitrary set of properties which define the database-related + configuration. + </para> + + <programlisting role="XML"><![CDATA[ <loaders passivation="false" shared="false"> <preload> <node fqn="/some/stuff"/> @@ -787,9 +798,9 @@ cache.jdbc.table.drop=true cache.jdbc.table.primarykey=jbosscache_pk cache.jdbc.fqn.column=fqn - cache.jdbc.fqn.type=varchar(255) + cache.jdbc.fqn.type=VARCHAR(255) cache.jdbc.node.column=node - cache.jdbc.node.type=blob + cache.jdbc.node.type=BLOB cache.jdbc.parent.column=parent cache.jdbc.driver=oracle.jdbc.OracleDriver cache.jdbc.url=jdbc:oracle:thin:@localhost:1521:JBOSSDB @@ -801,11 +812,11 @@ </loaders> ]]></programlisting> - <para>As an alternative to configuring the entire JDBC connection, - the name of an existing data source can be given: - </para> + <para>As an alternative to configuring the entire JDBC connection, + the name of an existing data source can be given: + </para> - <programlisting role="XML"><![CDATA[ + <programlisting role="XML"><![CDATA[ <loaders passivation="false" shared="false"> <preload> <node fqn="/some/stuff"/> @@ -820,9 +831,9 @@ </loaders> ]]></programlisting> - <para>Cconfiguration example for a cache loader using c3p0 JDBC connection pooling:</para> + <para>Cconfiguration example for a cache loader using c3p0 JDBC connection pooling:</para> - <programlisting role="XML"><![CDATA[ + <programlisting role="XML"><![CDATA[ <loaders passivation="false" shared="false"> <preload> <node fqn="/some/stuff"/> @@ -836,9 +847,9 @@ cache.jdbc.table.drop=true cache.jdbc.table.primarykey=jbosscache_pk cache.jdbc.fqn.column=fqn - cache.jdbc.fqn.type=varchar(255) + cache.jdbc.fqn.type=VARCHAR(255) cache.jdbc.node.column=node - cache.jdbc.node.type=blob + cache.jdbc.node.type=BLOB cache.jdbc.parent.column=parent cache.jdbc.driver=oracle.jdbc.OracleDriver cache.jdbc.url=jdbc:oracle:thin:@localhost:1521:JBOSSDB @@ -853,79 +864,79 @@ </loaders> ]]></programlisting> + </section> </section> - </section> - </section> + </section> - <section id="cl.s3"> - <title>S3CacheLoader</title> + <section id="cl.s3"> + <title>S3CacheLoader</title> - <para>The - <literal>S3CacheLoader</literal> - uses the - <ulink url="http://aws.amazon.com/">Amazon S3</ulink> - (Simple Storage Solution) - for storing cache data. - Since Amazon S3 is remote network storage and has fairly high latency, - it is really best for caches that store large pieces of data, such as media - or files. - But consider this cache loader over the JDBC or - file system based cache loaders if you want remotely managed, highly reliable - storage. Or, use it for applications running on Amazon's EC2 (Elastic Compute Cloud). - </para> + <para>The + <literal>S3CacheLoader</literal> + uses the + <ulink url="http://aws.amazon.com/">Amazon S3</ulink> + (Simple Storage Solution) + for storing cache data. + Since Amazon S3 is remote network storage and has fairly high latency, + it is really best for caches that store large pieces of data, such as media + or files. + But consider this cache loader over the JDBC or + file system based cache loaders if you want remotely managed, highly reliable + storage. Or, use it for applications running on Amazon's EC2 (Elastic Compute Cloud). + </para> - <para> - If you're planning to use Amazon S3 for storage, consider using it with JBoss Cache. - JBoss Cache itself provides in-memory caching for your data to minimize the amount of - remote access calls, thus reducing the latency and cost of fetching your Amazon S3 data. - With cache replication, you are also able to load data from your local cluster - without having to remotely access it every time. - </para> + <para> + If you're planning to use Amazon S3 for storage, consider using it with JBoss Cache. + JBoss Cache itself provides in-memory caching for your data to minimize the amount of + remote access calls, thus reducing the latency and cost of fetching your Amazon S3 data. + With cache replication, you are also able to load data from your local cluster + without having to remotely access it every time. + </para> - <para> - Note that Amazon S3 does not support transactions. If transactions - are used in your application then there is some possibility of state - inconsistency when using this cache loader. However, writes are atomic, in - that if a write fails nothing is considered written and data is never - corrupted. - </para> + <para> + Note that Amazon S3 does not support transactions. If transactions + are used in your application then there is some possibility of state + inconsistency when using this cache loader. However, writes are atomic, in + that if a write fails nothing is considered written and data is never + corrupted. + </para> - <para> - Data is stored in keys based on the Fqn of the Node and Node data is - serialized as a java.util.Map using the - <literal>CacheSPI.getMarshaller()</literal> - instance. - Read the javadoc on how data is structured and stored. - Data is stored using Java serialization. - Be aware this means data is not readily accessible over HTTP to - non-JBoss Cache clients. Your feedback and help would be appreciated - to extend this cache loader for that purpose. - </para> + <para> + Data is stored in keys based on the Fqn of the Node and Node data is + serialized as a java.util.Map using the + <literal>CacheSPI.getMarshaller()</literal> + instance. + Read the javadoc on how data is structured and stored. + Data is stored using Java serialization. + Be aware this means data is not readily accessible over HTTP to + non-JBoss Cache clients. Your feedback and help would be appreciated + to extend this cache loader for that purpose. + </para> - <para> - With this cache loader, single-key operations such as - <literal>Node.remove(Object)</literal> - and - <literal>Node.put(Object, Object)</literal> - are the slowest as data is stored in a single Map instance. - Use bulk operations such as - <literal>Node.replaceAll(Map)</literal> - and - <literal>Node.clearData()</literal> - for more efficiency. - Try the - <literal>cache.s3.optimize</literal> - option as well. - </para> + <para> + With this cache loader, single-key operations such as + <literal>Node.remove(Object)</literal> + and + <literal>Node.put(Object, Object)</literal> + are the slowest as data is stored in a single Map instance. + Use bulk operations such as + <literal>Node.replaceAll(Map)</literal> + and + <literal>Node.clearData()</literal> + for more efficiency. + Try the + <literal>cache.s3.optimize</literal> + option as well. + </para> - <section> - <title>Amazon S3 Library</title> - <para>The S3 cache loader is provided with the default - distribution but requires a library to access the service - at runtime. This runtime library may be obtained through a Sourceforge Maven - Repository. Include the following sections in your pom.xml file: - </para> - <programlisting role="XML"><![CDATA[ + <section> + <title>Amazon S3 Library</title> + <para>The S3 cache loader is provided with the default + distribution but requires a library to access the service + at runtime. This runtime library may be obtained through a Sourceforge Maven + Repository. Include the following sections in your pom.xml file: + </para> + <programlisting role="XML"><![CDATA[ <repository> <id>e-xml.sourceforge.net</id> <url>http://e-xml.sourceforge.net/maven2/repository</url> @@ -938,158 +949,163 @@ <scope>runtime</scope> </dependency> ]]> - </programlisting> - If you do not use Maven, you can still download the - amazon-s3 library by navigating the repository or through - <ulink url="http://e-xml.sourceforge.net/maven2/repository/net/noderunner/amazon-s3/1...">this URL</ulink>. - </section> + </programlisting> + If you do not use Maven, you can still download the + amazon-s3 library by navigating the repository or through + <ulink url="http://e-xml.sourceforge.net/maven2/repository/net/noderunner/amazon-s3/1..."> + this URL</ulink>. + </section> - <section> - <title>Configuration</title> - <para>At a minimum, you must configure your Amazon S3 access key and - secret access key. The following configuration keys are listed in general - order of utility. - </para> + <section> + <title>Configuration</title> + <para>At a minimum, you must configure your Amazon S3 access key and + secret access key. The following configuration keys are listed in general + order of utility. + </para> - <para> - <itemizedlist> - <listitem> - <literal>cache.s3.accessKeyId</literal> - - - Amazon S3 Access Key, available from your account profile. - </listitem> + <para> + <itemizedlist> + <listitem> + <literal>cache.s3.accessKeyId</literal> + - + Amazon S3 Access Key, available from your account profile. + </listitem> - <listitem> - <literal>cache.s3.secretAccessKey</literal> - - - Amazon S3 Secret Access Key, available from your account profile. - As this is a password, be careful not to distribute it or include - this secret key in built software. - </listitem> + <listitem> + <literal>cache.s3.secretAccessKey</literal> + - + Amazon S3 Secret Access Key, available from your account profile. + As this is a password, be careful not to distribute it or include + this secret key in built software. + </listitem> - <listitem> - <literal>cache.s3.secure</literal> - - - The default is<literal>false</literal>: - Traffic is sent unencrypted over the public Internet. - Set to - <literal>true</literal> - to use HTTPS. - Note that unencrypted uploads and downloads use less CPU. - </listitem> + <listitem> + <literal>cache.s3.secure</literal> + - + The default is<literal>false</literal>: + Traffic is sent unencrypted over the public Internet. + Set to + <literal>true</literal> + to use HTTPS. + Note that unencrypted uploads and downloads use less CPU. + </listitem> - <listitem> - <literal>cache.s3.bucket</literal> - - - Name of the bucket to store data. - For different caches using the same access key, use a different bucket name. - Read the S3 documentation on the definition of a bucket. - The default value is <literal>jboss-cache</literal>. - </listitem> + <listitem> + <literal>cache.s3.bucket</literal> + - + Name of the bucket to store data. + For different caches using the same access key, use a different bucket name. + Read the S3 documentation on the definition of a bucket. + The default value is<literal>jboss-cache</literal>. + </listitem> - <listitem> - <literal>cache.s3.callingFormat</literal> - - - One of <literal>PATH</literal>, <literal>SUBDOMAIN</literal>, or - <literal>VANITY</literal>. - Read the S3 documentation on the use of calling domains. - The default value is <literal>SUBDOMAIN</literal>. - </listitem> + <listitem> + <literal>cache.s3.callingFormat</literal> + - + One of<literal>PATH</literal>,<literal>SUBDOMAIN</literal>, or + <literal>VANITY</literal>. + Read the S3 documentation on the use of calling domains. + The default value is<literal>SUBDOMAIN</literal>. + </listitem> - <listitem> - <literal>cache.s3.optimize</literal> - - - The default is <literal>false</literal>. - If true, - <literal>put(Map)</literal> - operations - replace the data stored at an Fqn rather than attempt - to fetch and merge. (This option is fairly experimental - at the moment.) - </listitem> + <listitem> + <literal>cache.s3.optimize</literal> + - + The default is<literal>false</literal>. + If true, + <literal>put(Map)</literal> + operations + replace the data stored at an Fqn rather than attempt + to fetch and merge. (This option is fairly experimental + at the moment.) + </listitem> - <listitem> - <literal>cache.s3.parentCache</literal> - - - The default is <literal>true</literal>. - Set this value to - <literal>false</literal> - if you are using multiple caches - sharing the same S3 bucket, that remove parent nodes of nodes being created - in other caches. (This is not a common use case.) - <para> - JBoss Cache stores nodes in a tree format and automatically - creates intermediate parent nodes as necessary. - The S3 cache loader must also create these parent nodes as well - to allow for operations such as - <literal>getChildrenNames</literal> - to work - properly. Checking if all parent nodes exists for every - <literal>put</literal> - operation is fairly expensive, so by default the cache loader caches - the existence of these parent nodes. - </para> - </listitem> + <listitem> + <literal>cache.s3.parentCache</literal> + - + The default is<literal>true</literal>. + Set this value to + <literal>false</literal> + if you are using multiple caches + sharing the same S3 bucket, that remove parent nodes of nodes being created + in other caches. (This is not a common use case.) + <para> + JBoss Cache stores nodes in a tree format and automatically + creates intermediate parent nodes as necessary. + The S3 cache loader must also create these parent nodes as well + to allow for operations such as + <literal>getChildrenNames</literal> + to work + properly. Checking if all parent nodes exists for every + <literal>put</literal> + operation is fairly expensive, so by default the cache loader caches + the existence of these parent nodes. + </para> + </listitem> - <listitem> - <literal>cache.s3.location</literal> - - - This choses a primary storage location for your data - to reduce loading and retrieval latency. - Set to <literal>EU</literal> - to store data in Europe. - The default is <literal>null</literal>, to store data in - the United States. - </listitem> - </itemizedlist> - </para> - </section> + <listitem> + <literal>cache.s3.location</literal> + - + This choses a primary storage location for your data + to reduce loading and retrieval latency. + Set to + <literal>EU</literal> + to store data in Europe. + The default is<literal>null</literal>, to store data in + the United States. + </listitem> + </itemizedlist> + </para> + </section> - </section> + </section> - <section id="cl.tcp"> - <title>TcpDelegatingCacheLoader</title> + <section id="cl.tcp"> + <title>TcpDelegatingCacheLoader</title> - <para>This cache loader allows to delegate loads and stores to another - instance of JBoss Cache, which could reside (a) in the same address - space, (b) in a different process on the same host, or (c) in a - different process on a different host. - </para> + <para>This cache loader allows to delegate loads and stores to another + instance of JBoss Cache, which could reside (a) in the same address + space, (b) in a different process on the same host, or (c) in a + different process on a different host. + </para> - <para>A TcpDelegatingCacheLoader talks to a remote - <literal>org.jboss.cache.loader.tcp.TcpCacheServer</literal> - , - which can be a standalone process started on the command line, or embedded as an MBean inside - JBoss AS. The - <literal>TcpCacheServer</literal> - has a reference to another JBoss Cache instance, which - it can create itself, or which is given to it (e.g. by JBoss, using - dependency injection). - </para> + <para>A TcpDelegatingCacheLoader talks to a remote + <literal>org.jboss.cache.loader.tcp.TcpCacheServer</literal> + , + which can be a standalone process started on the command line, or embedded as an MBean inside + JBoss AS. The + <literal>TcpCacheServer</literal> + has a reference to another JBoss Cache instance, which + it can create itself, or which is given to it (e.g. by JBoss, using + dependency injection). + </para> - <para> - As of JBoss Cache 2.1.0, the <literal>TcpDelegatingCacheLoader</literal> transparently handles reconnects if the connection - to the TcpCacheServer is lost. - </para> + <para> + As of JBoss Cache 2.1.0, the + <literal>TcpDelegatingCacheLoader</literal> + transparently handles reconnects if the connection + to the TcpCacheServer is lost. + </para> - <para>The TcpDelegatingCacheLoader is configured with the host and port of the remote TcpCacheServer, and uses - this to communicate to - it. In addition, 2 new optional parameters are used to control transparent reconnecting to the - TcpCacheServer. - The - <literal>timeout</literal> - property (defaults to 5000) specifies the length of time the cache loader must continue - retrying to connect to the TcpCacheServer before giving up and throwing an exception. The - <literal>reconnectWaitTime</literal> - (defaults to 500) is how long the cache loader should wait before attempting a reconnect if it detects a - communication failure. - The last two parameters can be used to add a level of fault tolerance to the cache loader, do deal with - TcpCacheServer restarts. - </para> + <para>The TcpDelegatingCacheLoader is configured with the host and port of the remote TcpCacheServer, and + uses + this to communicate to + it. In addition, 2 new optional parameters are used to control transparent reconnecting to the + TcpCacheServer. + The + <literal>timeout</literal> + property (defaults to 5000) specifies the length of time the cache loader must continue + retrying to connect to the TcpCacheServer before giving up and throwing an exception. The + <literal>reconnectWaitTime</literal> + (defaults to 500) is how long the cache loader should wait before attempting a reconnect if it detects a + communication failure. + The last two parameters can be used to add a level of fault tolerance to the cache loader, do deal with + TcpCacheServer restarts. + </para> - <para>The configuration looks as follows:</para> + <para>The configuration looks as follows:</para> - <programlisting role="XML"><![CDATA[ + <programlisting role="XML"><![CDATA[ <loaders passivation="false" shared="false"> <preload> <node fqn="/"/> @@ -1106,434 +1122,438 @@ </loaders> ]]></programlisting> - <para>This means this instance of JBoss Cache will delegate all load - and store requests to the remote TcpCacheServer running on - <literal>myRemoteServer:7500</literal> - . - </para> + <para>This means this instance of JBoss Cache will delegate all load + and store requests to the remote TcpCacheServer running on + <literal>myRemoteServer:7500</literal> + . + </para> - <para>A typical use case could be multiple replicated instances of - JBoss Cache in the same cluster, all delegating to the same - TcpCacheServer instance. The TcpCacheServer might itself delegate to a - database via JDBCCacheLoader, but the point here is that - if we have - 5 nodes all accessing the same dataset - they will load the data from - the TcpCacheServer, which has do execute one SQL statement per - unloaded data set. If the nodes went directly to the database, then - we'd have the same SQL executed multiple times. So TcpCacheServer - serves as a natural cache in front of the DB (assuming that a network - round trip is faster than a DB access (which usually also include a - network round trip)). - </para> + <para>A typical use case could be multiple replicated instances of + JBoss Cache in the same cluster, all delegating to the same + TcpCacheServer instance. The TcpCacheServer might itself delegate to a + database via JDBCCacheLoader, but the point here is that - if we have + 5 nodes all accessing the same dataset - they will load the data from + the TcpCacheServer, which has do execute one SQL statement per + unloaded data set. If the nodes went directly to the database, then + we'd have the same SQL executed multiple times. So TcpCacheServer + serves as a natural cache in front of the DB (assuming that a network + round trip is faster than a DB access (which usually also include a + network round trip)). + </para> - <para>To alleviate single point of failure, we could configure several cache loaders. - The first cache loader is a ClusteredCacheLoader, the second a TcpDelegatingCacheLoader, and the - last a JDBCacheLoader, effectively defining our cost of access to a - cache in increasing order. - </para> + <para>To alleviate single point of failure, we could configure several cache loaders. + The first cache loader is a ClusteredCacheLoader, the second a TcpDelegatingCacheLoader, and the + last a JDBCacheLoader, effectively defining our cost of access to a + cache in increasing order. + </para> - </section> + </section> - <section id="cl.transforming"> - <title>Transforming Cache Loaders</title> + <section id="cl.transforming"> + <title>Transforming Cache Loaders</title> - <para>The way cached data is written to - <literal>FileCacheLoader</literal> - and - <literal>JDBCCacheLoader</literal> - based cache stores has changed in JBoss Cache 2.0 in such way that - these cache loaders now write and read data using the same marhalling framework used to replicate data - across the network. Such change is trivial for replication purposes as it just requires the rest of the - nodes to understand this format. However, changing the format of the data in cache stores brings up a new - problem: how do users, which have their data stored in JBoss Cache 1.x.x format, migrate their stores to - JBoss Cache 2.0 format? - </para> + <para>The way cached data is written to + <literal>FileCacheLoader</literal> + and + <literal>JDBCCacheLoader</literal> + based cache stores has changed in JBoss Cache 2.0 in such way that + these cache loaders now write and read data using the same marhalling framework used to replicate data + across the network. Such change is trivial for replication purposes as it just requires the rest of the + nodes to understand this format. However, changing the format of the data in cache stores brings up a + new + problem: how do users, which have their data stored in JBoss Cache 1.x.x format, migrate their stores to + JBoss Cache 2.0 format? + </para> - <para>With this in mind, JBoss Cache 2.0 comes with two cache loader implementations called - <literal>org.jboss.cache.loader.TransformingFileCacheLoader</literal> - and - <literal>org.jboss.cache.loader.TransformingJDBCCacheLoader</literal> - located within the optional - jbosscache-cacheloader-migration.jar file. These are one-off cache loaders that read data from the - cache store in JBoss Cache 1.x.x format and write data to cache stores in JBoss Cache 2.0 format. - </para> + <para>With this in mind, JBoss Cache 2.0 comes with two cache loader implementations called + <literal>org.jboss.cache.loader.TransformingFileCacheLoader</literal> + and + <literal>org.jboss.cache.loader.TransformingJDBCCacheLoader</literal> + located within the optional + jbosscache-cacheloader-migration.jar file. These are one-off cache loaders that read data from the + cache store in JBoss Cache 1.x.x format and write data to cache stores in JBoss Cache 2.0 format. + </para> - <para>The idea is for users to modify their existing cache configuration file(s) momentarily to use these - cache loaders and for them to create a small Java application that creates an instance of this cache, - recursively reads the entire cache and writes the data read back into the cache. Once the data is - transformed, users can revert back to their original cache configuration file(s). In order to help the users - with this task, a cache loader migration example has been constructed which can be located under the - <literal>examples/cacheloader-migration</literal> - directory within the JBoss Cache distribution. This - example, called - <literal>examples.TransformStore</literal> - , is independent of the actual data stored in - the cache as it writes back whatever it was read recursively. It is highly recommended that anyone - interested in porting their data run this example first, which contains a - <literal>readme.txt</literal> - file with detailed information about the example itself, and also use it as base for their own application. - </para> + <para>The idea is for users to modify their existing cache configuration file(s) momentarily to use these + cache loaders and for them to create a small Java application that creates an instance of this cache, + recursively reads the entire cache and writes the data read back into the cache. Once the data is + transformed, users can revert back to their original cache configuration file(s). In order to help the + users + with this task, a cache loader migration example has been constructed which can be located under the + <literal>examples/cacheloader-migration</literal> + directory within the JBoss Cache distribution. This + example, called + <literal>examples.TransformStore</literal> + , is independent of the actual data stored in + the cache as it writes back whatever it was read recursively. It is highly recommended that anyone + interested in porting their data run this example first, which contains a + <literal>readme.txt</literal> + file with detailed information about the example itself, and also use it as base for their own + application. + </para> - </section> + </section> - </section> + </section> - <section id="cl.pass"> - <title>Cache Passivation</title> + <section id="cl.pass"> + <title>Cache Passivation</title> - <para>A cache loader can be used to enforce node passivation and - activation on eviction in a cache. - </para> + <para>A cache loader can be used to enforce node passivation and + activation on eviction in a cache. + </para> - <para> - <emphasis>Cache Passivation</emphasis> - is the process of removing - an object from in-memory cache and writing it to a secondary data store - (e.g., file system, database) on eviction. - <emphasis>Cache - Activation - </emphasis> - is the process of restoring an object from the - data store into the in-memory cache when it's needed to be used. In both - cases, the configured cache loader will be used to read from the data - store and write to the data store. - </para> + <para> + <emphasis>Cache Passivation</emphasis> + is the process of removing + an object from in-memory cache and writing it to a secondary data store + (e.g., file system, database) on eviction. + <emphasis>Cache + Activation + </emphasis> + is the process of restoring an object from the + data store into the in-memory cache when it's needed to be used. In both + cases, the configured cache loader will be used to read from the data + store and write to the data store. + </para> - <para>When an eviction policy in effect evicts a node - from the cache, if passivation is enabled, a notification that the node - is being passivated will be emitted to the cache listeners and the - node and its children will be stored in the cache loader store. When a - user attempts to retrieve a node that was evicted earlier, the node is loaded - (lazy loaded) from the cache loader store into memory. When - the node and its children have been loaded, they're removed from the - cache loader and a notification is emitted to the cache listeners - that the node has been activated. - </para> + <para>When an eviction policy in effect evicts a node + from the cache, if passivation is enabled, a notification that the node + is being passivated will be emitted to the cache listeners and the + node and its children will be stored in the cache loader store. When a + user attempts to retrieve a node that was evicted earlier, the node is loaded + (lazy loaded) from the cache loader store into memory. When + the node and its children have been loaded, they're removed from the + cache loader and a notification is emitted to the cache listeners + that the node has been activated. + </para> - <para>To enable cache passivation/activation, you can set - <literal>passivation</literal> - to true. The default is - <literal>false</literal> - . - When passivation is used, only the first cache loader configured is - used and all others are ignored. - </para> + <para>To enable cache passivation/activation, you can set + <literal>passivation</literal> + to true. The default is + <literal>false</literal> + . + When passivation is used, only the first cache loader configured is + used and all others are ignored. + </para> - <section> - <title>Cache Loader Behavior with Passivation Disabled vs. Enabled</title> + <section> + <title>Cache Loader Behavior with Passivation Disabled vs. Enabled</title> - <para> - When passivation is disabled, whenever an element is modified, added or - removed, then that modification is persisted in the backend store via - the cache loader. There is no direct relationship between eviction and - cache loading. If you don't use eviction, what's in the persistent store - is basically a copy of what's in memory. If you do use eviction, what's - in the persistent store is basically a superset of what's in memory - (i.e. it includes nodes that have been evicted from memory). - </para> + <para> + When passivation is disabled, whenever an element is modified, added or + removed, then that modification is persisted in the backend store via + the cache loader. There is no direct relationship between eviction and + cache loading. If you don't use eviction, what's in the persistent store + is basically a copy of what's in memory. If you do use eviction, what's + in the persistent store is basically a superset of what's in memory + (i.e. it includes nodes that have been evicted from memory). + </para> - <para> - When passivation is enabled, there is a direct relationship between - eviction and the cache loader. Writes to the persistent store via the - cache loader only occur as part of the eviction process. Data is deleted - from the persistent store when the application reads it back into - memory. In this case, what's in memory and what's in the persistent - store are two subsets of the total information set, with no intersection between the subsets. - </para> + <para> + When passivation is enabled, there is a direct relationship between + eviction and the cache loader. Writes to the persistent store via the + cache loader only occur as part of the eviction process. Data is deleted + from the persistent store when the application reads it back into + memory. In this case, what's in memory and what's in the persistent + store are two subsets of the total information set, with no intersection between the subsets. + </para> - <para> - Following is a simple example, showing what state is in RAM and in the - persistent store after each step of a 6 step process: - </para> + <para> + Following is a simple example, showing what state is in RAM and in the + persistent store after each step of a 6 step process: + </para> - <orderedlist> - <listitem>Insert /A</listitem> - <listitem>Insert /B</listitem> - <listitem>Eviction thread runs, evicts /A</listitem> - <listitem>Read /A</listitem> - <listitem>Eviction thread runs, evicts /B</listitem> - <listitem>Remove /B</listitem> - </orderedlist> + <orderedlist> + <listitem>Insert /A</listitem> + <listitem>Insert /B</listitem> + <listitem>Eviction thread runs, evicts /A</listitem> + <listitem>Read /A</listitem> + <listitem>Eviction thread runs, evicts /B</listitem> + <listitem>Remove /B</listitem> + </orderedlist> - <para>When passivation is disabled:</para> - <programlisting> - 1) Memory: /A Disk: /A - 2) Memory: /A, /B Disk: /A, /B - 3) Memory: /B Disk: /A, /B - 4) Memory: /A, /B Disk: /A, /B - 5) Memory: /A Disk: /A, /B - 6) Memory: /A Disk: /A - </programlisting> + <para>When passivation is disabled:</para> + <programlisting> + 1) Memory: /A Disk: /A + 2) Memory: /A, /B Disk: /A, /B + 3) Memory: /B Disk: /A, /B + 4) Memory: /A, /B Disk: /A, /B + 5) Memory: /A Disk: /A, /B + 6) Memory: /A Disk: /A + </programlisting> - <para>When passivation is enabled:</para> - <programlisting> - 1) Memory: /A Disk: - 2) Memory: /A, /B Disk: - 3) Memory: /B Disk: /A - 4) Memory: /A, /B Disk: - 5) Memory: /A Disk: /B - 6) Memory: /A Disk: - </programlisting> - </section> + <para>When passivation is enabled:</para> + <programlisting> + 1) Memory: /A Disk: + 2) Memory: /A, /B Disk: + 3) Memory: /B Disk: /A + 4) Memory: /A, /B Disk: + 5) Memory: /A Disk: /B + 6) Memory: /A Disk: + </programlisting> + </section> - </section> + </section> - <section> - <title>Strategies</title> - <para> - This section discusses different patterns of combining different cache loader types and configuration - options to achieve specific outcomes. - </para> + <section> + <title>Strategies</title> + <para> + This section discusses different patterns of combining different cache loader types and configuration + options to achieve specific outcomes. + </para> - <section> - <title>Local Cache With Store</title> + <section> + <title>Local Cache With Store</title> - <para>This is the simplest case. We have a JBoss Cache instance, whose - cache mode is - <literal>LOCAL</literal> - , therefore no replication is going - on. The cache loader simply loads non-existing elements from the store - and stores modifications back to the store. When the cache is started, - depending on the - <literal>preload</literal> - element, certain data can - be preloaded, so that the cache is partly warmed up. - </para> - </section> + <para>This is the simplest case. We have a JBoss Cache instance, whose + cache mode is + <literal>LOCAL</literal> + , therefore no replication is going + on. The cache loader simply loads non-existing elements from the store + and stores modifications back to the store. When the cache is started, + depending on the + <literal>preload</literal> + element, certain data can + be preloaded, so that the cache is partly warmed up. + </para> + </section> - <section> - <title>Replicated Caches With All Caches Sharing The Same Store</title> + <section> + <title>Replicated Caches With All Caches Sharing The Same Store</title> - <para>The following figure shows 2 JBoss Cache instances sharing the same - backend store: - </para> + <para>The following figure shows 2 JBoss Cache instances sharing the same + backend store: + </para> - <figure> - <title>2 nodes sharing a backend store</title> + <figure> + <title>2 nodes sharing a backend store</title> - <mediaobject> - <imageobject> - <imagedata fileref="SharedCacheLoader.png"/> - </imageobject> - </mediaobject> - </figure> + <mediaobject> + <imageobject> + <imagedata fileref="SharedCacheLoader.png"/> + </imageobject> + </mediaobject> + </figure> - <para>Both nodes have a cache loader that accesses a common shared - backend store. This could for example be a shared filesystem (using - the FileCacheLoader), or a shared database. Because both nodes access - the same store, they don't necessarily need state transfer on - startup. - <footnote> - <para>Of course they can enable state transfer, if they want to - have a warm or hot cache after startup. - </para> - </footnote> - Rather, the - <literal>FetchInMemoryState</literal> - attribute could be set to false, resulting in a 'cold' cache, that - gradually warms up as elements are accessed and loaded for the first - time. This would mean that individual caches in a cluster might have - different in-memory state at any given time (largely depending on - their preloading and eviction strategies). - </para> + <para>Both nodes have a cache loader that accesses a common shared + backend store. This could for example be a shared filesystem (using + the FileCacheLoader), or a shared database. Because both nodes access + the same store, they don't necessarily need state transfer on + startup. + <footnote> + <para>Of course they can enable state transfer, if they want to + have a warm or hot cache after startup. + </para> + </footnote> + Rather, the + <literal>FetchInMemoryState</literal> + attribute could be set to false, resulting in a 'cold' cache, that + gradually warms up as elements are accessed and loaded for the first + time. This would mean that individual caches in a cluster might have + different in-memory state at any given time (largely depending on + their preloading and eviction strategies). + </para> - <para>When storing a value, the writer takes care of storing the - change in the backend store. For example, if node1 made change C1 and - node2 C2, then node1 would tell its cache loader to store C1, and node2 - would tell its cache loader to store C2. - </para> - </section> + <para>When storing a value, the writer takes care of storing the + change in the backend store. For example, if node1 made change C1 and + node2 C2, then node1 would tell its cache loader to store C1, and node2 + would tell its cache loader to store C2. + </para> + </section> - <section> - <title>Replicated Caches With Only One Cache Having A Store</title> + <section> + <title>Replicated Caches With Only One Cache Having A Store</title> - <figure> - <title>2 nodes but only one accesses the backend store</title> + <figure> + <title>2 nodes but only one accesses the backend store</title> - <mediaobject> - <imageobject> - <imagedata fileref="OnlyOneCacheLoader.png"/> - </imageobject> - </mediaobject> - </figure> + <mediaobject> + <imageobject> + <imagedata fileref="OnlyOneCacheLoader.png"/> + </imageobject> + </mediaobject> + </figure> - <para>This is a similar case to the previous one, but here only one - node in the cluster interacts with a backend store via its - cache loader. All other nodes perform in-memory replication. The idea - here is all application state is kept in memory in each node, with - the existence of multiple caches making the data highly available. - (This assumes that a client that needs the data is able to somehow - fail over from one cache to another.) The single persistent backend - store then provides a backup copy of the data in case all caches in - the cluster fail or need to be restarted. - </para> - <para> - Note that here it may make sense for the cache loader to store - changes asynchronously, that is - <emphasis>not</emphasis> - on the caller's thread, in order not to slow - down the cluster by accessing (for example) a database. This is a - non-issue when using asynchronous replication. - </para> - <para> - A weakness with this architecture is that the cache with access - to the cache loader becomes a single point of failure. Furthermore, - if the cluster is restarted, the cache with the cache loader must - be started first (easy to forget). A solution to the first problem - is to configure a cache loader on each node, but set the - <literal>singletonStore</literal> - configuration to - <literal>true</literal>. With this kind of setup, one but only one - node will always be writing to a persistent store. However, this - complicates the restart problem, as before restarting you need - to determine which cache was writing before the shutdown/failure - and then start that cache first. - </para> - </section> + <para>This is a similar case to the previous one, but here only one + node in the cluster interacts with a backend store via its + cache loader. All other nodes perform in-memory replication. The idea + here is all application state is kept in memory in each node, with + the existence of multiple caches making the data highly available. + (This assumes that a client that needs the data is able to somehow + fail over from one cache to another.) The single persistent backend + store then provides a backup copy of the data in case all caches in + the cluster fail or need to be restarted. + </para> + <para> + Note that here it may make sense for the cache loader to store + changes asynchronously, that is + <emphasis>not</emphasis> + on the caller's thread, in order not to slow + down the cluster by accessing (for example) a database. This is a + non-issue when using asynchronous replication. + </para> + <para> + A weakness with this architecture is that the cache with access + to the cache loader becomes a single point of failure. Furthermore, + if the cluster is restarted, the cache with the cache loader must + be started first (easy to forget). A solution to the first problem + is to configure a cache loader on each node, but set the + <literal>singletonStore</literal> + configuration to + <literal>true</literal>. With this kind of setup, one but only one + node will always be writing to a persistent store. However, this + complicates the restart problem, as before restarting you need + to determine which cache was writing before the shutdown/failure + and then start that cache first. + </para> + </section> - <section> - <title>Replicated Caches With Each Cache Having Its Own Store</title> + <section> + <title>Replicated Caches With Each Cache Having Its Own Store</title> - <figure> - <title>2 nodes each having its own backend store</title> + <figure> + <title>2 nodes each having its own backend store</title> - <mediaobject> - <imageobject> - <imagedata fileref="LocalCacheLoader.png"/> - </imageobject> - </mediaobject> - </figure> + <mediaobject> + <imageobject> + <imagedata fileref="LocalCacheLoader.png"/> + </imageobject> + </mediaobject> + </figure> - <para>Here, each node has its own datastore. Modifications to the - cache are (a) replicated across the cluster and (b) persisted using - the cache loader. This means that all datastores have exactly the same - state. When replicating changes synchronously and in a transaction, - the two phase commit protocol takes care that all modifications are - replicated and persisted in each datastore, or none is replicated and - persisted (atomic updates). - </para> + <para>Here, each node has its own datastore. Modifications to the + cache are (a) replicated across the cluster and (b) persisted using + the cache loader. This means that all datastores have exactly the same + state. When replicating changes synchronously and in a transaction, + the two phase commit protocol takes care that all modifications are + replicated and persisted in each datastore, or none is replicated and + persisted (atomic updates). + </para> - <para>Note that JBoss Cache is - <emphasis>not</emphasis> - an - XA Resource, that means it doesn't implement recovery. When used with a - transaction manager that supports recovery, this functionality is not - available. - </para> + <para>Note that JBoss Cache is + <emphasis>not</emphasis> + an + XA Resource, that means it doesn't implement recovery. When used with a + transaction manager that supports recovery, this functionality is not + available. + </para> - <para>The challenge here is state transfer: when a new node starts it - needs to do the following: - </para> + <para>The challenge here is state transfer: when a new node starts it + needs to do the following: + </para> - <orderedlist> - <listitem> - <para>Tell the coordinator (oldest node in a cluster) to send it - the state. This is always a full state transfer, overwriting - any state that may already be present. - </para> - </listitem> + <orderedlist> + <listitem> + <para>Tell the coordinator (oldest node in a cluster) to send it + the state. This is always a full state transfer, overwriting + any state that may already be present. + </para> + </listitem> - <listitem> - <para>The coordinator then needs to wait until all in-flight - transactions have completed. During this time, it will not allow - for new transactions to be started. - </para> - </listitem> + <listitem> + <para>The coordinator then needs to wait until all in-flight + transactions have completed. During this time, it will not allow + for new transactions to be started. + </para> + </listitem> - <listitem> - <para>Then the coordinator asks its cache loader for the entire - state using - <literal>loadEntireState()</literal> - . It then sends - back that state to the new node. - </para> - </listitem> + <listitem> + <para>Then the coordinator asks its cache loader for the entire + state using + <literal>loadEntireState()</literal> + . It then sends + back that state to the new node. + </para> + </listitem> - <listitem> - <para>The new node then tells its cache loader to store that state - in its store, overwriting the old state. This is the - <literal>CacheLoader.storeEntireState()</literal> - method - </para> - </listitem> + <listitem> + <para>The new node then tells its cache loader to store that state + in its store, overwriting the old state. This is the + <literal>CacheLoader.storeEntireState()</literal> + method + </para> + </listitem> - <listitem> - <para>As an option, the transient (in-memory) state can be - transferred as well during the state transfer. - </para> - </listitem> + <listitem> + <para>As an option, the transient (in-memory) state can be + transferred as well during the state transfer. + </para> + </listitem> - <listitem> - <para>The new node now has the same state in its backend store as - everyone else in the cluster, and modifications received from - other nodes will now be persisted using the local - cache loader. - </para> - </listitem> - </orderedlist> + <listitem> + <para>The new node now has the same state in its backend store as + everyone else in the cluster, and modifications received from + other nodes will now be persisted using the local + cache loader. + </para> + </listitem> + </orderedlist> - </section> + </section> - <section> - <title>Hierarchical Caches</title> + <section> + <title>Hierarchical Caches</title> - <para>If you need to set up a hierarchy within a single JVM, you can - use the - <literal>LocalDelegatingCacheLoader</literal> - . This type of - hierarchy can currently only be set up programmatically. - </para> + <para>If you need to set up a hierarchy within a single JVM, you can + use the + <literal>LocalDelegatingCacheLoader</literal> + . This type of + hierarchy can currently only be set up programmatically. + </para> - <para> - Hierarchical caches could also be set up spanning more than one JVM or server, using the - <literal>TcpDelegatingCacheLoader</literal> - . - <figure> - <title>TCP delegating cache loader</title> + <para> + Hierarchical caches could also be set up spanning more than one JVM or server, using the + <literal>TcpDelegatingCacheLoader</literal> + . + <figure> + <title>TCP delegating cache loader</title> - <mediaobject> - <imageobject> - <imagedata fileref="DelegatingCacheLoader.png"/> - </imageobject> - </mediaobject> - </figure> + <mediaobject> + <imageobject> + <imagedata fileref="DelegatingCacheLoader.png"/> + </imageobject> + </mediaobject> + </figure> - </para> + </para> - </section> + </section> - <section> - <title>Multiple Cache Loaders</title> + <section> + <title>Multiple Cache Loaders</title> - <para> - You can set up more than one cache loader in a chain. Internally, a delegating - <literal>ChainingCacheLoader</literal> - is used, with references to each - cache loader you have configured. Use cases vary depending on the type of cache loaders used in the chain. - One example is - using a filesystem based cache loader, co-located on the same host as the JVM, used as an overflow for - memory. This ensures - data is available relatively easily and with low cost. An additional remote cache loader, such as a - <literal>TcpDelegatingCacheLoader</literal> - provides resilience between server restarts. - </para> + <para> + You can set up more than one cache loader in a chain. Internally, a delegating + <literal>ChainingCacheLoader</literal> + is used, with references to each + cache loader you have configured. Use cases vary depending on the type of cache loaders used in the + chain. + One example is + using a filesystem based cache loader, co-located on the same host as the JVM, used as an overflow for + memory. This ensures + data is available relatively easily and with low cost. An additional remote cache loader, such as a + <literal>TcpDelegatingCacheLoader</literal> + provides resilience between server restarts. + </para> - <figure> - <title>Multiple cache loaders in a chain</title> + <figure> + <title>Multiple cache loaders in a chain</title> - <mediaobject> - <imageobject> - <imagedata fileref="MultipleCacheLoaders.png"/> - </imageobject> - </mediaobject> - </figure> + <mediaobject> + <imageobject> + <imagedata fileref="MultipleCacheLoaders.png"/> + </imageobject> + </mediaobject> + </figure> - </section> + </section> - </section> + </section> </chapter> Modified: core/trunk/src/main/resources/config-samples/all.xml =================================================================== --- core/trunk/src/main/resources/config-samples/all.xml 2009-01-05 17:54:59 UTC (rev 7380) +++ core/trunk/src/main/resources/config-samples/all.xml 2009-01-06 11:08:41 UTC (rev 7381) @@ -181,9 +181,9 @@ cache.jdbc.table.drop=true cache.jdbc.table.primarykey=jbosscache_pk cache.jdbc.fqn.column=fqn - cache.jdbc.fqn.type=varchar(255) + cache.jdbc.fqn.type=VARCHAR(255) cache.jdbc.node.column=node - cache.jdbc.node.type=blob + cache.jdbc.node.type=BINARY cache.jdbc.parent.column=parent cache.jdbc.driver=org.hsqldb.jdbcDriver cache.jdbc.url=jdbc:hsqldb:mem:jbosscache Modified: core/trunk/src/main/resources/config-samples/cacheloader-enabled.xml =================================================================== --- core/trunk/src/main/resources/config-samples/cacheloader-enabled.xml 2009-01-05 17:54:59 UTC (rev 7380) +++ core/trunk/src/main/resources/config-samples/cacheloader-enabled.xml 2009-01-06 11:08:41 UTC (rev 7381) @@ -39,9 +39,9 @@ cache.jdbc.table.drop=true cache.jdbc.table.primarykey=jbosscache_pk cache.jdbc.fqn.column=fqn - cache.jdbc.fqn.type=varchar(255) + cache.jdbc.fqn.type=VARCHAR(255) cache.jdbc.node.column=node - cache.jdbc.node.type=blob + cache.jdbc.node.type=BINARY cache.jdbc.parent.column=parent cache.jdbc.driver=org.hsqldb.jdbcDriver cache.jdbc.url=jdbc:hsqldb:mem:jbosscache Modified: core/trunk/src/test/java/org/jboss/cache/config/parsing/SampleConfigFilesCorrectnessTest.java =================================================================== --- core/trunk/src/test/java/org/jboss/cache/config/parsing/SampleConfigFilesCorrectnessTest.java 2009-01-05 17:54:59 UTC (rev 7380) +++ core/trunk/src/test/java/org/jboss/cache/config/parsing/SampleConfigFilesCorrectnessTest.java 2009-01-06 11:08:41 UTC (rev 7381) @@ -21,6 +21,8 @@ */ package org.jboss.cache.config.parsing; +import org.apache.commons.logging.Log; +import org.apache.commons.logging.LogFactory; import org.apache.log4j.AppenderSkeleton; import org.apache.log4j.Level; import org.apache.log4j.Logger; @@ -50,6 +52,7 @@ private InMemoryAppender appender; private Level oldLevel; + private Log log = LogFactory.getLog(SampleConfigFilesCorrectnessTest.class); @BeforeMethod public void setUpTest() @@ -112,13 +115,14 @@ private static class InMemoryAppender extends AppenderSkeleton { - String[] TOLERABLE_WARNINGS = {"Falling back to DummyTransactionManager"}; + String[] TOLERABLE_WARNINGS = {"DummyTransactionManager"}; boolean foundUnknownWarning = false; /** * As this test runs in parallel with other tests tha also log information, we should disregard * other possible warnings from other threads and only consider warnings issues within this test class's test. - * @see #isExpectedThread() + * + * @see #isExpectedThread() */ private Thread loggerThread = Thread.currentThread(); @@ -136,6 +140,8 @@ foundUnknownWarning = false; } } + + if (!skipPrinting) System.out.println("****** " + event.getMessage().toString()); } }

16 years

1
0
0 / 0

JBoss Cache SVN: r7380 - core/trunk/src/main/java/org/jboss/cache/util.

by jbosscache-commits＠lists.jboss.org

Author: jason.greene(a)jboss.com Date: 2009-01-05 12:54:59 -0500 (Mon, 05 Jan 2009) New Revision: 7380 Modified: core/trunk/src/main/java/org/jboss/cache/util/FastCopyHashMap.java Log: Optimize initial sizing by factoring in the load factor Modified: core/trunk/src/main/java/org/jboss/cache/util/FastCopyHashMap.java =================================================================== --- core/trunk/src/main/java/org/jboss/cache/util/FastCopyHashMap.java 2009-01-05 17:48:27 UTC (rev 7379) +++ core/trunk/src/main/java/org/jboss/cache/util/FastCopyHashMap.java 2009-01-05 17:54:59 UTC (rev 7380) @@ -134,10 +134,16 @@ { int c = 1; for (; c < initialCapacity; c <<= 1) ; + threshold = (int) (c * loadFactor); + // Include the load factor when sizing the table for the first time + if (initialCapacity > threshold && c < MAXIMUM_CAPACITY) + { + c <<= 1; + threshold = (int) (c * loadFactor); + } + this.table = (Entry<K, V>[]) new Entry[c]; - - threshold = (int) (c * loadFactor); } public FastCopyHashMap(int initialCapacity)

16 years

1
0
0 / 0

JBoss Cache SVN: r7379 - in core/trunk/src: test/java/org/jboss/cache/loader and 1 other directory.

by jbosscache-commits＠lists.jboss.org

Author: manik.surtani(a)jboss.com Date: 2009-01-05 12:48:27 -0500 (Mon, 05 Jan 2009) New Revision: 7379 Added: core/trunk/src/test/java/org/jboss/cache/loader/RootChildrenLoadedTest.java Modified: core/trunk/src/main/java/org/jboss/cache/DataContainerImpl.java Log: JBCACHE-1456 - The root node starts with "children loaded" flag Modified: core/trunk/src/main/java/org/jboss/cache/DataContainerImpl.java =================================================================== --- core/trunk/src/main/java/org/jboss/cache/DataContainerImpl.java 2009-01-05 17:35:41 UTC (rev 7378) +++ core/trunk/src/main/java/org/jboss/cache/DataContainerImpl.java 2009-01-05 17:48:27 UTC (rev 7379) @@ -111,9 +111,6 @@ } if (usingMvcc && rootInternal == null) setRoot(root); // sets the "internal root" - - if (root != null) root.setChildrenLoaded(true); - if (rootInternal != null) rootInternal.setChildrenLoaded(true); } @Stop(priority = 100) @@ -243,9 +240,13 @@ public List<NodeData> buildNodeData(List<NodeData> list, NodeSPI node, boolean mapSafe) { if (usingMvcc) + { return buildNodeData(list, node.getDelegationTarget(), node.getData(), mapSafe); + } else + { return buildNodeDataLegacy(list, node, mapSafe); + } } private List<NodeData> buildNodeData(List<NodeData> list, InternalNode<?, ?> node, Map dataInNode, boolean mapSafe) @@ -389,7 +390,9 @@ else { if (root == null) + { return sb.toString(); + } for (Object n : root.getChildrenDirect()) { ((NodeSPI) n).print(sb, indent); @@ -467,9 +470,13 @@ { StringBuilder sb = new StringBuilder(); if (root == null) + { rootInternal.printDetails(sb, 0); + } else + { root.printDetails(sb, 0); + } sb.append("\n"); return sb.toString(); } @@ -632,20 +639,30 @@ if (hasChildren(fqn)) { if (trace) + { log.trace("removing DATA as node has children: evict(" + fqn + ")"); + } if (usingMvcc) + { removeData(fqn); + } else + { removeDataLegacy(fqn); + } return false; } else { if (trace) log.trace("removing NODE as it is a leaf: evict(" + fqn + ")"); if (usingMvcc) + { removeNode(fqn); + } else + { removeNodeLegacy(fqn); + } return true; } } Added: core/trunk/src/test/java/org/jboss/cache/loader/RootChildrenLoadedTest.java =================================================================== --- core/trunk/src/test/java/org/jboss/cache/loader/RootChildrenLoadedTest.java (rev 0) +++ core/trunk/src/test/java/org/jboss/cache/loader/RootChildrenLoadedTest.java 2009-01-05 17:48:27 UTC (rev 7379) @@ -0,0 +1,52 @@ +package org.jboss.cache.loader; + +import org.jboss.cache.Cache; +import org.jboss.cache.DefaultCacheFactory; +import org.jboss.cache.Fqn; +import org.jboss.cache.config.CacheLoaderConfig; +import org.jboss.cache.config.Configuration; +import org.jboss.cache.factories.UnitTestCacheConfigurationFactory; +import org.jboss.cache.loader.testloaders.DummyInMemoryCacheLoader; +import org.jboss.cache.util.TestingUtil; +import org.testng.annotations.AfterTest; +import org.testng.annotations.BeforeTest; +import org.testng.annotations.Test; + +@Test(groups = "functional", enabled = true) +public class RootChildrenLoadedTest +{ + Cache<String, String> cache; + Fqn fqn = Fqn.fromElements("a", "a"); + String key = "key"; + + @BeforeTest + public void setUp() throws Exception + { + CacheLoaderConfig cacheLoaderConfig = UnitTestCacheConfigurationFactory.buildSingleCacheLoaderConfig(false, "", DummyInMemoryCacheLoader.class.getName(), "", false, true, false, false, false); + // assign the cache loader explicitly so it will stick between restarts + cacheLoaderConfig.getFirstCacheLoaderConfig().setCacheLoader(new DummyInMemoryCacheLoader()); + Configuration cfg = new Configuration(); + cfg.setCacheLoaderConfig(cacheLoaderConfig); + cache = new DefaultCacheFactory<String, String>().createCache(cfg); + cache.put(fqn, key, "value"); + + // flush the cache and start with totally clean state + cache.stop(); + cache.start(); + } + + @AfterTest + public void tearDown() + { + TestingUtil.killCaches(cache); + } + + public void doTest() throws Exception + { + // the workaround: + // NodeInvocationDelegate<String, String> root = (NodeInvocationDelegate<String, String>) cache.getRoot(); + // root.setChildrenLoaded(false); + + assert cache.getNode(Fqn.ROOT).getChildrenNames().size() == 1; + } +}

16 years

1
0
0 / 0

JBoss Cache SVN: r7378 - in core/trunk/src: main/java/org/jboss/cache/loader/tcp and 2 other directories.

by jbosscache-commits＠lists.jboss.org

Author: manik.surtani(a)jboss.com Date: 2009-01-05 12:35:41 -0500 (Mon, 05 Jan 2009) New Revision: 7378 Modified: core/trunk/src/main/java/org/jboss/cache/loader/TcpDelegatingCacheLoader.java core/trunk/src/main/java/org/jboss/cache/loader/tcp/TcpCacheServer.java core/trunk/src/test/java/org/jboss/cache/AbstractSingleCacheTest.java core/trunk/src/test/java/org/jboss/cache/loader/CacheLoaderTestsBase.java core/trunk/src/test/java/org/jboss/cache/loader/TcpCacheLoaderTest.java Log: Fixed TCP cache server, and re-enabled tests Modified: core/trunk/src/main/java/org/jboss/cache/loader/TcpDelegatingCacheLoader.java =================================================================== --- core/trunk/src/main/java/org/jboss/cache/loader/TcpDelegatingCacheLoader.java 2009-01-05 17:29:33 UTC (rev 7377) +++ core/trunk/src/main/java/org/jboss/cache/loader/TcpDelegatingCacheLoader.java 2009-01-05 17:35:41 UTC (rev 7378) @@ -36,6 +36,7 @@ import java.io.ObjectOutputStream; import java.lang.reflect.InvocationTargetException; import java.lang.reflect.Method; +import java.net.ConnectException; import java.net.Socket; import java.util.List; import java.util.Map; @@ -391,11 +392,19 @@ @Override public void start() throws IOException { - sock = new Socket(config.getHost(), config.getPort()); - sock.setSoTimeout(config.getReadTimeout()); - out = new ObjectOutputStream(new BufferedOutputStream(sock.getOutputStream())); - out.flush(); - in = new ObjectInputStream(new BufferedInputStream(sock.getInputStream())); + try + { + sock = new Socket(config.getHost(), config.getPort()); + sock.setSoTimeout(config.getReadTimeout()); + out = new ObjectOutputStream(new BufferedOutputStream(sock.getOutputStream())); + out.flush(); + in = new ObjectInputStream(new BufferedInputStream(sock.getInputStream())); + } + catch (ConnectException ce) + { + log.info("Unable to connect to TCP socket on interface " + config.getHost() + " and port " + config.getPort()); + throw ce; + } } @Override Modified: core/trunk/src/main/java/org/jboss/cache/loader/tcp/TcpCacheServer.java =================================================================== --- core/trunk/src/main/java/org/jboss/cache/loader/tcp/TcpCacheServer.java 2009-01-05 17:29:33 UTC (rev 7377) +++ core/trunk/src/main/java/org/jboss/cache/loader/tcp/TcpCacheServer.java 2009-01-05 17:35:41 UTC (rev 7378) @@ -45,7 +45,6 @@ import java.net.UnknownHostException; import java.util.ArrayList; import java.util.Collections; -import java.util.HashMap; import java.util.HashSet; import java.util.LinkedList; import java.util.List; @@ -215,33 +214,30 @@ public void stop() { - if (running) + running = false; + synchronized (conns) { - running = false; - synchronized (conns) + // Connection.close() removes conn from the list, + // so copy off the list first to avoid ConcurrentModificationException + List<Connection> copy = new ArrayList<Connection>(conns); + for (Connection conn : copy) { - // Connection.close() removes conn from the list, - // so copy off the list first to avoid ConcurrentModificationException - List<Connection> copy = new ArrayList<Connection>(conns); - for (Connection conn : copy) - { - conn.close(); - } - conns.clear(); + conn.close(); } + conns.clear(); + } - if (srv_sock != null) + if (srv_sock != null) + { + try { - try - { - srv_sock.close(); - } - catch (IOException e) - { - // nada - } - srv_sock = null; + srv_sock.close(); } + catch (IOException e) + { + // nada + } + srv_sock = null; } } @@ -384,10 +380,6 @@ { map = Collections.emptyMap(); } - else - { - map = new HashMap(map); // TODO: copy this since FastCopyHashMap has issues with serialization at the moment - } output.writeObject(map); break; case TcpCacheOperations.EXISTS: Modified: core/trunk/src/test/java/org/jboss/cache/AbstractSingleCacheTest.java =================================================================== --- core/trunk/src/test/java/org/jboss/cache/AbstractSingleCacheTest.java 2009-01-05 17:29:33 UTC (rev 7377) +++ core/trunk/src/test/java/org/jboss/cache/AbstractSingleCacheTest.java 2009-01-05 17:35:41 UTC (rev 7378) @@ -1,10 +1,10 @@ package org.jboss.cache; +import org.jboss.cache.util.TestingUtil; +import org.testng.annotations.AfterClass; +import org.testng.annotations.AfterMethod; import org.testng.annotations.BeforeClass; -import org.testng.annotations.AfterMethod; -import org.testng.annotations.AfterClass; import org.testng.annotations.Test; -import org.jboss.cache.util.TestingUtil; /** * @author Mircea.Markus(a)jboss.com @@ -14,7 +14,22 @@ { protected CacheSPI<K, V> cache; + /** + * This method will always be called before {@link #create()}. If you override this, make sure you annotate the + * overridden method with {@link org.testng.annotations.BeforeClass}. + * + * @throws Exception Just in case + */ @BeforeClass + public void preCreate() throws Exception + { + // no op, made for overriding. + } + + // Due to some weirdness with TestNG, it always appends the package and class name to the method names + // provided on dependsOnMethods unless it thinks there already is a package. This does accept regular expressions + // though so .*. works. Otherwise it won't detect overridden methods in subclasses. + @BeforeClass(dependsOnMethods = "org.jboss.*.preCreate") protected void create() throws Exception { cache = createCache(); Modified: core/trunk/src/test/java/org/jboss/cache/loader/CacheLoaderTestsBase.java =================================================================== --- core/trunk/src/test/java/org/jboss/cache/loader/CacheLoaderTestsBase.java 2009-01-05 17:29:33 UTC (rev 7377) +++ core/trunk/src/test/java/org/jboss/cache/loader/CacheLoaderTestsBase.java 2009-01-05 17:35:41 UTC (rev 7378) @@ -2,11 +2,16 @@ import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; -import org.jboss.cache.*; -import org.jboss.cache.factories.UnitTestCacheConfigurationFactory; +import org.jboss.cache.AbstractSingleCacheTest; +import org.jboss.cache.CacheException; +import org.jboss.cache.CacheSPI; +import org.jboss.cache.Fqn; +import org.jboss.cache.Modification; +import org.jboss.cache.Node; +import org.jboss.cache.NodeSPI; +import org.jboss.cache.UnitTestCacheFactory; import org.jboss.cache.buddyreplication.BuddyManager; import org.jboss.cache.config.Configuration; -import org.jboss.cache.config.CacheLoaderConfig; import org.jboss.cache.statetransfer.DefaultStateTransferManager; import org.jboss.cache.transaction.TransactionSetup; import org.jboss.cache.util.TestingUtil; @@ -14,15 +19,21 @@ import org.jboss.util.stream.MarshalledValueOutputStream; import static org.testng.AssertJUnit.*; import org.testng.annotations.AfterMethod; +import org.testng.annotations.BeforeMethod; import org.testng.annotations.Test; -import org.testng.annotations.BeforeMethod; import javax.transaction.Transaction; import javax.transaction.TransactionManager; import java.io.ByteArrayInputStream; import java.io.ByteArrayOutputStream; import java.io.Serializable; -import java.util.*; +import java.util.ArrayList; +import java.util.Collections; +import java.util.HashMap; +import java.util.List; +import java.util.Map; +import java.util.Random; +import java.util.Set; import java.util.concurrent.CopyOnWriteArraySet; import java.util.concurrent.CountDownLatch; @@ -61,6 +72,7 @@ { CacheSPI<Object, Object> result = (CacheSPI<Object, Object>) new UnitTestCacheFactory<Object, Object>().createCache(false, getClass()); Configuration c = result.getConfiguration(); + c.setEvictionConfig(null); c.setCacheMode(Configuration.CacheMode.LOCAL); c.setTransactionManagerLookupClass(TransactionSetup.getManagerLookup()); configureCache(result); @@ -76,7 +88,9 @@ /** * Subclass if you need any further cfg after the cache starts. */ - protected void postConfigure() { } + protected void postConfigure() + { + } abstract protected void configureCache(CacheSPI cache) throws Exception; @@ -893,8 +907,6 @@ public void testRemoveData4() throws Exception { - - Set keys; Fqn key = Fqn.fromString("/x/y/z/"); cache.put(key, "keyA", "valA"); @@ -1527,7 +1539,8 @@ { assertTrue(set.contains(names[i])); } - } else + } + else { assertNull(set); } @@ -1946,7 +1959,8 @@ if (nested == null) { return super.hashCode(); - } else + } + else { return 13 + nested.hashCode(); } @@ -2258,7 +2272,8 @@ fqns.add(f); loader.put(f, "k", "v"); } - } else + } + else { loader.put(fqn, "k", "v"); } @@ -2406,7 +2421,7 @@ return cache.getConfiguration().getRuntimeConfig().getTransactionManager(); } - + public void testSetData() throws Exception { log.info("testSetData"); @@ -2422,7 +2437,7 @@ log.info("GET"); loaderMap = loader.get(key); assertEquals(map, loaderMap); - + assertNull(cache.get(key, "x")); assertEquals("c", cache.get(key, "c")); assertEquals("a", cache.get(key, "a")); Modified: core/trunk/src/test/java/org/jboss/cache/loader/TcpCacheLoaderTest.java =================================================================== --- core/trunk/src/test/java/org/jboss/cache/loader/TcpCacheLoaderTest.java 2009-01-05 17:29:33 UTC (rev 7377) +++ core/trunk/src/test/java/org/jboss/cache/loader/TcpCacheLoaderTest.java 2009-01-05 17:35:41 UTC (rev 7378) @@ -1,255 +1,315 @@ package org.jboss.cache.loader; +import org.jboss.cache.CacheException; +import org.jboss.cache.CacheSPI; +import org.jboss.cache.DefaultCacheFactory; +import org.jboss.cache.config.CacheLoaderConfig; +import org.jboss.cache.config.Configuration; +import org.jboss.cache.factories.UnitTestCacheConfigurationFactory; +import org.jboss.cache.interceptors.OrderedSynchronizationHandler; +import org.jboss.cache.loader.tcp.TcpCacheServer; +import org.jboss.cache.notifications.annotation.CacheListener; +import org.jboss.cache.notifications.annotation.NodeCreated; +import org.jboss.cache.notifications.event.Event; +import org.jboss.cache.transaction.GlobalTransaction; +import org.jboss.cache.util.TestingUtil; +import org.testng.annotations.AfterClass; +import org.testng.annotations.AfterMethod; +import org.testng.annotations.BeforeClass; import org.testng.annotations.Test; +import javax.transaction.Synchronization; +import java.util.Collections; +import java.util.HashMap; +import java.util.HashSet; +import java.util.Map; +import java.util.Set; +import java.util.concurrent.CountDownLatch; +import java.util.concurrent.TimeUnit; + /** * Tests the TcpDelegatingCacheLoader * * @author Bela Ban * @version $Id$ */ -@Test(groups = "functional", enabled = false, testName = "loader.TcpCacheLoaderTest") -// TODO re-enable!! -public class TcpCacheLoaderTest //extends CacheLoaderTestsBase +@Test(groups = "functional", enabled = true, testName = "loader.TcpCacheLoaderTest", sequential = true) +public class TcpCacheLoaderTest extends CacheLoaderTestsBase { -// protected static final int CACHE_SERVER_RESTART_DELAY_MS = 1000; -// protected static final int TCP_CACHE_LOADER_TIMEOUT_MS = 2000; -// protected static int START_COUNT = 0; -// static TcpCacheServer cacheServer = null; -// -// @BeforeClass -// public static void startCacheServer() -// { -// final CountDownLatch startedSignal = new CountDownLatch(1); -// -// Thread t = new Thread() -// { -// public void run() -// { -// try -// { -// cacheServer = new TcpCacheServer(); -// cacheServer.setBindAddress("127.0.0.1"); -// cacheServer.setPort(12121); -// Configuration config = UnitTestCacheConfigurationFactory.createConfiguration(Configuration.CacheMode.LOCAL, true); -// CacheSPI cache = (CacheSPI) new DefaultCacheFactory<Object, Object>().createCache(config); -// cacheServer.setCache(cache); -// cacheServer.create(); -// cacheServer.start(); -// START_COUNT++; -// startedSignal.countDown(); -// } -// catch (Exception ex) -// { -// ex.printStackTrace(); -// } -// } -// -// }; -// t.setDaemon(true); -// t.start(); -// -// // Wait for the cache server to start up. -// boolean started = false; -// try -// { -// started = startedSignal.await(120, TimeUnit.SECONDS); -// } -// catch (InterruptedException e) -// { -// // do nothing -// } -// -// if (!started) -// { -// // the TcpCacheServer was unable to start up for some reason!! -// throw new RuntimeException("Unable to start the TcpCacheServer after 120 seconds!!"); -// } -// } -// -// @AfterClass -// public static void stopCacheServer() -// { -// if (cacheServer != null) -// { -// cacheServer.stop(); -// } -// } -// -// protected static void restartCacheServer() -// { -// stopCacheServer(); -// startCacheServer(); -// } -// -// @Override -// public void testPartialLoadAndStore() -// { -// // do nothing -// } -// -// @Override -// public void testBuddyBackupStore() -// { -// // do nothing -// } -// -// protected void configureCache() throws Exception -// { -// cache.getConfiguration().setCacheLoaderConfig(getSingleCacheLoaderConfig("", -// TcpDelegatingCacheLoader.class.getName(), -// "host=127.0.0.1\nport=12121\ntimeout=" + TCP_CACHE_LOADER_TIMEOUT_MS, false, true, false)); -// } -// -// // restart tests -// public void testCacheServerRestartMidCall() throws Exception -// { -// CacheServerRestarter restarter = new CacheServerRestarter(); -// restarter.restart = true; -// cache.addCacheListener(restarter); -// int oldStartCount = START_COUNT; -// // a restart of the cache server will happen before the cache loader interceptor is called. -// cache.put(FQN, "key", "value"); -// -// assert oldStartCount + 1 == START_COUNT : "Cache server should have restarted!"; -// assert loader.get(FQN).equals(Collections.singletonMap("key", "value")); -// } -// -// public void testCacheServerDelayedRestartMidCall() throws Exception -// { -// CacheServerRestarter restarter = new CacheServerRestarter(); -// restarter.restart = false; -// restarter.delayedRestart = true; -// restarter.startAfter = CACHE_SERVER_RESTART_DELAY_MS; -// cache.addCacheListener(restarter); -// int oldStartCount = START_COUNT; -// -// // the cache server will STOP before the cache laoder interceptor is called. -// // it will be restarted in a separate thread, startAfter millis later. -// // this should be less than the TcpCacheLoader timeout. -// cache.put(FQN, "key", "value"); -// -// assert oldStartCount + 1 == START_COUNT : "Cache server should have restarted!"; -// assert loader.get(FQN).equals(Collections.singletonMap("key", "value")); -// } -// -// public void testCacheServerTimeoutMidCall() throws Exception -// { -// CacheServerRestarter restarter = new CacheServerRestarter(); -// restarter.restart = false; -// restarter.delayedRestart = true; -// restarter.startAfter = -1; -// cache.addCacheListener(restarter); -// int oldStartCount = START_COUNT; -// -// // the cache server will STOP before the cache laoder interceptor is called. -// // it will be restarted in a separate thread, startAfter millis later. -// // this should be less than the TcpCacheLoader timeout. -// try -// { -// cache.put(FQN, "key", "value"); -// assert false : "Should have failed"; -// } -// catch (CacheException expected) -// { -// -// } -// -// assert oldStartCount == START_COUNT : "Cache server should NOT have restarted!"; -// // start the TCP server again -// startCacheServer(); -// assert loader.get(FQN) == null; -// } -// -// public void testCacheServerRestartMidTransaction() throws Exception -// { -// int oldStartCount = START_COUNT; -// cache.getTransactionManager().begin(); -// cache.put(FQN, "key", "value"); -// restartCacheServer(); -// cache.put(FQN, "key2", "value2"); -// cache.getTransactionManager().commit(); -// -// Map m = new HashMap(); -// m.put("key", "value"); -// m.put("key2", "value2"); -// -// assert oldStartCount + 1 == START_COUNT : "Cache server should have restarted!"; -// assert loader.get(FQN).equals(m); -// } -// -// public void testCacheServerRestartMidTransactionAfterPrepare() throws Exception -// { -// int oldStartCount = START_COUNT; -// cache.getTransactionManager().begin(); -// -// cache.put(FQN, "key", "value"); -// cache.put(FQN, "key2", "value2"); -// -// GlobalTransaction gtx = cache.getTransactionTable().get(cache.getTransactionManager().getTransaction()); -// OrderedSynchronizationHandler osh = cache.getTransactionTable().get(gtx).getOrderedSynchronizationHandler(); -// -//// OrderedSynchronizationHandler.getInstance(cache.getTransactionManager().getTransaction()).registerAtTail( -// osh.registerAtTail( -// new Synchronization() -// { -// -// public void beforeCompletion() -// { -// // this will be called after the cache's prepare() phase. Restart the cache server. -// restartCacheServer(); -// } -// -// public void afterCompletion(int i) -// { -// // do nothing -// } -// } -// ); -// -// cache.getTransactionManager().commit(); -// -// Map m = new HashMap(); -// m.put("key", "value"); -// m.put("key2", "value2"); -// -// assert oldStartCount + 1 == START_COUNT : "Cache server should have restarted!"; -// assert loader.get(FQN).equals(m); -// -// } -// -// @CacheListener -// public static class CacheServerRestarter -// { -// boolean restart; -// boolean delayedRestart; -// int startAfter; -// -// @NodeCreated -// public void restart(Event e) -// { -// if (e.isPre()) -// { -// if (restart) -// { -// restartCacheServer(); -// } -// else if (delayedRestart) -// { -// stopCacheServer(); -// new Thread() -// { -// public void run() -// { -// if (startAfter > 0) -// { -// TestingUtil.sleepThread(startAfter); -// startCacheServer(); -// } -// } -// }.start(); -// } -// } -// } -// } + protected static final String TCP_CACHE_SERVER_HOST = "127.0.0.1"; + protected static final int TCP_CACHE_SERVER_PORT = 12121; + protected static final int CACHE_SERVER_RESTART_DELAY_MS = 250; + protected static final int TCP_CACHE_LOADER_TIMEOUT_MS = 1000; + protected static int START_COUNT = 0; + static volatile TcpCacheServer cacheServer = null; + + @Override + @BeforeClass + public void preCreate() + { + if (cacheServer != null) stopCacheServer(); + startCacheServer(); + } + + private static void startCacheServer() + { + final CountDownLatch startedSignal = new CountDownLatch(1); + + Thread t = new Thread() + { + public void run() + { + try + { + cacheServer = new TcpCacheServer(); + cacheServer.setBindAddress(TCP_CACHE_SERVER_HOST); + cacheServer.setPort(TCP_CACHE_SERVER_PORT); + Configuration config = UnitTestCacheConfigurationFactory.createConfiguration(Configuration.CacheMode.LOCAL, true); + // disable eviction!! + config.setEvictionConfig(null); + CacheSPI cache = (CacheSPI) new DefaultCacheFactory<Object, Object>().createCache(config); + cacheServer.setCache(cache); + cacheServer.create(); + cacheServer.start(); + START_COUNT++; + startedSignal.countDown(); + } + catch (Exception ex) + { + ex.printStackTrace(); + } + } + + }; + t.setDaemon(true); + t.start(); + + // Wait for the cache server to start up. + boolean started = false; + try + { + started = startedSignal.await(120, TimeUnit.SECONDS); + } + catch (InterruptedException e) + { + // do nothing + } + + if (!started) + { + // the TcpCacheServer was unable to start up for some reason!! + throw new RuntimeException("Unable to start the TcpCacheServer after 120 seconds!!"); + } + } + + @AfterClass + public static void stopCacheServer() + { + if (cacheServer != null) + { + cacheServer.stop(); + cacheServer = null; + } + } + + @AfterMethod + public void removeRestarters() + { + if (cache != null) + { + Set<Object> restarters = new HashSet<Object>(); + for (Object listener : cache.getCacheListeners()) + { + if (listener instanceof CacheServerRestarter) restarters.add(listener); + } + try + { + for (Object restarter : restarters) cache.removeCacheListener(restarter); + } + catch (Exception ignored) + { + // ignored + } + } + } + + protected static void restartCacheServer() + { + stopCacheServer(); + startCacheServer(); + } + + @Override + public void testPartialLoadAndStore() + { + // do nothing + } + + @Override + public void testBuddyBackupStore() + { + // do nothing + } + + protected void configureCache(CacheSPI cache) throws Exception + { + CacheLoaderConfig clc = new CacheLoaderConfig(); + TcpDelegatingCacheLoaderConfig tcpCfg = new TcpDelegatingCacheLoaderConfig(TCP_CACHE_SERVER_HOST, TCP_CACHE_SERVER_PORT, TCP_CACHE_LOADER_TIMEOUT_MS); + tcpCfg.setReconnectWaitTime(CACHE_SERVER_RESTART_DELAY_MS); + tcpCfg.setFetchPersistentState(false); + clc.addIndividualCacheLoaderConfig(tcpCfg); + cache.getConfiguration().setCacheLoaderConfig(clc); + } + + // restart tests + public void testCacheServerRestartMidCall() throws Exception + { + CacheServerRestarter restarter = new CacheServerRestarter(); + restarter.restart = true; + cache.addCacheListener(restarter); + int oldStartCount = START_COUNT; + // a restart of the cache server will happen before the cache loader interceptor is called. + cache.put(FQN, "key", "value"); + + assert oldStartCount + 1 == START_COUNT : "Cache server should have restarted!"; + assert loader.get(FQN).equals(Collections.singletonMap("key", "value")); + } + + public void testCacheServerDelayedRestartMidCall() throws Exception + { + CacheServerRestarter restarter = new CacheServerRestarter(); + restarter.restart = false; + restarter.delayedRestart = true; + restarter.startAfter = CACHE_SERVER_RESTART_DELAY_MS; + cache.addCacheListener(restarter); + int oldStartCount = START_COUNT; + + // the cache server will STOP before the cache laoder interceptor is called. + // it will be restarted in a separate thread, startAfter millis later. + // this should be less than the TcpCacheLoader timeout. + cache.put(FQN, "key", "value"); + + assert oldStartCount < START_COUNT : "Cache server should have restarted! old = " + oldStartCount + " and count = " + START_COUNT; + assert loader.get(FQN).equals(Collections.singletonMap("key", "value")); + } + + public void testCacheServerTimeoutMidCall() throws Exception + { + CacheServerRestarter restarter = new CacheServerRestarter(); + restarter.restart = false; + restarter.delayedRestart = true; + restarter.startAfter = -1; + cache.addCacheListener(restarter); + int oldStartCount = START_COUNT; + + // the cache server will STOP before the cache laoder interceptor is called. + // it will be restarted in a separate thread, startAfter millis later. + // this should be less than the TcpCacheLoader timeout. + try + { + cache.put(FQN, "key", "value"); + assert false : "Should have failed"; + } + catch (CacheException expected) + { + + } + + assert oldStartCount == START_COUNT : "Cache server should NOT have restarted!"; + // start the TCP server again + startCacheServer(); + assert loader.get(FQN) == null; + } + + public void testCacheServerRestartMidTransaction() throws Exception + { + int oldStartCount = START_COUNT; + cache.getTransactionManager().begin(); + cache.put(FQN, "key", "value"); + restartCacheServer(); + cache.put(FQN, "key2", "value2"); + cache.getTransactionManager().commit(); + + Map m = new HashMap(); + m.put("key", "value"); + m.put("key2", "value2"); + + assert oldStartCount < START_COUNT : "Cache server should have restarted!"; + assert loader.get(FQN).equals(m); + } + + public void testCacheServerRestartMidTransactionAfterPrepare() throws Exception + { + int oldStartCount = START_COUNT; + cache.getTransactionManager().begin(); + + cache.put(FQN, "key", "value"); + cache.put(FQN, "key2", "value2"); + + GlobalTransaction gtx = cache.getTransactionTable().get(cache.getTransactionManager().getTransaction()); + OrderedSynchronizationHandler osh = cache.getTransactionTable().get(gtx).getOrderedSynchronizationHandler(); + +// OrderedSynchronizationHandler.getInstance(cache.getTransactionManager().getTransaction()).registerAtTail( + osh.registerAtTail( + new Synchronization() + { + + public void beforeCompletion() + { + // this will be called after the cache's prepare() phase. Restart the cache server. + restartCacheServer(); + } + + public void afterCompletion(int i) + { + // do nothing + } + } + ); + + cache.getTransactionManager().commit(); + + Map m = new HashMap(); + m.put("key", "value"); + m.put("key2", "value2"); + + assert oldStartCount + 1 == START_COUNT : "Cache server should have restarted!"; + assert loader.get(FQN).equals(m); + + } + + @CacheListener + public static class CacheServerRestarter + { + boolean restart; + boolean delayedRestart; + int startAfter; + + @NodeCreated + public void restart(Event e) + { + if (e.isPre()) + { + if (restart) + { + restartCacheServer(); + } + else if (delayedRestart) + { + stopCacheServer(); + new Thread() + { + public void run() + { + if (startAfter > 0) + { + TestingUtil.sleepThread(startAfter); + startCacheServer(); + } + } + }.start(); + } + } + } + } }

16 years

1
0
0 / 0

JBoss Cache SVN: r7377 - core/trunk/src/main/java/org/jboss/cache/util.

by jbosscache-commits＠lists.jboss.org

Author: jason.greene(a)jboss.com Date: 2009-01-05 12:29:33 -0500 (Mon, 05 Jan 2009) New Revision: 7377 Modified: core/trunk/src/main/java/org/jboss/cache/util/FastCopyHashMap.java Log: Fix infinite loop condition on full table with get() and containsKey() Modified: core/trunk/src/main/java/org/jboss/cache/util/FastCopyHashMap.java =================================================================== --- core/trunk/src/main/java/org/jboss/cache/util/FastCopyHashMap.java 2009-01-05 17:18:58 UTC (rev 7376) +++ core/trunk/src/main/java/org/jboss/cache/util/FastCopyHashMap.java 2009-01-05 17:29:33 UTC (rev 7377) @@ -203,7 +203,7 @@ int length = table.length; int index = index(hash, length); - for (; ;) + for (int start = index; ;) { Entry<K, V> e = table[index]; if (e == null) @@ -213,6 +213,8 @@ return e.value; index = nextIndex(index, length); + if (index == start) // Full table + return null; } } @@ -224,7 +226,7 @@ int length = table.length; int index = index(hash, length); - for (; ;) + for (int start = index; ;) { Entry<K, V> e = table[index]; if (e == null) @@ -234,6 +236,8 @@ return true; index = nextIndex(index, length); + if (index == start) // Full table + return false; } } @@ -253,11 +257,9 @@ Entry<K, V>[] table = this.table; int hash = hash(key); int length = table.length; - int start = index(hash, length); - int index = start; + int index = index(hash, length); - - for (; ;) + for (int start = index; ;) { Entry<K, V> e = table[index]; if (e == null)

16 years

1
0
0 / 0

2025

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

2008

2007

2006

jbosscache-commits January 2009