Modifier and Type	Class and Description
private static class	EhcacheReadWriteCache.Item Wrapper type representing unlocked items.
private static class	EhcacheReadWriteCache.Lock Wrapper type representing locked items.
private static interface	EhcacheReadWriteCache.Lockable Interface type implemented by all wrapper objects in the cache.

Modifier and Type	Field and Description
private final ReentrantReadWriteLock.ReadLock	coarseReadLock
private final ReentrantReadWriteLock.WriteLock	coarseWriteLock
private static final Logger	LOG Hides net.sf.ehcache.hibernate.ccs.AbstractEhcacheConcurrencyStrategy.LOG.
private final AtomicLong	nextLockId
private final UUID	uuid

Access	Constructor and Description
public	EhcacheReadWriteCache()

Method Summary

Modifier and Type	Method and Description
public boolean	afterInsert(Object key, Object value, Object version) Implements org.hibernate.cache.CacheConcurrencyStrategy.afterInsert. Called after an item has been inserted (after the transaction completes), instead of calling release().
public boolean	afterUpdate(Object key, Object value, Object version, SoftLock softlock) Implements org.hibernate.cache.CacheConcurrencyStrategy.afterUpdate. Called after an item has been updated (after the transaction completes), instead of calling release().
private void	decrementLock(Object key, EhcacheReadWriteCache.Lock lock)
public void	evict(Object key) Implements org.hibernate.cache.CacheConcurrencyStrategy.evict. A No-Op, since we are an asynchronous cache concurrency strategy.
public Object	get(Object key, long a timestamp prior to the transaction start time txTimestamp) Implements org.hibernate.cache.CacheConcurrencyStrategy.get. Attempt to retrieve an object from the cache.
private void	handleLockExpiry(Object key)
public boolean	insert(Object key, Object value, Object currentVersion) Implements org.hibernate.cache.CacheConcurrencyStrategy.insert. A No-Op, since we are an asynchronous cache concurrency strategy.
public SoftLock	lock(Object key, Object version) Implements org.hibernate.cache.CacheConcurrencyStrategy.lock. Soft-locks the associated mapping prior to updating/inserting a new value.
private long	nextLockId()
public boolean	put(Object key, Object value, long a timestamp prior to the transaction start time txTimestamp, Object the item version number version, Comparator<T> a comparator used to compare version numbers versionComparator, boolean indicates that the cache should avoid a put is the item is already cached minimalPut) Implements org.hibernate.cache.CacheConcurrencyStrategy.put. Attempt to cache an object, after loading from the database.
private void	readLockIfCoarse(Object key)
private void	readUnlockIfCoarse(Object key)
public void	release(Object key, SoftLock lock) Implements org.hibernate.cache.CacheConcurrencyStrategy.release. Soft-unlocks the associated mapping.
public boolean	update(Object key, Object value, Object currentVersion, Object previousVersion) Implements org.hibernate.cache.CacheConcurrencyStrategy.update. A No-Op, since we are an asynchronous cache concurrency strategy.
private void	writeLock(Object key)
private void	writeUnlock(Object key)

Inherited from net.sf.ehcache.hibernate.ccs.AbstractEhcacheConcurrencyStrategy:: clear destroy getCache getRegionName remove setCache

Field Detail

coarseReadLock	back to summary
private final ReentrantReadWriteLock.ReadLock coarseReadLock

coarseWriteLock	back to summary
private final ReentrantReadWriteLock.WriteLock coarseWriteLock

LOG	back to summary
private static final Logger LOG Hides net.sf.ehcache.hibernate.ccs.AbstractEhcacheConcurrencyStrategy.LOG.

nextLockId	back to summary
private final AtomicLong nextLockId

uuid	back to summary
private final UUID uuid

EhcacheReadWriteCache	back to summary
public EhcacheReadWriteCache()

Method Detail

afterInsert	back to summary
public boolean afterInsert(Object key, Object value, Object version) throws CacheException Implements org.hibernate.cache.CacheConcurrencyStrategy.afterInsert. Doc from org.hibernate.cache.CacheConcurrencyStrategy.afterInsert. Called after an item has been inserted (after the transaction completes), instead of calling release(). This method is used by "asynchronous" concurrency strategies.

afterInsert

back to summary

public boolean afterInsert(Object key, Object value, Object version) throws CacheException

Implements org.hibernate.cache.CacheConcurrencyStrategy.afterInsert.

Doc from org.hibernate.cache.CacheConcurrencyStrategy.afterInsert.

Called after an item has been inserted (after the transaction completes), instead of calling release(). This method is used by "asynchronous" concurrency strategies.

afterUpdate	back to summary
public boolean afterUpdate(Object key, Object value, Object version, SoftLock softlock) throws CacheException Implements org.hibernate.cache.CacheConcurrencyStrategy.afterUpdate. Doc from org.hibernate.cache.CacheConcurrencyStrategy.afterUpdate. Called after an item has been updated (after the transaction completes), instead of calling release(). This method is used by "asynchronous" concurrency strategies.

afterUpdate

back to summary

public boolean afterUpdate(Object key, Object value, Object version, SoftLock softlock) throws CacheException

Implements org.hibernate.cache.CacheConcurrencyStrategy.afterUpdate.

Doc from org.hibernate.cache.CacheConcurrencyStrategy.afterUpdate.

Called after an item has been updated (after the transaction completes), instead of calling release(). This method is used by "asynchronous" concurrency strategies.

decrementLock	back to summary
private void decrementLock(Object key, EhcacheReadWriteCache.Lock lock)

evict	back to summary
public void evict(Object key) throws CacheException Implements org.hibernate.cache.CacheConcurrencyStrategy.evict. A No-Op, since we are an asynchronous cache concurrency strategy.

evict

back to summary

public void evict(Object key) throws CacheException

Implements org.hibernate.cache.CacheConcurrencyStrategy.evict.

A No-Op, since we are an asynchronous cache concurrency strategy.

get back to summary

get	back to summary
public Object get(Object key, long txTimestamp) throws CacheException Implements org.hibernate.cache.CacheConcurrencyStrategy.get. Doc from org.hibernate.cache.CacheConcurrencyStrategy.get. Attempt to retrieve an object from the cache. Mainly used in attempting to resolve entities/collections from the second level cache. Parameters txTimestamp:long a timestamp prior to the transaction start time Returns:Object the cached object or `null`

public Object get(Object key, long txTimestamp) throws CacheException

Implements org.hibernate.cache.CacheConcurrencyStrategy.get.

Doc from org.hibernate.cache.CacheConcurrencyStrategy.get.

Attempt to retrieve an object from the cache. Mainly used in attempting to resolve entities/collections from the second level cache.

Parameters

txTimestamp:long: a timestamp prior to the transaction start time

Returns:Object

the cached object or null

handleLockExpiry	back to summary
private void handleLockExpiry(Object key)

insert	back to summary
public boolean insert(Object key, Object value, Object currentVersion) throws CacheException Implements org.hibernate.cache.CacheConcurrencyStrategy.insert. A No-Op, since we are an asynchronous cache concurrency strategy.

insert

back to summary

public boolean insert(Object key, Object value, Object currentVersion) throws CacheException

Implements org.hibernate.cache.CacheConcurrencyStrategy.insert.

A No-Op, since we are an asynchronous cache concurrency strategy.

lock	back to summary
public SoftLock lock(Object key, Object version) throws CacheException Implements org.hibernate.cache.CacheConcurrencyStrategy.lock. Soft-locks the associated mapping prior to updating/inserting a new value.

lock

back to summary

public SoftLock lock(Object key, Object version) throws CacheException

Implements org.hibernate.cache.CacheConcurrencyStrategy.lock.

Soft-locks the associated mapping prior to updating/inserting a new value.

nextLockId	back to summary
private long nextLockId()

put back to summary

put	back to summary
public boolean put(Object key, Object value, long txTimestamp, Object version, Comparator<T> versionComparator, boolean minimalPut) throws CacheException Implements org.hibernate.cache.CacheConcurrencyStrategy.put. Doc from org.hibernate.cache.CacheConcurrencyStrategy.put. Attempt to cache an object, after loading from the database. Parameters txTimestamp:long a timestamp prior to the transaction start time version:Object the item version number versionComparator:Comparator<T> a comparator used to compare version numbers minimalPut:boolean indicates that the cache should avoid a put is the item is already cached Returns:boolean `true` if the object was successfully cached

public boolean put(Object key, Object value, long txTimestamp, Object version, Comparator<T> versionComparator, boolean minimalPut) throws CacheException

Implements org.hibernate.cache.CacheConcurrencyStrategy.put.

Doc from org.hibernate.cache.CacheConcurrencyStrategy.put.

Attempt to cache an object, after loading from the database.

Parameters

txTimestamp:long: a timestamp prior to the transaction start time
version:Object: the item version number
versionComparator:Comparator<T>: a comparator used to compare version numbers
minimalPut:boolean: indicates that the cache should avoid a put is the item is already cached

Returns:boolean

true if the object was successfully cached

readLockIfCoarse	back to summary
private void readLockIfCoarse(Object key)

readUnlockIfCoarse	back to summary
private void readUnlockIfCoarse(Object key)

release	back to summary
public void release(Object key, SoftLock lock) throws CacheException Implements org.hibernate.cache.CacheConcurrencyStrategy.release. Soft-unlocks the associated mapping.

release

back to summary

public void release(Object key, SoftLock lock) throws CacheException

Implements org.hibernate.cache.CacheConcurrencyStrategy.release.

Soft-unlocks the associated mapping.

update	back to summary
public boolean update(Object key, Object value, Object currentVersion, Object previousVersion) throws CacheException Implements org.hibernate.cache.CacheConcurrencyStrategy.update. A No-Op, since we are an asynchronous cache concurrency strategy.

update

back to summary

public boolean update(Object key, Object value, Object currentVersion, Object previousVersion) throws CacheException

Implements org.hibernate.cache.CacheConcurrencyStrategy.update.

A No-Op, since we are an asynchronous cache concurrency strategy.

writeLock	back to summary
private void writeLock(Object key)

writeUnlock	back to summary
private void writeUnlock(Object key)

net.sf.ehcache.hibernate.ccs back to summary

private final Class EhcacheReadWriteCache.Item

Class Inheritance

extends Object
implements Serializable, Lockable

java.lang.Object
net.sf.ehcache.hibernate.ccs.EhcacheReadWriteCache.Item

All Implemented Interfaces

net.sf.ehcache.hibernate.ccs.EhcacheReadWriteCache.Lockable, java.io.Serializable

Wrapper type representing unlocked items.

Field Summary

Modifier and Type	Field and Description
private static final long	serialVersionUID
private final long	timestamp
private final Object	value
private final Object	version

Constructor Summary

Access	Constructor and Description
private	Item(Object value, Object version, long timestamp)

Method Summary

Modifier and Type	Method and Description
public Object	getValue() Implements net.sf.ehcache.hibernate.ccs.EhcacheReadWriteCache.Lockable.getValue.
public boolean	isReadable(long txTimestamp) Implements net.sf.ehcache.hibernate.ccs.EhcacheReadWriteCache.Lockable.isReadable.
public boolean	isUnlockable(SoftLock lock) Implements net.sf.ehcache.hibernate.ccs.EhcacheReadWriteCache.Lockable.isUnlockable.
public boolean	isWriteable(long txTimestamp, Object newVersion, Comparator<T> versionComparator) Implements net.sf.ehcache.hibernate.ccs.EhcacheReadWriteCache.Lockable.isWriteable.
public EhcacheReadWriteCache.Lock	lock(long timeout, UUID uuid, long lockId) Implements net.sf.ehcache.hibernate.ccs.EhcacheReadWriteCache.Lockable.lock.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

serialVersionUID	back to summary
private static final long serialVersionUID

timestamp	back to summary
private final long timestamp

value	back to summary
private final Object value

version	back to summary
private final Object version

Constructor Detail

Item	back to summary
private Item(Object value, Object version, long timestamp)

Method Detail

getValue	back to summary
public Object getValue() Implements net.sf.ehcache.hibernate.ccs.EhcacheReadWriteCache.Lockable.getValue.

isReadable	back to summary
public boolean isReadable(long txTimestamp) Implements net.sf.ehcache.hibernate.ccs.EhcacheReadWriteCache.Lockable.isReadable.

isUnlockable	back to summary
public boolean isUnlockable(SoftLock lock) Implements net.sf.ehcache.hibernate.ccs.EhcacheReadWriteCache.Lockable.isUnlockable.

isWriteable	back to summary
public boolean isWriteable(long txTimestamp, Object newVersion, Comparator<T> versionComparator) Implements net.sf.ehcache.hibernate.ccs.EhcacheReadWriteCache.Lockable.isWriteable.

lock	back to summary
public EhcacheReadWriteCache.Lock lock(long timeout, UUID uuid, long lockId) Implements net.sf.ehcache.hibernate.ccs.EhcacheReadWriteCache.Lockable.lock.

net.sf.ehcache.hibernate.ccs back to summary

private final Class EhcacheReadWriteCache.Lock

Class Inheritance

extends Object
implements Serializable, Lockable, SoftLock

java.lang.Object
net.sf.ehcache.hibernate.ccs.EhcacheReadWriteCache.Lock

All Implemented Interfaces

org.hibernate.cache.access.SoftLock, net.sf.ehcache.hibernate.ccs.EhcacheReadWriteCache.Lockable, java.io.Serializable

Wrapper type representing locked items.

Field Summary

Modifier and Type	Field and Description
private boolean	concurrent
private final long	lockId
private int	multiplicity
private static final long	serialVersionUID
private final UUID	sourceUuid
private long	timeout
private long	unlockTimestamp
private final Object	version

Constructor Summary

Access	Constructor and Description
pack-priv	Lock(long timeout, UUID sourceUuid, long lockId, Object version)

Method Summary

Modifier and Type	Method and Description
public boolean	equals(Object the reference object with which to compare. o) Overrides java.lang.Object.equals. Indicates whether some other object is "equal to" this one.
public Object	getValue() Implements net.sf.ehcache.hibernate.ccs.EhcacheReadWriteCache.Lockable.getValue.
public int	hashCode() Overrides java.lang.Object.hashCode. Returns a hash code value for the object.
public boolean	isReadable(long txTimestamp) Implements net.sf.ehcache.hibernate.ccs.EhcacheReadWriteCache.Lockable.isReadable.
public boolean	isUnlockable(SoftLock lock) Implements net.sf.ehcache.hibernate.ccs.EhcacheReadWriteCache.Lockable.isUnlockable.
public boolean	isWriteable(long txTimestamp, Object newVersion, Comparator<T> versionComparator) Implements net.sf.ehcache.hibernate.ccs.EhcacheReadWriteCache.Lockable.isWriteable.
public EhcacheReadWriteCache.Lock	lock(long timeout, UUID uuid, long lockId) Implements net.sf.ehcache.hibernate.ccs.EhcacheReadWriteCache.Lockable.lock.
private void	unlock(long timestamp)
private boolean	wasLockedConcurrently()

Inherited from java.lang.Object:: clone finalize getClass notify notifyAll toString wait wait wait

Field Detail

concurrent	back to summary
private boolean concurrent

lockId	back to summary
private final long lockId

multiplicity	back to summary
private int multiplicity

serialVersionUID	back to summary
private static final long serialVersionUID

sourceUuid	back to summary
private final UUID sourceUuid

timeout	back to summary
private long timeout

unlockTimestamp	back to summary
private long unlockTimestamp

version	back to summary
private final Object version

Constructor Detail

Lock	back to summary
pack-priv Lock(long timeout, UUID sourceUuid, long lockId, Object version)

Method Detail

equals back to summary

public boolean equals(Object o)

Overrides java.lang.Object.equals.

Doc from java.lang.Object.equals.

Indicates whether some other object is "equal to" this one.

The equals method implements an equivalence relation on non-null object references:

It is reflexive: for any non-null reference value x, x.equals(x) should return true.
It is symmetric: for any non-null reference values x and y, x.equals(y) should return true if and only if y.equals(x) returns true.
It is transitive: for any non-null reference values x, y, and z, if x.equals(y) returns true and y.equals(z) returns true, then x.equals(z) should return true.
It is consistent: for any non-null reference values x and y, multiple invocations of x.equals(y) consistently return true or consistently return false, provided no information used in equals comparisons on the objects is modified.
For any non-null reference value x, x.equals(null) should return false.

An equivalence relation partitions the elements it operates on into equivalence classes; all the members of an equivalence class are equal to each other. Members of an equivalence class are substitutable for each other, at least for some purposes.

Parameters

o:Object: the reference object with which to compare.

Returns:boolean

true if this object is the same as the obj argument; false otherwise.

Annotations

@Override

getValue	back to summary
public Object getValue() Implements net.sf.ehcache.hibernate.ccs.EhcacheReadWriteCache.Lockable.getValue.

hashCode back to summary

public int hashCode()

Overrides java.lang.Object.hashCode.

Doc from java.lang.Object.hashCode.

Returns a hash code value for the object. This method is supported for the benefit of hash tables such as those provided by java.util.HashMap.

The general contract of hashCode is:

Whenever it is invoked on the same object more than once during an execution of a Java application, the hashCode method must consistently return the same integer, provided no information used in equals comparisons on the object is modified. This integer need not remain consistent from one execution of an application to another execution of the same application.
If two objects are equal according to the equals method, then calling the hashCode method on each of the two objects must produce the same integer result.
It is not required that if two objects are unequal according to the equals method, then calling the hashCode method on each of the two objects must produce distinct integer results. However, the programmer should be aware that producing distinct integer results for unequal objects may improve the performance of hash tables.

Returns:int

a hash code value for this object.

Annotations

@Override

isReadable	back to summary
public boolean isReadable(long txTimestamp) Implements net.sf.ehcache.hibernate.ccs.EhcacheReadWriteCache.Lockable.isReadable.

isUnlockable	back to summary
public boolean isUnlockable(SoftLock lock) Implements net.sf.ehcache.hibernate.ccs.EhcacheReadWriteCache.Lockable.isUnlockable.

isWriteable	back to summary
public boolean isWriteable(long txTimestamp, Object newVersion, Comparator<T> versionComparator) Implements net.sf.ehcache.hibernate.ccs.EhcacheReadWriteCache.Lockable.isWriteable.

lock	back to summary
public EhcacheReadWriteCache.Lock lock(long timeout, UUID uuid, long lockId) Implements net.sf.ehcache.hibernate.ccs.EhcacheReadWriteCache.Lockable.lock.

unlock	back to summary
private void unlock(long timestamp)

wasLockedConcurrently	back to summary
private boolean wasLockedConcurrently()

public Class EhcacheReadWriteCache

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class EhcacheReadWriteCache.Item

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class EhcacheReadWriteCache.Lock

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Interface EhcacheReadWriteCache.Lockable

Method Summary

Method Detail

Modifier and Type	Method and Description
public Object	getValue()
public boolean	isReadable(long txTimestamp)
public boolean	isUnlockable(SoftLock lock)
public boolean	isWriteable(long txTimestamp, Object version, Comparator<T> versionComparator)
public EhcacheReadWriteCache.Lock	lock(long timeout, UUID uuid, long lockId)