requestCenter添加日志打印

liuxiaolong

2021-01-07 7c54f5867f4add59e5a5c046eecd5e83781b628e

requestCenter添加日志打印

 hbusc.go

@@ -470,12 +470,12 @@
    h.mtxWorker.Lock()
    defer h.mtxWorker.Unlock()
    var ret []bhomebus.Mesg
    if n := h.sockWorker.sock.SendandrecvTimeout(rNodes, data,&ret, h.conf.sendTimeOut);n > 0 {
        if len(ret) > 0 {
            var cr *CommonReply
            if err = json.Unmarshal(ret[0].Data, cr); err == nil {
                return cr, nil
            }
    n := h.sockWorker.sock.SendandrecvTimeout(rNodes, data,&ret, h.conf.sendTimeOut)
    h.printLog("requestCenter n:", n, "len(ret):", len(ret))
    if n > 0 && len(ret) > 0{
        var cr *CommonReply
        if err = json.Unmarshal(ret[0].Data, cr); err == nil {
            return cr, nil
        }
    }
    return nil, fmt.Errorf("request center err")

 micronode.go

@@ -195,6 +195,7 @@
        Topic: TOPIC_QUERYPROC,
    }
    cr, err := ms.handle.RequestCenter(&r)
    ms.printLog("requestCenter reply:", *cr, "err:", err)
    if err != nil {
        return nil, err
    }