torrent.go | 4 ++++ diff --git a/torrent.go b/torrent.go index 82dfc0a54acf9ccea2d952faf0409ef7037f6798..bb68cfc1e7af06dedb710a38341bc301fbeea1d9 100644 --- a/torrent.go +++ b/torrent.go @@ -2777,6 +2777,7 @@ func (t *Torrent) handleReceivedUtHolepunchMsg(msg utHolepunch.Msg, sender *PeerConn) error { switch msg.MsgType { case utHolepunch.Rendezvous: t.logger.Printf("got holepunch rendezvous request for %v from %p", msg.AddrPort, sender) + torrent.Add("holepunch rendezvous messages received", 1) sendMsg := sendUtHolepunchMsg senderAddrPort, err := sender.remoteDialAddrPort() if err != nil { @@ -2804,6 +2805,7 @@ sendMsg(pc, utHolepunch.Connect, senderAddrPort, 0) } return nil case utHolepunch.Connect: + torrent.Add("holepunch connect messages received", 1) t.logger.Printf("got holepunch connect request for %v from %p", msg.AddrPort, sender) opts := outgoingConnOpts{ peerInfo: PeerInfo{ @@ -2822,6 +2824,7 @@ } initiateConn(opts, true) return nil case utHolepunch.Error: + torrent.Add("holepunch error messages received", 1) t.logger.Levelf(log.Debug, "received ut_holepunch error message from %v: %v", sender, msg.ErrCode) return nil default: @@ -2842,6 +2845,7 @@ } } t.logger.Levelf(log.Debug, "sent ut_holepunch rendezvous message to %v for %v", pc, addrPort) sendUtHolepunchMsg(pc, utHolepunch.Rendezvous, addrPort, 0) + torrent.Add("holepunch rendezvous messages sent", 1) rzsSent++ } if rzsSent == 0 {