org.hibernate.cache.infinispan.access

Class NonStrictAccessDelegate

java.lang.Object

org.hibernate.cache.infinispan.access.NonStrictAccessDelegate

All Implemented Interfaces:

AccessDelegate

public class NonStrictAccessDelegate
extends java.lang.Object
implements AccessDelegate

Access delegate that relaxes the consistency a bit: stale reads are prohibited only after the transaction commits. This should also be able to work with async caches, and that would allow the replication delay even after the commit.

Constructor Summary

Constructors

Constructor and Description
NonStrictAccessDelegate(BaseTransactionalDataRegion region)

Method Summary

Modifier and Type	Method and Description
boolean	afterInsert(SharedSessionContractImplementor session, java.lang.Object key, java.lang.Object value, java.lang.Object version) Called after an item has been inserted (after the transaction completes), instead of calling release().
boolean	afterUpdate(SharedSessionContractImplementor session, java.lang.Object key, java.lang.Object value, java.lang.Object currentVersion, java.lang.Object previousVersion, SoftLock lock) Called after an item has been updated (after the transaction completes), instead of calling release().
void	evict(java.lang.Object key) Forcibly evict an item from the cache immediately without regard for transaction isolation.
void	evictAll() Forcibly evict all items from the cache immediately without regard for transaction isolation.
java.lang.Object	get(SharedSessionContractImplementor session, java.lang.Object key, long txTimestamp)
protected java.lang.Object	getVersion(java.lang.Object value)
protected java.lang.Object	getVersioned(java.lang.Object value, java.lang.Object version, long timestamp)
boolean	insert(SharedSessionContractImplementor session, java.lang.Object key, java.lang.Object value, java.lang.Object version) Called after an item has been inserted (before the transaction completes), instead of calling evict().
boolean	putFromLoad(SharedSessionContractImplementor session, java.lang.Object key, java.lang.Object value, long txTimestamp, java.lang.Object version) Attempt to cache an object, after loading from the database.
boolean	putFromLoad(SharedSessionContractImplementor session, java.lang.Object key, java.lang.Object value, long txTimestamp, java.lang.Object version, boolean minimalPutOverride) Attempt to cache an object, after loading from the database, explicitly specifying the minimalPut behavior.
void	remove(SharedSessionContractImplementor session, java.lang.Object key) Called after an item has become stale (before the transaction completes).
void	removeAll() Called to evict data from the entire region
void	unlockItem(SharedSessionContractImplementor session, java.lang.Object key) Called when we have finished the attempted update/delete (which may or may not have been successful), after transaction completion.
boolean	update(SharedSessionContractImplementor session, java.lang.Object key, java.lang.Object value, java.lang.Object currentVersion, java.lang.Object previousVersion) Called after an item has been updated (before the transaction completes), instead of calling evict().

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NonStrictAccessDelegate

public NonStrictAccessDelegate(BaseTransactionalDataRegion region)

Method Detail

get

public java.lang.Object get(SharedSessionContractImplementor session,
                            java.lang.Object key,
                            long txTimestamp)
                     throws CacheException

Specified by:

get in interface AccessDelegate

Throws:

CacheException

putFromLoad

public boolean putFromLoad(SharedSessionContractImplementor session,
                           java.lang.Object key,
                           java.lang.Object value,
                           long txTimestamp,
                           java.lang.Object version)

Description copied from interface: AccessDelegate

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

Specified by:

putFromLoad in interface AccessDelegate

Parameters:

session - Current session

key - The item key

value - The item

txTimestamp - a timestamp prior to the transaction start time

version - the item version number

Returns:

true if the object was successfully cached

putFromLoad

public boolean putFromLoad(SharedSessionContractImplementor session,
                           java.lang.Object key,
                           java.lang.Object value,
                           long txTimestamp,
                           java.lang.Object version,
                           boolean minimalPutOverride)
                    throws CacheException

Description copied from interface: AccessDelegate

Attempt to cache an object, after loading from the database, explicitly specifying the minimalPut behavior.

Specified by:

putFromLoad in interface AccessDelegate

Parameters:

session - Current session.

key - The item key

value - The item

txTimestamp - a timestamp prior to the transaction start time

version - the item version number

minimalPutOverride - Explicit minimalPut flag

Returns:

true if the object was successfully cached

Throws:

CacheException - Propogated from underlying Region

insert

public boolean insert(SharedSessionContractImplementor session,
                      java.lang.Object key,
                      java.lang.Object value,
                      java.lang.Object version)
               throws CacheException

Description copied from interface: AccessDelegate

Called after an item has been inserted (before the transaction completes), instead of calling evict().

Specified by:

insert in interface AccessDelegate

Parameters:

session - Current session

key - The item key

value - The item

version - The item's version value

Returns:

Were the contents of the cache actual changed by this operation?

Throws:

CacheException - if the insert fails

update

public boolean update(SharedSessionContractImplementor session,
                      java.lang.Object key,
                      java.lang.Object value,
                      java.lang.Object currentVersion,
                      java.lang.Object previousVersion)
               throws CacheException

Description copied from interface: AccessDelegate

Called after an item has been updated (before the transaction completes), instead of calling evict().

Specified by:

update in interface AccessDelegate

Parameters:

session - Current session

key - The item key

value - The item

currentVersion - The item's current version value

previousVersion - The item's previous version value

Returns:

Whether the contents of the cache actual changed by this operation

Throws:

CacheException - if the update fails

remove

public void remove(SharedSessionContractImplementor session,
                   java.lang.Object key)
            throws CacheException

Description copied from interface: AccessDelegate

Called after an item has become stale (before the transaction completes).

Specified by:

remove in interface AccessDelegate

Parameters:

session - Current session

key - The key of the item to remove

Throws:

CacheException - if removing the cached item fails

removeAll

public void removeAll()
               throws CacheException

Description copied from interface: AccessDelegate

Called to evict data from the entire region

Specified by:

removeAll in interface AccessDelegate

Throws:

CacheException - if eviction the region fails

evict

public void evict(java.lang.Object key)
           throws CacheException

Description copied from interface: AccessDelegate

Forcibly evict an item from the cache immediately without regard for transaction isolation.

Specified by:

evict in interface AccessDelegate

Parameters:

key - The key of the item to remove

Throws:

CacheException - if evicting the item fails

evictAll

public void evictAll()
              throws CacheException

Description copied from interface: AccessDelegate

Forcibly evict all items from the cache immediately without regard for transaction isolation.

Specified by:

evictAll in interface AccessDelegate

Throws:

CacheException - if evicting items fails

unlockItem

public void unlockItem(SharedSessionContractImplementor session,
                       java.lang.Object key)
                throws CacheException

Description copied from interface: AccessDelegate

Called when we have finished the attempted update/delete (which may or may not have been successful), after transaction completion. This method is used by "asynchronous" concurrency strategies.

Specified by:

unlockItem in interface AccessDelegate

key - The item key

Throws:

CacheException - Propogated from underlying Region

afterInsert

public boolean afterInsert(SharedSessionContractImplementor session,
                           java.lang.Object key,
                           java.lang.Object value,
                           java.lang.Object version)

Description copied from interface: AccessDelegate

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

Specified by:

afterInsert in interface AccessDelegate

key - The item key

value - The item

version - The item's version value

Returns:

Were the contents of the cache actual changed by this operation?

afterUpdate

public boolean afterUpdate(SharedSessionContractImplementor session,
                           java.lang.Object key,
                           java.lang.Object value,
                           java.lang.Object currentVersion,
                           java.lang.Object previousVersion,
                           SoftLock lock)

Description copied from interface: AccessDelegate

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

Specified by:

afterUpdate in interface AccessDelegate

key - The item key

value - The item

currentVersion - The item's current version value

previousVersion - The item's previous version value

lock - The lock previously obtained from #lockItem

Returns:

Were the contents of the cache actual changed by this operation?

getVersion

protected java.lang.Object getVersion(java.lang.Object value)

getVersioned

protected java.lang.Object getVersioned(java.lang.Object value,
                                        java.lang.Object version,
                                        long timestamp)