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

Class OStandardCompleteAction

java.lang.Object

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

All Implemented Interfaces:

OCompleteAction

Direct Known Subclasses:

OMergeCompleteAction

public class OStandardCompleteAction
extends Object
implements OCompleteAction

Field Summary

Fields

Modifier and Type	Field	Description
protected final OrientDBDistributed	context
protected final OOperationMessage	operation

Constructor Summary

Constructors

Constructor	Description
OStandardCompleteAction(OrientDBDistributed context, OOperationMessage operation, OCompleteExecution execution)

Method Summary

Modifier and Type	Method	Description
void	complete(OTransactionIdPromise promise, Set<ONodeId> nodes, Optional<OAcceptResult> result)
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)
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

context

protected final OrientDBDistributed context

operation

protected final OOperationMessage operation

Constructor Details

OStandardCompleteAction

public OStandardCompleteAction(OrientDBDistributed context,
 OOperationMessage operation,
 OCompleteExecution execution)

Method Details

success

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

Specified by:

success in interface OCompleteAction

failure

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

Specified by:

failure in interface OCompleteAction

retryOperation

protected void retryOperation(int delay)

complete

public void complete(OTransactionIdPromise promise,
 Set<ONodeId> nodes,
 Optional<OAcceptResult> result)

Specified by:

complete in interface OCompleteAction

newResponseCollector

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

Specified by:

newResponseCollector in interface OCompleteAction

toString

public String toString()

Overrides:

toString in class Object