test(file): fix timeouts

ethersphere · Feb 4, 2024 · 969a134 · 969a134
1 parent ec66cc4
commit 969a134
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 3 deletions.
diff --git a/pkg/file/joiner/joiner_test.go b/pkg/file/joiner/joiner_test.go
@@ -1243,11 +1243,12 @@ func TestJoinerRedundancyMultilevel(t *testing.T) {
 		canReadRange := func(t *testing.T, s getter.Strategy, fallback bool, levels int, canRead bool) {
 			ctx := context.Background()
 			strategyTimeout := 100 * time.Millisecond
+			decodingTimeout := 600 * time.Millisecond
 			if racedetection.IsOn() {
-				strategyTimeout *= 2
+				decodingTimeout *= 2
 			}
 			ctx = getter.SetConfigInContext(ctx, s, fallback, (2 * strategyTimeout).String(), strategyTimeout.String())
-			ctx, cancel := context.WithTimeout(ctx, time.Duration(levels*3+2)*strategyTimeout)
+			ctx, cancel := context.WithTimeout(ctx, time.Duration(levels)*(3*strategyTimeout+decodingTimeout))
 			defer cancel()
 			j, _, err := joiner.New(ctx, store, store, addr)
 			if err != nil {

diff --git a/pkg/file/redundancy/getter/getter_test.go b/pkg/file/redundancy/getter/getter_test.go
@@ -95,6 +95,9 @@ func TestGetterFallback(t *testing.T) {
 func testDecodingRACE(t *testing.T, bufSize, shardCnt, erasureCnt int) {
 	t.Helper()
 	strategyTimeout := 100 * time.Millisecond
+	if racedetection.On {
+		strategyTimeout *= 2
+	}
 	store := inmem.New()
 	buf := make([][]byte, bufSize)
 	addrs := initData(t, buf, shardCnt, store)
@@ -128,7 +131,7 @@ func testDecodingRACE(t *testing.T, bufSize, shardCnt, erasureCnt int) {
 	err := context.DeadlineExceeded
 	wait := strategyTimeout * 2
 	if racedetection.On {
-		wait = strategyTimeout * 3
+		wait *= 2
 	}
 	select {
 	case err = <-q: