From 40673b2e959ec5a632d1b5539c0a2ffcfa133016 Mon Sep 17 00:00:00 2001
From: liuxiaolong <liuxiaolong@aiotlink.com>
Date: 星期三, 23 十二月 2020 10:59:26 +0800
Subject: [PATCH] 心跳发送添加超时设置
---
hbusc.go | 5 +++--
1 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/hbusc.go b/hbusc.go
index 75c9ae2..6de8b80 100644
--- a/hbusc.go
+++ b/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)
}
}
--
Gitblit v1.8.0