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
void	commit(ODatabaseDocumentDistributed database, OTransactionInternal iTx)
protected OTransactionPhase1Task	createTxTask(OTransactionId id, 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()
void	retriedCommit(ODatabaseDocumentDistributed database, OTransactionInternal iTx, OTransactionId txId, 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 void commit(ODatabaseDocumentDistributed database,
                   OTransactionInternal iTx)

retriedCommit

public void retriedCommit(ODatabaseDocumentDistributed database,
                          OTransactionInternal iTx,
                          OTransactionId txId,
                          ODistributedRequestId requestId)

getLsn

public OLogSequenceNumber getLsn()

getAvailableNodesButLocal

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

getInvolvedClusters

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

createTxTask

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