aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chrislusf@users.noreply.github.com>2022-07-27 22:37:18 -0700
committerGitHub <noreply@github.com>2022-07-27 22:37:18 -0700
commit32d0413be1fbf114268284b7cf6415a518195212 (patch)
tree0b2fa63ff46b29ad6d03df6b036ae2e4a9975043
parentca836568ac3df79373225bf6b98334e641194cfc (diff)
parent01b7aa79fa941cff0c83487da07a658be4bca377 (diff)
downloadseaweedfs-32d0413be1fbf114268284b7cf6415a518195212.tar.xz
seaweedfs-32d0413be1fbf114268284b7cf6415a518195212.zip
Merge pull request #3374 from famosss/fixcreatebucket
fix: Buckets are not created and deleted correctly on the filer with …
-rw-r--r--weed/filer/filer_on_meta_event.go6
1 files changed, 1 insertions, 5 deletions
diff --git a/weed/filer/filer_on_meta_event.go b/weed/filer/filer_on_meta_event.go
index 3b290deca..79176821f 100644
--- a/weed/filer/filer_on_meta_event.go
+++ b/weed/filer/filer_on_meta_event.go
@@ -16,11 +16,7 @@ func (f *Filer) onMetadataChangeEvent(event *filer_pb.SubscribeMetadataResponse)
func (f *Filer) onBucketEvents(event *filer_pb.SubscribeMetadataResponse) {
message := event.EventNotification
- for _, sig := range message.Signatures {
- if sig == f.Signature {
- return
- }
- }
+
if f.DirBucketsPath == event.Directory {
if filer_pb.IsCreate(event) {
if message.NewEntry.IsDirectory {