fix: deadlock caused by sending keepalive frame

Signed-off-by: Jianhui Zhao <[email protected]>
zhaojh329 · Dec 15, 2021 · 43ed146 · 43ed146
1 parent 0e7632d
commit 43ed146
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/device.go b/device.go
@@ -341,7 +341,9 @@ func (dev *device) writeLoop() {
 
  if now.Sub(lastHeartbeat) > heartbeatInterval-1 {
  lastHeartbeat = now
- dev.WriteMsg(msgTypeHeartbeat, []byte{})
+ if len(dev.send) < 1 {
+ dev.WriteMsg(msgTypeHeartbeat, []byte{})
+ }
  }
  }
  }