diff --git a/lib/storage/storage.go b/lib/storage/storage.go index 4c009e3ef7..ee5a37066d 100644 --- a/lib/storage/storage.go +++ b/lib/storage/storage.go @@ -1112,8 +1112,10 @@ func (s *Storage) AddRows(mrs []MetricRow, precisionBits uint8) error { putRawRows(rr) // Notify blocked goroutines at Storage.searchTSIDs that they may proceed with their work. + searchTSIDsCondLock.Lock() <-addRowsConcurrencyCh searchTSIDsCond.Signal() + searchTSIDsCondLock.Unlock() return err }