Package com.orientechnologies.orient.distributed.context.coordination.action

Class OMergeCompleteAction

java.lang.Object

com.orientechnologies.orient.distributed.context.coordination.action.OStandardCompleteAction

com.orientechnologies.orient.distributed.context.coordination.action.OMergeCompleteAction

All Implemented Interfaces:

OCompleteAction

public class OMergeCompleteAction
extends OStandardCompleteAction
implements OCompleteAction

Field Summary

Fields inherited from class com.orientechnologies.orient.distributed.context.coordination.action.OStandardCompleteAction

context, operation

Constructor Summary

Constructors

Constructor	Description
OMergeCompleteAction(OrientDBDistributed context, OOperationMessage operation, ONodeStateNetwork mergedState, ONodeStateNetwork original, OCompleteExecution execution, ONodeId mergeNode)

Method Summary

Modifier and Type	Method	Description
void	failure(OTransactionIdPromise promise, Set<ONodeId> all, Optional<OAcceptResult> result)
OResponseCollector	newResponseCollector(OTransactionIdPromise promise, int quorum, Set<ONodeId> nodes)
protected void	retryOperation(int delay)
void	success(OTransactionIdPromise promise, Set<ONodeId> all)

Methods inherited from class com.orientechnologies.orient.distributed.context.coordination.action.OStandardCompleteAction

complete, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.orientechnologies.orient.distributed.context.coordination.action.OCompleteAction

complete

Constructor Details

OMergeCompleteAction

public OMergeCompleteAction(OrientDBDistributed context,
 OOperationMessage operation,
 ONodeStateNetwork mergedState,
 ONodeStateNetwork original,
 OCompleteExecution execution,
 ONodeId mergeNode)

Method Details

newResponseCollector

public OResponseCollector newResponseCollector(OTransactionIdPromise promise,
 int quorum,
 Set<ONodeId> nodes)

Specified by:

newResponseCollector in interface OCompleteAction

Overrides:

newResponseCollector in class OStandardCompleteAction

retryOperation

protected void retryOperation(int delay)

Overrides:

retryOperation in class OStandardCompleteAction

success

public void success(OTransactionIdPromise promise,
 Set<ONodeId> all)

Specified by:

success in interface OCompleteAction

Overrides:

success in class OStandardCompleteAction

failure

public void failure(OTransactionIdPromise promise,
 Set<ONodeId> all,
 Optional<OAcceptResult> result)

Specified by:

failure in interface OCompleteAction

Overrides:

failure in class OStandardCompleteAction