fix race condition in tests

sei-protocol · Apr 24, 2023 · 78ec60b · 78ec60b
1 parent 023605a
commit 78ec60b
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/internal/dbsync/syncer_test.go b/internal/dbsync/syncer_test.go
@@ -81,7 +81,10 @@ func TestFileProcessHappyPath(t *testing.T) {
 		Md5Checksum: [][]byte{sum[:]},
 	})
 	for {
-		if _, ok := syncer.pendingFiles["f1"]; ok {
+		syncer.mtx.RLock()
+		_, ok := syncer.pendingFiles["f1"]
+		syncer.mtx.RUnlock()
+		if ok {
 			break
 		}
 	}
@@ -105,7 +108,10 @@ func TestFileProcessTimeoutReprocess(t *testing.T) {
 		Md5Checksum: [][]byte{sum[:]},
 	})
 	for {
-		if _, ok := syncer.pendingFiles["f1"]; ok {
+		syncer.mtx.RLock()
+		_, ok := syncer.pendingFiles["f1"]
+		syncer.mtx.RUnlock()
+		if ok {
 			break
 		}
 	}