Fix codebase reload. (#124)

flomesh-io · Dec 12, 2022 · 37b5c9b · 37b5c9b
1 parent 8e14402
commit 37b5c9b
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/pkg/sidecar/providers/pipy/repo/broadcast.go b/pkg/sidecar/providers/pipy/repo/broadcast.go
@@ -113,16 +113,19 @@ func (s *Server) fireExistProxies() []*pipy.Proxy {
 		if err != nil {
 			continue
 		}
-		s.fireUpdatedPod(s.proxyRegistry, proxy)
+		proxy = s.fireUpdatedPod(s.proxyRegistry, proxy)
 		allProxies = append(allProxies, proxy)
 	}
 	return allProxies
 }
 
-func (s *Server) fireUpdatedPod(proxyRegistry *registry.ProxyRegistry, proxy *pipy.Proxy) {
-	if v := proxyRegistry.GetConnectedProxy(proxy.UUID.String()); v == nil {
+func (s *Server) fireUpdatedPod(proxyRegistry *registry.ProxyRegistry, proxy *pipy.Proxy) *pipy.Proxy {
+	connectedProxy := proxyRegistry.GetConnectedProxy(proxy.UUID.String())
+	if connectedProxy == nil {
 		s.informProxy(proxy)
+		return proxy
 	}
+	return connectedProxy
 }
 
 func (s *Server) informProxy(proxy *pipy.Proxy) {