From b23b30aac5a9ed7878d1e15391fa68589a77e7f3 Mon Sep 17 00:00:00 2001 From: boyce Date: Tue, 30 Apr 2024 19:05:44 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E6=9C=8D=E5=8A=A1=E5=8F=91?= =?UTF-8?q?=E7=8E=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- cluster/origindiscovery.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/cluster/origindiscovery.go b/cluster/origindiscovery.go index 048654d..b9047af 100644 --- a/cluster/origindiscovery.go +++ b/cluster/origindiscovery.go @@ -183,6 +183,10 @@ func (ds *OriginDiscoveryMaster) OnNodeDisconnect(nodeId string) { func (ds *OriginDiscoveryMaster) RpcCastGo(serviceMethod string, args interface{}) { for nodeId, _ := range ds.mapNodeInfo { + if nodeId == cluster.GetLocalNodeInfo().NodeId { + continue + } + ds.GoNode(nodeId, serviceMethod, args) } }