Browse Source

filer subscribe: handle rename subscription

pull/1658/head
Chris Lu 4 years ago
parent
commit
ac22f1dd26
  1. 9
      weed/server/filer_grpc_server_sub_meta.go

9
weed/server/filer_grpc_server_sub_meta.go

@ -153,7 +153,14 @@ func (fs *FilerServer) eachEventNotificationFn(req *filer_pb.SubscribeMetadataRe
} }
if !strings.HasPrefix(fullpath, req.PathPrefix) { if !strings.HasPrefix(fullpath, req.PathPrefix) {
return nil
if eventNotification.NewParentPath != "" {
newFullPath := util.Join(eventNotification.NewParentPath, entryName)
if !strings.HasPrefix(newFullPath, req.PathPrefix) {
return nil
}
} else {
return nil
}
} }
message := &filer_pb.SubscribeMetadataResponse{ message := &filer_pb.SubscribeMetadataResponse{

Loading…
Cancel
Save