github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2025-03-21 15:45:01 +00:00
Code Issues Projects Releases Packages Wiki Activity

lib/logstorage: Set ptwHot to nil when the partition pointed by ptwHot is dropped (#4902)

Browse source
This commit is contained in:
crossoverJie 2023-08-29 17:01:19 +08:00 committed by GitHub
parent 379b92cc10
commit 8d50032dd6
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
lib/logstorage/storage.go
View file

@ -329,6 +329,9 @@ func (s *Storage) watchRetention() {
logger.Infof("the partition %s is scheduled to be deleted because it is outside the -retentionPeriod=%dd", ptw.pt.path, durationToDays(s.retention)) logger.Infof("the partition %s is scheduled to be deleted because it is outside the -retentionPeriod=%dd", ptw.pt.path, durationToDays(s.retention))
atomic.StoreUint32(&ptw.mustBeDeleted, 1) atomic.StoreUint32(&ptw.mustBeDeleted, 1)
ptw.decRef() ptw.decRef()
if s.ptwHot != nil && s.ptwHot.pt == ptw.pt {
s.ptwHot = nil
}
} }
select { select {
@ -363,6 +366,7 @@ func (s *Storage) MustClose() {
} }
} }
s.partitions = nil s.partitions = nil
s.ptwHot = nil
// Save caches // Save caches
streamIDCachePath := filepath.Join(s.path, cacheDirname, streamIDCacheFilename) streamIDCachePath := filepath.Join(s.path, cacheDirname, streamIDCacheFilename)
@ -395,7 +399,7 @@ func (s *Storage) MustAddRows(lr *LogRows) {
} }
s.partitionsLock.Unlock() s.partitionsLock.Unlock()
if ptwHot != nil && ptwHot.pt != nil { if ptwHot != nil {
if ptwHot.canAddAllRows(lr) { if ptwHot.canAddAllRows(lr) {
ptwHot.pt.mustAddRows(lr) ptwHot.pt.mustAddRows(lr)
ptwHot.decRef() ptwHot.decRef()