Kiu/VictoriaMetrics
Kiu/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2025-01-20 07:19:17 +01:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

lib/logstorage: fix streamID and tenantID search (#4856) (#5295)

Browse Source
This commit is contained in:
XLONG96 2023-11-14 06:09:39 +08:00 committed by GitHub
parent 8eed04b2c6
commit 89dcbc2fe7
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
lib/logstorage/storage_search.go
View File

@ -382,7 +382,7 @@ func (p *part) searchByTenantIDs(so *searchOptions, bhss *blockHeaders, workCh c
n = sort.Search(len(ibhs), func(i int) bool { n = sort.Search(len(ibhs), func(i int) bool {
return !ibhs[i].streamID.tenantID.less(tenantID) return !ibhs[i].streamID.tenantID.less(tenantID)
}) })
if n == len(ibhs) || n > 0 && ibhs[n].streamID.tenantID.equal(tenantID) { if n == len(ibhs) || n > 0 && !ibhs[n].streamID.tenantID.equal(tenantID) {
// The end of ibhs[n-1] may contain blocks for the given tenantID, so move it backwards // The end of ibhs[n-1] may contain blocks for the given tenantID, so move it backwards
n-- n--
} }
@ -493,7 +493,7 @@ func (p *part) searchByStreamIDs(so *searchOptions, bhss *blockHeaders, workCh c
n = sort.Search(len(ibhs), func(i int) bool { n = sort.Search(len(ibhs), func(i int) bool {
return !ibhs[i].streamID.less(streamID) return !ibhs[i].streamID.less(streamID)
}) })
if n == len(ibhs) || n > 0 && ibhs[n].streamID.equal(streamID) { if n == len(ibhs) || n > 0 && !ibhs[n].streamID.equal(streamID) {
// The end of ibhs[n-1] may contain blocks for the given streamID, so move it backwards // The end of ibhs[n-1] may contain blocks for the given streamID, so move it backwards
n-- n--
} }