Wikimedia\Rdbms\TransactionManager Class Reference

Public Member Functions
	__construct (LoggerInterface $logger=null, $profiler=null)
	addPostCommitOrIdleCallback (callable $callback, $fname=__METHOD__)
	addPreCommitOrIdleCallback (callable $callback, $fname=__METHOD__)
	addToAtomicLevels ( $fname, AtomicSectionIdentifier $sectionId, $savepointId)
	assertSessionStatus (IDatabase $db, $fname)
	assertTransactionStatus (IDatabase $db, $deprecationLogger, $fname)
	cancelAtomic ( $pos)
	clearEndCallbacks ()
	clearPreEndCallbacks ()
	clearSessionError ()
	Unflag the session as needing a reset due to an error.
	consumeEndCallbacks ( $trigger)
	consumeTrxId ()
	Reset the application-side transaction identifier instance and return the old one.
	countPostCommitOrIdleCallbacks ()
	currentAtomicSectionId ()
	explicitTrxActive ()
	getPositionFromSectionId (AtomicSectionIdentifier $sectionId=null)
	getRecurringCallbacks ()
	getTrxId ()
	Get the application-side transaction identifier instance.
	isClean ()
	isEndCallbacksSuppressed ()
	modifyCallbacksForCancel (IDatabase $db, array $sectionIds, AtomicSectionIdentifier $newSectionId=null)
	Update callbacks that were owned by cancelled atomic sections.
	newTrxId ( $mode, $fname, $rtt)
	TODO: This should be removed once all usages have been migrated here.
	nextSavePointId (IDatabase $db, $fname)
	onAtomicSectionCancel (IDatabase $db, $callback, $fname)
	onBeginTransaction (IDatabase $db, $fname)
	onCancelAtomicBeforeCriticalSection (IDatabase $db, $fname)
	onCommit (IDatabase $db, $fname, $flush)
	onCommitInCriticalSection (IDatabase $db)
	onDestruct ()
	onEndAtomic (IDatabase $db, $fname)
	onEndAtomicInCriticalSection ( $sectionId)
	onFlushSnapshot (IDatabase $db, $fname, $flush, $trxRoundId)
	onGetScopedLockAndFlush (IDatabase $db, $fname)
	onRollback (IDatabase $db)
	onTransactionResolution (IDatabase $db, callable $callback, $fname)
	pendingPreCommitCallbackCallers ()
	List the methods that have precommit callbacks for the current transaction.
	pendingWriteAndCallbackCallers ()
	List the methods that have write queries or callbacks for the current transaction.
	pendingWriteCallers ()
	pendingWriteQueryDuration ( $type=IDatabase::ESTIMATE_TOTAL)
	popAtomicLevel ()
	reassignCallbacksForSection (AtomicSectionIdentifier $old, AtomicSectionIdentifier $new)
	Hoist callback ownership for callbacks in a section to a parent section.
	recordQueryCompletion ( $sql, $startTime, $isPermWrite, $rowCount, $serverName)
	resetTrxAtomicLevels ()
	runOnAtomicSectionCancelCallbacks (IDatabase $db, int $trigger, array $sectionIds)
	Consume and run any relevant "on atomic section cancel" callbacks for the active transaction.
	runOnTransactionPreCommitCallbacks (IDatabase $db)
	Consume and run any "on transaction pre-commit" callbacks.
	sessionStatus ()
	Get the status of the current session (ephemeral server-side state tied to the connection)
	setAutomaticAtomic ( $value)
	setSessionError (Throwable $sessionError)
	Flag the session as needing a reset due to an error, if not already flagged.
	setTransactionError (Throwable $trxError)
	Mark the transaction as requiring rollback (STATUS_TRX_ERROR) due to an error.
	setTransactionListener ( $name, callable $callback=null)
	setTrxEndCallbackSuppression (bool $suppress)
	Whether to disable running of post-COMMIT/ROLLBACK callbacks.
	setTrxStatusIgnoredCause (?array $trxStatusIgnoredCause)
	setTrxStatusToNone ()
	setTrxStatusToOk ()
	transactionWritingIn ( $serverName, $domainId)
	transactionWritingOut (IDatabase $db, $oldId)
	trxCheckBeforeClose (IDatabase $db, $fname)
	trxLevel ()
	trxStatus ()
	trxTimestamp ()
	turnOnAutomatic ()
	updateTrxWriteQueryReport ( $queryVerb, $runtime, $affected, $fname)
	Update the estimated run-time of a query, not counting large row lock times.
	writesOrCallbacksPending ()
	writesPending ()

Public Attributes
const	STATUS_SESS_ERROR = 1
	Session is in a error state requiring a reset.
const	STATUS_SESS_OK = 2
	Session is in a normal state.

Detailed Description

Access: internal

This class should not be used outside of Database

Definition at line 32 of file TransactionManager.php.

Constructor & Destructor Documentation

__construct()

Wikimedia\Rdbms\TransactionManager::__construct	(	LoggerInterface	$logger = null,
			$profiler = null )

Definition at line 119 of file TransactionManager.php.

Member Function Documentation

addPostCommitOrIdleCallback()

Wikimedia\Rdbms\TransactionManager::addPostCommitOrIdleCallback	(	callable	$callback,
			$fname = __METHOD__ )

Definition at line 631 of file TransactionManager.php.

addPreCommitOrIdleCallback()

Wikimedia\Rdbms\TransactionManager::addPreCommitOrIdleCallback ( callable $callback, $fname = __METHOD__ )

final

Definition at line 639 of file TransactionManager.php.

addToAtomicLevels()

Wikimedia\Rdbms\TransactionManager::addToAtomicLevels	(		$fname,
		AtomicSectionIdentifier	$sectionId,
			$savepointId )

Definition at line 416 of file TransactionManager.php.

assertSessionStatus()

Wikimedia\Rdbms\TransactionManager::assertSessionStatus	(	IDatabase	$db,
			$fname )

Definition at line 223 of file TransactionManager.php.

assertTransactionStatus()

Wikimedia\Rdbms\TransactionManager::assertTransactionStatus	(	IDatabase	$db,
			$deprecationLogger,
			$fname )

Definition at line 205 of file TransactionManager.php.

cancelAtomic()

Wikimedia\Rdbms\TransactionManager::cancelAtomic

(

$pos

)

Definition at line 516 of file TransactionManager.php.

clearEndCallbacks()

Wikimedia\Rdbms\TransactionManager::clearEndCallbacks

(

)

Definition at line 835 of file TransactionManager.php.

clearPreEndCallbacks()

Wikimedia\Rdbms\TransactionManager::clearPreEndCallbacks

(

)

Definition at line 830 of file TransactionManager.php.

clearSessionError()

Wikimedia\Rdbms\TransactionManager::clearSessionError

(

)

Unflag the session as needing a reset due to an error.

Definition at line 275 of file TransactionManager.php.

consumeEndCallbacks()

Wikimedia\Rdbms\TransactionManager::consumeEndCallbacks

(

$trigger

)

Definition at line 752 of file TransactionManager.php.

consumeTrxId()

Wikimedia\Rdbms\TransactionManager::consumeTrxId

(

)

Reset the application-side transaction identifier instance and return the old one.

This will become private soon.

Returns

TransactionIdentifier|null The old transaction token; null if there wasn't one

Definition at line 174 of file TransactionManager.php.

countPostCommitOrIdleCallbacks()

Wikimedia\Rdbms\TransactionManager::countPostCommitOrIdleCallbacks

(

)

Definition at line 893 of file TransactionManager.php.

currentAtomicSectionId()

Wikimedia\Rdbms\TransactionManager::currentAtomicSectionId

(

)

Returns

AtomicSectionIdentifier|null ID of the topmost atomic section level

Definition at line 406 of file TransactionManager.php.

explicitTrxActive()

Wikimedia\Rdbms\TransactionManager::explicitTrxActive

(

)

Definition at line 360 of file TransactionManager.php.

getPositionFromSectionId()

Wikimedia\Rdbms\TransactionManager::getPositionFromSectionId

(

AtomicSectionIdentifier

$sectionId = null

)

Definition at line 500 of file TransactionManager.php.

getRecurringCallbacks()

Wikimedia\Rdbms\TransactionManager::getRecurringCallbacks

(

)

Definition at line 889 of file TransactionManager.php.

getTrxId()

Wikimedia\Rdbms\TransactionManager::getTrxId

(

)

Get the application-side transaction identifier instance.

Returns

TransactionIdentifier Token for the active transaction; null if there isn't one

Definition at line 164 of file TransactionManager.php.

isClean()

Wikimedia\Rdbms\TransactionManager::isClean

(

)

Definition at line 553 of file TransactionManager.php.

isEndCallbacksSuppressed()

Wikimedia\Rdbms\TransactionManager::isEndCallbacksSuppressed

(

)

Definition at line 885 of file TransactionManager.php.

modifyCallbacksForCancel()

Wikimedia\Rdbms\TransactionManager::modifyCallbacksForCancel	(	IDatabase	$db,
		array	$sectionIds,
		AtomicSectionIdentifier	$newSectionId = null )

Update callbacks that were owned by cancelled atomic sections.

Callbacks for "on commit" should never be run if they're owned by a section that won't be committed.

Callbacks for "on resolution" need to reflect that the section was rolled back, even if the transaction as a whole commits successfully.

Callbacks for "on section cancel" should already have been consumed, but errors during the cancellation itself can prevent that while still destroying the section. Hoist any such callbacks to the new top section, which we assume will itself have to be cancelled or rolled back to resolve the error.

Parameters

IDatabase	$db
AtomicSectionIdentifier[]	$sectionIds	ID of an actual savepoint
AtomicSectionIdentifier | null	$newSectionId	New top section ID.

Exceptions

UnexpectedValueException

Definition at line 715 of file TransactionManager.php.

newTrxId()

Wikimedia\Rdbms\TransactionManager::newTrxId	(		$mode,
			$fname,
			$rtt )

TODO: This should be removed once all usages have been migrated here.

Parameters

string	$mode	One of IDatabase::TRANSACTION_* values
string	$fname	method name
float	$rtt	Trivial query round-trip-delay

Definition at line 134 of file TransactionManager.php.

References Wikimedia\Rdbms\TransactionManager\trxStatus(), and Wikimedia\Rdbms\TransactionManager\trxTimestamp().

nextSavePointId()

Wikimedia\Rdbms\TransactionManager::nextSavePointId	(	IDatabase	$db,
			$fname )

Definition at line 565 of file TransactionManager.php.

onAtomicSectionCancel()

Wikimedia\Rdbms\TransactionManager::onAtomicSectionCancel	(	IDatabase	$db,
			$callback,
			$fname )

Definition at line 390 of file TransactionManager.php.

onBeginTransaction()

Wikimedia\Rdbms\TransactionManager::onBeginTransaction	(	IDatabase	$db,
			$fname )

Definition at line 422 of file TransactionManager.php.

onCancelAtomicBeforeCriticalSection()

Wikimedia\Rdbms\TransactionManager::onCancelAtomicBeforeCriticalSection	(	IDatabase	$db,
			$fname )

Definition at line 397 of file TransactionManager.php.

onCommit()

Wikimedia\Rdbms\TransactionManager::onCommit	(	IDatabase	$db,
			$fname,
			$flush )

Parameters

IDatabase	$db
string	$fname
string	$flush	one of IDatabase::FLUSHING_* values

Returns

bool false if the commit should go aborted, true otherwise.

Definition at line 443 of file TransactionManager.php.

onCommitInCriticalSection()

Wikimedia\Rdbms\TransactionManager::onCommitInCriticalSection

(

IDatabase

$db

)

Definition at line 905 of file TransactionManager.php.

onDestruct()

Wikimedia\Rdbms\TransactionManager::onDestruct

(

)

Definition at line 584 of file TransactionManager.php.

onEndAtomic()

Wikimedia\Rdbms\TransactionManager::onEndAtomic	(	IDatabase	$db,
			$fname )

Definition at line 481 of file TransactionManager.php.

onEndAtomicInCriticalSection()

Wikimedia\Rdbms\TransactionManager::onEndAtomicInCriticalSection

(

$sectionId

)

Definition at line 916 of file TransactionManager.php.

onFlushSnapshot()

Wikimedia\Rdbms\TransactionManager::onFlushSnapshot	(	IDatabase	$db,
			$fname,
			$flush,
			$trxRoundId )

Definition at line 925 of file TransactionManager.php.

onGetScopedLockAndFlush()

Wikimedia\Rdbms\TransactionManager::onGetScopedLockAndFlush	(	IDatabase	$db,
			$fname )

Definition at line 958 of file TransactionManager.php.

onRollback()

Wikimedia\Rdbms\TransactionManager::onRollback

(

IDatabase

$db

)

Definition at line 897 of file TransactionManager.php.

onTransactionResolution()

Wikimedia\Rdbms\TransactionManager::onTransactionResolution	(	IDatabase	$db,
		callable	$callback,
			$fname )

Definition at line 624 of file TransactionManager.php.

pendingPreCommitCallbackCallers()

Wikimedia\Rdbms\TransactionManager::pendingPreCommitCallbackCallers

(

)

List the methods that have precommit callbacks for the current transaction.

Returns

string[]

Definition at line 876 of file TransactionManager.php.

pendingWriteAndCallbackCallers()

Wikimedia\Rdbms\TransactionManager::pendingWriteAndCallbackCallers

(

)

List the methods that have write queries or callbacks for the current transaction.

Returns

string[]

Definition at line 855 of file TransactionManager.php.

pendingWriteCallers()

Wikimedia\Rdbms\TransactionManager::pendingWriteCallers

(

)

Definition at line 293 of file TransactionManager.php.

pendingWriteQueryDuration()

Wikimedia\Rdbms\TransactionManager::pendingWriteQueryDuration

(

$type = IDatabase::ESTIMATE_TOTAL

)

Definition at line 333 of file TransactionManager.php.

popAtomicLevel()

Wikimedia\Rdbms\TransactionManager::popAtomicLevel

(

)

Definition at line 549 of file TransactionManager.php.

reassignCallbacksForSection()

Wikimedia\Rdbms\TransactionManager::reassignCallbacksForSection	(	AtomicSectionIdentifier	$old,
		AtomicSectionIdentifier	$new )

Hoist callback ownership for callbacks in a section to a parent section.

All callbacks should have an owner that is present in trxAtomicLevels.

Parameters

AtomicSectionIdentifier	$old
AtomicSectionIdentifier	$new

Definition at line 669 of file TransactionManager.php.

recordQueryCompletion()

Wikimedia\Rdbms\TransactionManager::recordQueryCompletion	(		$sql,
			$startTime,
			$isPermWrite,
			$rowCount,
			$serverName )

Definition at line 613 of file TransactionManager.php.

resetTrxAtomicLevels()

Wikimedia\Rdbms\TransactionManager::resetTrxAtomicLevels

(

)

Definition at line 356 of file TransactionManager.php.

runOnAtomicSectionCancelCallbacks()

Wikimedia\Rdbms\TransactionManager::runOnAtomicSectionCancelCallbacks	(	IDatabase	$db,
		int	$trigger,
		array	$sectionIds )

Consume and run any relevant "on atomic section cancel" callbacks for the active transaction.

Parameters

IDatabase	$db
int	$trigger	IDatabase::TRIGGER_* constant
AtomicSectionIdentifier[]	$sectionIds	IDs of the sections that where just cancelled

Exceptions

Throwable

Any exception thrown by a callback

Definition at line 775 of file TransactionManager.php.

runOnTransactionPreCommitCallbacks()

Wikimedia\Rdbms\TransactionManager::runOnTransactionPreCommitCallbacks

(

IDatabase

$db

)

Consume and run any "on transaction pre-commit" callbacks.

Parameters

IDatabase

$db

Returns

int Number of callbacks attempted

Exceptions

Throwable

Any exception thrown by a callback

Definition at line 807 of file TransactionManager.php.

sessionStatus()

Wikimedia\Rdbms\TransactionManager::sessionStatus

(

)

Get the status of the current session (ephemeral server-side state tied to the connection)

Returns

int One of the STATUS_SESSION_* class constants

Definition at line 258 of file TransactionManager.php.

setAutomaticAtomic()

Wikimedia\Rdbms\TransactionManager::setAutomaticAtomic

(

$value

)

Definition at line 557 of file TransactionManager.php.

setSessionError()

Wikimedia\Rdbms\TransactionManager::setSessionError

(

Throwable

$sessionError

)

Flag the session as needing a reset due to an error, if not already flagged.

Parameters

Throwable

$sessionError

Definition at line 268 of file TransactionManager.php.

setTransactionError()

Wikimedia\Rdbms\TransactionManager::setTransactionError

(

Throwable

$trxError

)

Mark the transaction as requiring rollback (STATUS_TRX_ERROR) due to an error.

Parameters

Throwable

$trxError

Definition at line 239 of file TransactionManager.php.

setTransactionListener()

Wikimedia\Rdbms\TransactionManager::setTransactionListener	(		$name,
		callable	$callback = null )

Definition at line 647 of file TransactionManager.php.

setTrxEndCallbackSuppression()

Wikimedia\Rdbms\TransactionManager::setTrxEndCallbackSuppression

(

bool

$suppress

)

Whether to disable running of post-COMMIT/ROLLBACK callbacks.

Parameters

bool

$suppress

Definition at line 659 of file TransactionManager.php.

setTrxStatusIgnoredCause()

Wikimedia\Rdbms\TransactionManager::setTrxStatusIgnoredCause

(

?array

$trxStatusIgnoredCause

)

Parameters

array | null

$trxStatusIgnoredCause

Definition at line 249 of file TransactionManager.php.

setTrxStatusToNone()

Wikimedia\Rdbms\TransactionManager::setTrxStatusToNone

(

)

Definition at line 199 of file TransactionManager.php.

setTrxStatusToOk()

Wikimedia\Rdbms\TransactionManager::setTrxStatusToOk

(

)

Definition at line 193 of file TransactionManager.php.

transactionWritingIn()

Wikimedia\Rdbms\TransactionManager::transactionWritingIn	(		$serverName,
			$domainId )

Definition at line 590 of file TransactionManager.php.

transactionWritingOut()

Wikimedia\Rdbms\TransactionManager::transactionWritingOut	(	IDatabase	$db,
			$oldId )

Definition at line 601 of file TransactionManager.php.

References Wikimedia\Rdbms\IReadableDatabase\getDomainID(), and Wikimedia\Rdbms\IReadableDatabase\getServerName().

trxCheckBeforeClose()

Wikimedia\Rdbms\TransactionManager::trxCheckBeforeClose	(	IDatabase	$db,
			$fname )

Definition at line 364 of file TransactionManager.php.

References Wikimedia\Rdbms\IDatabase\writesOrCallbacksPending().

trxLevel()

Wikimedia\Rdbms\TransactionManager::trxLevel

(

)

Definition at line 124 of file TransactionManager.php.

trxStatus()

Wikimedia\Rdbms\TransactionManager::trxStatus

(

)

Returns

int One of the STATUS_TRX_* class constants

Definition at line 189 of file TransactionManager.php.

Referenced by Wikimedia\Rdbms\TransactionManager\newTrxId().

trxTimestamp()

Wikimedia\Rdbms\TransactionManager::trxTimestamp

(

)

Definition at line 182 of file TransactionManager.php.

Referenced by Wikimedia\Rdbms\TransactionManager\newTrxId().

turnOnAutomatic()

Wikimedia\Rdbms\TransactionManager::turnOnAutomatic

(

)

Definition at line 561 of file TransactionManager.php.

updateTrxWriteQueryReport()

Wikimedia\Rdbms\TransactionManager::updateTrxWriteQueryReport	(		$queryVerb,
			$runtime,
			$affected,
			$fname )

Update the estimated run-time of a query, not counting large row lock times.

LoadBalancer can be set to rollback transactions that will create huge replication lag. It bases this estimate off of pendingWriteQueryDuration(). Certain simple queries, like inserting a row can take a long time due to row locking. This method uses some simple heuristics to discount those cases.

Parameters

string	$queryVerb	action in the write query
float	$runtime	Total runtime, including RTT
int	$affected	Affected row count
string	$fname	method name invoking the action

Definition at line 310 of file TransactionManager.php.

writesOrCallbacksPending()

Wikimedia\Rdbms\TransactionManager::writesOrCallbacksPending

(

)

Definition at line 840 of file TransactionManager.php.

writesPending()

Wikimedia\Rdbms\TransactionManager::writesPending

(

)

Definition at line 580 of file TransactionManager.php.

Member Data Documentation

STATUS_SESS_ERROR

const Wikimedia\Rdbms\TransactionManager::STATUS_SESS_ERROR = 1

Session is in a error state requiring a reset.

Definition at line 41 of file TransactionManager.php.

STATUS_SESS_OK

const Wikimedia\Rdbms\TransactionManager::STATUS_SESS_OK = 2

Session is in a normal state.

Definition at line 43 of file TransactionManager.php.

---

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

• includes/libs/rdbms/database/TransactionManager.php