Class OCoordinatedDistributedOpsImpl
java.lang.Object
com.orientechnologies.orient.distributed.context.OCoordinatedDistributedOpsImpl
- All Implemented Interfaces:
OCoordinatedDistributedOps
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidvoidvoidcompleteExecution(OTransactionId complete) discoverNode(ONodeId node) voidenstablish(OGroupId groupId, Set<ONodeId> candidates) voidfailure(ONodeId node, OTransactionIdPromise promise, OAcceptResult acceptResult) voidload(ONodeStateStore nodeStateStore) nodeJoinStart(ONodeId node, ONodeStateNetwork state) booleanpromiseRegister(ONodeId node, long version) voidregisterNode(ONodeId node, long version) start(OTransactionIdPromise promise, OCompleteAction action) voidstartEstablish(OTransactionIdPromise idPromise, Set<ONodeId> nodes, OCompleteAction action) voidsuccess(ONodeId node, OTransactionIdPromise promise) voidunregisterNode(ONodeId node, long version) validateEnstablish(OGroupId groupId, Set<ONodeId> candidates)
-
Constructor Details
-
OCoordinatedDistributedOpsImpl
-
-
Method Details
-
discoverNode
- Specified by:
discoverNodein interfaceOCoordinatedDistributedOps
-
registerNode
- Specified by:
registerNodein interfaceOCoordinatedDistributedOps
-
unregisterNode
- Specified by:
unregisterNodein interfaceOCoordinatedDistributedOps
-
start
- Specified by:
startin interfaceOCoordinatedDistributedOps
-
success
- Specified by:
successin interfaceOCoordinatedDistributedOps
-
failure
- Specified by:
failurein interfaceOCoordinatedDistributedOps
-
completeExecution
- Specified by:
completeExecutionin interfaceOCoordinatedDistributedOps
-
getMembers
- Specified by:
getMembersin interfaceOCoordinatedDistributedOps
-
promiseRegister
- Specified by:
promiseRegisterin interfaceOCoordinatedDistributedOps
-
enstablish
- Specified by:
enstablishin interfaceOCoordinatedDistributedOps
-
validateEnstablish
- Specified by:
validateEnstablishin interfaceOCoordinatedDistributedOps
-
startEstablish
public void startEstablish(OTransactionIdPromise idPromise, Set<ONodeId> nodes, OCompleteAction action) - Specified by:
startEstablishin interfaceOCoordinatedDistributedOps
-
nodeJoinStart
- Specified by:
nodeJoinStartin interfaceOCoordinatedDistributedOps
-
getNetworkState
- Specified by:
getNetworkStatein interfaceOCoordinatedDistributedOps
-
load
- Specified by:
loadin interfaceOCoordinatedDistributedOps
-
cancelRegisterPromise
public void cancelRegisterPromise()- Specified by:
cancelRegisterPromisein interfaceOCoordinatedDistributedOps
-
cancelEnstablish
public void cancelEnstablish()- Specified by:
cancelEnstablishin interfaceOCoordinatedDistributedOps
-