@@ -67,7 +67,7 @@ public LocalGridModel(EventBus events) {
67
67
68
68
public static GridModel create (Config config ) {
69
69
EventBus bus = new EventBusOptions (config ).getEventBus ();
70
-
70
+
71
71
return new LocalGridModel (bus );
72
72
}
73
73
@@ -168,13 +168,13 @@ public void purgeDeadNodes() {
168
168
writeLock .lock ();
169
169
try {
170
170
Set <NodeStatus > lost = nodes (UP ).stream ()
171
- .filter (status -> now - status .touched () > status .heartbeatPeriod ().toMillis () * 2 )
171
+ .filter (status -> now - status .touched () > status .getHeartbeatPeriod ().toMillis () * 2 )
172
172
.collect (toSet ());
173
173
Set <NodeStatus > resurrected = nodes (DOWN ).stream ()
174
- .filter (status -> now - status .touched () <= status .heartbeatPeriod ().toMillis ())
174
+ .filter (status -> now - status .touched () <= status .getHeartbeatPeriod ().toMillis ())
175
175
.collect (toSet ());
176
176
Set <NodeStatus > dead = nodes (DOWN ).stream ()
177
- .filter (status -> now - status .touched () > status .heartbeatPeriod ().toMillis () * 4 )
177
+ .filter (status -> now - status .touched () > status .getHeartbeatPeriod ().toMillis () * 4 )
178
178
.collect (toSet ());
179
179
if (lost .size () > 0 ) {
180
180
LOG .info (String .format (
@@ -319,7 +319,7 @@ public NodeStatus rewrite(NodeStatus status, Availability availability) {
319
319
status .getMaxSessionCount (),
320
320
status .getSlots (),
321
321
availability ,
322
- status .heartbeatPeriod (),
322
+ status .getHeartbeatPeriod (),
323
323
status .getVersion (),
324
324
status .getOsInfo ());
325
325
}
@@ -435,7 +435,7 @@ public void amend(Availability availability, NodeStatus status, Slot slot) {
435
435
status .getMaxSessionCount (),
436
436
newSlots ,
437
437
status .getAvailability (),
438
- status .heartbeatPeriod (),
438
+ status .getHeartbeatPeriod (),
439
439
status .getVersion (),
440
440
status .getOsInfo ()));
441
441
}
0 commit comments