mirror of
https://github.com/tendermint/tendermint.git
synced 2026-01-04 04:04:00 +00:00
fix receive
This commit is contained in:
@@ -400,7 +400,7 @@ func createMConnection(
|
||||
onReceive := func(chID byte, msgBytes []byte) {
|
||||
before := time.Now()
|
||||
defer func() {
|
||||
p.metrics.MessageReceiveTime.Observe(float64(time.Since(before)))
|
||||
p.metrics.MessageReceiveTime.Observe(time.Since(before).Seconds())
|
||||
}()
|
||||
reactor := reactorsByCh[chID]
|
||||
if reactor == nil {
|
||||
|
||||
Reference in New Issue
Block a user