From 37efcfc8e8d05005ded85351a5d1ca43495888bd Mon Sep 17 00:00:00 2001 From: me020523 Date: Wed, 20 Nov 2019 23:30:47 +0800 Subject: [PATCH] update node last ping/pong time --- p2p/discv5/net.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/p2p/discv5/net.go b/p2p/discv5/net.go index de7d8de6aa..9c36468745 100644 --- a/p2p/discv5/net.go +++ b/p2p/discv5/net.go @@ -1112,6 +1112,9 @@ func (net *Network) ping(n *Node, addr *net.UDPAddr) { n.pingTopics = net.ticketStore.regTopicSet() n.pingEcho = net.conn.sendPing(n, addr, n.pingTopics) net.timedEvent(respTimeout, n, pongTimeout) + + //update last ping sent to Node n + net.db.updateLastPing(n.ID, time.Now()) } func (net *Network) handlePing(n *Node, pkt *ingressPacket) { @@ -1140,6 +1143,9 @@ func (net *Network) handleKnownPong(n *Node, pkt *ingressPacket) error { } else { log.Trace("Failed to convert pong to ticket", "err", err) } + //update Node n last seen pong time + net.db.updateLastPong(n.ID, time.Now()) + n.pingEcho = nil n.pingTopics = nil return err