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

vmstorage: add more context to the flock acquiring msg (#3584)

Browse source 
See https://github.com/VictoriaMetrics/VictoriaMetrics/issues/3578

Signed-off-by: hagen1778 <roman@victoriametrics.com>

Signed-off-by: hagen1778 <roman@victoriametrics.com>
This commit is contained in:
Roman Khavronenko 2023-01-06 03:30:42 +01:00 committed by Aliaksandr Valialkin
parent 750d309f63
commit 57277ed6bc
No known key found for this signature in database
GPG key ID: A72BEC6CD3D0DED1
3 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
lib/mergeset/table.go
View file

@ -316,7 +316,8 @@ func OpenTable(path string, flushCallback func(), prepareBlock PrepareBlockCallb
// Protect from concurrent opens. // Protect from concurrent opens.
flockF, err := fs.CreateFlockFile(path) flockF, err := fs.CreateFlockFile(path)
if err != nil { if err != nil {
return nil, err return nil, fmt.Errorf("cannot create lock file in %q; "+
"make sure the dir isn't used by other processes or manually delete the file if you recover from abrupt VictoriaMetrics crash; error: %w", path, err)
} }
// Open table parts. // Open table parts.

3
lib/storage/storage.go
View file

@ -187,7 +187,8 @@ func OpenStorage(path string, retentionMsecs int64, maxHourlySeries, maxDailySer
// Protect from concurrent opens. // Protect from concurrent opens.
flockF, err := fs.CreateFlockFile(path) flockF, err := fs.CreateFlockFile(path)
if err != nil { if err != nil {
return nil, err return nil, fmt.Errorf("cannot create lock file in %q; "+
"make sure the dir isn't used by other processes or manually delete the file if you recover from abrupt VictoriaMetrics crash; error: %w", path, err)
} }
s.flockF = flockF s.flockF = flockF

3
lib/storage/table.go
View file

@ -90,7 +90,8 @@ func openTable(path string, s *Storage) (*table, error) {
// Protect from concurrent opens. // Protect from concurrent opens.
flockF, err := fs.CreateFlockFile(path) flockF, err := fs.CreateFlockFile(path)
if err != nil { if err != nil {
return nil, err return nil, fmt.Errorf("cannot create lock file in %q; "+
"make sure the dir isn't used by other processes or manually delete the file if you recover from abrupt VictoriaMetrics crash; error: %w", path, err)
} }
// Create directories for small and big partitions if they don't exist yet. // Create directories for small and big partitions if they don't exist yet.