com.orientechnologies.orient.server.distributed.impl

Class ODistributedTransactionManager

java.lang.Object

com.orientechnologies.orient.server.distributed.impl.ODistributedTransactionManager

public class ODistributedTransactionManager
extends Object

Distributed transaction manager.

Author:

Luca Garulli (l.garulli--at--orientechnologies.com)

Constructor Summary

Constructors

Constructor and Description
ODistributedTransactionManager(ODistributedStorage storage, ODistributedServerManager manager, ODistributedDatabase iDDatabase)

Method Summary

Modifier and Type	Method and Description
static void	acquireMultipleRecordLocks(Object iThis, ODistributedServerManager dManager, List<ORecordId> recordsToLock, ODistributedStorageEventListener eventListener, ODistributedTxContext reqContext, long timeout)
protected void	acquireMultipleRecordLocks(OTransaction iTx, ODistributedStorageEventListener eventListener, ODistributedTxContext reqContext) Acquires lock in block by using an optimistic approach with retry & random delay.
protected void	checkForClusterIds(OTransaction iTx, String localNodeName, ODistributedConfiguration dbCfg)
List<ORecordOperation>	commit(ODatabaseDocumentTx database, OTransaction iTx, Runnable callback, ODistributedStorageEventListener eventListener)
protected OTxTaskResult	createLocalTxResult(List<ORecordOperation> uResult)
protected OTxTask	createTxTask(List<ORecordOperation> uResult, Set<String> nodes)
protected List<OAbstractRemoteTask>	createUndoTasksFromTx(OTransaction iTx, ODistributedDatabase database, ODistributedRequestId requestId) Create undo content for distributed 2-phase rollback.
protected void	executeAsyncTx(Set<String> nodes, OTxTaskResult localResult, Set<String> involvedClusters, OAbstractReplicatedTask txTask, long messageId, String localNodeName, OCallable<Void,ODistributedRequestId> afterSendCallback)
protected Set<String>	getAvailableNodesButLocal(ODistributedConfiguration dbCfg, Set<String> involvedClusters, String localNodeName)
protected Set<String>	getInvolvedClusters(List<ORecordOperation> uResult)
protected void	processCommitResult(String localNodeName, OTransaction iTx, OTxTask txTask, Set<String> involvedClusters, Iterable<ORecordOperation> tmpEntries, Collection<String> nodes, ODistributedRequestId reqId, ODistributedResponse dResponse)
protected void	updateUndoTaskWithCreatedRecords(List<ORecordOperation> uResult, List<OAbstractRemoteTask> undoTasks)

Methods inherited from class java.lang.Object

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

Constructor Detail

ODistributedTransactionManager

public ODistributedTransactionManager(ODistributedStorage storage,
                                      ODistributedServerManager manager,
                                      ODistributedDatabase iDDatabase)

Method Detail

commit

public List<ORecordOperation> commit(ODatabaseDocumentTx database,
                                     OTransaction iTx,
                                     Runnable callback,
                                     ODistributedStorageEventListener eventListener)

checkForClusterIds

protected void checkForClusterIds(OTransaction iTx,
                                  String localNodeName,
                                  ODistributedConfiguration dbCfg)

getAvailableNodesButLocal

protected Set<String> getAvailableNodesButLocal(ODistributedConfiguration dbCfg,
                                                Set<String> involvedClusters,
                                                String localNodeName)

executeAsyncTx

protected void executeAsyncTx(Set<String> nodes,
                              OTxTaskResult localResult,
                              Set<String> involvedClusters,
                              OAbstractReplicatedTask txTask,
                              long messageId,
                              String localNodeName,
                              OCallable<Void,ODistributedRequestId> afterSendCallback)

updateUndoTaskWithCreatedRecords

protected void updateUndoTaskWithCreatedRecords(List<ORecordOperation> uResult,
                                                List<OAbstractRemoteTask> undoTasks)

getInvolvedClusters

protected Set<String> getInvolvedClusters(List<ORecordOperation> uResult)

createTxTask

protected OTxTask createTxTask(List<ORecordOperation> uResult,
                               Set<String> nodes)

createLocalTxResult

protected OTxTaskResult createLocalTxResult(List<ORecordOperation> uResult)

acquireMultipleRecordLocks

protected void acquireMultipleRecordLocks(OTransaction iTx,
                                          ODistributedStorageEventListener eventListener,
                                          ODistributedTxContext reqContext)
                                   throws InterruptedException

Acquires lock in block by using an optimistic approach with retry & random delay. In case any record is locked, all the lock acquired so far are released before to retry.

Throws:

InterruptedException

acquireMultipleRecordLocks

public static void acquireMultipleRecordLocks(Object iThis,
                                              ODistributedServerManager dManager,
                                              List<ORecordId> recordsToLock,
                                              ODistributedStorageEventListener eventListener,
                                              ODistributedTxContext reqContext,
                                              long timeout)
                                       throws InterruptedException

Throws:

InterruptedException

createUndoTasksFromTx

protected List<OAbstractRemoteTask> createUndoTasksFromTx(OTransaction iTx,
                                                          ODistributedDatabase database,
                                                          ODistributedRequestId requestId)

Create undo content for distributed 2-phase rollback. This list of undo tasks is sent to all the nodes to revert a transaction and it's also applied locally.

Parameters:

iTx - Current transaction

database -

requestId -

Returns:

List of remote undo tasks

processCommitResult

protected void processCommitResult(String localNodeName,
                                   OTransaction iTx,
                                   OTxTask txTask,
                                   Set<String> involvedClusters,
                                   Iterable<ORecordOperation> tmpEntries,
                                   Collection<String> nodes,
                                   ODistributedRequestId reqId,
                                   ODistributedResponse dResponse)
                            throws InterruptedException

Throws:

InterruptedException