From 3c12b5cd8eb14a35d6fa6eec53f0b29070fed70c Mon Sep 17 00:00:00 2001
From: liuxiaolong <liuxiaolong@aiotlink.com>
Date: 星期四, 07 一月 2021 10:55:01 +0800
Subject: [PATCH] 添加日志
---
micronode.go | 1 +
hbusc.go | 7 +++++++
2 files changed, 8 insertions(+), 0 deletions(-)
diff --git a/hbusc.go b/hbusc.go
index f558b23..698bde1 100644
--- a/hbusc.go
+++ b/hbusc.go
@@ -373,19 +373,24 @@
Topic: TOPIC_QUERYTOPIC,
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 {
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 {
@@ -402,11 +407,13 @@
func (h *BHBus) Request(serverId string, req *MsgInfo, milliSecs int) (resp *MsgInfo, err error) {
//1.棣栧厛闇�瑕侀�氳繃topic鎷垮埌鏈満瀵瑰簲鐨凬etNode
rNodes, err := h.GetNetNodeByTopic(serverId, &req.SrcProc, req.Topic)
+ h.printLog("rNodes:", rNodes, "err:", err)
if err != nil {
return nil, err
}
//2.灏嗚姹傝繑閫佸埌瀵瑰簲鐨剆erver,骞剁瓑寰呰繑鍥炲��
data, err := json.Marshal(*req)
+ h.printLog("marshal(*req) err:", err)
if err != nil {
return nil, err
}
diff --git a/micronode.go b/micronode.go
index 75b3ffe..711896c 100644
--- a/micronode.go
+++ b/micronode.go
@@ -172,6 +172,7 @@
//鑾峰彇鏈満涓煇涓�涓富棰樼殑 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 {
return nil
}
--
Gitblit v1.8.0