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

down机修复

Browse Source
This commit is contained in:
lifeiyi
2019-04-03 16:46:24 +08:00
parent 3e45ff9941
commit 49da76319f
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
cluster/cluster.go
View File

@@ -230,6 +230,10 @@ func (slf *CCluster) Call(NodeServiceMethod string, args interface{}, reply inte
if nodeid == GetNodeId() { if nodeid == GetNodeId() {
//判断服务是否已经完成初始化 //判断服务是否已经完成初始化
iService := service.InstanceServiceMgr().FindService(serviceName) iService := service.InstanceServiceMgr().FindService(serviceName)
if iService == nil {
service.GetLogger().Printf(sysmodule.LEVER_ERROR, "CCluster.Call(%s): NodeId %d cannot find.", NodeServiceMethod, nodeid)
return fmt.Errorf("CCluster.Call(%s): NodeId %d cannot find..", NodeServiceMethod, nodeid)
}
if iService.IsInit() == false { if iService.IsInit() == false {
service.GetLogger().Printf(sysmodule.LEVER_ERROR, "CCluster.Call(%s): NodeId %d is not init.", NodeServiceMethod, nodeid) service.GetLogger().Printf(sysmodule.LEVER_ERROR, "CCluster.Call(%s): NodeId %d is not init.", NodeServiceMethod, nodeid)
return fmt.Errorf("CCluster.Call(%s): NodeId %d is not init.", NodeServiceMethod, nodeid) return fmt.Errorf("CCluster.Call(%s): NodeId %d is not init.", NodeServiceMethod, nodeid)