diff options
| author | chrislu <chris.lu@gmail.com> | 2022-07-28 16:32:02 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-07-28 16:32:02 -0700 |
| commit | a458bee9f27e15450b9f9c2aa3a186737e4672e2 (patch) | |
| tree | 785a3e40491a592779e891106eeb51773332dbab | |
| parent | e0eda52c5418f53fda895741a1878e66d8dffb44 (diff) | |
| parent | 32d0413be1fbf114268284b7cf6415a518195212 (diff) | |
| download | seaweedfs-a458bee9f27e15450b9f9c2aa3a186737e4672e2.tar.xz seaweedfs-a458bee9f27e15450b9f9c2aa3a186737e4672e2.zip | |
Merge branch 'master' of https://github.com/chrislusf/seaweedfs
| -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 { |