fix

antlabs · May 15, 2024 · c35e241 · c35e241
1 parent c9e0203
commit c35e241
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/min_heap.go b/min_heap.go
@@ -104,7 +104,7 @@ func (m *minHeap) getNewSleepTime() time.Duration {
 		return time.Hour
 	}
 
-	timeout := m.minHeaps[0].absExpire.Sub(time.Now())
+	timeout := time.Until(m.minHeaps[0].absExpire)
 	if timeout < 0 {
 		timeout = 0
 	}