peer-conn-msg-writer.go | 4 +++- diff --git a/peer-conn-msg-writer.go b/peer-conn-msg-writer.go index 16892546e77618de610199d884324000a9c442e1..dff4eb9ec8f98405821ffa36ae9122dcb1e2b67d 100644 --- a/peer-conn-msg-writer.go +++ b/peer-conn-msg-writer.go @@ -79,14 +79,16 @@ for { if cn.closed.IsSet() { return } + keepAlive := false if cn.writeBuffer.Len() == 0 { func() { cn.mu.Unlock() defer cn.mu.Lock() cn.fillWriteBuffer() + keepAlive = cn.keepAlive() }() } - if cn.writeBuffer.Len() == 0 && time.Since(lastWrite) >= keepAliveTimeout && cn.keepAlive() { + if cn.writeBuffer.Len() == 0 && time.Since(lastWrite) >= keepAliveTimeout && keepAlive { cn.writeBuffer.Write(pp.Message{Keepalive: true}.MustMarshalBinary()) torrent.Add("written keepalives", 1) }