From b65be503a4086c2015504035aa1c4db5e2dedcdb Mon Sep 17 00:00:00 2001 From: boyce Date: Fri, 15 Mar 2019 17:20:42 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E9=94=99=E8=AF=AF=E8=BE=93?= =?UTF-8?q?=E5=87=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- cluster/cluster.go | 16 +++++++--------- 1 file changed, 7 insertions(+), 9 deletions(-) diff --git a/cluster/cluster.go b/cluster/cluster.go index 7d967a6..4bc6520 100644 --- a/cluster/cluster.go +++ b/cluster/cluster.go @@ -37,8 +37,7 @@ func (slf *CCluster) ReadNodeInfo(nodeid int) error { var err error slf.cfg, err = ReadCfg("./config/cluster.json", nodeid) if err != nil { - fmt.Printf("%v", err) - return nil + return err } return nil @@ -179,18 +178,18 @@ func (slf *CCluster) ConnService() error { func (slf *CCluster) Init() error { 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], "=") 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" { - 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) @@ -198,7 +197,6 @@ func (slf *CCluster) Init() error { //读取配置 ret, err := strconv.Atoi(parts[1]) if err != nil { - service.GetLogger().Printf(sysmodule.LEVER_ERROR, "CCluster.Init parts[1] error,%v", err) return err }