diff options
| author | Chris Lu <chris.lu@gmail.com> | 2021-03-09 13:21:26 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2021-03-09 13:21:26 -0800 |
| commit | 9d8ca513d93cf92735a34d79dc2e29c660cfada7 (patch) | |
| tree | a4cd7e3626102de5e9360917fd26a98902d9b30f | |
| parent | f5b5e4da2d3e201aaf6873d53ce952c844f362f6 (diff) | |
| download | seaweedfs-9d8ca513d93cf92735a34d79dc2e29c660cfada7.tar.xz seaweedfs-9d8ca513d93cf92735a34d79dc2e29c660cfada7.zip | |
refactor
| -rw-r--r-- | weed/filer/filer_on_meta_event.go | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/weed/filer/filer_on_meta_event.go b/weed/filer/filer_on_meta_event.go index 295a5039e..b29324b61 100644 --- a/weed/filer/filer_on_meta_event.go +++ b/weed/filer/filer_on_meta_event.go @@ -11,6 +11,10 @@ import ( // onMetadataChangeEvent is triggered after filer processed change events from local or remote filers func (f *Filer) onMetadataChangeEvent(event *filer_pb.SubscribeMetadataResponse) { + f.maybeReloadFilerConfiguration(event) +} + +func (f *Filer) maybeReloadFilerConfiguration(event *filer_pb.SubscribeMetadataResponse) { if DirectoryEtcSeaweedFS != event.Directory { if DirectoryEtcSeaweedFS != event.EventNotification.NewParentPath { return @@ -26,7 +30,6 @@ func (f *Filer) onMetadataChangeEvent(event *filer_pb.SubscribeMetadataResponse) if entry.Name == FilerConfName { f.reloadFilerConfiguration(entry) } - } func (f *Filer) readEntry(chunks []*filer_pb.FileChunk) ([]byte, error) { |