fix: race issue

Author: nugaon

pkg/replicas/getter_soc.go

@@ -22,7 +22,7 @@ import (
 // to a multiplexed variant that fetches chunks with replicas for SOC.
 //
 // the strategy to retrieve a chunk that has replicas can be configured with a few parameters:
-//   - RetryInterval: the delay before a new batch of replicas is fetched.
+//   - SOCRetryInterval: the delay before a new batch of replicas is fetched.
 //   - depth: 2^{depth} is the total number of additional replicas that have been uploaded
 //     (by default, it is assumed to be 4, ie. total of 16)
 //   - (not implemented) pivot: replicas with address in the proximity of pivot will be tried first
@@ -32,6 +32,8 @@ type socGetter struct {
 	level redundancy.Level
 }
 
+var SOCRetryInterval = 300 * time.Millisecond
+
 // NewSocGetter is the getter constructor
 func NewSocGetter(g storage.Getter, level redundancy.Level) storage.Getter {
 	return &socGetter{Getter: g, level: level}
@@ -76,7 +78,7 @@ func (g *socGetter) Get(ctx context.Context, addr swarm.Address) (ch swarm.Chunk
 	var wait <-chan time.Time // nil channel to disable case
 	// addresses used are doubling each period of search expansion
 	// (at intervals of RetryInterval)
-	ticker := time.NewTicker(RetryInterval)
+	ticker := time.NewTicker(SOCRetryInterval)
 	defer ticker.Stop()
 	for level := uint8(0); level <= uint8(g.level); {
 		select {

pkg/replicas/getter_soc_test.go

@@ -1,7 +1,10 @@
-// Copyright 2023 The Swarm Authors. All rights reserved.
+// Copyright 2025 The Swarm Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style
 // license that can be found in the LICENSE file.
 
+// This file is a copy of the original getter_test.go file
+// and tailored to socGetter implementation.
+
 package replicas_test
 
 import (
@@ -103,9 +106,9 @@ func TestSOCGetter(t *testing.T) {
 	}
 
 	// reset retry interval to speed up tests
-	retryInterval := replicas.RetryInterval
-	defer func() { replicas.RetryInterval = retryInterval }()
-	replicas.RetryInterval = 100 * time.Millisecond
+	retryInterval := replicas.SOCRetryInterval
+	defer func() { replicas.SOCRetryInterval = retryInterval }()
+	replicas.SOCRetryInterval = 100 * time.Millisecond
 
 	// run the tests
 	for _, tc := range tests {
@@ -117,7 +120,7 @@ func TestSOCGetter(t *testing.T) {
 			store.now = time.Now()
 			ctx, cancel := context.WithCancel(context.Background())
 			if tc.found > tc.count {
-				wait := replicas.RetryInterval / 2 * time.Duration(1+2*tc.level)
+				wait := replicas.SOCRetryInterval / 2 * time.Duration(1+2*tc.level)
 				go func() {
 					time.Sleep(wait)
 					cancel()

pkg/replicas/putter_soc_test.go

@@ -2,6 +2,9 @@
 // Use of this source code is governed by a BSD-style
 // license that can be found in the LICENSE file.
 
+// This file was created as a copy of the original putter_test.go file
+// and tailored to the socPutter implementation.
+
 package replicas_test
 
 import (