diff options
| author | zzq09494 <zzq09494@ly.com> | 2022-07-28 12:04:37 +0800 |
|---|---|---|
| committer | zzq09494 <zzq09494@ly.com> | 2022-07-28 12:04:37 +0800 |
| commit | 01b7aa79fa941cff0c83487da07a658be4bca377 (patch) | |
| tree | 0b2fa63ff46b29ad6d03df6b036ae2e4a9975043 | |
| parent | ca836568ac3df79373225bf6b98334e641194cfc (diff) | |
| download | seaweedfs-01b7aa79fa941cff0c83487da07a658be4bca377.tar.xz seaweedfs-01b7aa79fa941cff0c83487da07a658be4bca377.zip | |
fix: Buckets are not created and deleted correctly on the filer with the same signature when they are created and deleted
| -rw-r--r-- | weed/filer/filer_on_meta_event.go | 6 |
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 { |