心跳发送添加超时设置

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)
        }
    }