|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.sleepycat.je.rep.stream.FeederTxns
public class FeederTxns
FeederTxns manages transactions that need acknowledgments.
Constructor Summary | |
---|---|
FeederTxns(RepImpl repImpl)
|
Method Summary | |
---|---|
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. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public FeederTxns(RepImpl repImpl)
Method Detail |
---|
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 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 met
InterruptedException
public void close()
public StatGroup getStats()
public void resetStats()
public StatGroup getStats(StatsConfig config)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |