Package org.infinispan.util.concurrent.locks.impl

Class DefaultPendingLockManager

java.lang.Object

org.infinispan.util.concurrent.locks.impl.DefaultPendingLockManager

All Implemented Interfaces:

PendingLockManager

public class DefaultPendingLockManager
extends Object
implements PendingLockManager

The default implementation for PendingLockManager.

In transactional caches, a transaction would wait for transaction originated in a older topology id. It can happen when topology changes and a backup owner becomes the primary owner.

Since:

8.0

Author:

Pedro Ruivo

Constructor Summary

Constructors

Constructor	Description
DefaultPendingLockManager()

Method Summary

Modifier and Type	Method	Description
long	awaitPendingTransactionsForAllKeys(TxInvocationContext<?> ctx, Collection<Object> keys, long time, TimeUnit unit)	It waits for any transaction with older topology id to complete that may have the lock for any key in keys acquired.
long	awaitPendingTransactionsForKey(TxInvocationContext<?> ctx, Object key, long time, TimeUnit unit)	It waits for any transaction with older topology id to complete that may have the lock for key acquired.
PendingLockPromise	checkPendingTransactionsForKey(TxInvocationContext<?> ctx, Object key, long time, TimeUnit unit)	Same as PendingLockManager.awaitPendingTransactionsForKey(TxInvocationContext, Object, long, TimeUnit) but non-blocking.
PendingLockPromise	checkPendingTransactionsForKeys(TxInvocationContext<?> ctx, Collection<Object> keys, long time, TimeUnit unit)	Same as PendingLockManager.awaitPendingTransactionsForAllKeys(TxInvocationContext, Collection, long, TimeUnit) but non-blocking.

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultPendingLockManager

public DefaultPendingLockManager()

Method Details

checkPendingTransactionsForKey

public PendingLockPromise checkPendingTransactionsForKey(TxInvocationContext<?> ctx,
 Object key,
 long time,
 TimeUnit unit)

Description copied from interface: PendingLockManager

Same as PendingLockManager.awaitPendingTransactionsForKey(TxInvocationContext, Object, long, TimeUnit) but non-blocking.

Multiple invocations with the same transaction returns the same PendingLockPromise. For cleanup purposes, PendingLockManager.awaitPendingTransactionsForKey(TxInvocationContext, Object, long, TimeUnit) must be invoked afterwards.

Specified by:

checkPendingTransactionsForKey in interface PendingLockManager

Parameters:

ctx - the TxInvocationContext.

key - the key to check.

time - timeout.

unit - TimeUnit of time.

Returns:

a PendingLockPromise.

checkPendingTransactionsForKeys

public PendingLockPromise checkPendingTransactionsForKeys(TxInvocationContext<?> ctx,
 Collection<Object> keys,
 long time,
 TimeUnit unit)

Description copied from interface: PendingLockManager

Same as PendingLockManager.awaitPendingTransactionsForAllKeys(TxInvocationContext, Collection, long, TimeUnit) but non-blocking.

Multiple invocations with the same transaction returns the same PendingLockPromise. For cleanup purposes, PendingLockManager.awaitPendingTransactionsForAllKeys(TxInvocationContext, Collection, long, TimeUnit) must be invoked afterwards.

Specified by:

checkPendingTransactionsForKeys in interface PendingLockManager

Parameters:

ctx - the TxInvocationContext.

keys - the keys to check.

time - timeout.

unit - TimeUnit of time.

Returns:

a PendingLockPromise.

awaitPendingTransactionsForKey

public long awaitPendingTransactionsForKey(TxInvocationContext<?> ctx,
 Object key,
 long time,
 TimeUnit unit)
                                    throws InterruptedException

Description copied from interface: PendingLockManager

It waits for any transaction with older topology id to complete that may have the lock for key acquired.

Specified by:

awaitPendingTransactionsForKey in interface PendingLockManager

Parameters:

ctx - the TxInvocationContext.

key - the key to check.

time - timeout.

unit - TimeUnit of time.

Returns:

the remaining timeout.

Throws:

InterruptedException - if the thread is interrupted while waiting.

awaitPendingTransactionsForAllKeys

public long awaitPendingTransactionsForAllKeys(TxInvocationContext<?> ctx,
 Collection<Object> keys,
 long time,
 TimeUnit unit)
                                        throws InterruptedException

Description copied from interface: PendingLockManager

It waits for any transaction with older topology id to complete that may have the lock for any key in keys acquired.

Specified by:

awaitPendingTransactionsForAllKeys in interface PendingLockManager

Parameters:

ctx - the TxInvocationContext.

keys - the keys to check.

time - timeout.

unit - TimeUnit of time.

Returns:

the remaining timeout.

Throws:

InterruptedException - if the thread is interrupted while waiting.