liuxiaolong
2021-01-07 7c54f5867f4add59e5a5c046eecd5e83781b628e
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 {
   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")