Assert that taskQueueLatency >= 0

nicktindall · nicktindall · commit 876ae78d2e82 · 2025-05-01T16:04:58.000+10:00
diff --git a/server/src/main/java/org/elasticsearch/common/util/concurrent/TaskExecutionTimeTrackingEsThreadPoolExecutor.java b/server/src/main/java/org/elasticsearch/common/util/concurrent/TaskExecutionTimeTrackingEsThreadPoolExecutor.java
@@ -162,6 +162,7 @@ protected void beforeExecute(Thread t, Runnable r) {
         final TimedRunnable timedRunnable = (TimedRunnable) super.unwrap(r);
         timedRunnable.beforeExecute();
         final long taskQueueLatency = timedRunnable.getQueueTimeNanos();
+        assert taskQueueLatency >= 0;
         queueLatencyMillisHistogram.addObservation(TimeUnit.NANOSECONDS.toMillis(taskQueueLatency));
     }
 

Original file line number	Diff line number	Diff line change
`@@ -162,6 +162,7 @@ protected void beforeExecute(Thread t, Runnable r) {`
`162`	`162`	`final TimedRunnable timedRunnable = (TimedRunnable) super.unwrap(r);`
`163`	`163`	`timedRunnable.beforeExecute();`
`164`	`164`	`final long taskQueueLatency = timedRunnable.getQueueTimeNanos();`
	`165`	`+ assert taskQueueLatency >= 0;`
`165`	`166`	`queueLatencyMillisHistogram.addObservation(TimeUnit.NANOSECONDS.toMillis(taskQueueLatency));`
`166`	`167`	`}`
`167`	`168`