com.orientechnologies.orient.server.distributed.impl

Class ONewDistributedTransactionManager

java.lang.Object

com.orientechnologies.orient.server.distributed.impl.ONewDistributedTransactionManager

public class ONewDistributedTransactionManager
extends Object

Distributed transaction manager.

Author:

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected void	checkForClusterIds(OTransactionInternal iTx)
List<ORecordOperation>	commit(ODatabaseDocumentDistributed database, OTransactionInternal iTx, ODistributedStorageEventListener eventListener)
protected OTransactionPhase1Task	createTxTask(OTransactionInternal transaction, Set<String> nodes)
protected Set<String>	getAvailableNodesButLocal(ODistributedConfiguration dbCfg, Set<String> involvedClusters, String localNodeName)
protected Set<String>	getInvolvedClusters(Iterable<ORecordOperation> uResult)
OLogSequenceNumber	getLsn()
List<ORecordOperation>	retriedCommit(ODatabaseDocumentDistributed database, OTransactionInternal iTx, ODistributedRequestId requestId)

Methods inherited from class java.lang.Object

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

Constructor Detail

ONewDistributedTransactionManager

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

Method Detail

commit

public List<ORecordOperation> commit(ODatabaseDocumentDistributed database,
                                     OTransactionInternal iTx,
                                     ODistributedStorageEventListener eventListener)

retriedCommit

public List<ORecordOperation> retriedCommit(ODatabaseDocumentDistributed database,
                                            OTransactionInternal iTx,
                                            ODistributedRequestId requestId)

getLsn

public OLogSequenceNumber getLsn()

checkForClusterIds

protected void checkForClusterIds(OTransactionInternal iTx)

getAvailableNodesButLocal

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

getInvolvedClusters

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

createTxTask

protected OTransactionPhase1Task createTxTask(OTransactionInternal transaction,
                                              Set<String> nodes)