mirror/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2024-11-24 02:59:13 +08:00
Code Issues Packages Projects Releases Wiki Activity

bug fixed to filer store elastic deleteEntry (#5988)

Browse Source
This commit is contained in:
zouyixiong 2024-09-09 17:15:25 +08:00 committed by GitHub
parent ff3d46637d
commit d8e18a8eb7
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
weed/filer/elastic/v7/elastic_store.go
View File

@ -159,8 +159,16 @@ func (store *ElasticStore) FindEntry(ctx context.Context, fullpath weed_util.Ful
func (store *ElasticStore) DeleteEntry(ctx context.Context, fullpath weed_util.FullPath) (err error) { func (store *ElasticStore) DeleteEntry(ctx context.Context, fullpath weed_util.FullPath) (err error) {
index := getIndex(fullpath, false) index := getIndex(fullpath, false)
id := weed_util.Md5String([]byte(fullpath)) id := weed_util.Md5String([]byte(fullpath))
if strings.Count(string(fullpath), "/") == 1 { strFullpath := string(fullpath)
return store.deleteIndex(ctx, index)
// A top-level subdirectory refers to an Elasticsearch index.
// If we delete an entry at the top level, we should attempt to delete the corresponding Elasticsearch index.
if strings.Count(strFullpath, "/") == 1 {
entry, err2 := store.FindEntry(ctx, fullpath)
if err2 == nil && entry.IsDirectory() {
bucketIndex := indexPrefix + strFullpath[1:]
store.deleteIndex(ctx, bucketIndex)
}
} }
return store.deleteEntry(ctx, index, id) return store.deleteEntry(ctx, index, id)
} }