From b8e535516aac52df49eb7d1ab91ff7391bfda0af Mon Sep 17 00:00:00 2001 From: boyce Date: Mon, 25 Feb 2019 18:01:48 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E8=8E=B7=E5=8F=96nodeid?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- cluster/cluster.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/cluster/cluster.go b/cluster/cluster.go index 66c0cc3..58299d8 100644 --- a/cluster/cluster.go +++ b/cluster/cluster.go @@ -212,7 +212,7 @@ func (slf *CCluster) Call(NodeServiceMethod string, args interface{}, reply inte } nodeid := nodeidList[0] - if nodeid == slf.GetCurrentNodeId() { + if nodeid == GetNodeId() { return slf.LocalRpcClient.Call(callServiceName, args, reply) } else { pclient := slf.GetClusterClient(nodeid) @@ -253,7 +253,7 @@ func (slf *CCluster) GetNodeList(NodeServiceMethod string, rpcServerMethod *stri nodeidList = make([]int, 0) if servicename[:1] == "_" { servicename = servicename[1:] - nodeidList = append(nodeidList, slf.GetCurrentNodeId()) + nodeidList = append(nodeidList, GetNodeId()) } else { nodeidList = slf.cfg.GetIdByService(servicename) } @@ -278,7 +278,7 @@ func (slf *CCluster) Go(bCast bool, NodeServiceMethod string, args interface{}) } for _, nodeid := range nodeidList { - if nodeid == slf.GetCurrentNodeId() { + if nodeid == GetNodeId() { replyCall := slf.LocalRpcClient.Go(callServiceName, args, nil, nil) if replyCall.Error != nil { service.GetLogger().Printf(sysmodule.LEVER_ERROR, "CCluster.Go(%s) fail:%v.", NodeServiceMethod, replyCall.Error)