org.infinispan.context.impl

Class LocalTxInvocationContext

java.lang.Object

org.infinispan.context.impl.AbstractInvocationContext

org.infinispan.context.impl.AbstractTxInvocationContext

org.infinispan.context.impl.LocalTxInvocationContext

All Implemented Interfaces:

Cloneable, EntryLookup, TxInvocationContext, InvocationContext

public class LocalTxInvocationContext
extends AbstractTxInvocationContext

Invocation context to be used for locally originated transactions.

Since:

4.0

Author:

Mircea.Markus@jboss.com, Galder Zamarreño

Field Summary

Fields

Modifier and Type	Field and Description
Map<Object,CacheEntry>	emptyEntryMap

Constructor Summary

Constructors

Constructor and Description
LocalTxInvocationContext(Equivalence<Object> keyEq)

Method Summary

Methods

Modifier and Type	Method and Description
void	addLockedKey(Object key) Tracks the given key as locked by this invocation context.
AbstractCacheTransaction	getCacheTransaction()
GlobalTransaction	getGlobalTransaction() Returns the id of the transaction associated with the current call.
Set<Object>	getLockedKeys() Returns the set of keys that are locked for writing.
Object	getLockOwner() Returns the in behalf of which locks will be aquired.
Map<Object,CacheEntry>	getLookedUpEntries() Retrieves a map of entries looked up within the current scope.
List<WriteCommand>	getModifications() Returns the modifications performed in the scope of the current transaction.
Collection<Address>	getRemoteLocksAcquired()
Transaction	getTransaction() Returns the tx associated with the current thread.
boolean	hasLockedKey(Object key) Returns true if the lock being tested is already held in the current scope, false otherwise.
boolean	isOriginLocal() Returns true if the call was originated locally, false if it is the result of a remote rpc.
boolean	isTransactionValid()
CacheEntry	lookupEntry(Object key) Retrieves an entry from the collection of looked up entries in the current scope.
void	putLookedUpEntry(Object key, CacheEntry e) Puts an entry in the registry of looked up entries in the current scope.
void	remoteLocksAcquired(Collection<Address> nodes)
void	removeLookedUpEntry(Object key)
void	setLocalTransaction(LocalTransaction localTransaction)
boolean	skipTransactionCompleteCheck()
void	skipTransactionCompleteCheck(boolean skip)

Methods inherited from class org.infinispan.context.impl.AbstractTxInvocationContext

addAffectedKey, addAllAffectedKeys, clearLockedKeys, getAffectedKeys, hasModifications, isImplicitTransaction, isInTxScope, onEntryValueReplaced, setImplicitTransaction, setTransaction

Methods inherited from class org.infinispan.context.impl.AbstractInvocationContext

clone, getClassLoader, getOrigin, isEntryRemovedInContext, replaceValue, setClassLoader, setOrigin, setOriginLocal

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.context.InvocationContext

clone, getClassLoader, getOrigin, isEntryRemovedInContext, replaceValue, setClassLoader

Field Detail

emptyEntryMap

public final Map<Object,CacheEntry> emptyEntryMap

Constructor Detail

LocalTxInvocationContext

public LocalTxInvocationContext(Equivalence<Object> keyEq)

Method Detail

isTransactionValid

public boolean isTransactionValid()

Returns:

true if the current transaction is in a valid state to perform operations on (i.e.,RUNNING or PREPARING) or false otherwise.

isOriginLocal

public boolean isOriginLocal()

Description copied from interface: InvocationContext

Returns true if the call was originated locally, false if it is the result of a remote rpc.

Specified by:

isOriginLocal in interface InvocationContext

Overrides:

isOriginLocal in class AbstractInvocationContext

getLockOwner

public Object getLockOwner()

Description copied from interface: InvocationContext

Returns the in behalf of which locks will be aquired.

getGlobalTransaction

public GlobalTransaction getGlobalTransaction()

Description copied from interface: TxInvocationContext

Returns the id of the transaction associated with the current call.

getModifications

public List<WriteCommand> getModifications()

Description copied from interface: TxInvocationContext

Returns the modifications performed in the scope of the current transaction. Any modifications having Flag.CACHE_MODE_LOCAL are ignored. The returned list can be null.

setLocalTransaction

public void setLocalTransaction(LocalTransaction localTransaction)

lookupEntry

public CacheEntry lookupEntry(Object key)

Description copied from interface: EntryLookup

Retrieves an entry from the collection of looked up entries in the current scope.

Parameters:

key - key to look up

Returns:

an entry, or null if it cannot be found.

getLookedUpEntries

public Map<Object,CacheEntry> getLookedUpEntries()

Description copied from interface: EntryLookup

Retrieves a map of entries looked up within the current scope.

Returns:

a map of looked up entries.

putLookedUpEntry

public void putLookedUpEntry(Object key,
                    CacheEntry e)

Description copied from interface: EntryLookup

Puts an entry in the registry of looked up entries in the current scope.

Parameters:

key - key to store

e - entry to store

removeLookedUpEntry

public void removeLookedUpEntry(Object key)

hasLockedKey

public boolean hasLockedKey(Object key)

Description copied from interface: InvocationContext

Returns true if the lock being tested is already held in the current scope, false otherwise.

Specified by:

hasLockedKey in interface InvocationContext

Overrides:

hasLockedKey in class AbstractInvocationContext

Parameters:

key - lock to test

remoteLocksAcquired

public void remoteLocksAcquired(Collection<Address> nodes)

getRemoteLocksAcquired

public Collection<Address> getRemoteLocksAcquired()

getCacheTransaction

public AbstractCacheTransaction getCacheTransaction()

Specified by:

getCacheTransaction in interface TxInvocationContext

Specified by:

getCacheTransaction in class AbstractTxInvocationContext

skipTransactionCompleteCheck

public void skipTransactionCompleteCheck(boolean skip)

skipTransactionCompleteCheck

public boolean skipTransactionCompleteCheck()

getLockedKeys

public Set<Object> getLockedKeys()

Description copied from interface: InvocationContext

Returns the set of keys that are locked for writing.

addLockedKey

public void addLockedKey(Object key)

Description copied from interface: InvocationContext

Tracks the given key as locked by this invocation context.

getTransaction

public Transaction getTransaction()

Description copied from interface: TxInvocationContext

Returns the tx associated with the current thread. This method MUST be guarded with a call to InvocationContext.isOriginLocal(), as Transaction are not propagated from the node where tx was started.

Specified by:

getTransaction in interface TxInvocationContext

Overrides:

getTransaction in class AbstractTxInvocationContext