ACCUMULATED_LIMIT, commitLsn, deletedDatabases, firstLoggedLsn, lastLoggedLsn, openedDatabaseHandles, repContext, undoDatabases
defaultNoWait, deleteInfo, envImpl, id, lockManager, readUncommittedDefault, thread
Constructor and Description |
---|
ReplayTxn(EnvironmentImpl envImpl,
TransactionConfig config,
long txnId,
java.util.logging.Logger logger)
Used when creating ReplayTxns at recovery.
|
ReplayTxn(EnvironmentImpl envImpl,
TransactionConfig config,
long txnId,
java.util.Map<java.lang.Long,ReplayTxn> activeTxns,
java.util.logging.Logger logger)
Used when creating ReplayTxns for Replay.
|
Modifier and Type | Method and Description |
---|---|
void |
abort()
Abort this transaction.
|
long |
abort(boolean forceFlush)
Abort this transaction.
|
long |
abort(ReplicationContext clientRepContext,
int abortMasterNodeId) |
void |
cleanup()
Invoked when a ReplayTxn is being abandoned on shutdown.
|
protected void |
close(boolean isCommit)
Close and unregister this txn.
|
long |
commit()
Call commit() with the default sync configuration property.
|
long |
commit(Durability.SyncPolicy syncPolicy,
ReplicationContext clientRepContext,
int commitMasterNodeId)
Commits the txn being replayed.
|
long |
commit(Durability durability)
Commit this transaction; it involves the following logical steps:
1.
|
long |
elapsedTime()
Returns the elapsed time associated with this transaction.
|
protected long |
generateId(TxnManager txnManager,
long mandatedId)
Replay transactions always use the txn id that is included in its
replicated operation.
|
protected long |
getInitialLockTimeout()
Don't let the ReplayTxn have a timeout of 0.
|
boolean |
getRepGroupDbChange() |
protected int |
getReplicatorNodeId() |
boolean |
isReplicationDefined()
Used for debugging checks to ensure that replication-defined lockers are
used for accessing replicated databases.
|
void |
noteRepGroupDbChange() |
void |
registerWithActiveTxns(java.util.Map<java.lang.Long,ReplayTxn> newActiveTxns) |
java.util.Collection<java.lang.Long> |
rollback(long matchpointLsn)
Rollback all write operations that are logged with an LSN > the
matchpointLsn parameter.
|
void |
setLastAppliedVLSN(VLSN justApplied) |
void |
setRepContext(ReplicationContext repContext)
ReplicatedTxns set it when the txn commit
or abort arrives.
|
java.lang.String |
toString() |
protected boolean |
updateLoggedForTxn()
Always return true in order to ensure that the VLSN is logged.
|
abort, addLock, addLogInfo, addOpenedDatabase, checkPreempted, checkState, cleanupDatabaseImpls, clearWriteLocks, collectStats, commit, createdNode, createLocalAutoTxn, createLocalTxn, dumpLog, getCommitDurability, getCommitToken, getDefaultDurability, getEnvironmentImpl, getExplicitDurabilityConfigured, getExplicitSyncConfigured, getFirstActiveLsn, getImportunate, getLastLsn, getLogSize, getPrepared, getReadLockIds, getState, getTransaction, getTransactionId, getTriggerDbs, getTxnLocker, getWriteLockIds, getWriteLockInfo, isAutoTxn, isClosed, isOnlyAbortable, isReadCommittedIsolation, isRolledBack, isSerializableIsolation, isSuspended, isTransactional, isValid, lockingRequired, lockInternal, logicalEquals, markDeleteAtTxnEnd, newNonTxnLocker, nonTxnOperationEnd, noteTriggerDb, operationEnd, postLogAbortHook, postLogCommitAbortHook, postLogCommitHook, preLogAbortHook, preLogCommitHook, preLogWithoutLock, prepare, propagatePostCommitException, readFromLog, registerCursor, releaseNonTxnLocks, releaseWriteLocks, setDeletedDatabaseState, setImportunate, setOnlyAbortable, setPrepared, setRollback, setSuspended, setTransaction, txnBeginHook, undo, unRegisterCursor, writeToLog
addDeleteInfo, allowReleaseLockAfterLsnChange, demoteLock, disallowReplicaWrite, dumpLockTable, getDefaultNoWait, getEnvironment, getId, getLockTimeout, getPreemptable, getTxnTimeout, isReadUncommittedDefault, isTimedOut, lock, lockAfterLsnChange, nonBlockingLock, openCursorHook, operationEnd, operationEnd, releaseLock, setClosingLocker, setLockTimeout, setPreemptable, setPreempted, setTxnTimeout, sharesLocksWith
public ReplayTxn(EnvironmentImpl envImpl, TransactionConfig config, long txnId, java.util.Map<java.lang.Long,ReplayTxn> activeTxns, java.util.logging.Logger logger) throws DatabaseException
DatabaseException
public ReplayTxn(EnvironmentImpl envImpl, TransactionConfig config, long txnId, java.util.logging.Logger logger) throws DatabaseException
DatabaseException
protected long getInitialLockTimeout()
getInitialLockTimeout
in class Locker
public boolean getRepGroupDbChange()
public void noteRepGroupDbChange()
public void registerWithActiveTxns(java.util.Map<java.lang.Long,ReplayTxn> newActiveTxns)
protected long generateId(TxnManager txnManager, long mandatedId)
generateId
in class Txn
protected int getReplicatorNodeId()
getReplicatorNodeId
in class Txn
public long commit(Durability.SyncPolicy syncPolicy, ReplicationContext clientRepContext, int commitMasterNodeId) throws DatabaseException
syncPolicy
- to be used for the commit.clientRepContext
- the replication context it encapsulates the VLSN
associated with the txn.DatabaseException
public long commit()
Txn
public long commit(Durability durability)
Txn
public void abort()
Txn
public long abort(boolean forceFlush)
Txn
public long abort(ReplicationContext clientRepContext, int abortMasterNodeId) throws DatabaseException
DatabaseException
protected boolean updateLoggedForTxn()
updateLoggedForTxn
in class Txn
protected void close(boolean isCommit) throws DatabaseException
Txn
close
in class Txn
DatabaseException
public void cleanup() throws DatabaseException
DatabaseException
public java.util.Collection<java.lang.Long> rollback(long matchpointLsn) throws DatabaseException
DatabaseException
public long elapsedTime()
public void setLastAppliedVLSN(VLSN justApplied)
public void setRepContext(ReplicationContext repContext)
public boolean isReplicationDefined()
Locker
isReplicationDefined
in class Locker
Copyright (c) 2004-2012 Oracle. All rights reserved.