#include <mobile_recovery_unit.h>

Inheritance diagram for mongo::MobileRecoveryUnit:

Public Member Functions
	MobileRecoveryUnit (MobileSessionPool *sessionPool)

virtual	~MobileRecoveryUnit ()

void	beginUnitOfWork (OperationContext *opCtx) override
	Marks the beginning of a unit of work. More...

void	commitUnitOfWork () override
	Marks the end of a unit of work and commits all changes registered by calls to onCommit or registerChange, in order. More...

void	abortUnitOfWork () override
	Marks the end of a unit of work and rolls back all changes registered by calls to onRollback or registerChange, in reverse order. More...

bool	waitUntilDurable () override
	Waits until all commits that happened before this call are durable in the journal. More...

void	abandonSnapshot () override
	If there is an open transaction, it is closed. More...

void	registerChange (Change *change) override
	The RecoveryUnit takes ownership of the change. More...

void *	writingPtr (void *data, size_t len) override
	Declare that the data at [x, x + len) is being written. More...

void	setRollbackWritesDisabled () override
	Sets a flag that declares this RecoveryUnit will skip rolling back writes, for the duration of the current outermost WriteUnitOfWork. More...

SnapshotId	getSnapshotId () const override
	Gets the local SnapshotId. More...

MobileSession *	getSession (OperationContext *opCtx)

MobileSession *	getSessionNoTxn (OperationContext *opCtx)

bool	inActiveTxn () const

void	assertInActiveTxn () const

void	enqueueFailedDrop (std::string &dropQuery)

void	setOrderedCommit (bool orderedCommit) override

Public Member Functions inherited from mongo::RecoveryUnit
virtual	~RecoveryUnit ()

virtual void	prepareUnitOfWork ()
	Transitions the active unit of work to the "prepared" state. More...

virtual void	setIgnorePrepared (bool ignore)
	Sets whether or not to ignore prepared transactions if supported by this storage engine. More...

virtual bool	waitUntilUnjournaledWritesDurable ()
	Unlike `waitUntilDurable`, this method takes a stable checkpoint, making durable any writes on unjournaled tables that are behind the current stable timestamp. More...

virtual void	preallocateSnapshot ()
	Informs the RecoveryUnit that a snapshot will be needed soon, if one was not already established. More...

virtual Status	obtainMajorityCommittedSnapshot ()
	Obtains a majority committed snapshot. More...

virtual boost::optional< Timestamp >	getPointInTimeReadTimestamp () const
	Returns the Timestamp being used by this recovery unit or boost::none if not reading from a point in time. More...

virtual Status	setTimestamp (Timestamp timestamp)
	Sets a timestamp to assign to future writes in a transaction. More...

virtual void	setCommitTimestamp (Timestamp timestamp)
	Sets a timestamp that will be assigned to all future writes on this RecoveryUnit until clearCommitTimestamp() is called. More...

virtual void	clearCommitTimestamp ()

virtual Timestamp	getCommitTimestamp ()

virtual void	setPrepareTimestamp (Timestamp timestamp)
	Sets a prepare timestamp for the current transaction. More...

virtual void	setTimestampReadSource (ReadSource source, boost::optional< Timestamp > provided=boost::none)
	Sets which timestamp to use for read transactions. More...

virtual ReadSource	getTimestampReadSource () const

template<typename Callback >
void	onRollback (Callback callback)
	Registers a callback to be called if the current WriteUnitOfWork rolls back. More...

template<typename Callback >
void	onCommit (Callback callback)
	Registers a callback to be called if the current WriteUnitOfWork commits. More...

int &	writingInt (int &d)
	Declare write intent for an int. More...

template<typename T >
T *	writing (T *x)
	A templated helper for writingPtr. More...

Static Public Member Functions
static MobileRecoveryUnit *	get (OperationContext *opCtx)

Private Types
using	Changes = std::vector< std::unique_ptr< Change > >

Private Member Functions
void	_abort ()

void	_commit ()

void	_ensureSession (OperationContext *opCtx)

void	_txnClose (bool commit)

void	_txnOpen (OperationContext *opCtx)

Private Attributes
bool	_areWriteUnitOfWorksBanned = false

bool	_inUnitOfWork

bool	_active

std::string	_path

MobileSessionPool *	_sessionPool

std::unique_ptr< MobileSession >	_session

Changes	_changes

Additional Inherited Members
Public Types inherited from mongo::RecoveryUnit
enum	ReadSource { kNone, kMajorityCommitted, kLastApplied, kLastAppliedSnapshot, kProvided }
	The ReadSource indicates which exteral or provided timestamp to read from for future transactions. More...

Protected Member Functions inherited from mongo::RecoveryUnit
	RecoveryUnit ()

Member Typedef Documentation

◆ Changes

using mongo::MobileRecoveryUnit::Changes = std::vector<std::unique_ptr<Change> >

private

Constructor & Destructor Documentation

◆ MobileRecoveryUnit()

mongo::MobileRecoveryUnit::MobileRecoveryUnit ( MobileSessionPool * sessionPool )

◆ ~MobileRecoveryUnit()

mongo::MobileRecoveryUnit::~MobileRecoveryUnit ( )

virtual

Member Function Documentation

◆ _abort()

void mongo::MobileRecoveryUnit::_abort ( )

private

◆ _commit()

void mongo::MobileRecoveryUnit::_commit ( )

private

◆ _ensureSession()

void mongo::MobileRecoveryUnit::_ensureSession ( OperationContext * opCtx )

private

◆ _txnClose()

void mongo::MobileRecoveryUnit::_txnClose ( bool commit )

private

◆ _txnOpen()

void mongo::MobileRecoveryUnit::_txnOpen ( OperationContext * opCtx )

private

◆ abandonSnapshot()

void mongo::MobileRecoveryUnit::abandonSnapshot ( )

overridevirtual

If there is an open transaction, it is closed.

On return no transaction is active. This cannot be called inside of a WriteUnitOfWork, and should fail if it is.

Implements mongo::RecoveryUnit.

◆ abortUnitOfWork()

void mongo::MobileRecoveryUnit::abortUnitOfWork ( )

overridevirtual

Marks the end of a unit of work and rolls back all changes registered by calls to onRollback or registerChange, in reverse order.

Must be matched by exactly one preceding call to beginUnitOfWork.

Should be called through WriteUnitOfWork rather than directly.

Implements mongo::RecoveryUnit.

◆ assertInActiveTxn()

void mongo::MobileRecoveryUnit::assertInActiveTxn ( ) const

◆ beginUnitOfWork()

void mongo::MobileRecoveryUnit::beginUnitOfWork ( OperationContext * opCtx )

overridevirtual

Marks the beginning of a unit of work.

Each call must be matched with exactly one call to either commitUnitOfWork or abortUnitOfWork.

Should be called through WriteUnitOfWork rather than directly.

Implements mongo::RecoveryUnit.

◆ commitUnitOfWork()

void mongo::MobileRecoveryUnit::commitUnitOfWork ( )

overridevirtual

Marks the end of a unit of work and commits all changes registered by calls to onCommit or registerChange, in order.

Must be matched by exactly one preceding call to beginUnitOfWork.

Should be called through WriteUnitOfWork rather than directly.

Implements mongo::RecoveryUnit.

◆ enqueueFailedDrop()

void mongo::MobileRecoveryUnit::enqueueFailedDrop ( std::string & dropQuery )

◆ get()

static MobileRecoveryUnit* mongo::MobileRecoveryUnit::get ( OperationContext * opCtx )

inlinestatic

◆ getSession()

MobileSession * mongo::MobileRecoveryUnit::getSession ( OperationContext * opCtx )

◆ getSessionNoTxn()

MobileSession * mongo::MobileRecoveryUnit::getSessionNoTxn ( OperationContext * opCtx )

◆ getSnapshotId()

SnapshotId mongo::MobileRecoveryUnit::getSnapshotId ( ) const

inlineoverridevirtual

Gets the local SnapshotId.

It is only valid to compare SnapshotIds generated by a single RecoveryUnit.

This is unrelated to Timestamp which must be globally comparable.

Implements mongo::RecoveryUnit.

◆ inActiveTxn()

bool mongo::MobileRecoveryUnit::inActiveTxn ( ) const

inline

◆ registerChange()

void mongo::MobileRecoveryUnit::registerChange ( Change * change )

overridevirtual

The RecoveryUnit takes ownership of the change.

The commitUnitOfWork() method calls the commit() method of each registered change in order of registration. The endUnitOfWork() method calls the rollback() method of each registered Change in reverse order of registration. Either will unregister and delete the changes.

The registerChange() method may only be called when a WriteUnitOfWork is active, and may not be called during commit or rollback.

Implements mongo::RecoveryUnit.

◆ setOrderedCommit()

void mongo::MobileRecoveryUnit::setOrderedCommit ( bool orderedCommit )

inlineoverridevirtual

Implements mongo::RecoveryUnit.

◆ setRollbackWritesDisabled()

void mongo::MobileRecoveryUnit::setRollbackWritesDisabled ( )

inlineoverridevirtual

Sets a flag that declares this RecoveryUnit will skip rolling back writes, for the duration of the current outermost WriteUnitOfWork.

This function can only be called between a pair of unnested beginUnitOfWork() / endUnitOfWork() calls. The flag is cleared when endUnitOfWork() is called. While the flag is set, rollback will skip rolling back writes, but custom rollback change functions are still called. Clearly, this functionality should only be used when writing to temporary collections that can be cleaned up externally. For example, foreground index builds write to a temporary collection; if something goes wrong that normally requires a rollback, we can instead clean up the index by dropping the entire index. Setting the flag may permit increased performance.

Implements mongo::RecoveryUnit.

◆ waitUntilDurable()

bool mongo::MobileRecoveryUnit::waitUntilDurable ( )

inlineoverridevirtual

Waits until all commits that happened before this call are durable in the journal.

Returns true, unless the storage engine cannot guarantee durability, which should never happen when isDurable() returned true. This cannot be called from inside a unit of work, and should fail if it is.

Returns: Whether or not the storage engine can guarantee durability.

Implements mongo::RecoveryUnit.

◆ writingPtr()

void* mongo::MobileRecoveryUnit::writingPtr	(	void *	data,
		size_t	len
	)

inlineoverridevirtual

Declare that the data at [x, x + len) is being written.

Implements mongo::RecoveryUnit.

Member Data Documentation

◆ _active

bool mongo::MobileRecoveryUnit::_active

private

◆ _areWriteUnitOfWorksBanned

bool mongo::MobileRecoveryUnit::_areWriteUnitOfWorksBanned = false

private

◆ _changes

Changes mongo::MobileRecoveryUnit::_changes

private

◆ _inUnitOfWork

bool mongo::MobileRecoveryUnit::_inUnitOfWork

private

◆ _path

std::string mongo::MobileRecoveryUnit::_path

private

◆ _session

std::unique_ptr<MobileSession> mongo::MobileRecoveryUnit::_session

private

◆ _sessionPool

MobileSessionPool* mongo::MobileRecoveryUnit::_sessionPool

private

The documentation for this class was generated from the following files:

/home/louis/git/mongodbsource.github.io/src/src/mongo/db/storage/mobile/mobile_recovery_unit.h
/home/louis/git/mongodbsource.github.io/src/src/mongo/db/storage/mobile/mobile_recovery_unit.cpp

Public Member Functions

Static Public Member Functions

Private Types

Private Member Functions

Private Attributes

Additional Inherited Members

Member Typedef Documentation

◆ Changes

Constructor & Destructor Documentation

◆ MobileRecoveryUnit()

◆ ~MobileRecoveryUnit()

Member Function Documentation

◆ _abort()

◆ _commit()

◆ _ensureSession()

◆ _txnClose()

◆ _txnOpen()

◆ abandonSnapshot()

◆ abortUnitOfWork()

◆ assertInActiveTxn()

◆ beginUnitOfWork()

◆ commitUnitOfWork()

◆ enqueueFailedDrop()

◆ get()

◆ getSession()

◆ getSessionNoTxn()

◆ getSnapshotId()

◆ inActiveTxn()

◆ registerChange()

◆ setOrderedCommit()

◆ setRollbackWritesDisabled()

◆ waitUntilDurable()

◆ writingPtr()

Member Data Documentation

◆ _active

◆ _areWriteUnitOfWorksBanned

◆ _changes

◆ _inUnitOfWork

◆ _path

◆ _session

◆ _sessionPool