org.corfudb.infrastructure.management

Class FailureDetector

java.lang.Object

org.corfudb.infrastructure.management.FailureDetector

All Implemented Interfaces:

IDetector

public class FailureDetector
extends Object
implements IDetector

FailureDetector polls all the "responsive members" in the layout. Responsive members: All endpoints that are responding to heartbeats. This list can be derived by excluding unresponsiveServers from all endpoints. For every poll method call invoked, it starts a polling round and generates a poll report. Each polling round comprises of "failureThreshold" number of iterations. - We asynchronously poll every known responsive member in the layout. - Poll result aggregation. - If we complete an iteration without detecting failures, we end the round successfully. The management Server ensures only one instance of this class and hence this is NOT thread safe. Created by zlokhandwala on 11/29/17.

Constructor Summary

Constructors

Constructor and Description
FailureDetector(ClusterStateContext.HeartbeatCounter heartbeatCounter, String localEndpoint)

Method Summary

Modifier and Type	Method and Description
PollReport	poll(Layout layout, CorfuRuntime corfuRuntime, SequencerMetrics sequencerMetrics) Executes the policy once.

Methods inherited from class java.lang.Object

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

Constructor Detail

FailureDetector

public FailureDetector(ClusterStateContext.HeartbeatCounter heartbeatCounter,
                       String localEndpoint)

Method Detail

poll

public PollReport poll(@Nonnull
                       Layout layout,
                       @Nonnull
                       CorfuRuntime corfuRuntime,
                       @NonNull
                       SequencerMetrics sequencerMetrics)

Executes the policy once. Checks for changes in the layout. Then polls all the servers generates pollReport.

Specified by:

poll in interface IDetector

Parameters:

layout - Current Layout

Returns:

A poll report containing the results of the poll.