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

lib/persistentqueue: use the proper function call after 31945fb38d

Browse source
This commit is contained in:
Aliaksandr Valialkin 2023-11-02 21:18:00 +01:00
parent dc8bc5d6cd
commit e42af059a1
No known key found for this signature in database
GPG key ID: A72BEC6CD3D0DED1
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/persistentqueue/persistentqueue.go
View file

@ -204,7 +204,11 @@ func tryOpeningQueue(path, name string, chunkFileSize, maxBlockSize, maxPendingB
// path contents is broken or missing. Re-create it from scratch. // path contents is broken or missing. Re-create it from scratch.
fs.MustClose(q.flockF) fs.MustClose(q.flockF)
fs.RemoveDirContents(path) fs.RemoveDirContents(path)
q.flockF = fs.MustCreateFlockFile(path) flockF, err := fs.CreateFlockFile(path)
if err != nil {
logger.Panicf("FATAL: cannot create flock file: %s", err)
}
q.flockF = flockF
mi.Reset() mi.Reset()
mi.Name = q.name mi.Name = q.name
if err := mi.WriteToFile(metainfoPath); err != nil { if err := mi.WriteToFile(metainfoPath); err != nil {