添加日志

liuxiaolong

2021-01-07 3c12b5cd8eb14a35d6fa6eec53f0b29070fed70c

 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拿到本机对应的NetNode
   rNodes, err := h.GetNetNodeByTopic(serverId, &req.SrcProc, req.Topic)
   h.printLog("rNodes:", rNodes, "err:", err)
   if err != nil {
      return nil, err
   }
   //2.将请求返送到对应的server,并等待返回值
   data, err := json.Marshal(*req)
   h.printLog("marshal(*req) err:", err)
   if err != nil {
      return nil, err
   }