codex-storage/nim-codex-dht
1
0
Fork 0
mirror of https://github.com/codex-storage/nim-codex-dht.git synced 2025-01-09 19:35:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

metrics: add transport byte counters

Browse Source 
Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>

# Conflicts:
#	codexdht/private/eth/p2p/discoveryv5/transport.nim
This commit is contained in:
Csaba Kiraly 2024-10-10 11:43:23 +02:00
parent ffeeeeb3fb
commit 80cc069c5e
No known key found for this signature in database
GPG Key ID: 0FE274EE8C95166E
1 changed files with 16 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
codexdht/private/eth/p2p/discoveryv5/transport.nim
View File

@ -24,10 +24,14 @@ const
logScope: logScope:
topics = "discv5 transport" topics = "discv5 transport"
declarePublicCounter discovery_transport_tx, declarePublicCounter discovery_transport_tx_packets,
"Discovery transport messages sent", labels = ["state"] "Discovery transport packets sent", labels = ["state"]
declarePublicCounter discovery_transport_rx, declarePublicCounter discovery_transport_tx_bytes,
"Discovery transport messages received", labels = ["state"] "Discovery transport bytes sent", labels = ["state"]
declarePublicCounter discovery_transport_rx_packets,
"Discovery transport packets received", labels = ["state"]
declarePublicCounter discovery_transport_rx_bytes,
"Discovery transport bytes received", labels = ["state"]
type type
Transport* [Client] = ref object Transport* [Client] = ref object
@ -62,9 +66,11 @@ proc sendToA(t: Transport, a: Address, msg: seq[byte]) =
# nodes. Else the revalidation might end up clearing the routing tabl # nodes. Else the revalidation might end up clearing the routing tabl
# because of ping failures due to own network connection failure. # because of ping failures due to own network connection failure.
warn "Discovery send failed", msg = f.readError.msg warn "Discovery send failed", msg = f.readError.msg
discovery_transport_tx.inc(labelValues = ["failed"]) discovery_transport_tx_packets.inc(labelValues = ["failed"])
discovery_transport_tx_bytes.inc(msg.len.int64, labelValues = ["failed"])
) )
discovery_transport_tx.inc() discovery_transport_tx_packets.inc()
discovery_transport_tx_bytes.inc(msg.len.int64)
proc send(t: Transport, n: Node, data: seq[byte]) = proc send(t: Transport, n: Node, data: seq[byte]) =
doAssert(n.address.isSome()) doAssert(n.address.isSome())
@ -152,7 +158,8 @@ proc sendPending(t:Transport, toNode: Node):
t.pendingRequestsByNode.del(toNode.id) t.pendingRequestsByNode.del(toNode.id)
proc receive*(t: Transport, a: Address, packet: openArray[byte]) = proc receive*(t: Transport, a: Address, packet: openArray[byte]) =
discovery_transport_rx.inc() discovery_transport_rx_packets.inc()
discovery_transport_rx_bytes.inc(packet.len.int64)
let decoded = t.codec.decodePacket(a, packet) let decoded = t.codec.decodePacket(a, packet)
if decoded.isOk: if decoded.isOk:
let packet = decoded[] let packet = decoded[]
@ -224,7 +231,8 @@ proc receive*(t: Transport, a: Address, packet: openArray[byte]) =
else: else:
trace "address mismatch, not adding seen flag", node, address = a, nodeAddress = node.address.get() trace "address mismatch, not adding seen flag", node, address = a, nodeAddress = node.address.get()
else: else:
discovery_transport_rx.inc(labelValues = ["failed_decode"]) discovery_transport_rx_packets.inc(labelValues = ["failed_decode"])
discovery_transport_rx_bytes.inc(packet.len.int64, labelValues = ["failed_decode"])
trace "Packet decoding error", myport = t.bindAddress.port, error = decoded.error, address = a trace "Packet decoding error", myport = t.bindAddress.port, error = decoded.error, address = a
proc processClient[T](transp: DatagramTransport, raddr: TransportAddress): proc processClient[T](transp: DatagramTransport, raddr: TransportAddress):