mirror of
https://github.com/tendermint/tendermint.git
synced 2026-01-10 06:57:24 +00:00
add timings
This commit is contained in:
@@ -259,7 +259,7 @@ func (p *peer) Send(chID byte, msgBytes []byte) bool {
|
||||
}
|
||||
before := time.Now()
|
||||
defer func() {
|
||||
p.metrics.MessageSendTime.Observe(float64(time.Since(before)))
|
||||
p.metrics.MessageSendTime.Observe(time.Since(before).Seconds())
|
||||
}()
|
||||
res := p.mconn.Send(chID, msgBytes)
|
||||
if res {
|
||||
@@ -282,7 +282,7 @@ func (p *peer) TrySend(chID byte, msgBytes []byte) bool {
|
||||
}
|
||||
before := time.Now()
|
||||
defer func() {
|
||||
p.metrics.MessageSendTime.Observe(float64(time.Since(before)))
|
||||
p.metrics.MessageSendTime.Observe(time.Since(before).Seconds())
|
||||
}()
|
||||
res := p.mconn.TrySend(chID, msgBytes)
|
||||
if res {
|
||||
|
||||
Reference in New Issue
Block a user