减少日志数量

liuxiaolong

2021-01-07 a0e11e37000b85fb5fbb6f71021f50d88c5e0e31

减少日志数量

 hbusc.go

@@ -373,33 +373,33 @@
        Topic:   TOPIC_QUERYKEY,
        Body:    []byte(topic),
    })
    h.printLog("marshal req err:", err)
    if err != nil {
        return nil, fmt.Errorf("marshal req err:%s", err.Error())
    }
    var ret []bhomebus.Mesg
    n := h.sockWorker.sock.SendandrecvTimeout(reqNetNode, reqD, &ret, h.conf.sendTimeOut)
    h.printLog("getNetNodeByTopic ret n:", n)
    if n > 0 {
        var reply CommonReply
        err = json.Unmarshal(ret[0].Data, &reply)
        h.printLog("unmarshal err:", err)
        if err != nil {
            h.printLog("unmarshal err:", err)
            return nil, err
        }
        h.printLog("reply.Status:", reply.Status)

        if reply.Status == REPLY_SUCCESS {
            err = json.Unmarshal(reply.Body, &nodes)
            h.printLog("unmarshal err:", err, "nodes:", nodes)
            if err == nil {
                return nodes, nil
            } else {
                h.printLog("unmarshal err:", err, "nodes:", nodes)
                return nil, fmt.Errorf("unmarshal reply.Body err:%s", err.Error())
            }
        } else {
            h.printLog("reply.Status:", reply.Status)
            return nil, fmt.Errorf("REPLY STATUS:%d", reply.Status)
        }
    } else {
        h.printLog("getNetNodeByTopic ret n:", n)
        return nil,    fmt.Errorf("GetNetNodeByTopic n:%d", n)
    }
}

 micronode.go

@@ -172,8 +172,8 @@
//获取本机中某一个主题的 key  （结果只有一个元素）
func (ms *MicroNode) GetLocalNetNodeByTopic(topicName string) []bhomebus.NetNode {
    netNodes, err := ms.handle.GetNetNodeByTopic(ms.serverId, ms.procInfo, topicName)
    ms.printLog("netNodes:", netNodes, "err:", err)
    if err != nil {
        ms.printLog("netNodes:", netNodes, "err:", err)
        return nil
    }
    return netNodes
@@ -195,8 +195,8 @@
        Topic: TOPIC_QUERYPROC,
    }
    cr, err := ms.handle.RequestCenter(&r)
    ms.printLog("requestCenter reply:", cr, "err:", err)
    if err != nil {
        ms.printLog("requestCenter reply:", cr, "err:", err)
        return nil, err
    }
    if cr.Status == REPLY_SUCCESS && cr.Body != nil {