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, tryJoinCommitUninterruptibly
public VetoCommitBarrier()
public VetoCommitBarrier(boolean fair)
fair
- if the lock should be fair.protected boolean isLastParty()
isLastParty
in class CommitBarrier
public 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 © 2020. All rights reserved.