fix

antlabs · May 15, 2024 · c9e0203 · c9e0203
1 parent da630ca
commit c9e0203
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 := time.Since(m.minHeaps[0].absExpire)
+	timeout := m.minHeaps[0].absExpire.Sub(time.Now())
 	if timeout < 0 {
 		timeout = 0
 	}