com.sleepycat.je.rep.stream

Class FeederTxns

java.lang.Object

com.sleepycat.je.rep.stream.FeederTxns

public class FeederTxns
extends java.lang.Object

FeederTxns manages transactions that need acknowledgments.

Constructor Summary

Constructors

Constructor and Description
FeederTxns(RepImpl repImpl)

Method Summary

Methods

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FeederTxns

public FeederTxns(RepImpl repImpl)

Method Detail

setupForAcks

public void setupForAcks(MasterTxn txn)

Create a new TxnInfo so that transaction commit can wait onthe latch it sets up.

Parameters:

txn - identifies the transaction.

getAckTxn

public MasterTxn getAckTxn(long txnId)

Returns the transaction if it's waiting for acknowledgments. Returns null otherwise.

clearTransactionAcks

public void clearTransactionAcks(Txn txn)

noteReplicaAck

public VLSN noteReplicaAck(long txnId)

Notes that an acknowledgment was received from a replica.

Parameters:

txnId - the locally committed transaction that was acknowledged.

Returns:

the transaction VLSN, if txnId needs an ack, null otherwise

awaitReplicaAcks

public void awaitReplicaAcks(MasterTxn txn,
                    int timeoutMs)
                      throws java.lang.InterruptedException

Waits for the required number of replica acks to come through.

Parameters:

txn - identifies the transaction to wait for.

timeoutMs - the amount of time to wait for the acknowledgments before giving up.

Throws:

InsufficientAcksException - if the ack requirements were not met

java.lang.InterruptedException

close

public void close()

getStats

public StatGroup getStats()

resetStats

public void resetStats()

getStats

public StatGroup getStats(StatsConfig config)