This commit is contained in:
Nonoo 2020-10-25 21:12:25 +01:00
parent 2580312083
commit bee19b1bb9

View file

@ -112,12 +112,13 @@ func (p *pkt7Type) loop(s *streamCommon) {
for {
if p.timeoutTimer != nil {
select {
case <-p.timeoutTimer.C:
reportError(errors.New(s.name + "/ping timeout"))
case <-p.sendTicker.C:
if err := p.send(s); err != nil {
reportError(err)
}
case <-p.timeoutTimer.C:
reportError(errors.New(s.name + "/ping timeout"))
case <-p.periodicStopNeededChan:
p.periodicStopFinishedChan <- true
return