github-mirrors/prometheus
1
0
Fork 0
mirror of https://github.com/prometheus/prometheus synced 2026-04-20 22:41:05 +08:00
Code Issues Actions 7 Packages Projects Releases Wiki Activity

bench

Browse Source 
Signed-off-by: bwplotka <bwplotka@gmail.com>
This commit is contained in:
bwplotka
2026-03-06 13:49:23 +00:00
parent 6578562e84
commit b52ca810d0
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
tsdb/wlog/watcher_test.go
View File

@@ -539,7 +539,7 @@ func BenchmarkWatcher_ReadSegment(b *testing.B) {
b.Run("case=one-go", func(b *testing.B) {
// Start watcher to that reads into a bench mock that only records sampleAppends.
wt := newBenchWriteToMock(0)
watcher := NewWatcher(wMetrics, nil, nil, "test", wt, b.TempDir(), true, true, true, nil)
watcher := NewWatcher(wMetrics, nil, nil, "test", wt, b.TempDir(), true, true, true, record.NewBuffersPool())
watcher.SetMetrics()
// Update the time because by default, watchers starts with start time=="now" time and watcher
// only starts reading data after that time.
@@ -552,7 +552,7 @@ func BenchmarkWatcher_ReadSegment(b *testing.B) {
_ = segment.Close()
})
// Warm any caches.
// Warm any caches and pools.
decBuf := compression.NewSyncDecodeBuffer()
segReader := NewLiveReader(watcher.logger, watcher.readerMetrics, segment)
segReader.decBuf = decBuf
@@ -580,7 +580,7 @@ func BenchmarkWatcher_ReadSegment(b *testing.B) {
b.Run("case=per-scrape", func(b *testing.B) {
// Start watcher to that reads into a bench mock that only records sampleAppends.
wt := newBenchWriteToMock(0)
watcher := NewWatcher(wMetrics, nil, nil, "test", wt, b.TempDir(), true, true, true, nil)
watcher := NewWatcher(wMetrics, nil, nil, "test", wt, b.TempDir(), true, true, true, record.NewBuffersPool())
watcher.SetMetrics()
// Update the time because by default, watchers starts with start time=="now" time and watcher
// only starts reading data after that time.
@@ -618,6 +618,9 @@ func BenchmarkWatcher_ReadSegment(b *testing.B) {
}
limitReader := &io.LimitedReader{R: segment}
// Warm any caches and pools.
require.NoError(b, watcher.readAndHandleError(segReader, 0, true, int64(math.MaxInt64)))
b.ReportAllocs()
b.ResetTimer()
for b.Loop() {