Merge 0fd6bf0a1c
into ffaa6be8a4
commit
05aa537950
|
@ -4438,7 +4438,10 @@ func (de *endpoint) heartbeat() {
|
||||||
de.mu.Lock()
|
de.mu.Lock()
|
||||||
defer de.mu.Unlock()
|
defer de.mu.Unlock()
|
||||||
|
|
||||||
|
if de.heartBeatTimer != nil {
|
||||||
|
de.heartBeatTimer.Stop()
|
||||||
de.heartBeatTimer = nil
|
de.heartBeatTimer = nil
|
||||||
|
}
|
||||||
|
|
||||||
if de.heartbeatDisabled {
|
if de.heartbeatDisabled {
|
||||||
// If control override to disable heartBeatTimer set, return early.
|
// If control override to disable heartBeatTimer set, return early.
|
||||||
|
|
Loading…
Reference in New Issue