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, OGroupId groupId, int minimumQuorum, ODatabaseStateChangeListener listener, ONodeStateUpdated updateLister)

Method Summary

Modifier and Type	Method	Description
boolean	acceptSync(ONodeId sender, ONodeId receiver, ODatabaseId dbId, OSyncId syncId)
void	addDatabaseMember(ODatabaseId dbId, List<OAddNodeInfo> nodes, long version)
void	cancelAddDatabaseMember(ODatabaseId dbId, List<OAddNodeInfo> nodes)
void	cancelDeclareDatabase(OTransactionIdPromise promise, ODatabaseId dbId, String database)
void	cancelEnstablish()
void	cancelRegisterNode()
void	cancelSetState(ODatabaseId dbId, ONodeId nodeId, long version)
Optional<OSyncState>	canSync(ONodeId sender, ONodeId receiver, ODatabaseId dbId, OSyncId syncId, boolean canSync, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus)
void	completeExecution(OTransactionIdPromise promise)
void	completeSync(OSyncId syncId)
Optional<ODistributedMessage>	consensusFailure(OTransactionIdPromise promise)
Optional<ODistributedMessage>	consensusSuccess(OTransactionIdPromise promise)
void	declareDatabase(OTransactionIdPromise promise, ODatabaseId dbId, String database, Set<ONodeId> partecipants, int minimumQuorum)
ODiscoverAction	discoverNode(ONodeId node)
Set<ONodeId>	enstablish(OGroupId groupId, Set<ONodeId> candidates)
boolean	executeOnOneOnline(ODatabaseId dbId, OStateAction execute)
ODatabasesTopologyState	getDatabaseTopology()
Set<ONodeId>	getNetworkMembers()
ONodeStateNetwork	getNetworkState()
ONodeStateStore	getStore()
OSyncState	getSyncState(OSyncId syncId)
boolean	isApplied(OTransactionId txId)
void	load(ONodeStateStore state)
Optional<OSyncInfo>	newSync(ODatabaseId dbId)
void	nodeFailure(ONodeId node, OTransactionIdPromise promise, OAcceptResult acceptResult)
ODiscoverAction	nodeJoinStart(ONodeId node, ONodeStateNetwork state)
void	nodeSuccess(ONodeId node, OTransactionIdPromise promise)
Optional<OAcceptResult>	receive(ODistributedMessage message)
void	registerNode(ONodeId node, long version)
void	setState(ODatabaseId db, ONodeId node, ODatabaseState state, long version)
Optional<OOperationStart>	start(OCompleteAction action)
Optional<OTransactionIdPromise>	startEstablish(Set<ONodeId> nodes, OCompleteAction action)
OSyncState	startSend(ONodeId to, ONodeId from, ODatabaseId dbId, OSyncId syncId, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus)
void	unregisterNode(ONodeId node, long version)
Optional<OAcceptResult>	validateAddDatabaseMember(ODatabaseId dbId, List<OAddNodeInfo> nodes, long version)
Optional<OAcceptResult>	validateDeclareDatabase(OTransactionIdPromise promise, ODatabaseId databaseId, String database, Set<ONodeId> partecipants, int minimumQuorum)
Optional<OAcceptResult>	validateEnstablish(OGroupId groupId, Set<ONodeId> candidates)
Optional<OAcceptResult>	validateRegisterNode(ONodeId node, long version)
Optional<OAcceptResult>	validateSetState(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state, long version)
boolean	waitOnlineQuorum(ODatabaseId dbId, Optional<Long> timeout)

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,
 OGroupId groupId,
 int minimumQuorum,
 ODatabaseStateChangeListener listener,
 ONodeStateUpdated updateLister)

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 Optional<OOperationStart> start(OCompleteAction action)

Specified by:

start in interface OCoordinatedDistributedOps

receive

public Optional<OAcceptResult> receive(ODistributedMessage message)

Specified by:

receive in interface OCoordinatedDistributedOps

consensusFailure

public Optional<ODistributedMessage> consensusFailure(OTransactionIdPromise promise)

Specified by:

consensusFailure in interface OCoordinatedDistributedOps

consensusSuccess

public Optional<ODistributedMessage> consensusSuccess(OTransactionIdPromise promise)

Specified by:

consensusSuccess in interface OCoordinatedDistributedOps

nodeSuccess

public void nodeSuccess(ONodeId node,
 OTransactionIdPromise promise)

Specified by:

nodeSuccess in interface OCoordinatedDistributedOps

nodeFailure

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

Specified by:

nodeFailure in interface OCoordinatedDistributedOps

completeExecution

public void completeExecution(OTransactionIdPromise promise)

Specified by:

completeExecution in interface OCoordinatedDistributedOps

getNetworkMembers

public Set<ONodeId> getNetworkMembers()

Specified by:

getNetworkMembers in interface OCoordinatedDistributedOps

validateRegisterNode

public Optional<OAcceptResult> validateRegisterNode(ONodeId node,
 long version)

Specified by:

validateRegisterNode in interface OCoordinatedDistributedOps

enstablish

public Set<ONodeId> 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 Optional<OTransactionIdPromise> startEstablish(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 state)

Specified by:

load in interface OCoordinatedDistributedOps

cancelRegisterNode

public void cancelRegisterNode()

Specified by:

cancelRegisterNode in interface OCoordinatedDistributedOps

cancelEnstablish

public void cancelEnstablish()

Specified by:

cancelEnstablish in interface OCoordinatedDistributedOps

validateDeclareDatabase

public Optional<OAcceptResult> validateDeclareDatabase(OTransactionIdPromise promise,
 ODatabaseId databaseId,
 String database,
 Set<ONodeId> partecipants,
 int minimumQuorum)

Specified by:

validateDeclareDatabase in interface OCoordinatedDistributedOps

declareDatabase

public void declareDatabase(OTransactionIdPromise promise,
 ODatabaseId dbId,
 String database,
 Set<ONodeId> partecipants,
 int minimumQuorum)

Specified by:

declareDatabase in interface OCoordinatedDistributedOps

cancelDeclareDatabase

public void cancelDeclareDatabase(OTransactionIdPromise promise,
 ODatabaseId dbId,
 String database)

Specified by:

cancelDeclareDatabase in interface OCoordinatedDistributedOps

getDatabaseTopology

public ODatabasesTopologyState getDatabaseTopology()

Specified by:

getDatabaseTopology in interface OCoordinatedDistributedOps

validateAddDatabaseMember

public Optional<OAcceptResult> validateAddDatabaseMember(ODatabaseId dbId,
 List<OAddNodeInfo> nodes,
 long version)

Specified by:

validateAddDatabaseMember in interface OCoordinatedDistributedOps

addDatabaseMember

public void addDatabaseMember(ODatabaseId dbId,
 List<OAddNodeInfo> nodes,
 long version)

Specified by:

addDatabaseMember in interface OCoordinatedDistributedOps

cancelAddDatabaseMember

public void cancelAddDatabaseMember(ODatabaseId dbId,
 List<OAddNodeInfo> nodes)

Specified by:

cancelAddDatabaseMember in interface OCoordinatedDistributedOps

validateSetState

public Optional<OAcceptResult> validateSetState(ODatabaseId dbId,
 ONodeId nodeId,
 ODatabaseState state,
 long version)

Specified by:

validateSetState in interface OCoordinatedDistributedOps

setState

public void setState(ODatabaseId db,
 ONodeId node,
 ODatabaseState state,
 long version)

Specified by:

setState in interface OCoordinatedDistributedOps

cancelSetState

public void cancelSetState(ODatabaseId dbId,
 ONodeId nodeId,
 long version)

Specified by:

cancelSetState in interface OCoordinatedDistributedOps

newSync

public Optional<OSyncInfo> newSync(ODatabaseId dbId)

Specified by:

newSync in interface OCoordinatedDistributedOps

acceptSync

public boolean acceptSync(ONodeId sender,
 ONodeId receiver,
 ODatabaseId dbId,
 OSyncId syncId)

Specified by:

acceptSync in interface OCoordinatedDistributedOps

canSync

public Optional<OSyncState> canSync(ONodeId sender,
 ONodeId receiver,
 ODatabaseId dbId,
 OSyncId syncId,
 boolean canSync,
 OSyncMode mode,
 Optional<OTransactionSequenceStatus> sequenceStatus)

Specified by:

canSync in interface OCoordinatedDistributedOps

startSend

public OSyncState startSend(ONodeId to,
 ONodeId from,
 ODatabaseId dbId,
 OSyncId syncId,
 OSyncMode mode,
 Optional<OTransactionSequenceStatus> sequenceStatus)

Specified by:

startSend in interface OCoordinatedDistributedOps

getSyncState

public OSyncState getSyncState(OSyncId syncId)

Specified by:

getSyncState in interface OCoordinatedDistributedOps

executeOnOneOnline

public boolean executeOnOneOnline(ODatabaseId dbId,
 OStateAction execute)

Specified by:

executeOnOneOnline in interface OCoordinatedDistributedOps

waitOnlineQuorum

public boolean waitOnlineQuorum(ODatabaseId dbId,
 Optional<Long> timeout)
                         throws InterruptedException

Specified by:

waitOnlineQuorum in interface OCoordinatedDistributedOps

Throws:

InterruptedException

isApplied

public boolean isApplied(OTransactionId txId)

Specified by:

isApplied in interface OCoordinatedDistributedOps

completeSync

public void completeSync(OSyncId syncId)

Specified by:

completeSync in interface OCoordinatedDistributedOps

getStore

public ONodeStateStore getStore()