Package com.orientechnologies.orient.distributed.context

Class OCoordinatedDistributedOpsImpl

java.lang.Object

com.orientechnologies.orient.distributed.context.OCoordinatedDistributedOpsImpl

All Implemented Interfaces:

OCoordinatedDistributedOps

public class OCoordinatedDistributedOpsImpl
extends Object
implements OCoordinatedDistributedOps

Constructor Summary

Constructors

Constructor	Description
OCoordinatedDistributedOpsImpl(ONodeId current, int quorum)

Method Summary

Modifier and Type	Method	Description
void	cancelEnstablish()
void	cancelRegisterPromise()
void	completeExecution(OTransactionId complete)
ODiscoverAction	discoverNode(ONodeId node)
void	enstablish(OGroupId groupId, Set<ONodeId> candidates)
void	failure(ONodeId node, OTransactionIdPromise promise, OAcceptResult acceptResult)
Set<ONodeId>	getMembers()
ONodeStateNetwork	getNetworkState()
void	load(ONodeStateStore nodeStateStore)
ODiscoverAction	nodeJoinStart(ONodeId node, ONodeStateNetwork state)
boolean	promiseRegister(ONodeId node, long version)
void	registerNode(ONodeId node, long version)
OOperationStart	start(OTransactionIdPromise promise, OCompleteAction action)
void	startEstablish(OTransactionIdPromise idPromise, Set<ONodeId> nodes, OCompleteAction action)
void	success(ONodeId node, OTransactionIdPromise promise)
void	unregisterNode(ONodeId node, long version)
Optional<OAcceptResult>	validateEnstablish(OGroupId groupId, Set<ONodeId> candidates)

Methods inherited from class java.lang.Object

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

Constructor Details

OCoordinatedDistributedOpsImpl

public OCoordinatedDistributedOpsImpl(ONodeId current,
 int quorum)

Method Details

discoverNode

public ODiscoverAction discoverNode(ONodeId node)

Specified by:

discoverNode in interface OCoordinatedDistributedOps

registerNode

public void registerNode(ONodeId node,
 long version)

Specified by:

registerNode in interface OCoordinatedDistributedOps

unregisterNode

public void unregisterNode(ONodeId node,
 long version)

Specified by:

unregisterNode in interface OCoordinatedDistributedOps

start

public OOperationStart start(OTransactionIdPromise promise,
 OCompleteAction action)

Specified by:

start in interface OCoordinatedDistributedOps

success

public void success(ONodeId node,
 OTransactionIdPromise promise)

Specified by:

success in interface OCoordinatedDistributedOps

failure

public void failure(ONodeId node,
 OTransactionIdPromise promise,
 OAcceptResult acceptResult)

Specified by:

failure in interface OCoordinatedDistributedOps

completeExecution

public void completeExecution(OTransactionId complete)

Specified by:

completeExecution in interface OCoordinatedDistributedOps

getMembers

public Set<ONodeId> getMembers()

Specified by:

getMembers in interface OCoordinatedDistributedOps

promiseRegister

public boolean promiseRegister(ONodeId node,
 long version)

Specified by:

promiseRegister in interface OCoordinatedDistributedOps

enstablish

public void enstablish(OGroupId groupId,
 Set<ONodeId> candidates)

Specified by:

enstablish in interface OCoordinatedDistributedOps

validateEnstablish

public Optional<OAcceptResult> validateEnstablish(OGroupId groupId,
 Set<ONodeId> candidates)

Specified by:

validateEnstablish in interface OCoordinatedDistributedOps

startEstablish

public void startEstablish(OTransactionIdPromise idPromise,
 Set<ONodeId> nodes,
 OCompleteAction action)

Specified by:

startEstablish in interface OCoordinatedDistributedOps

nodeJoinStart

public ODiscoverAction nodeJoinStart(ONodeId node,
 ONodeStateNetwork state)

Specified by:

nodeJoinStart in interface OCoordinatedDistributedOps

getNetworkState

public ONodeStateNetwork getNetworkState()

Specified by:

getNetworkState in interface OCoordinatedDistributedOps

load

public void load(ONodeStateStore nodeStateStore)

Specified by:

load in interface OCoordinatedDistributedOps

cancelRegisterPromise

public void cancelRegisterPromise()

Specified by:

cancelRegisterPromise in interface OCoordinatedDistributedOps

cancelEnstablish

public void cancelEnstablish()

Specified by:

cancelEnstablish in interface OCoordinatedDistributedOps