Ma/origin
1
0
Fork 0
mirror of https://github.com/duanhf2012/origin.git synced 2026-02-03 22:45:13 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

优化origin服务发现

Browse Source
This commit is contained in:
boyce
2024-06-28 12:29:58 +08:00
parent d225bb4bd2
commit 987d35ff15
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
cluster/origindiscovery.go
View File

@@ -160,6 +160,12 @@ func (dc *OriginDiscoveryMaster) OnNatsDisconnect(){
} }
func (ds *OriginDiscoveryMaster) OnNodeConnected(nodeId string) { 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, &notifyDiscover)
} }
func (ds *OriginDiscoveryMaster) OnNodeDisconnect(nodeId string) { func (ds *OriginDiscoveryMaster) OnNodeDisconnect(nodeId string) {