add client id for all metadata listening clients

1 files changed, 5 insertions, 0 deletions

diff --git a/weed/server/filer_server.go b/weed/server/filer_server.go
index 1a5f80369..39df11e45 100644
--- a/weed/server/filer_server.go
+++ b/weed/server/filer_server.go
@@ -81,6 +81,10 @@ type FilerServer struct {
 	listenersLock sync.Mutex
 	listenersCond *sync.Cond
 
+	// track known metadata listeners
+	knownListenersLock sync.Mutex
+	knownListeners     map[int32]struct{}
+
 	brokers     map[string]map[string]bool
 	brokersLock sync.Mutex
 
@@ -93,6 +97,7 @@ func NewFilerServer(defaultMux, readonlyMux *http.ServeMux, option *FilerOption)
 	fs = &FilerServer{
 		option:                option,
 		grpcDialOption:        security.LoadClientTLS(util.GetViper(), "grpc.filer"),
+		knownListeners:        make(map[int32]struct{}),
 		brokers:               make(map[string]map[string]bool),
 		inFlightDataLimitCond: sync.NewCond(new(sync.Mutex)),
 	}