org.corfudb.infrastructure.management

Class ClusterStateAggregator

java.lang.Object

org.corfudb.infrastructure.management.ClusterStateAggregator

public class ClusterStateAggregator
extends Object

Aggregates cluster state from a list of collected states.

Constructor Summary

Constructors

Constructor and Description
ClusterStateAggregator()

Method Summary

Modifier and Type	Method and Description
ClusterState	getAggregatedState() Aggregates state from a list of poll reports.

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterStateAggregator

public ClusterStateAggregator()

Method Detail

getAggregatedState

public ClusterState getAggregatedState()

Aggregates state from a list of poll reports. In order to prevent accidentally adding a node to the list of unresponsive nodes we collect PollReport more than one time (3 times by default) and then aggregate reports: - if at least one report contains NodeState with CONNECTED status we believe that the node is connected. - use latest possible (connected) NodeState, if there is no 'connected' state then any other latest state, (see NodeConnectivity.NodeConnectivityType), for instance: 1. reports = [CONNECTED, UNAVAILABLE, UNAVAILABLE], reports[0] will be used 2. reports = [CONNECTED, UNAVAILABLE, CONNECTED], reports[2] will be used 3. reports = [UNAVAILABLE, CONNECTED, UNAVAILABLE], reports[1] will be used 4. reports = [CONNECTED, CONNECTED, CONNECTED], reports[2] will be used 5. reports = [UNAVAILABLE, UNAVAILABLE, NOT_READY], reports[2] will be used

Returns:

aggregated cluster state