心跳发送添加超时设置

liuxiaolong

2020-12-23 40673b2e959ec5a632d1b5539c0a2ffcfa133016

 hbusc.go

@@ -315,12 +315,13 @@
      hbAddr := append([]bhomebus.NetNode{}, bhomebus.NetNode{
         Key: h.sockHB.peer,
      })
      n := h.sockHB.sock.Sendandrecv(hbAddr, hbd, &rMsg) //n代表成功发送的节点的个数
      h.printLog("start send heartbeat")
      n := h.sockHB.sock.SendandrecvTimeout(hbAddr, hbd, &rMsg, h.conf.sendTimeOut) //n代表成功发送的节点的个数
      h.printLog("sockHB.Sendandrecv n:", n, "len(rMsg):", len(rMsg))

      if n > 0 {
         return nil
      } else {
         h.printLog("sockHB.Sendandrecv n:", n, "len(rMsg):", len(rMsg))
         return fmt.Errorf("sockHB Sendandrecv ret n:%d", n)
      }
   }