Hibernate
/
hibernate-orm
mirror of https://github.com/hibernate/hibernate-orm
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[HHH-3390] Use READ_COMMITTED for JBC 2 cache 

git-svn-id: https://svn.jboss.org/repos/hibernate/core/trunk@14957 1b8cb986-b30d-0410-93ca-fae66ebed9b2
This commit is contained in:
Brian Stansberry 2008-07-18 17:10:47 +00:00
parent 869e7e7975
commit 9b76275df5
5 changed files with 491 additions and 82 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

281
cache-jbosscache2/src/main/resources/org/hibernate/cache/jbc2/builder/jbc2-configs.xml vendored
View File

@ -40,11 +40,7 @@
<!-- Node locking scheme -->
<attribute name="NodeLockingScheme">OPTIMISTIC</attribute>
<!-- Valid modes are LOCAL
REPL_ASYNC
REPL_SYNC
INVALIDATION_ASYNC
INVALIDATION_SYNC
<!-- Mode of communication with peer caches.
INVALIDATION_SYNC is highly recommended as the mode for use
with entity and collection caches.
@ -81,14 +77,15 @@
<attribute name="LockAcquisitionTimeout">15000</attribute>
<!--
Indicate whether to use marshalling or not. Set this to true if you are running under a scoped
class loader, e.g., inside an application server. Default is "false".
Indicate whether to use marshalling or not. Set this to true if you
are running under a scoped class loader, e.g., inside an application
server.
-->
<attribute name="UseRegionBasedMarshalling">true</attribute>
<!-- Must match the value of "useRegionBasedMarshalling" -->
<attribute name="InactiveOnStartup">true</attribute>
<!-- Specific eviction policy configurations. This is LRU -->
<!-- Eviction policy configurations. -->
<attribute name="EvictionPolicyConfig">
<config>
<attribute name="wakeUpIntervalSeconds">5</attribute>
@ -121,19 +118,12 @@
<attribute name="NodeLockingScheme">PESSIMISTIC</attribute>
<!--
Isolation level : SERIALIZABLE
REPEATABLE_READ (default)
READ_COMMITTED
READ_UNCOMMITTED
NONE
READ_COMMITTED is as strong as necessary for most
2nd Level Cache use cases.
-->
<attribute name="IsolationLevel">REPEATABLE_READ</attribute>
<attribute name="IsolationLevel">READ_COMMITTED</attribute>
<!-- Valid modes are LOCAL
REPL_ASYNC
REPL_SYNC
INVALIDATION_ASYNC
INVALIDATION_SYNC
<!-- Mode of communication with peer caches.
INVALIDATION_SYNC is highly recommended as the mode for use
with entity and collection caches.
@ -172,13 +162,99 @@
<!--
Indicate whether to use marshalling or not. Set this to true if you
are running under a scoped class loader, e.g., inside an application
server. Default is "false".
server.
-->
<attribute name="UseRegionBasedMarshalling">true</attribute>
<!-- Must match the value of "useRegionBasedMarshalling" -->
<attribute name="InactiveOnStartup">true</attribute>
<!-- Specific eviction policy configurations. This is LRU -->
<!-- Eviction policy configurations. -->
<attribute name="EvictionPolicyConfig">
<config>
<attribute name="wakeUpIntervalSeconds">5</attribute>
<!-- Name of the DEFAULT eviction policy class. -->
<attribute name="policyClass">org.jboss.cache.eviction.LRUPolicy</attribute>
<!-- Cache wide default -->
<region name="/_default_">
<!-- Evict LRU node once we have more than this number of nodes -->
<attribute name="maxNodes">10000</attribute>
<!-- And, evict any node that hasn't been accessed in this many seconds -->
<attribute name="timeToLiveSeconds">1000</attribute>
<!-- Don't evict a node that's been accessed within this many seconds.
Set this to a value greater than your max expected transaction length. -->
<attribute name="minTimeToLiveSeconds">120</attribute>
</region>
<!-- Don't ever evict modification timestamps -->
<region name="/TS" policyClass="org.jboss.cache.eviction.NullEvictionPolicy"/>
</config>
</attribute>
</cache-config>
<!-- Same as "pessimistic-entity" but here we use REPEATABLE_READ
instead of READ_COMMITTED. REPEATABLE_READ is only useful if the
application evicts/clears entities from the Hibernate Session and
then expects to repeatably re-read them in the same transaction.
Otherwise, the Session's internal cache provides a repeatable-read
semantic. Before choosing this config, carefully read the docs
and make sure you really need REPEATABLE_READ.
-->
<cache-config name="pessimistic-entity-repeatable">
<!-- Node locking scheme -->
<attribute name="NodeLockingScheme">PESSIMISTIC</attribute>
<!-- Here we use REPEATABLE_READ. -->
<attribute name="IsolationLevel">REPEATABLE_READ</attribute>
<!-- Mode of communication with peer caches.
INVALIDATION_SYNC is highly recommended as the mode for use
with entity and collection caches.
-->
<attribute name="CacheMode">INVALIDATION_SYNC</attribute>
<!-- Name of cluster. Needs to be the same for all members, in order
to find each other -->
<attribute name="ClusterName">pessimistic-entity</attribute>
<!-- Use a UDP (multicast) based stack. A udp-sync stack might be
slightly better (no JGroups FC) but we stick with udp to
help ensure this cache and others like timestamps-cache
that require FC can use the same underlying JGroups resources. -->
<attribute name="MultiplexerStack">udp</attribute>
<!-- Whether or not to fetch state on joining a cluster. -->
<attribute name="FetchInMemoryState">false</attribute>
<!--
The max amount of time (in milliseconds) we wait until the
state (ie. the contents of the cache) are retrieved from
existing members at startup. Ignored if FetchInMemoryState=false.
-->
<attribute name="StateRetrievalTimeout">20000</attribute>
<!--
Number of milliseconds to wait until all responses for a
synchronous call have been received.
-->
<attribute name="SyncReplTimeout">20000</attribute>
<!-- Max number of milliseconds to wait for a lock acquisition -->
<attribute name="LockAcquisitionTimeout">15000</attribute>
<!--
Indicate whether to use marshalling or not. Set this to true if you
are running under a scoped class loader, e.g., inside an application
server.
-->
<attribute name="UseRegionBasedMarshalling">true</attribute>
<!-- Must match the value of "useRegionBasedMarshalling" -->
<attribute name="InactiveOnStartup">true</attribute>
<!-- Eviction policy configurations. -->
<attribute name="EvictionPolicyConfig">
<config>
<attribute name="wakeUpIntervalSeconds">5</attribute>
@ -211,12 +287,16 @@
<!-- Node locking scheme -->
<attribute name="NodeLockingScheme">OPTIMISTIC</attribute>
<!-- Mode of communication with peer caches.
LOCAL means don't communicate with other caches.
-->
<attribute name="CacheMode">LOCAL</attribute>
<!-- Max number of milliseconds to wait for a lock acquisition -->
<attribute name="LockAcquisitionTimeout">15000</attribute>
<!-- Specific eviction policy configurations. This is LRU -->
<!-- Eviction policy configurations. -->
<attribute name="EvictionPolicyConfig">
<config>
<attribute name="wakeUpIntervalSeconds">5</attribute>
@ -242,30 +322,20 @@
<!-- A query cache that replicates queries. Replication is asynchronous.
DO NOT STORE TIMESTAMPS IN THIS CACHE.
DO NOT STORE TIMESTAMPS IN THIS CACHE as no initial state transfer
is performed.
-->
<cache-config name="replicated-query">
<!-- Node locking scheme -->
<attribute name="NodeLockingScheme">OPTIMISTIC</attribute>
<!--
Isolation level : SERIALIZABLE
REPEATABLE_READ (default)
READ_COMMITTED
READ_UNCOMMITTED
NONE
-->
<attribute name="IsolationLevel">REPEATABLE_READ</attribute>
<!-- Mode of communication with peer caches.
<!-- Valid modes are LOCAL
REPL_ASYNC
REPL_SYNC
INVALIDATION_ASYNC
INVALIDATION_SYNC
INVALIDATION_SYNC is highly recommended as the mode for use
with entity and collection caches.
REPL_ASYNC means replicate but sender does not block waiting for
peers to acknowledge applying the change. Valid for queries as
the timestamp cache mechanism will allow Hibernate to discard
out-of-date queries.
-->
<attribute name="CacheMode">REPL_ASYNC</attribute>
@ -304,7 +374,7 @@
<!-- Must match the value of "useRegionBasedMarshalling" -->
<attribute name="InactiveOnStartup">true</attribute>
<!-- Specific eviction policy configurations. This is LRU -->
<!-- Eviction policy configurations. -->
<attribute name="EvictionPolicyConfig">
<config>
<attribute name="wakeUpIntervalSeconds">5</attribute>
@ -339,13 +409,9 @@
<attribute name="NodeLockingScheme">PESSIMISTIC</attribute>
<!--
Isolation level : SERIALIZABLE
REPEATABLE_READ (default)
READ_COMMITTED
READ_UNCOMMITTED
NONE
READ_COMMITTED is as strong as necessary.
-->
<attribute name="IsolationLevel">REPEATABLE_READ</attribute>
<attribute name="IsolationLevel">READ_COMMITTED</attribute>
<!-- Cannot be INVALIDATION. ASYNC for improved performance. -->
<attribute name="CacheMode">REPL_ASYNC</attribute>
@ -385,7 +451,7 @@
<!-- Must match the value of "useRegionBasedMarshalling" -->
<attribute name="InactiveOnStartup">true</attribute>
<!-- Specific eviction policy configurations. This is LRU -->
<!-- Eviction policy configurations. -->
<attribute name="EvictionPolicyConfig">
<config>
<attribute name="wakeUpIntervalSeconds">5</attribute>
@ -423,7 +489,9 @@
-->
<attribute name="NodeLockingScheme">OPTIMISTIC</attribute>
<!-- Must use REPL since used for timestamp caching. -->
<!-- Must use REPL since used for timestamp caching.
Must use SYNC to maintain cache coherency for entities.
-->
<attribute name="CacheMode">REPL_SYNC</attribute>
<!-- With OPTIMISTIC with replication we need to use synchronous commits. -->
@ -466,7 +534,7 @@
<!-- Must match the value of "useRegionBasedMarshalling" -->
<attribute name="InactiveOnStartup">true</attribute>
<!-- Specific eviction policy configurations. This is LRU -->
<!-- Eviction policy configurations. -->
<attribute name="EvictionPolicyConfig">
<config>
<attribute name="wakeUpIntervalSeconds">5</attribute>
@ -503,29 +571,17 @@
Hibernate will plug in its own transaction manager integration.
-->
<!-- Node locking scheme:
OPTIMISTIC
PESSIMISTIC (default)
-->
<!-- Node locking scheme -->
<attribute name="NodeLockingScheme">PESSIMISTIC</attribute>
<!--
Isolation level : SERIALIZABLE
REPEATABLE_READ (default)
READ_COMMITTED
READ_UNCOMMITTED
NONE
READ_COMMITTED is as strong as necessary for most
2nd Level Cache use cases.
-->
<attribute name="IsolationLevel">REPEATABLE_READ</attribute>
<attribute name="IsolationLevel">READ_COMMITTED</attribute>
<!-- Valid modes are LOCAL
REPL_ASYNC
REPL_SYNC
INVALIDATION_ASYNC
INVALIDATION_SYNC
INVALIDATION_SYNC is highly recommended as the mode for use
with entity and collection caches.
<!-- Must use REPL since used for timestamp caching.
Must use SYNC to maintain cache coherency for entities.
-->
<attribute name="CacheMode">REPL_SYNC</attribute>
@ -560,13 +616,100 @@
<!--
Indicate whether to use marshalling or not. Set this to true if you
are running under a scoped class loader, e.g., inside an application
server. Default is "false".
server.
-->
<attribute name="UseRegionBasedMarshalling">true</attribute>
<!-- Must match the value of "useRegionBasedMarshalling" -->
<attribute name="InactiveOnStartup">true</attribute>
<!-- Specific eviction policy configurations. This is LRU -->
<!-- Eviction policy configurations. -->
<attribute name="EvictionPolicyConfig">
<config>
<attribute name="wakeUpIntervalSeconds">5</attribute>
<!-- Name of the DEFAULT eviction policy class. -->
<attribute name="policyClass">org.jboss.cache.eviction.LRUPolicy</attribute>
<!-- Cache wide default -->
<region name="/_default_">
<!-- Evict LRU node once we have more than this number of nodes -->
<attribute name="maxNodes">10000</attribute>
<!-- And, evict any node that hasn't been accessed in this many seconds -->
<attribute name="timeToLiveSeconds">1000</attribute>
<!-- Don't evict a node that's been accessed within this many seconds.
Set this to a value greater than your max expected transaction length. -->
<attribute name="minTimeToLiveSeconds">120</attribute>
</region>
<!-- Don't ever evict modification timestamps -->
<region name="/TS" policyClass="org.jboss.cache.eviction.NullEvictionPolicy"/>
</config>
</attribute>
</cache-config>
<!-- Same as "pessimistic-shared" but here we use REPEATABLE_READ
instead of READ_COMMITTED. REPEATABLE_READ is only useful if the
application evicts/clears entities from the Hibernate Session and
then expects to repeatably re-read them in the same transaction.
Otherwise, the Session's internal cache provides a repeatable-read
semantic. Before choosing this config, carefully read the docs
and make sure you really need REPEATABLE_READ.
-->
<cache-config name="pessimistic-shared-repeatable">
<!-- TransactionManager configuration not required for Hibernate!
Hibernate will plug in its own transaction manager integration.
-->
<!-- Node locking scheme -->
<attribute name="NodeLockingScheme">PESSIMISTIC</attribute>
<!-- Here we use REPEATABLE_READ. -->
<attribute name="IsolationLevel">REPEATABLE_READ</attribute>
<!-- Must use REPL since used for timestamp caching.
Must use SYNC to maintain cache coherency for entities.
-->
<attribute name="CacheMode">REPL_SYNC</attribute>
<!-- Name of cluster. Needs to be the same for all members, in order
to find each other -->
<attribute name="ClusterName">pessimistic-shared</attribute>
<!-- Use a UDP (multicast) based stack. Need JGroups flow control (FC)
because timestamp communication will not require a synchronous response.
-->
<attribute name="MultiplexerStack">udp</attribute>
<!-- Used for timestamps, so must fetch state. -->
<attribute name="FetchInMemoryState">true</attribute>
<!--
The max amount of time (in milliseconds) we wait until the
state (ie. the contents of the cache) are retrieved from
existing members at startup.
-->
<attribute name="StateRetrievalTimeout">20000</attribute>
<!--
Number of milliseconds to wait until all responses for a
synchronous call have been received.
-->
<attribute name="SyncReplTimeout">20000</attribute>
<!-- Max number of milliseconds to wait for a lock acquisition -->
<attribute name="LockAcquisitionTimeout">15000</attribute>
<!--
Indicate whether to use marshalling or not. Set this to true if you
are running under a scoped class loader, e.g., inside an application
server.
-->
<attribute name="UseRegionBasedMarshalling">true</attribute>
<!-- Must match the value of "useRegionBasedMarshalling" -->
<attribute name="InactiveOnStartup">true</attribute>
<!-- Eviction policy configurations. -->
<attribute name="EvictionPolicyConfig">
<config>
<attribute name="wakeUpIntervalSeconds">5</attribute>

172
cache-jbosscache2/src/test/java/org/hibernate/test/cache/jbc2/Jbc2ConfigsXmlValidityTestCase.java vendored Normal file
View File

@ -0,0 +1,172 @@
/*
* Copyright (c) 2007, Red Hat Middleware, LLC. All rights reserved.
*
* This copyrighted material is made available to anyone wishing to use, modify,
* copy, or redistribute it subject to the terms and conditions of the GNU
* Lesser General Public License, v. 2.1. This program is distributed in the
* hope that it will be useful, but WITHOUT A WARRANTY; without even the implied
* warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details. You should have received a
* copy of the GNU Lesser General Public License, v.2.1 along with this
* distribution; if not, write to the Free Software Foundation, Inc.,
* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
*
* Red Hat Author(s): Brian Stansberry
*/
package org.hibernate.test.cache.jbc2;
import java.util.HashSet;
import java.util.Set;
import java.util.concurrent.atomic.AtomicReference;
import junit.framework.Test;
import junit.framework.TestSuite;
import org.hibernate.test.util.CacheManagerTestSetup;
import org.jboss.cache.Cache;
import org.jboss.cache.CacheManager;
/**
* Tests the validity of the JBC configs in jbc2-configs.xml.
*
* @author <a href="brian.stansberry@jboss.com">Brian Stansberry</a>
* @version $Revision: 1 $
*/
public class Jbc2ConfigsXmlValidityTestCase extends AbstractJBossCacheTestCase
{
private static final AtomicReference<CacheManager> cacheManagerRef = new AtomicReference<CacheManager>();
private static final Set<String> stdConfigs = new HashSet<String>();
static
{
stdConfigs.add("optimistic-entity");
stdConfigs.add("pessimistic-entity");
stdConfigs.add("pessimistic-entity-repeatable");
stdConfigs.add("optimistic-shared");
stdConfigs.add("pessimistic-shared");
stdConfigs.add("pessimistic-shared-repeatable");
stdConfigs.add("local-query");
stdConfigs.add("replicated-query");
stdConfigs.add("timestamps-cache");
}
private CacheManager mgr;
private String cacheName;
private Cache cache;
/**
* Create a new Jbc2ConfigsXmlValidityTestCase.
*
* @param name
*/
public Jbc2ConfigsXmlValidityTestCase(String name)
{
super(name);
}
public static Test suite() throws Exception {
TestSuite suite = new TestSuite(Jbc2ConfigsXmlValidityTestCase.class);
return new CacheManagerTestSetup(suite, cacheManagerRef);
}
@Override
protected void setUp() throws Exception
{
super.setUp();
this.mgr = cacheManagerRef.get();
}
@Override
protected void tearDown() throws Exception
{
super.tearDown();
if (cache != null)
{
try
{
mgr.releaseCache(this.cacheName);
}
catch (Exception ignored) {}
cache = null;
}
mgr = null;
}
public void testOptimisticEntity() throws Exception
{
stdConfigTest("optimistic-entity");
}
public void testPessimisticEntity() throws Exception
{
stdConfigTest("pessimistic-entity");
}
public void testPessimisticEntityRepeatable() throws Exception
{
stdConfigTest("pessimistic-entity-repeatable");
}
public void testOptimisticShared() throws Exception
{
stdConfigTest("optimistic-shared");
}
public void testPessimisticShared() throws Exception
{
stdConfigTest("pessimistic-shared");
}
public void testPessimisticSharedRepeatable() throws Exception
{
stdConfigTest("pessimistic-shared-repeatable");
}
public void testLocalQuery() throws Exception
{
stdConfigTest("local-query");
}
public void testReplicatedQuery() throws Exception
{
stdConfigTest("replicated-query");
}
public void testTimestampsCache() throws Exception
{
stdConfigTest("timestamps-cache");
}
public void testAdditionalConfigs() throws Exception
{
Set<String> names = new HashSet<String>(this.mgr.getConfigurationNames());
names.removeAll(stdConfigs);
for (String name : names)
{
configTest(name);
}
}
private void stdConfigTest(String configName) throws Exception
{
assertTrue(this.mgr.getConfigurationNames().contains(configName));
configTest(configName);
}
private void configTest(String configName) throws Exception
{
this.cacheName = configName;
this.cache = mgr.getCache(configName, true);
this.cache.start();
this.mgr.releaseCache(this.cacheName);
this.cache = null;
}
}

3
cache-jbosscache2/src/test/java/org/hibernate/test/cache/jbc2/query/QueryRegionImplTestCase.java vendored
View File

@ -265,7 +265,8 @@ public class QueryRegionImplTestCase extends AbstractGeneralDataRegionTestCase {
blockerLatch.countDown();
unblocked = true;
if ("PESSIMISTIC".equals(jbc.getConfiguration().getNodeLockingSchemeString())) {
if ("PESSIMISTIC".equals(jbc.getConfiguration().getNodeLockingSchemeString())
&& "REPEATABLE_READ".equals(jbc.getConfiguration().getIsolationLevelString())) {
assertEquals(VALUE1, region.get(KEY));
}
else {

97
cache-jbosscache2/src/test/java/org/hibernate/test/util/CacheManagerTestSetup.java Normal file
View File

@ -0,0 +1,97 @@
/*
* Copyright (c) 2007, Red Hat Middleware, LLC. All rights reserved.
*
* This copyrighted material is made available to anyone wishing to use, modify,
* copy, or redistribute it subject to the terms and conditions of the GNU
* Lesser General Public License, v. 2.1. This program is distributed in the
* hope that it will be useful, but WITHOUT A WARRANTY; without even the implied
* warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details. You should have received a
* copy of the GNU Lesser General Public License, v.2.1 along with this
* distribution; if not, write to the Free Software Foundation, Inc.,
* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
*
* Red Hat Author(s): Brian Stansberry
*/
package org.hibernate.test.util;
import java.util.concurrent.atomic.AtomicReference;
import junit.extensions.TestSetup;
import junit.framework.Test;
import org.jboss.cache.CacheManager;
import org.jboss.cache.CacheManagerImpl;
import org.jgroups.ChannelFactory;
import org.jgroups.JChannelFactory;
/**
* A TestSetup that starts a CacheManager in setUp() and stops it in tearDown().
* AtomicReference passed to the constructor can be used by the test to
* access the CacheManager.
*
* @author <a href="brian.stansberry@jboss.com">Brian Stansberry</a>
* @version $Revision: 1 $
*/
public class CacheManagerTestSetup extends TestSetup
{
public static final String DEF_CACHE_FACTORY_RESOURCE = "org/hibernate/cache/jbc2/builder/jbc2-configs.xml";
public static final String DEF_JGROUPS_RESOURCE = "org/hibernate/cache/jbc2/builder/jgroups-stacks.xml";
private final String jbcConfig;
private final String jgConfig;
private final AtomicReference<CacheManager> cacheManagerRef;
private ChannelFactory channelFactory;
public CacheManagerTestSetup(Test test, AtomicReference<CacheManager> cacheManagerRef)
{
this(test, DEF_CACHE_FACTORY_RESOURCE, DEF_JGROUPS_RESOURCE, cacheManagerRef);
}
public CacheManagerTestSetup(Test test, String jbcConfig, String jgConfig, AtomicReference<CacheManager> cacheManagerRef)
{
super(test);
this.jbcConfig = jbcConfig;
this.jgConfig = jgConfig;
this.cacheManagerRef = cacheManagerRef;
}
public CacheManagerTestSetup(Test test, String jbcConfig, ChannelFactory channelFactory, AtomicReference<CacheManager> cacheManagerRef)
{
super(test);
this.jbcConfig = jbcConfig;
this.jgConfig = null;
this.cacheManagerRef = cacheManagerRef;
this.channelFactory = channelFactory;
}
@Override
protected void setUp() throws Exception
{
super.setUp();
if (this.channelFactory == null)
{
this.channelFactory = new JChannelFactory();
this.channelFactory.setMultiplexerConfig(this.jgConfig);
}
CacheManagerImpl jbcFactory = new CacheManagerImpl(this.jbcConfig, this.channelFactory);
this.cacheManagerRef.set(jbcFactory);
jbcFactory.start();
}
@Override
protected void tearDown() throws Exception
{
super.tearDown();
this.channelFactory = null;
CacheManager jbcFactory = this.cacheManagerRef.get();
this.cacheManagerRef.set(null);
((CacheManagerImpl) jbcFactory).stop();
}
}

8
cache-jbosscache2/src/test/resources/treecache.xml
View File

@ -56,13 +56,9 @@
<attribute name="NodeLockingScheme">PESSIMISTIC</attribute>
<!--
Isolation level : SERIALIZABLE
REPEATABLE_READ (default)
READ_COMMITTED
READ_UNCOMMITTED
NONE
READ_COMMITTED is as strong as necessary for most 2nd Level Cache usage.
-->
<attribute name="IsolationLevel">REPEATABLE_READ</attribute>
<attribute name="IsolationLevel">READ_COMMITTED</attribute>
<!-- Valid modes are LOCAL
REPL_ASYNC