mirrors/tendermint
1
0
Fork 0
mirror of https://github.com/tendermint/tendermint.git synced 2026-01-03 03:35:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix metric to be seconds

Browse Source
This commit is contained in:
William Banfield
2022-11-03 16:03:08 -04:00
parent 5fa49830e4
commit f7218259c5
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
p2p/peer.go
View File

@@ -67,7 +67,7 @@ func SendEnvelopeShim(p Peer, e Envelope, lg log.Logger) bool {
before := time.Now() before := time.Now()
defer func() { defer func() {
if pp, ok := p.(*peer); ok { if pp, ok := p.(*peer); ok {
pp.metrics.MessageSendTime.Observe(float64(time.Since(before))) pp.metrics.MessageSendTime.Observe(time.Since(before).Seconds())
} }
}() }()
/* /*
@@ -97,7 +97,7 @@ func TrySendEnvelopeShim(p Peer, e Envelope, lg log.Logger) bool {
before := time.Now() before := time.Now()
defer func() { defer func() {
if pp, ok := p.(*peer); ok { if pp, ok := p.(*peer); ok {
pp.metrics.MessageSendTime.Observe(float64(time.Since(before))) pp.metrics.MessageSendTime.Observe(time.Since(before).Seconds())
} }
}() }()
/* /*
@@ -528,7 +528,7 @@ func createMConnection(
onReceive := func(chID byte, msgBytes []byte) { onReceive := func(chID byte, msgBytes []byte) {
before := time.Now() before := time.Now()
defer func() { defer func() {
p.metrics.MessageReceiveTime.Observe(float64(time.Since(before))) p.metrics.MessageReceiveTime.Observe(time.Since(before).Seconds())
}() }()
reactor := reactorsByCh[chID] reactor := reactorsByCh[chID]
if reactor == nil { if reactor == nil {