From 38342b1df521cc32c1cb299777ffef950a502e4c Mon Sep 17 00:00:00 2001 From: Anis Eleuch Date: Wed, 7 Jun 2023 22:27:51 +0100 Subject: [PATCH] decom: Parallelize decommissining (#17364) --- cmd/erasure-server-pool-decom.go | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/cmd/erasure-server-pool-decom.go b/cmd/erasure-server-pool-decom.go index bcbf8876f..3048eff39 100644 --- a/cmd/erasure-server-pool-decom.go +++ b/cmd/erasure-server-pool-decom.go @@ -1097,11 +1097,9 @@ func (z *erasureServerPools) Decommission(ctx context.Context, indices ...int) e return err } - go func() { - for _, idx := range indices { - z.doDecommissionInRoutine(ctx, idx) - } - }() + for _, idx := range indices { + go z.doDecommissionInRoutine(ctx, idx) + } // Successfully started decommissioning. return nil