修复KV存储锁无法创建的问题

This commit is contained in:
GoEdgeLab
2024-03-31 16:03:35 +08:00
parent e2c9839761
commit d7de2bd167

View File

@@ -70,16 +70,16 @@ func OpenStoreDir(dir string, storeName string) (*Store, error) {
return nil, errors.New("invalid store name '" + storeName + "'")
}
_, err := os.Stat(dir)
var path = strings.TrimSuffix(dir, "/") + "/" + storeName + StoreSuffix
_, err := os.Stat(path)
if err != nil && os.IsNotExist(err) {
_ = os.MkdirAll(dir, 0777)
_ = os.MkdirAll(path, 0777)
}
dir = strings.TrimSuffix(dir, "/")
var store = &Store{
name: storeName,
path: dir + "/" + storeName + StoreSuffix,
path: path,
locker: fsutils.NewLocker(path + "/.fs"),
}
err = store.Open()