From 750aafdea1146df4f40fa9fd447cd860a660ec5d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=88=98=E7=A5=A5=E8=B6=85?= Date: Sun, 31 Mar 2024 16:03:35 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8DKV=E5=AD=98=E5=82=A8=E9=94=81?= =?UTF-8?q?=E6=97=A0=E6=B3=95=E5=88=9B=E5=BB=BA=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/utils/kvstore/store.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/internal/utils/kvstore/store.go b/internal/utils/kvstore/store.go index 6137e0f..7b21e51 100644 --- a/internal/utils/kvstore/store.go +++ b/internal/utils/kvstore/store.go @@ -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, + name: storeName, + path: path, + locker: fsutils.NewLocker(path + "/.fs"), } err = store.Open()