pl.edu.agh.age.services.worker.internal

Class ComputeTopologyProvider

java.lang.Object

pl.edu.agh.age.services.worker.internal.ComputeTopologyProvider

All Implemented Interfaces:

TopologyProvider<java.io.Serializable>, CommunicationFacility

@Named
 @ThreadSafe
public final class ComputeTopologyProvider
extends java.lang.Object
implements TopologyProvider<java.io.Serializable>, CommunicationFacility

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	ComputeTopologyProvider.IdsListener

Field Summary

Fields

Modifier and Type	Field and Description
private @Nullable org.jgrapht.Graph<java.io.Serializable,AnnotatedEdge>	cachedTopology
private java.util.Map<HazelcastObjectNames.ConfigurationKey,java.lang.Object>	configurationMap
private ISet<java.io.Serializable>	idsSet Global set of IDs.
private java.util.concurrent.locks.ReentrantReadWriteLock	lock
private static org.slf4j.Logger	logger
private boolean	needUpgrade
private Topology<java.io.Serializable>	topology
private WorkerCommunication	workerCommunication

Constructor Summary

Constructors

Constructor and Description
ComputeTopologyProvider(HazelcastInstance hazelcastInstance, WorkerCommunication workerCommunication)

Method Summary

Modifier and Type	Method and Description
void	addNodes(java.util.Set<java.io.Serializable> ids) Add nodes to the current topology.
boolean	areNeighbours(java.io.Serializable first, java.io.Serializable second) Check if the second is a neighbour of first in this exact direction
private void	markForUpgrade()
java.util.Map<java.io.Serializable,java.util.Set<java.lang.String>>	neighboursOf(java.io.Serializable id) Returns neighbours (according to the current topology).
java.util.Map<java.lang.String,java.io.Serializable>	neighboursOfByAnnotation(java.io.Serializable id) Returns neighbours (according to the current topology).
<T extends java.io.Serializable> boolean	onMessage(WorkerMessage<T> workerMessage) Handles a message.
void	reset()
void	setTopology(Topology<java.io.Serializable> topology) Set the new topology function.
void	start()
java.util.Set<WorkerMessage.Type>	subscribedTypes() Returns a set of message types that this listener wants to subscribe to.

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static final org.slf4j.Logger logger

workerCommunication

private final WorkerCommunication workerCommunication

configurationMap

private final java.util.Map<HazelcastObjectNames.ConfigurationKey,java.lang.Object> configurationMap

idsSet

private final ISet<java.io.Serializable> idsSet

Global set of IDs.

lock

private final java.util.concurrent.locks.ReentrantReadWriteLock lock

topology

private Topology<java.io.Serializable> topology

cachedTopology

private @Nullable org.jgrapht.Graph<java.io.Serializable,AnnotatedEdge> cachedTopology

needUpgrade

private boolean needUpgrade

Constructor Detail

ComputeTopologyProvider

@Inject
public ComputeTopologyProvider(HazelcastInstance hazelcastInstance,
                                       WorkerCommunication workerCommunication)

Method Detail

onMessage

public <T extends java.io.Serializable> boolean onMessage(WorkerMessage<T> workerMessage)

Description copied from interface: CommunicationFacility

Handles a message.

Only messages directed to this node will be passed with this method, so implementers do not need to check whether they are recipients.

Specified by:

onMessage in interface CommunicationFacility

Type Parameters:

T - a type of the payload.

Parameters:

workerMessage - a received message (for the current node).

Returns:

true if the message should be not processed anymore, false otherwise.

subscribedTypes

public java.util.Set<WorkerMessage.Type> subscribedTypes()

Description copied from interface: CommunicationFacility

Returns a set of message types that this listener wants to subscribe to.

Specified by:

subscribedTypes in interface CommunicationFacility

start

public void start()

Specified by:

start in interface CommunicationFacility

reset

public void reset()

Specified by:

reset in interface CommunicationFacility

setTopology

public void setTopology(Topology<java.io.Serializable> topology)

Description copied from interface: TopologyProvider

Set the new topology function.

Specified by:

setTopology in interface TopologyProvider<java.io.Serializable>

Parameters:

topology - a function used to generate topologies

addNodes

public void addNodes(java.util.Set<java.io.Serializable> ids)

Description copied from interface: TopologyProvider

Add nodes to the current topology.

Specified by:

addNodes in interface TopologyProvider<java.io.Serializable>

Parameters:

ids - IDs of the nodes to add

neighboursOf

public java.util.Map<java.io.Serializable,java.util.Set<java.lang.String>> neighboursOf(java.io.Serializable id)

Description copied from interface: TopologyProvider

Returns neighbours (according to the current topology).

Specified by:

neighboursOf in interface TopologyProvider<java.io.Serializable>

Parameters:

id - id of the workplace to look up neighbours

Returns:

a map where keys are neighbours IDs (passed using #addNodes) and values are sets of annotations assigned by the topology function to this neighbour

neighboursOfByAnnotation

public java.util.Map<java.lang.String,java.io.Serializable> neighboursOfByAnnotation(java.io.Serializable id)

Description copied from interface: TopologyProvider

Returns neighbours (according to the current topology).

Warning: values may be duplicated if single neighbour has multiple annotations on its edges.

Specified by:

neighboursOfByAnnotation in interface TopologyProvider<java.io.Serializable>

Parameters:

id - id of the workplace to look up neighbours

Returns:

a map where keys are annotations assigned by the topology function and values are IDs passed using #addNodes

areNeighbours

public boolean areNeighbours(java.io.Serializable first,
                             java.io.Serializable second)

Description copied from interface: TopologyProvider

Check if the second is a neighbour of first in this exact direction

Specified by:

areNeighbours in interface TopologyProvider<java.io.Serializable>

Parameters:

first - first id

second - second it

Returns:

true if and only if second is neighbour of first

markForUpgrade

private void markForUpgrade()