Constructor Detail

• ODistributedTransactionManager

  public ODistributedTransactionManager(ODistributedStorage storage,
                                        OServer iServer,
                                        ODistributedDatabase iDDatabase)

Method Detail

• commit

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

• 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)

• createLocalTxResult

  protected OTxTaskResult createLocalTxResult(List<ORecordOperation> uResult)

• acquireMultipleRecordLocks

  protected void acquireMultipleRecordLocks(OTransaction iTx,
                                            int maxAutoRetry,
                                            int autoRetryDelay,
                                            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

• createUndoTasksFromTx

  protected List<OAbstractRemoteTask> createUndoTasksFromTx(OTransaction iTx)

  Create undo content for distributed 2-phase rollback.

  Parameters:

  iTx - Current transaction

  Returns:

  List of remote undo tasks

• processCommitResult

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

  Throws:

  InterruptedException