forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-10 14:03:46 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

content validation metrics

Browse source
This commit is contained in:
Rafael Sampaio 2024-10-18 00:19:22 -03:00
parent e85b17cf37
commit c9ddfbf290
2 changed files with 14 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
p2p/discover/portal_protocol.go
View file

@ -1410,12 +1410,18 @@ func (p *PortalProtocol) handleOffer(id enode.ID, addr *net.UDPAddr, request *po
func (p *PortalProtocol) handleOfferedContents(id enode.ID, keys [][]byte, payload []byte) error { func (p *PortalProtocol) handleOfferedContents(id enode.ID, keys [][]byte, payload []byte) error {
contents, err := decodeContents(payload) contents, err := decodeContents(payload)
if err != nil { if err != nil {
if metrics.Enabled {
p.portalMetrics.contentInvalidated.Inc(1)
}
return err return err
} }
keyLen := len(keys) keyLen := len(keys)
contentLen := len(contents) contentLen := len(contents)
if keyLen != contentLen { if keyLen != contentLen {
if metrics.Enabled {
p.portalMetrics.contentInvalidated.Inc(1)
}
return fmt.Errorf("content keys len %d doesn't match content values len %d", keyLen, contentLen) return fmt.Errorf("content keys len %d doesn't match content values len %d", keyLen, contentLen)
} }
@ -1427,6 +1433,9 @@ func (p *PortalProtocol) handleOfferedContents(id enode.ID, keys [][]byte, paylo
p.contentQueue <- contentElement p.contentQueue <- contentElement
if metrics.Enabled {
p.portalMetrics.contentValidated.Inc(1)
}
return nil return nil
} }

5
p2p/discover/portal_protocol_metrics.go
View file

@ -30,6 +30,9 @@ type portalMetrics struct {
utpOutFailTx metrics.Counter utpOutFailTx metrics.Counter
utpOutFailShutdown metrics.Counter utpOutFailShutdown metrics.Counter
utpOutSuccess metrics.Counter utpOutSuccess metrics.Counter
contentValidated metrics.Counter
contentInvalidated metrics.Counter
} }
func newPortalMetrics(protocolName string) *portalMetrics { func newPortalMetrics(protocolName string) *portalMetrics {
@ -58,5 +61,7 @@ func newPortalMetrics(protocolName string) *portalMetrics {
utpOutFailTx: metrics.NewRegisteredCounter("portal/"+protocolName+"/utp/outbound/fail_tx", nil), utpOutFailTx: metrics.NewRegisteredCounter("portal/"+protocolName+"/utp/outbound/fail_tx", nil),
utpOutFailShutdown: metrics.NewRegisteredCounter("portal/"+protocolName+"/utp/outbound/fail_shutdown", nil), utpOutFailShutdown: metrics.NewRegisteredCounter("portal/"+protocolName+"/utp/outbound/fail_shutdown", nil),
utpOutSuccess: metrics.NewRegisteredCounter("portal/"+protocolName+"/utp/outbound/success", nil), utpOutSuccess: metrics.NewRegisteredCounter("portal/"+protocolName+"/utp/outbound/success", nil),
contentValidated: metrics.NewRegisteredCounter("portal/"+protocolName+"/content/validated", nil),
contentInvalidated: metrics.NewRegisteredCounter("portal/"+protocolName+"/content/invalidated", nil),
} }
} }