From a93b951df468d0daa9485d87dbfecfdd8e2671e0 Mon Sep 17 00:00:00 2001 From: Calin Martinconi Date: Fri, 19 Jun 2026 09:48:45 +0300 Subject: [PATCH] fix(redundancy): increment fetchedCnt before closing wait channel --- pkg/file/redundancy/getter/getter.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/file/redundancy/getter/getter.go b/pkg/file/redundancy/getter/getter.go index f027cdf6a65..358618041cc 100644 --- a/pkg/file/redundancy/getter/getter.go +++ b/pkg/file/redundancy/getter/getter.go @@ -151,8 +151,8 @@ func (g *decoder) fetch(ctx context.Context, i int, waitForRecovery bool) (err e } g.setData(i, ch.Data()) - close(g.waits[i]) g.fetchedCnt.Add(1) + close(g.waits[i]) return nil }