From a64ac7f81e75c64467e786c7d06e809575c70be5 Mon Sep 17 00:00:00 2001 From: Jimmy Hu Date: Fri, 5 Apr 2019 11:29:41 +0800 Subject: add log --- .../dexon-foundation/dexon-consensus/core/consensus.go | 15 +++++++++++++++ 1 file changed, 15 insertions(+) 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)) -- cgit v1.2.3