diff --git a/pkg/file/redundancy/getter/getter.go b/pkg/file/redundancy/getter/getter.go index 361860164f4..982c5080109 100644 --- a/pkg/file/redundancy/getter/getter.go +++ b/pkg/file/redundancy/getter/getter.go @@ -242,7 +242,7 @@ func (g *getter) cautiousStrategy(ctx context.Context) error { return } g.setErasureData(c.pos, ch.Data()) - if c.pos < len(g.sAddresses) { + if c.pos < len(g.sAddresses) && !channelIsClosed(c.wait) { close(c.wait) } retrievedCh <- struct{}{}