Browse Source
Merge pull request #3374 from famosss/fixcreatebucket
fix: Buckets are not created and deleted correctly on the filer with …
pull/3378/head
Chris Lu
2 years ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with
1 additions and
5 deletions
-
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) { |
|
|
func (f *Filer) onBucketEvents(event *filer_pb.SubscribeMetadataResponse) { |
|
|
message := event.EventNotification |
|
|
message := event.EventNotification |
|
|
for _, sig := range message.Signatures { |
|
|
|
|
|
if sig == f.Signature { |
|
|
|
|
|
return |
|
|
|
|
|
} |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
if f.DirBucketsPath == event.Directory { |
|
|
if f.DirBucketsPath == event.Directory { |
|
|
if filer_pb.IsCreate(event) { |
|
|
if filer_pb.IsCreate(event) { |
|
|
if message.NewEntry.IsDirectory { |
|
|
if message.NewEntry.IsDirectory { |
|
|
|
