public class FeederTxns
extends java.lang.Object
Constructor and Description |
---|
FeederTxns(RepImpl repImpl) |
Modifier and Type | Method and Description |
---|---|
void |
awaitReplicaAcks(MasterTxn txn,
int timeoutMs)
Waits for the required number of replica acks to come through.
|
void |
clearTransactionAcks(Txn txn) |
void |
close() |
MasterTxn |
getAckTxn(long txnId)
Returns the transaction if it's waiting for acknowledgments.
|
StatGroup |
getStats() |
StatGroup |
getStats(StatsConfig config) |
VLSN |
noteReplicaAck(long txnId)
Notes that an acknowledgment was received from a replica.
|
void |
resetStats() |
void |
setupForAcks(MasterTxn txn)
Create a new TxnInfo so that transaction commit can wait onthe latch it
sets up.
|
public FeederTxns(RepImpl repImpl)
public void setupForAcks(MasterTxn txn)
txn
- identifies the transaction.public MasterTxn getAckTxn(long txnId)
public void clearTransactionAcks(Txn txn)
public VLSN noteReplicaAck(long txnId)
txnId
- the locally committed transaction that was acknowledged.public void awaitReplicaAcks(MasterTxn txn, int timeoutMs) throws java.lang.InterruptedException
txn
- identifies the transaction to wait for.timeoutMs
- the amount of time to wait for the acknowledgments
before giving up.InsufficientAcksException
- if the ack requirements were not metjava.lang.InterruptedException
public void close()
public StatGroup getStats()
public void resetStats()
public StatGroup getStats(StatsConfig config)
Copyright (c) 2004-2012 Oracle. All rights reserved.