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

修改错误输出

Browse Source
This commit is contained in:
boyce
2019-03-15 17:20:42 +08:00
parent 91bb7d7833
commit b65be503a4
1 changed files with 7 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
cluster/cluster.go
View File

@@ -37,8 +37,7 @@ func (slf *CCluster) ReadNodeInfo(nodeid int) error {
var err error var err error
slf.cfg, err = ReadCfg("./config/cluster.json", nodeid) slf.cfg, err = ReadCfg("./config/cluster.json", nodeid)
if err != nil { if err != nil {
fmt.Printf("%v", err) return err
return nil
} }
return nil return nil
@@ -179,18 +178,18 @@ func (slf *CCluster) ConnService() error {
func (slf *CCluster) Init() error { func (slf *CCluster) Init() error {
if len(os.Args) < 2 { if len(os.Args) < 2 {
service.GetLogger().Printf(sysmodule.LEVER_ERROR, "CCluster.Init error,param not find NodeId=number")
return fmt.Errorf("param error not find NodeId=number") return fmt.Errorf("Param error not find NodeId=number")
} }
parts := strings.Split(os.Args[1], "=") parts := strings.Split(os.Args[1], "=")
if len(parts) < 2 { if len(parts) < 2 {
service.GetLogger().Printf(sysmodule.LEVER_ERROR, "CCluster.Init error,param not find NodeId=number") return fmt.Errorf("Param error not find NodeId=number")
return fmt.Errorf("param error not find NodeId=number")
} }
if parts[0] != "NodeId" { if parts[0] != "NodeId" {
service.GetLogger().Printf(sysmodule.LEVER_ERROR, "CCluster.Init error,param error not find NodeId=number")
return fmt.Errorf("param error not find NodeId=number") return fmt.Errorf("Param error not find NodeId=number")
} }
slf.nodeclient = make(map[int]*RpcClient) slf.nodeclient = make(map[int]*RpcClient)
@@ -198,7 +197,6 @@ func (slf *CCluster) Init() error {
//读取配置 //读取配置
ret, err := strconv.Atoi(parts[1]) ret, err := strconv.Atoi(parts[1])
if err != nil { if err != nil {
service.GetLogger().Printf(sysmodule.LEVER_ERROR, "CCluster.Init parts[1] error,%v", err)
return err return err
} }