diff options
| -rw-r--r-- | orchestrator/src/main/java/com/yahoo/vespa/orchestrator/status/ZookeeperStatusService.java | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/orchestrator/src/main/java/com/yahoo/vespa/orchestrator/status/ZookeeperStatusService.java b/orchestrator/src/main/java/com/yahoo/vespa/orchestrator/status/ZookeeperStatusService.java index 0803e453da6..65bdaed86b8 100644 --- a/orchestrator/src/main/java/com/yahoo/vespa/orchestrator/status/ZookeeperStatusService.java +++ b/orchestrator/src/main/java/com/yahoo/vespa/orchestrator/status/ZookeeperStatusService.java @@ -137,14 +137,14 @@ public class ZookeeperStatusService implements StatusService { lockAcquired = true; } finally { acquireEndTime = timer.currentTime(); - double seconds = Duration.between(startTime, acquireEndTime).toMillis() / 1000.0; + double seconds = durationInSeconds(startTime, acquireEndTime); metric.set("orchestrator.lock.acquire-latency", seconds, metricContext); metric.set("orchestrator.lock.acquired", lockAcquired ? 1 : 0, metricContext); } Runnable updateLockHoldMetric = () -> { Instant lockReleasedTime = timer.currentTime(); - double seconds = Duration.between(acquireEndTime, lockReleasedTime).toMillis() / 1000.0; + double seconds = durationInSeconds(acquireEndTime, lockReleasedTime); metric.set("orchestrator.lock.hold-latency", seconds, metricContext); }; @@ -158,6 +158,10 @@ public class ZookeeperStatusService implements StatusService { } } + private double durationInSeconds(Instant startInstant, Instant endInstant) { + return Duration.between(startInstant, endInstant).toMillis() / 1000.0; + } + private void setHostStatus(ApplicationInstanceReference applicationInstanceReference, HostName hostName, HostStatus status) { |