From 7c54f5867f4add59e5a5c046eecd5e83781b628e Mon Sep 17 00:00:00 2001
From: liuxiaolong <liuxiaolong@aiotlink.com>
Date: 星期四, 07 一月 2021 16:27:33 +0800
Subject: [PATCH] requestCenter添加日志打印
---
micronode.go | 1 +
hbusc.go | 12 ++++++------
2 files changed, 7 insertions(+), 6 deletions(-)
diff --git a/hbusc.go b/hbusc.go
index 37429f8..2273393 100644
--- a/hbusc.go
+++ b/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")
diff --git a/micronode.go b/micronode.go
index 711896c..8644aec 100644
--- a/micronode.go
+++ b/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
}
--
Gitblit v1.8.0