21126: Disable trash if BlobTrashConcurrency: 0, as documented.
authorTom Clegg <tom@curii.com>
Thu, 26 Oct 2023 20:09:21 +0000 (16:09 -0400)
committerTom Clegg <tom@curii.com>
Thu, 26 Oct 2023 20:09:21 +0000 (16:09 -0400)
Arvados-DCO-1.1-Signed-off-by: Tom Clegg <tom@curii.com>

services/keepstore/command.go

index 9d220022ab3cf5e05508cc36d2268ca94b08fae9..9761680fb5137e8601e1a389a918fadecf7a9bc3 100644 (file)
@@ -186,7 +186,7 @@ func (h *handler) setup(ctx context.Context, cluster *arvados.Cluster, token str
 
        // Initialize the trashq and workers
        h.trashq = NewWorkQueue()
-       for i := 0; i < 1 || i < h.Cluster.Collections.BlobTrashConcurrency; i++ {
+       for i := 0; i < h.Cluster.Collections.BlobTrashConcurrency; i++ {
                go RunTrashWorker(h.volmgr, h.Logger, h.Cluster, h.trashq)
        }