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

修改获取nodeid

Browse Source
This commit is contained in:
boyce
2019-02-25 18:01:48 +08:00
parent c21698314e
commit b8e535516a
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
cluster/cluster.go
View File

@@ -212,7 +212,7 @@ func (slf *CCluster) Call(NodeServiceMethod string, args interface{}, reply inte
} }
nodeid := nodeidList[0] nodeid := nodeidList[0]
if nodeid == slf.GetCurrentNodeId() { if nodeid == GetNodeId() {
return slf.LocalRpcClient.Call(callServiceName, args, reply) return slf.LocalRpcClient.Call(callServiceName, args, reply)
} else { } else {
pclient := slf.GetClusterClient(nodeid) pclient := slf.GetClusterClient(nodeid)
@@ -253,7 +253,7 @@ func (slf *CCluster) GetNodeList(NodeServiceMethod string, rpcServerMethod *stri
nodeidList = make([]int, 0) nodeidList = make([]int, 0)
if servicename[:1] == "_" { if servicename[:1] == "_" {
servicename = servicename[1:] servicename = servicename[1:]
nodeidList = append(nodeidList, slf.GetCurrentNodeId()) nodeidList = append(nodeidList, GetNodeId())
} else { } else {
nodeidList = slf.cfg.GetIdByService(servicename) nodeidList = slf.cfg.GetIdByService(servicename)
} }
@@ -278,7 +278,7 @@ func (slf *CCluster) Go(bCast bool, NodeServiceMethod string, args interface{})
} }
for _, nodeid := range nodeidList { for _, nodeid := range nodeidList {
if nodeid == slf.GetCurrentNodeId() { if nodeid == GetNodeId() {
replyCall := slf.LocalRpcClient.Go(callServiceName, args, nil, nil) replyCall := slf.LocalRpcClient.Go(callServiceName, args, nil, nil)
if replyCall.Error != nil { if replyCall.Error != nil {
service.GetLogger().Printf(sysmodule.LEVER_ERROR, "CCluster.Go(%s) fail:%v.", NodeServiceMethod, replyCall.Error) service.GetLogger().Printf(sysmodule.LEVER_ERROR, "CCluster.Go(%s) fail:%v.", NodeServiceMethod, replyCall.Error)