diff options
| -rw-r--r-- | vendor/github.com/dexon-foundation/dexon-consensus/core/consensus.go | 15 |
1 files changed, 15 insertions, 0 deletions
diff --git a/vendor/github.com/dexon-foundation/dexon-consensus/core/consensus.go b/vendor/github.com/dexon-foundation/dexon-consensus/core/consensus.go index a1def58e0..2e457d026 100644 --- a/vendor/github.com/dexon-foundation/dexon-consensus/core/consensus.go +++ b/vendor/github.com/dexon-foundation/dexon-consensus/core/consensus.go @@ -1227,8 +1227,13 @@ func (con *Consensus) deliverNetworkMsg() { func (con *Consensus) processMsg() { defer con.waitGroup.Done() + ch := make(chan struct{}) + go func() { + <-ch + }() MessageLoop: for { + ch <- struct{}{} select { case <-con.ctx.Done(): return @@ -1248,6 +1253,16 @@ MessageLoop: return } } + + start := time.Now() + go func(start time.Time, msg interface{}) { + <-ch + if time.Since(start) > 1*time.Millisecond { + con.logger.Debug("Consensus core handling message", + "time", time.Since(start), + "msg", msg) + } + }(start, msg) switch val := msg.(type) { case *selfAgreementResult: con.baMgr.touchAgreementResult((*types.AgreementResult)(val)) |