From 987d35ff154ad2717f11d1719717f7c10c902221 Mon Sep 17 00:00:00 2001 From: boyce Date: Fri, 28 Jun 2024 12:29:58 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96origin=E6=9C=8D=E5=8A=A1?= =?UTF-8?q?=E5=8F=91=E7=8E=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- cluster/origindiscovery.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/cluster/origindiscovery.go b/cluster/origindiscovery.go index b9047af..5f50471 100644 --- a/cluster/origindiscovery.go +++ b/cluster/origindiscovery.go @@ -160,6 +160,12 @@ func (dc *OriginDiscoveryMaster) OnNatsDisconnect(){ } func (ds *OriginDiscoveryMaster) OnNodeConnected(nodeId string) { + var notifyDiscover rpc.SubscribeDiscoverNotify + notifyDiscover.IsFull = true + notifyDiscover.NodeInfo = ds.nodeInfo + notifyDiscover.MasterNodeId = cluster.GetLocalNodeInfo().NodeId + + ds.GoNode(nodeId, SubServiceDiscover, ¬ifyDiscover) } func (ds *OriginDiscoveryMaster) OnNodeDisconnect(nodeId string) {