Class PhiAccrual
java.lang.Object
pt.unl.fct.di.novasys.channel.accrual.PhiAccrual
Based on the akka implementation of the Phi Accrual Failure Detector:
https://github.com/akka/akka/blob/main/akka-remote/src/main/scala/akka/remote/PhiAccrualFailureDetector.scala
-
Constructor Summary
ConstructorsConstructorDescriptionPhiAccrual
(int windowSize, double threshold, int minStdDeviationMs, int acceptableHbPauseMs, int firstHbEstimateMs) -
Method Summary
Modifier and TypeMethodDescriptionboolean
isAvailable
(long timestamp) phi
(long timestamp) void
receivedHb
(long hbCounter)
-
Constructor Details
-
PhiAccrual
public PhiAccrual(int windowSize, double threshold, int minStdDeviationMs, int acceptableHbPauseMs, int firstHbEstimateMs)
-
-
Method Details
-
receivedHb
public void receivedHb(long hbCounter) -
isAvailable
public boolean isAvailable(long timestamp) -
phi
-