|
@@ -1083,7 +1083,7 @@ class BPServiceActor implements Runnable {
|
|
|
volatile long nextHeartbeatTime = monotonicNow();
|
|
|
|
|
|
@VisibleForTesting
|
|
|
- volatile long nextLifelineTime = monotonicNow();
|
|
|
+ volatile long nextLifelineTime;
|
|
|
|
|
|
@VisibleForTesting
|
|
|
volatile long lastBlockReportTime = monotonicNow();
|
|
@@ -1111,6 +1111,7 @@ class BPServiceActor implements Runnable {
|
|
|
this.lifelineIntervalMs = lifelineIntervalMs;
|
|
|
this.blockReportIntervalMs = blockReportIntervalMs;
|
|
|
this.slowPeersReportIntervalMs = slowPeersReportIntervalMs;
|
|
|
+ scheduleNextLifeline(nextHeartbeatTime);
|
|
|
}
|
|
|
|
|
|
// This is useful to make sure NN gets Heartbeat before Blockreport
|