fix: Buckets are not created and deleted correctly on the filer with the same signature when they are created and deleted
This commit is contained in:
@@ -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 {
|
||||||
|
|||||||
Reference in New Issue
Block a user