vacp2p
/
nim-libp2p
mirror of https://github.com/vacp2p/nim-libp2p.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix: yamux metrics (#1022)

This commit is contained in:
Ludovic Chenut 2024-02-08 12:36:58 +01:00 committed by GitHub
parent 04af0c4323
commit c1dfd58772
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
libp2p/muxers/yamux/yamux.nim
View File

@ -29,9 +29,9 @@ const
when defined(libp2p_yamux_metrics): when defined(libp2p_yamux_metrics):
declareGauge(libp2p_yamux_channels, "yamux channels", labels = ["initiator", "peer"]) declareGauge(libp2p_yamux_channels, "yamux channels", labels = ["initiator", "peer"])
declareHistogram libp2p_yamux_send_queue, "message send queue length (in byte)", declareHistogram libp2p_yamux_send_queue, "message send queue length (in byte)",
buckets = [0.0, 100.0, 250.0, 1000.0, 2000.0, 1600.0, 6400.0, 25600.0, 256000.0] buckets = [0.0, 100.0, 250.0, 1000.0, 2000.0, 3200.0, 6400.0, 25600.0, 256000.0]
declareHistogram libp2p_yamux_recv_queue, "message recv queue length (in byte)", declareHistogram libp2p_yamux_recv_queue, "message recv queue length (in byte)",
buckets = [0.0, 100.0, 250.0, 1000.0, 2000.0, 1600.0, 6400.0, 25600.0, 256000.0] buckets = [0.0, 100.0, 250.0, 1000.0, 2000.0, 3200.0, 6400.0, 25600.0, 256000.0]
type type
YamuxError* = object of CatchableError YamuxError* = object of CatchableError
@ -370,7 +370,7 @@ method write*(channel: YamuxChannel, msg: seq[byte]): Future[void] =
return result return result
channel.sendQueue.add((msg, 0, result)) channel.sendQueue.add((msg, 0, result))
when defined(libp2p_yamux_metrics): when defined(libp2p_yamux_metrics):
libp2p_yamux_recv_queue.observe(channel.lengthSendQueue().int64) libp2p_yamux_send_queue.observe(channel.lengthSendQueue().int64)
asyncSpawn channel.trySend() asyncSpawn channel.trySend()
proc open(channel: YamuxChannel) {.async.} = proc open(channel: YamuxChannel) {.async.} =