diff --git a/p2p/peer.go b/p2p/peer.go index cd36293c8b..e4482deae9 100644 --- a/p2p/peer.go +++ b/p2p/peer.go @@ -297,7 +297,7 @@ loop: func (p *Peer) pingLoop() { defer p.wg.Done() - ping := time.NewTicker(pingInterval) + ping := time.NewTimer(pingInterval) defer ping.Stop() for { @@ -307,6 +307,7 @@ func (p *Peer) pingLoop() { p.protoErr <- err return } + ping.Reset(pingInterval) case <-p.pingRecv: SendItems(p.rw, pongMsg)