// 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)
}
if d := h.Cluster.Collections.BlobTrashCheckInterval.Duration(); d > 0 &&
h.Cluster.Collections.BlobTrash &&
h.Cluster.Collections.BlobDeleteConcurrency > 0 {
- go emptyTrash(h.volmgr.writables, d)
+ go emptyTrash(h.volmgr.mounts, d)
}
return nil