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

Class OTopologyManager

java.lang.Object

com.orientechnologies.orient.distributed.context.coordination.dbs.OWatcher

com.orientechnologies.orient.distributed.context.coordination.topology.OTopologyManager

All Implemented Interfaces:

ONetworkTopology, OTopologyEvents

public class OTopologyManager
extends OWatcher
implements OTopologyEvents, ONetworkTopology

Nested Class Summary

Nested classes/interfaces inherited from class com.orientechnologies.orient.distributed.context.coordination.dbs.OWatcher

OWatcher.ONotificationActionData, OWatcher.WaitCond

Constructor Summary

Constructors

Constructor	Description
OTopologyManager(ONodeId current, OGroupId groupId, int minimumQuorum)

Method Summary

Modifier and Type	Method	Description
void	applyMerge(OTopologyStateNetwork topology, OTransactionIdPromise promise)
Set<ONodeId>	awayNodes(long time)
void	cancelEstablish(OTransactionIdPromise promise)
void	cancelMerge(OTransactionIdPromise promise)
void	cancelRegisterPromise(OTransactionIdPromise promise)
void	cancelSetQuorum(int quorumToSet, OVersion version, OTransactionIdPromise promise)
void	cancelUnregisterPromise(OTransactionIdPromise promise)
boolean	enoughNodes()
void	executeOnEnstablish(ONotificationAction action)
Set<ONodeId>	finalizeEstablish(OGroupId groupId, Set<ONodeId> candidates, OTransactionIdPromise promise)
OGroupId	getGroupId()
Set<ONodeId>	getMembers()
int	getMinimumQuorum()
OTopologyStateNetwork	getNetworkState()
ONodeId	getNodeId()
Optional<ONodeId>	getNodeId(String nodeName)
int	getQuorum()
OTopologyState	getState()
ONetworkTopologyStore	getStore()
OVersion	getVersion()
protected boolean	hasMember(ONodeId node)
boolean	isSelfEnstablished()
void	load(ONetworkTopologyStore nodeStateStore)
void	mergeNode(ONodeId node, OVersion version, OTransactionIdPromise promise)
OVersion	nextVersion()
ODiscoverAction	nodeDiscovered(ONodeId node)
ODiscoverAction	nodeJoinStart(ONodeId node, OTopologyStateNetwork externState, boolean merge)
void	ping(ONodeId node)
Optional<OAcceptResult>	promiseRegister(ONodeId toAdd, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	promiseUnregister(ONodeId node, OVersion version, OTransactionIdPromise promise)
void	register(ONodeId toRegister, OVersion version, OTransactionIdPromise promise)
void	setQuorum(int quorumToSet, OVersion version, OTransactionIdPromise promise)
void	unregister(ONodeId node, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	validateEstablish(OGroupId groupId, Set<ONodeId> candidates, OTransactionIdPromise promise)
Optional<OAcceptResult>	validateMergeNode(OGroupId group, ONodeStateNetwork original, OTransactionIdPromise promise)
Optional<OAcceptResult>	validateMergeToNetwork(OGroupId group, ONodeStateNetwork mergeState, OTransactionIdPromise promise)
Optional<OAcceptResult>	validateSetQuorum(int quorumToSet, OVersion version, OTransactionIdPromise promise)
boolean	waitForEnstablished(Optional<Long> timeout)
boolean	waitNodeJoined(ONodeId node, Optional<Long> timeout)

Methods inherited from class com.orientechnologies.orient.distributed.context.coordination.dbs.OWatcher

executeOn, notifyChange, waitFor

Methods inherited from class java.lang.Object

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

Constructor Details

OTopologyManager

public OTopologyManager(ONodeId current,
 OGroupId groupId,
 int minimumQuorum)

Method Details

nodeDiscovered

public ODiscoverAction nodeDiscovered(ONodeId node)

Specified by:

nodeDiscovered in interface OTopologyEvents

hasMember

protected boolean hasMember(ONodeId node)

getVersion

public OVersion getVersion()

Specified by:

getVersion in interface ONetworkTopology

promiseRegister

public Optional<OAcceptResult> promiseRegister(ONodeId toAdd,
 OVersion version,
 OTransactionIdPromise promise)

register

public void register(ONodeId toRegister,
 OVersion version,
 OTransactionIdPromise promise)

enoughNodes

public boolean enoughNodes()

unregister

public void unregister(ONodeId node,
 OVersion version,
 OTransactionIdPromise promise)

getQuorum

public int getQuorum()

Specified by:

getQuorum in interface ONetworkTopology

getMinimumQuorum

public int getMinimumQuorum()

getMembers

public Set<ONodeId> getMembers()

Specified by:

getMembers in interface ONetworkTopology

finalizeEstablish

public Set<ONodeId> finalizeEstablish(OGroupId groupId,
 Set<ONodeId> candidates,
 OTransactionIdPromise promise)

validateEstablish

public Optional<OAcceptResult> validateEstablish(OGroupId groupId,
 Set<ONodeId> candidates,
 OTransactionIdPromise promise)

nodeJoinStart

public ODiscoverAction nodeJoinStart(ONodeId node,
 OTopologyStateNetwork externState,
 boolean merge)

getNetworkState

public OTopologyStateNetwork getNetworkState()

load

public void load(ONetworkTopologyStore nodeStateStore)

getStore

public ONetworkTopologyStore getStore()

cancelRegisterPromise

public void cancelRegisterPromise(OTransactionIdPromise promise)

cancelUnregisterPromise

public void cancelUnregisterPromise(OTransactionIdPromise promise)

cancelEstablish

public void cancelEstablish(OTransactionIdPromise promise)

getGroupId

public OGroupId getGroupId()

getNodeId

public ONodeId getNodeId()

nextVersion

public OVersion nextVersion()

validateMergeNode

public Optional<OAcceptResult> validateMergeNode(OGroupId group,
 ONodeStateNetwork original,
 OTransactionIdPromise promise)

validateMergeToNetwork

public Optional<OAcceptResult> validateMergeToNetwork(OGroupId group,
 ONodeStateNetwork mergeState,
 OTransactionIdPromise promise)

cancelMerge

public void cancelMerge(OTransactionIdPromise promise)

ping

public void ping(ONodeId node)

awayNodes

public Set<ONodeId> awayNodes(long time)

promiseUnregister

public Optional<OAcceptResult> promiseUnregister(ONodeId node,
 OVersion version,
 OTransactionIdPromise promise)

isSelfEnstablished

public boolean isSelfEnstablished()

Specified by:

isSelfEnstablished in interface ONetworkTopology

executeOnEnstablish

public void executeOnEnstablish(ONotificationAction action)

getState

public OTopologyState getState()

Specified by:

getState in interface ONetworkTopology

applyMerge

public void applyMerge(OTopologyStateNetwork topology,
 OTransactionIdPromise promise)

waitForEnstablished

public boolean waitForEnstablished(Optional<Long> timeout)
                            throws InterruptedException

Throws:

InterruptedException

waitNodeJoined

public boolean waitNodeJoined(ONodeId node,
 Optional<Long> timeout)
                       throws InterruptedException

Throws:

InterruptedException

mergeNode

public void mergeNode(ONodeId node,
 OVersion version,
 OTransactionIdPromise promise)

validateSetQuorum

public Optional<OAcceptResult> validateSetQuorum(int quorumToSet,
 OVersion version,
 OTransactionIdPromise promise)

setQuorum

public void setQuorum(int quorumToSet,
 OVersion version,
 OTransactionIdPromise promise)

cancelSetQuorum

public void cancelSetQuorum(int quorumToSet,
 OVersion version,
 OTransactionIdPromise promise)

getNodeId

public Optional<ONodeId> getNodeId(String nodeName)

Specified by:

getNodeId in interface ONetworkTopology