mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-08-20 10:52:25 +00:00
Revert "p2p/discover: add traffic metrics (#27008)"
This reverts commit 11fafa4b88.
This commit is contained in:
parent
5e06356bd5
commit
4a282049b9
3 changed files with 2 additions and 67 deletions
|
|
@ -1,65 +0,0 @@
|
||||||
// Copyright 2023 The go-ethereum Authors
|
|
||||||
// This file is part of the go-ethereum library.
|
|
||||||
//
|
|
||||||
// The go-ethereum library is free software: you can redistribute it and/or modify
|
|
||||||
// it under the terms of the GNU Lesser General Public License as published by
|
|
||||||
// the Free Software Foundation, either version 3 of the License, or
|
|
||||||
// (at your option) any later version.
|
|
||||||
//
|
|
||||||
// The go-ethereum library is distributed in the hope that it will be useful,
|
|
||||||
// but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
||||||
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
||||||
// GNU Lesser General Public License for more details.
|
|
||||||
//
|
|
||||||
// You should have received a copy of the GNU Lesser General Public License
|
|
||||||
// along with the go-ethereum library. If not, see <http://www.gnu.org/licenses/>.
|
|
||||||
|
|
||||||
package discover
|
|
||||||
|
|
||||||
import (
|
|
||||||
"net"
|
|
||||||
|
|
||||||
"github.com/ethereum/go-ethereum/metrics"
|
|
||||||
)
|
|
||||||
|
|
||||||
const (
|
|
||||||
moduleName = "discover"
|
|
||||||
// ingressMeterName is the prefix of the per-packet inbound metrics.
|
|
||||||
ingressMeterName = moduleName + "/ingress"
|
|
||||||
|
|
||||||
// egressMeterName is the prefix of the per-packet outbound metrics.
|
|
||||||
egressMeterName = moduleName + "/egress"
|
|
||||||
)
|
|
||||||
|
|
||||||
var (
|
|
||||||
ingressTrafficMeter = metrics.NewRegisteredMeter(ingressMeterName, nil)
|
|
||||||
egressTrafficMeter = metrics.NewRegisteredMeter(egressMeterName, nil)
|
|
||||||
)
|
|
||||||
|
|
||||||
// meteredConn is a wrapper around a net.UDPConn that meters both the
|
|
||||||
// inbound and outbound network traffic.
|
|
||||||
type meteredUdpConn struct {
|
|
||||||
UDPConn
|
|
||||||
}
|
|
||||||
|
|
||||||
func newMeteredConn(conn UDPConn) UDPConn {
|
|
||||||
// Short circuit if metrics are disabled
|
|
||||||
if !metrics.Enabled {
|
|
||||||
return conn
|
|
||||||
}
|
|
||||||
return &meteredUdpConn{UDPConn: conn}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Read delegates a network read to the underlying connection, bumping the udp ingress traffic meter along the way.
|
|
||||||
func (c *meteredUdpConn) ReadFromUDP(b []byte) (n int, addr *net.UDPAddr, err error) {
|
|
||||||
n, addr, err = c.UDPConn.ReadFromUDP(b)
|
|
||||||
ingressTrafficMeter.Mark(int64(n))
|
|
||||||
return n, addr, err
|
|
||||||
}
|
|
||||||
|
|
||||||
// Write delegates a network write to the underlying connection, bumping the udp egress traffic meter along the way.
|
|
||||||
func (c *meteredUdpConn) WriteToUDP(b []byte, addr *net.UDPAddr) (n int, err error) {
|
|
||||||
n, err = c.UDPConn.WriteToUDP(b, addr)
|
|
||||||
egressTrafficMeter.Mark(int64(n))
|
|
||||||
return n, err
|
|
||||||
}
|
|
||||||
|
|
@ -130,7 +130,7 @@ func ListenV4(c UDPConn, ln *enode.LocalNode, cfg Config) (*UDPv4, error) {
|
||||||
cfg = cfg.withDefaults()
|
cfg = cfg.withDefaults()
|
||||||
closeCtx, cancel := context.WithCancel(context.Background())
|
closeCtx, cancel := context.WithCancel(context.Background())
|
||||||
t := &UDPv4{
|
t := &UDPv4{
|
||||||
conn: newMeteredConn(c),
|
conn: c,
|
||||||
priv: cfg.PrivateKey,
|
priv: cfg.PrivateKey,
|
||||||
netrestrict: cfg.NetRestrict,
|
netrestrict: cfg.NetRestrict,
|
||||||
localNode: ln,
|
localNode: ln,
|
||||||
|
|
|
||||||
|
|
@ -142,7 +142,7 @@ func newUDPv5(conn UDPConn, ln *enode.LocalNode, cfg Config) (*UDPv5, error) {
|
||||||
cfg = cfg.withDefaults()
|
cfg = cfg.withDefaults()
|
||||||
t := &UDPv5{
|
t := &UDPv5{
|
||||||
// static fields
|
// static fields
|
||||||
conn: newMeteredConn(conn),
|
conn: conn,
|
||||||
localNode: ln,
|
localNode: ln,
|
||||||
db: ln.Database(),
|
db: ln.Database(),
|
||||||
netrestrict: cfg.NetRestrict,
|
netrestrict: cfg.NetRestrict,
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue