public final class VetoCommitBarrier extends CommitBarrier
lock, statusCondition| Constructor and Description |
|---|
VetoCommitBarrier()
Creates a new VetoCommitBarrier that uses an unfair Lock.
|
VetoCommitBarrier(boolean fair)
Creates a new VetoCommitBarrier.
|
| Modifier and Type | Method and Description |
|---|---|
void |
atomicVetoCommit()
Veto's the commit so that all prepared Transactions in this VetoCommitBarriers should commit.
|
protected boolean |
isLastParty() |
String |
toString() |
void |
vetoCommit(Txn tx)
Veto's the commit of this VetoCommitBarrier including the provided transaction.
|
abort, addJoiner, awaitOpen, awaitOpenUninterruptibly, ensureNotDead, executeTasks, finish, getNumberWaiting, getStatus, isAborted, isClosed, isCommitted, joinCommit, joinCommitUninterruptibly, registerOnAbortTask, registerOnCommitTask, setScheduledExecutorService, setTimeout, signalAborted, signalCommit, tryAwaitOpen, tryAwaitOpenUninterruptibly, tryJoinCommit, tryJoinCommit, tryJoinCommitUninterruptiblypublic VetoCommitBarrier()
public VetoCommitBarrier(boolean fair)
fair - if the lock should be fair.protected boolean isLastParty()
isLastParty in class CommitBarrierpublic void atomicVetoCommit()
CommitBarrierOpenException - if the VetoCommitBarrier already is aborted.public void vetoCommit(Txn tx)
tx - the Txn to commit.NullPointerException - if tx is null.DeadTxnException - if the Txn already is aborted or committed.ReadWriteConflict - if the commit was not executed successfully.CommitBarrierOpenException - if the VetoCommitBarrier already is open.Copyright © 2025. All rights reserved.