From dc37d2ea8f4716174b9fa3bab563e7703146265f Mon Sep 17 00:00:00 2001 From: boyce Date: Mon, 22 Apr 2019 16:09:53 +0800 Subject: [PATCH] =?UTF-8?q?=E6=A3=80=E6=9F=A5nodeid=E6=98=AF=E5=90=A6?= =?UTF-8?q?=E5=9C=A8=E7=BA=BF=EF=BC=8C=E9=BB=98=E8=AE=A4=E5=B0=86=E8=87=AA?= =?UTF-8?q?=E5=B7=B1=E7=BB=93=E7=82=B9=E8=AE=A4=E4=B8=BA=E5=9C=A8=E7=BA=BF?= =?UTF-8?q?=E7=8A=B6=E6=80=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- cluster/cluster.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/cluster/cluster.go b/cluster/cluster.go index cfe9a2b..f6bfff7 100644 --- a/cluster/cluster.go +++ b/cluster/cluster.go @@ -317,6 +317,10 @@ func (slf *CCluster) GetNodeIdByServiceName(servicename string, bOnline bool) [] } func (slf *CCluster) CheckNodeIsConnectedByID(nodeid int) bool { + if nodeid == GetNodeId() { + return true + } + pclient := slf.GetRpcClientByNodeId(nodeid) if pclient == nil { return false @@ -326,6 +330,7 @@ func (slf *CCluster) CheckNodeIsConnectedByID(nodeid int) bool { } func (slf *CCluster) GetRpcClientByNodeId(nodeid int) *RpcClient { + pclient, ok := slf.nodeclient[nodeid] if ok == false { return nil