public class TotalOrderManager extends Object
Constructor and Description |
---|
TotalOrderManager() |
Modifier and Type | Method and Description |
---|---|
void |
ensureOrder(TotalOrderRemoteTransactionState state,
Collection<Object> keysModified)
It ensures the validation order for the transaction corresponding to the prepare command.
|
boolean |
hasAnyLockAcquired() |
void |
inject(BlockingTaskAwareExecutorService totalOrderExecutor) |
void |
notifyStateTransferEnd()
It notifies the end of the state transfer possibly unblock waiting prepares.
|
Collection<TotalOrderLatch> |
notifyStateTransferStart(int topologyId,
boolean isRebalance)
It notifies that a state transfer is about to start.
|
void |
release(TotalOrderRemoteTransactionState state)
Release the locked key possibly unblock waiting prepares.
|
public void inject(BlockingTaskAwareExecutorService totalOrderExecutor)
public final void ensureOrder(TotalOrderRemoteTransactionState state, Collection<Object> keysModified) throws InterruptedException
state
- the total order prepare stateInterruptedException
public final void release(TotalOrderRemoteTransactionState state)
state
- the statepublic final Collection<TotalOrderLatch> notifyStateTransferStart(int topologyId, boolean isRebalance)
topologyId
- the new topology IDpublic final void notifyStateTransferEnd()
public final boolean hasAnyLockAcquired()
Copyright © 2021 JBoss, a division of Red Hat. All rights reserved.