From 42095cc99e4c46034a13f01819a132dadf53ca08 Mon Sep 17 00:00:00 2001
From: Nate Maninger <me@n8m.us>
Date: Sat, 2 Mar 2024 21:28:02 -0800
Subject: [PATCH] downloader: add timestamp for stable heap order

---
 renterd/downloader/downloader.go | 19 ++++++++++++-------
 1 file changed, 12 insertions(+), 7 deletions(-)

diff --git a/renterd/downloader/downloader.go b/renterd/downloader/downloader.go
index 6c6260b..060f6e9 100644
--- a/renterd/downloader/downloader.go
+++ b/renterd/downloader/downloader.go
@@ -31,9 +31,10 @@ type (
 		b   []byte
 		err error
 
-		key      string
-		priority int
-		index    int
+		key       string
+		priority  int
+		index     int
+		timestamp time.Time
 	}
 
 	priorityQueue []*blockResponse
@@ -60,7 +61,10 @@ type (
 func (h priorityQueue) Len() int { return len(h) }
 
 func (h priorityQueue) Less(i, j int) bool {
-	return h[i].priority < h[j].priority
+	if h[i].priority != h[j].priority {
+		return h[i].priority < h[j].priority
+	}
+	return h[i].timestamp.Before(h[j].timestamp)
 }
 
 func (h priorityQueue) Swap(i, j int) {
@@ -156,9 +160,10 @@ func (bd *BlockDownloader) getResponse(c cid.Cid, priority int) *blockResponse {
 		return task
 	}
 	task := &blockResponse{
-		key:      key,
-		priority: priority,
-		ch:       make(chan struct{}),
+		key:       key,
+		priority:  priority,
+		timestamp: time.Now(),
+		ch:        make(chan struct{}),
 	}
 	bd.cache.Add(key, task)
 	heap.Push(bd.queue, task)