Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

feat: Working on the tests to find lock contention

db/which-way-lock
devanbenz 2025-03-26 13:23:06 -05:00
parent 7c028d94ed
commit 2a56a870bf
1 changed files with 18 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
tsdb/index/tsi1/log_file_test.go
View File

@ -174,7 +174,7 @@ func TestLogFile_SeriesStoredInOrder(t *testing.T) {
// Data race test to check for contention between AddSeriesList, LogFile.TagValueIterator, and logTagKey.TagValueIterator
func TestLogFile_AddSeries_TagValueIterator_Contention(t *testing.T) {
const TAG_COUNT = 10000
const ROUNDS = 1000
const ROUNDS = 100
sfile := MustOpenSeriesFile(t)
defer func(sfile *SeriesFile) {
@ -204,17 +204,23 @@ func TestLogFile_AddSeries_TagValueIterator_Contention(t *testing.T) {
var wg sync.WaitGroup
for round := 0; round < ROUNDS; round++ {
wg.Add(1)
go func() {
f.TagValueIterator([]byte("cpu"), []byte("region"))
wg.Done()
}()
wg.Add(1)
go func() {
f.AddSeriesList(seriesSet, slices.StringsToBytes("cpu", "mem"), newTags)
wg.Done()
}()
wg.Wait()
time.Sleep(time.Duration(rand.Intn(100)) * time.Millisecond)
for round := 0; round < ROUNDS; round++ {
wg.Add(1)
go func() {
f.TagValueIterator([]byte("cpu"), []byte("region"))
wg.Done()
}()
}
for round := 0; round < ROUNDS; round++ {
time.Sleep(time.Duration(rand.Intn(100)) * time.Millisecond)
wg.Add(1)
go func() {
f.AddSeriesList(seriesSet, slices.StringsToBytes("cpu", "mem"), newTags)
wg.Done()
}()
wg.Wait()
}
}
}