From 0fc9ffc603cd5ceeb7d268ff6bb559f2967573b2 Mon Sep 17 00:00:00 2001
From: Chris Lu <chris.lu@gmail.com>
Date: Sat, 14 Nov 2020 21:21:20 -0800
Subject: [PATCH] able to read filer.conf if updated

---
 weed/filer/filer_on_meta_event.go | 33 +++++++++++++++++++++++++++++++
 1 file changed, 33 insertions(+)

diff --git a/weed/filer/filer_on_meta_event.go b/weed/filer/filer_on_meta_event.go
index 70b62a974..f0b64f4e2 100644
--- a/weed/filer/filer_on_meta_event.go
+++ b/weed/filer/filer_on_meta_event.go
@@ -1,6 +1,9 @@
 package filer
 
 import (
+	"bytes"
+	"math"
+
 	"github.com/chrislusf/seaweedfs/weed/glog"
 	"github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
 )
@@ -12,10 +15,40 @@ const (
 // onMetadataChangeEvent is triggered after filer processed change events from local or remote filers
 func (f *Filer) onMetadataChangeEvent(event *filer_pb.SubscribeMetadataResponse) {
 	if DirectoryEtc != event.Directory {
+		if DirectoryEtc != event.EventNotification.NewParentPath {
+			return
+		}
+	}
+
+	entry := event.EventNotification.NewEntry
+	if entry == nil {
 		return
 	}
 
 	glog.V(0).Infof("procesing %v", event)
+	if entry.Name == "filer.conf" {
+		f.reloadFilerConfiguration(entry)
+	}
+
+}
+
+func (f *Filer) readEntry(entry *filer_pb.Entry) ([]byte, error){
+	var buf bytes.Buffer
+	err := StreamContent(f.MasterClient, &buf, entry.Chunks, 0, math.MaxInt64)
+	if err != nil {
+		return nil, err
+	}
+	return buf.Bytes(), nil
+}
+
+func (f *Filer) reloadFilerConfiguration(entry *filer_pb.Entry) {
+	data, err := f.readEntry(entry)
+	if err != nil {
+		glog.Warningf("read entry %s: %v", entry.Name, err)
+		return
+
+	}
 
+	println(string(data))
 
 }