Class TransactionManager

java.lang.Object

net.neoforged.neoforge.transfer.transaction.TransactionManager

final class TransactionManager
extends Object

Manager for handling opening new Transactions or querying status of a transaction chain in a given thread.

See Also:

• Transaction

Field Summary

Fields

Modifier and Type	Field	Description
(package private) int	currentDepth
private static final ThreadLocal<TransactionManager>	MANAGERS
(package private) boolean	processingRootCommitQueue
(package private) final Queue<SnapshotJournal<?>>	rootCommitQueue
(package private) final List<Transaction>	stack
(package private) final Thread	thread

Constructor Summary

Constructors

Modifier	Constructor	Description
private	TransactionManager()

Method Summary

Modifier and Type	Method	Description
(package private) static TransactionManager	getManagerForThread()
(package private) Transaction	getOpenTransaction(int depth)	Return the transaction with the specified depth.
(package private) Transaction	open(@Nullable TransactionContext parent, Class<?> callerClass)
(package private) @Nullable RuntimeException	processRootCommitQueue(@Nullable RuntimeException closeException)
(package private) void	validateCurrentThread()
(package private) void	validateCurrentTransaction(Transaction transaction)

Methods inherited from class Object

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

Field Details

MANAGERS

private static final ThreadLocal<TransactionManager> MANAGERS

thread

final Thread thread

stack

final List<Transaction> stack

currentDepth

int currentDepth

rootCommitQueue

final Queue<SnapshotJournal<?>> rootCommitQueue

processingRootCommitQueue

boolean processingRootCommitQueue

Constructor Details

TransactionManager

private TransactionManager()

Method Details

getManagerForThread

static TransactionManager getManagerForThread()

Returns:

The manager for the current thread.

open

Transaction open(@Nullable TransactionContext parent,
 Class<?> callerClass)

getOpenTransaction

Transaction getOpenTransaction(int depth)

Return the transaction with the specified depth.

Parameters:

depth - Queried depth of the transaction desired.

Throws:

IndexOutOfBoundsException - If there is no open transaction with the requested depth.

IllegalStateException - If this function is not called on the thread this transaction was opened in.

validateCurrentThread

void validateCurrentThread()

validateCurrentTransaction

void validateCurrentTransaction(Transaction transaction)

processRootCommitQueue

@Nullable RuntimeException processRootCommitQueue(@Nullable RuntimeException closeException)