Merge pull request #3290 from paochiang/fix_dedup_subscribers

2025-09-19 12:27:58 +08:00 · 2022-07-08 07:40:52 -07:00
parent 22e05a2942 4e83e92156
commit b9518e06f5
1 changed files with 3 additions and 0 deletions
--- a/weed/server/filer_grpc_server_sub_meta.go
+++ b/weed/server/filer_grpc_server_sub_meta.go
@@ -263,6 +263,9 @@ func (fs *FilerServer) addClient(clientType string, clientAddress string, client
 	if clientId != 0 {
 		fs.knownListenersLock.Lock()
 		_, alreadyKnown = fs.knownListeners[clientId]
+		if !alreadyKnown {
+			fs.knownListeners[clientId] = struct{}{}
+		}
 		fs.knownListenersLock.Unlock()
 	}
 	return