|
@@ -427,10 +427,11 @@ func (s *Session) Heartbeat(i time.Duration) {
|
|
s.heartbeatLock.Unlock()
|
|
s.heartbeatLock.Unlock()
|
|
return
|
|
return
|
|
}
|
|
}
|
|
- s.heartbeatRunning = true
|
|
|
|
- defer func() { s.heartbeatRunning = false }()
|
|
|
|
s.heartbeatLock.Unlock()
|
|
s.heartbeatLock.Unlock()
|
|
|
|
|
|
|
|
+ defer func() { s.heartbeatRunning = false }()
|
|
|
|
+ s.heartbeatRunning = true
|
|
|
|
+
|
|
// send first heartbeat immediately because lag could put the
|
|
// send first heartbeat immediately because lag could put the
|
|
// first heartbeat outside the required heartbeat interval window
|
|
// first heartbeat outside the required heartbeat interval window
|
|
ticker := time.NewTicker(i * time.Millisecond)
|
|
ticker := time.NewTicker(i * time.Millisecond)
|