corrected Queue.Enqueue non determinism

ipfs · May 24, 2023 · 08e0680 · 08e0680
1 parent 04cf63e
commit 08e0680
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/provider/internal/queue/queue.go b/provider/internal/queue/queue.go
@@ -56,6 +56,12 @@ func (q *Queue) Close() error {
 
 // Enqueue puts a cid in the queue
 func (q *Queue) Enqueue(cid cid.Cid) error {
+	select {
+	case <-q.ctx.Done():
+		return fmt.Errorf("failed to enqueue CID: shutting down")
+	default:
+	}
+
 	select {
 	case q.enqueue <- cid:
 		return nil