aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-12-21 21:15:22 -0800
committerChris Lu <chris.lu@gmail.com>2020-12-21 21:15:22 -0800
commit488c2680e86555a84951838940dba4f3391a3904 (patch)
treed56cbbbfe3ceff6b203b639da2a0f6def7ca798f
parentf5a19a87be8e8802605d9abef425ac2fdf688cf6 (diff)
downloadseaweedfs-488c2680e86555a84951838940dba4f3391a3904.tar.xz
seaweedfs-488c2680e86555a84951838940dba4f3391a3904.zip
change default filer store root
-rw-r--r--weed/filer/filerstore.go20
1 files changed, 10 insertions, 10 deletions
diff --git a/weed/filer/filerstore.go b/weed/filer/filerstore.go
index 10aee75df..072772b4c 100644
--- a/weed/filer/filerstore.go
+++ b/weed/filer/filerstore.go
@@ -80,7 +80,7 @@ func (fsw *FilerStoreWrapper) AddPathSpecificStore(path string, storeId string,
func (fsw *FilerStoreWrapper) getActualStore(path util.FullPath) (store FilerStore) {
store = fsw.defaultStore
- if path == "" {
+ if path == "/" {
return
}
var storeId string
@@ -95,11 +95,11 @@ func (fsw *FilerStoreWrapper) getActualStore(path util.FullPath) (store FilerSto
}
func (fsw *FilerStoreWrapper) GetName() string {
- return fsw.getActualStore("").GetName()
+ return fsw.getActualStore("/").GetName()
}
func (fsw *FilerStoreWrapper) Initialize(configuration util.Configuration, prefix string) error {
- return fsw.getActualStore("").Initialize(configuration, prefix)
+ return fsw.getActualStore("/").Initialize(configuration, prefix)
}
func (fsw *FilerStoreWrapper) InsertEntry(ctx context.Context, entry *Entry) error {
@@ -299,27 +299,27 @@ func (fsw *FilerStoreWrapper) prefixFilterEntries(ctx context.Context, dirPath u
}
func (fsw *FilerStoreWrapper) BeginTransaction(ctx context.Context) (context.Context, error) {
- return fsw.getActualStore("").BeginTransaction(ctx)
+ return fsw.getActualStore("/").BeginTransaction(ctx)
}
func (fsw *FilerStoreWrapper) CommitTransaction(ctx context.Context) error {
- return fsw.getActualStore("").CommitTransaction(ctx)
+ return fsw.getActualStore("/").CommitTransaction(ctx)
}
func (fsw *FilerStoreWrapper) RollbackTransaction(ctx context.Context) error {
- return fsw.getActualStore("").RollbackTransaction(ctx)
+ return fsw.getActualStore("/").RollbackTransaction(ctx)
}
func (fsw *FilerStoreWrapper) Shutdown() {
- fsw.getActualStore("").Shutdown()
+ fsw.getActualStore("/").Shutdown()
}
func (fsw *FilerStoreWrapper) KvPut(ctx context.Context, key []byte, value []byte) (err error) {
- return fsw.getActualStore("").KvPut(ctx, key, value)
+ return fsw.getActualStore("/").KvPut(ctx, key, value)
}
func (fsw *FilerStoreWrapper) KvGet(ctx context.Context, key []byte) (value []byte, err error) {
- return fsw.getActualStore("").KvGet(ctx, key)
+ return fsw.getActualStore("/").KvGet(ctx, key)
}
func (fsw *FilerStoreWrapper) KvDelete(ctx context.Context, key []byte) (err error) {
- return fsw.getActualStore("").KvDelete(ctx, key)
+ return fsw.getActualStore("/").KvDelete(ctx, key)
}