A few more

clients/pkg/promtail/targets/file/filetarget_test.go

@@ -92,12 +92,14 @@ func TestFileTargetSync(t *testing.T) {
 	err = target.sync()
 	assert.NoError(t, err)
 
+	target.mu.Lock()
 	if len(target.watches) != 0 {
 		t.Fatal("Expected watches to be 0 at this point in the test...")
 	}
 	if len(target.readers) != 0 {
 		t.Fatal("Expected tails to be 0 at this point in the test...")
 	}
+	target.mu.Unlock()
 
 	// Add a file, which should create a watcher and a tailer.
 	_, err = os.Create(logDir1File1)

clients/pkg/promtail/wal/watcher_test.go

@@ -301,6 +301,8 @@ var cases = map[string]watcherTest{
 		// collecting segment 0
 		res.notifySegmentReclaimed(0)
 		require.Eventually(t, func() bool {
+			res.writeTo.mu.Lock()
+			defer res.writeTo.mu.Unlock()
 			return len(res.writeTo.ReceivedSeriesReset) == 1 && res.writeTo.ReceivedSeriesReset[0] == 0
 		}, time.Second*10, time.Second, "timed out waiting to receive series reset")
 
@@ -316,6 +318,8 @@ var cases = map[string]watcherTest{
 		res.notifySegmentReclaimed(2)
 		// Expect second SeriesReset call to have the highest numbered deleted segment, 2
 		require.Eventually(t, func() bool {
+			res.writeTo.mu.Lock()
+			defer res.writeTo.mu.Unlock()
 			t.Logf("received series reset: %v", res.writeTo.ReceivedSeriesReset)
 			return len(res.writeTo.ReceivedSeriesReset) == 2 && res.writeTo.ReceivedSeriesReset[1] == 2
 		}, time.Second*10, time.Second, "timed out waiting to receive series reset")