diff options
| author | Chris Lu <chris.lu@gmail.com> | 2021-09-18 14:05:16 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2021-09-18 14:05:16 -0700 |
| commit | 49d971e602af60cfe9f7a716cca7172e7d415ba4 (patch) | |
| tree | 3965fb8e1dd50f540dfedbb6f86adfdad074fc2d | |
| parent | 94a01fcfcb473057028c6e24b49032f0897be958 (diff) | |
| download | seaweedfs-49d971e602af60cfe9f7a716cca7172e7d415ba4.tar.xz seaweedfs-49d971e602af60cfe9f7a716cca7172e7d415ba4.zip | |
filer: redis store needs to clean up batch deleted sub folders
| -rw-r--r-- | weed/filer/redis/universal_redis_store.go | 2 | ||||
| -rw-r--r-- | weed/filer/redis2/universal_redis_store.go | 2 |
2 files changed, 4 insertions, 0 deletions
diff --git a/weed/filer/redis/universal_redis_store.go b/weed/filer/redis/universal_redis_store.go index 30d11a7f4..2cc7f49b1 100644 --- a/weed/filer/redis/universal_redis_store.go +++ b/weed/filer/redis/universal_redis_store.go @@ -120,6 +120,8 @@ func (store *UniversalRedisStore) DeleteFolderChildren(ctx context.Context, full if err != nil { return fmt.Errorf("delete %s in parent dir: %v", fullpath, err) } + // not efficient, but need to remove if it is a directory + store.Client.Del(ctx, genDirectoryListKey(string(path))) } return nil diff --git a/weed/filer/redis2/universal_redis_store.go b/weed/filer/redis2/universal_redis_store.go index aab3d1f4a..ecf68a9ee 100644 --- a/weed/filer/redis2/universal_redis_store.go +++ b/weed/filer/redis2/universal_redis_store.go @@ -144,6 +144,8 @@ func (store *UniversalRedis2Store) DeleteFolderChildren(ctx context.Context, ful if err != nil { return fmt.Errorf("DeleteFolderChildren %s in parent dir: %v", fullpath, err) } + // not efficient, but need to remove if it is a directory + store.Client.Del(ctx, genDirectoryListKey(string(path))) } return nil |