mudhorn/prometheus
1
0
Fork 0
mirror of https://github.com/prometheus/prometheus.git synced 2025-02-21 03:16:00 -08:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

tsdb/wlog tests: remove unnecessary sleep check

Browse source 
Sleep() is documented to return immediately on negative or zero input.

Signed-off-by: Bryan Boreham <bjboreham@gmail.com>
This commit is contained in:
Bryan Boreham 2024-02-22 09:14:52 +00:00
parent 0c71230784
commit 78f46bccca
1 changed files with 6 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
tsdb/wlog/watcher_test.go
View file

@ -59,46 +59,36 @@ type writeToMock struct {
seriesLock sync.Mutex seriesLock sync.Mutex
seriesSegmentIndexes map[chunks.HeadSeriesRef]int seriesSegmentIndexes map[chunks.HeadSeriesRef]int
// delay reads with a short sleep // If nonzero, delay reads with a short sleep.
delay time.Duration delay time.Duration
} }
func (wtm *writeToMock) Append(s []record.RefSample) bool { func (wtm *writeToMock) Append(s []record.RefSample) bool {
if wtm.delay > 0 {
time.Sleep(wtm.delay) time.Sleep(wtm.delay)
}
wtm.samplesAppended += len(s) wtm.samplesAppended += len(s)
return true return true
} }
func (wtm *writeToMock) AppendExemplars(e []record.RefExemplar) bool { func (wtm *writeToMock) AppendExemplars(e []record.RefExemplar) bool {
if wtm.delay > 0 {
time.Sleep(wtm.delay) time.Sleep(wtm.delay)
}
wtm.exemplarsAppended += len(e) wtm.exemplarsAppended += len(e)
return true return true
} }
func (wtm *writeToMock) AppendHistograms(h []record.RefHistogramSample) bool { func (wtm *writeToMock) AppendHistograms(h []record.RefHistogramSample) bool {
if wtm.delay > 0 {
time.Sleep(wtm.delay) time.Sleep(wtm.delay)
}
wtm.histogramsAppended += len(h) wtm.histogramsAppended += len(h)
return true return true
} }
func (wtm *writeToMock) AppendFloatHistograms(fh []record.RefFloatHistogramSample) bool { func (wtm *writeToMock) AppendFloatHistograms(fh []record.RefFloatHistogramSample) bool {
if wtm.delay > 0 {
time.Sleep(wtm.delay) time.Sleep(wtm.delay)
}
wtm.floatHistogramsAppended += len(fh) wtm.floatHistogramsAppended += len(fh)
return true return true
} }
func (wtm *writeToMock) StoreSeries(series []record.RefSeries, index int) { func (wtm *writeToMock) StoreSeries(series []record.RefSeries, index int) {
if wtm.delay > 0 {
time.Sleep(wtm.delay) time.Sleep(wtm.delay)
}
wtm.UpdateSeriesSegment(series, index) wtm.UpdateSeriesSegment(series, index)
} }