From 93f532a911aa606a966695a73784fe34e821b8be Mon Sep 17 00:00:00 2001
From: Aliaksandr Valialkin <valyala@victoriametrics.com>
Date: Thu, 2 Nov 2023 21:18:00 +0100
Subject: [PATCH] lib/persistentqueue: use the proper function call after
 31945fb38d8d7dc0b9cbf881c53808af91ab0214

---
 lib/persistentqueue/persistentqueue.go | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/lib/persistentqueue/persistentqueue.go b/lib/persistentqueue/persistentqueue.go
index 2c2c853b31..4ca255207f 100644
--- a/lib/persistentqueue/persistentqueue.go
+++ b/lib/persistentqueue/persistentqueue.go
@@ -204,7 +204,11 @@ func tryOpeningQueue(path, name string, chunkFileSize, maxBlockSize, maxPendingB
 		// path contents is broken or missing. Re-create it from scratch.
 		fs.MustClose(q.flockF)
 		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.Name = q.name
 		if err := mi.WriteToFile(metainfoPath); err != nil {