github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2024-11-21 14:44:00 +00:00
Code Issues Projects Releases Packages Wiki Activity

lib/persistentqueue: properly re-create flock.lock file inside directory if persistent queue is broken.

Browse source 
Updates https://github.com/VictoriaMetrics/VictoriaMetrics/issues/5249

Thanks to @Sniper91 for the bugreport and initial fix at https://github.com/VictoriaMetrics/VictoriaMetrics/pull/5233
This commit is contained in:
Aliaksandr Valialkin 2023-10-31 18:34:44 +01:00
parent efb6ac27c2
commit 98699f203b
No known key found for this signature in database
GPG key ID: A72BEC6CD3D0DED1
1 changed files with 2 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
lib/persistentqueue/persistentqueue.go
View file

@ -188,7 +188,9 @@ 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.RemoveDirContents(path) fs.RemoveDirContents(path)
q.flockF = fs.MustCreateFlockFile(path)
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 {