Package org.infinispan.remoting.inboundhandler.action

Class BaseLockingAction

java.lang.Object

org.infinispan.remoting.inboundhandler.action.BaseLockingAction

All Implemented Interfaces:

Action

Direct Known Subclasses:

LockAction, PendingTxAction

public abstract class BaseLockingAction
extends Object
implements Action

A base Action implementation for locking.

This contains the basic steps for lock acquisition: try to acquire, check when it is available and acquired (or not).

Since:

8.0

Author:

Pedro Ruivo

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	BaseLockingAction.InternalState

Constructor Summary

Constructors

Constructor	Description
BaseLockingAction(DistributionManager distributionManager)

Method Summary

Modifier and Type	Method	Description
protected boolean	cas(BaseLockingAction.InternalState expectedState, BaseLockingAction.InternalState newState)
ActionStatus	check(ActionState state)	It checks this action.
protected abstract ActionStatus	checking(ActionState state)
protected List<Object>	getAndUpdateFilteredKeys(ActionState state)
protected abstract ActionStatus	init(ActionState state)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.remoting.inboundhandler.action.Action

addListener, onException, onFinally

Constructor Detail

BaseLockingAction

public BaseLockingAction(DistributionManager distributionManager)

Method Detail

check

public final ActionStatus check(ActionState state)

Description copied from interface: Action

It checks this action.

When ActionStatus.READY or ActionStatus.CANCELED are final states.

This method should be thread safe and idempotent since it can be invoked multiple times by multiples threads.

Specified by:

check in interface Action

Parameters:

state - the current state.

Returns:

the status of this action.

checking

protected abstract ActionStatus checking(ActionState state)

init

protected abstract ActionStatus init(ActionState state)

cas

protected final boolean cas(BaseLockingAction.InternalState expectedState,
                            BaseLockingAction.InternalState newState)

getAndUpdateFilteredKeys

protected final List<Object> getAndUpdateFilteredKeys(ActionState state)