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
PendingLockPromise	checkPendingTransactionsForKey(TxInvocationContext<?> ctx, Object key, long time, TimeUnit unit)	Check for any transaction with older topology id to complete that may have the lock for any key in keys acquired.
PendingLockPromise	checkPendingTransactionsForKeys(TxInvocationContext<?> ctx, Collection<Object> keys, long time, TimeUnit unit)	Check for any transaction with older topology id to complete that may have the lock for any key in keys acquired.

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

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

Multiple invocations with the same transaction returns the same PendingLockPromise.

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

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

Multiple invocations with the same transaction returns the same PendingLockPromise.

Specified by:

checkPendingTransactionsForKeys in interface PendingLockManager

Parameters:

ctx - the TxInvocationContext.

keys - the keys to check.

time - timeout.

unit - TimeUnit of time.

Returns:

a PendingLockPromise.