|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface ReplicatorInstance
The ReplicatorInstance is the sole conduit of replication functionality available to the core JE code. All references to any classes from com.sleepycat.je.rep* should be funnelled through this interface. Keeping a strict boundary serves to maintain the reliability of the standalone node. All ReplicatorInstance methods are prohibited from blocking, and should be examine carefully to determine whether they can throw exceptions or have any side effects which would diminish the reliability of the non-replication code paths. The ReplicatorInstance also allows us to package JE without the additional replication classes.
Method Summary | |
---|---|
VLSN |
bumpVLSN()
Increment and get the next VLSN. |
Txn |
createRepTxn(EnvironmentImpl envImpl,
TransactionConfig config)
Create an appropriate type of Replicated transaction. |
Txn |
createRepTxn(EnvironmentImpl envImpl,
TransactionConfig config,
boolean noAPIReadLock,
long mandatedId)
A form used primarily for auto commit transactions. |
Txn |
createRepTxn(EnvironmentImpl envImpl,
TransactionConfig config,
ReplicationContext repContext)
A variation of the above used for testing; it arranges for a ReplicationContext to be passed in for testing purposes. |
void |
decrementVLSN()
Decrement the vlsn if there was a problem logging the entry |
boolean |
isMaster()
|
void |
preCheckpointEndFlush()
Do any work that must be included as part of the checkpoint process. |
void |
registerVLSN(long lsn,
LogEntryHeader header)
Record the vlsn->lsn mapping for this just-logged log entry. |
Method Detail |
---|
void registerVLSN(long lsn, LogEntryHeader header)
lsn
- lsn of the target log entryheader
- of the target log entry, which contains the VLSN and
log entry type.VLSN bumpVLSN()
void decrementVLSN()
boolean isMaster()
void preCheckpointEndFlush() throws DatabaseException
DatabaseException
- if any activity failsTxn createRepTxn(EnvironmentImpl envImpl, TransactionConfig config) throws DatabaseException
envImpl
- the environment associated with the transactionconfig
- the transaction configuration
DatabaseException
Txn createRepTxn(EnvironmentImpl envImpl, TransactionConfig config, boolean noAPIReadLock, long mandatedId) throws DatabaseException
DatabaseException
(com.sleepycat.je.dbi.EnvironmentImpl,
com.sleepycat.je.TransactionConfig,
boolean,
long)
Txn createRepTxn(EnvironmentImpl envImpl, TransactionConfig config, ReplicationContext repContext) throws DatabaseException
DatabaseException
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |