rms/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2026-05-17 08:36:55 +03:00
Code Issues Packages Projects Releases Wiki Activity

lib/persistentqueue: verify that ReaderOffset doesnt exceed WriterOffset when opening the persistent queue

Browse Source 
Updates https://github.com/VictoriaMetrics/VictoriaMetrics/issues/964
This commit is contained in:
Aliaksandr Valialkin
2020-12-14 19:25:23 +02:00
parent ae972429c7
commit d006b41eff
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
lib/persistentqueue/persistentqueue.go
View File

@@ -336,6 +336,10 @@ func tryOpeningQueue(path, name string, chunkFileSize, maxBlockSize, maxPendingB
cleanOnError()
return nil, fmt.Errorf("couldn't find chunk file for writing in %q", q.dir)
}
if q.readerOffset > q.writerOffset {
cleanOnError()
return nil, fmt.Errorf("readerOffset=%d cannot exceed writerOffset=%d", q.readerOffset, q.writerOffset)
}
mustCloseFlockF = false
return &q, nil
}