From 7b9b2569a9546456a39184713378e9663769b7be Mon Sep 17 00:00:00 2001 From: Stefan Iliev <46542846+StefanIliev545@users.noreply.github.com> Date: Tue, 9 Mar 2021 18:00:04 +0000 Subject: [PATCH] NAAS-107 StartupQueueTime metric fix (#6886) * Fixed StartupQueueTime metric producing negative numbers. --- .../corda/node/services/statemachine/FlowStateMachineImpl.kt | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/node/src/main/kotlin/net/corda/node/services/statemachine/FlowStateMachineImpl.kt b/node/src/main/kotlin/net/corda/node/services/statemachine/FlowStateMachineImpl.kt index ebe89b5d4c..db697148cd 100644 --- a/node/src/main/kotlin/net/corda/node/services/statemachine/FlowStateMachineImpl.kt +++ b/node/src/main/kotlin/net/corda/node/services/statemachine/FlowStateMachineImpl.kt @@ -62,7 +62,6 @@ import org.apache.activemq.artemis.utils.ReusableLatch import org.slf4j.Logger import org.slf4j.LoggerFactory import org.slf4j.MDC -import java.time.Duration import java.util.concurrent.TimeUnit class FlowPermissionException(message: String) : FlowException(message) @@ -336,7 +335,7 @@ class FlowStateMachineImpl(override val id: StateMachineRunId, val startTime = System.nanoTime() serviceHub.monitoringService.metrics .timer("Flows.StartupQueueTime") - .update(Duration.ofNanos(startTime).toMillis() - creationTime, TimeUnit.MILLISECONDS) + .update(System.currentTimeMillis() - creationTime, TimeUnit.MILLISECONDS) var initialised = false val resultOrError = try {