fix: put mutex lock because of race condition

ethersphere · Dec 1, 2023 · e78c374 · e78c374
1 parent 155e846
commit e78c374
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/file/redundancy/getter/getter.go b/pkg/file/redundancy/getter/getter.go
@@ -197,11 +197,13 @@ func (g *getter) executeStrategies(ctx context.Context, addr swarm.Address) (swa
 
 // initWaitChannels initializes the wait channels in the cache mapping which indicates the start of the recovery process as well
 func (g *getter) initWaitChannels() {
+	g.mu.Lock()
 	for _, addr := range g.sAddresses {
 		iCh := g.cache[addr.String()]
 		iCh.wait = make(chan struct{})
 		g.cache[addr.String()] = iCh
 	}
+	g.mu.Unlock()
 }
 
 // closeChannls closes all pending channels