cerc-io/lotus
10
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

events: Basic tracing

Browse Source
This commit is contained in:
Łukasz Magiera 2019-11-05 15:36:44 +01:00
parent eb28c45c00
commit 4c4c2095a6
1 changed files with 28 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
chain/events/events_height.go
View File

@ -2,6 +2,7 @@ package events
import ( import (
"context" "context"
"go.opencensus.io/trace"
"sync" "sync"
"github.com/filecoin-project/lotus/chain/types" "github.com/filecoin-project/lotus/chain/types"
@ -23,13 +24,24 @@ type heightEvents struct {
} }
func (e *heightEvents) headChangeAt(rev, app []*types.TipSet) error { func (e *heightEvents) headChangeAt(rev, app []*types.TipSet) error {
ctx, span := trace.StartSpan(e.ctx, "events.HeightHeadChange")
defer span.End()
span.AddAttributes(trace.Int64Attribute("endHeight", int64(app[0].Height())))
span.AddAttributes(trace.Int64Attribute("reverts", int64(len(rev))))
span.AddAttributes(trace.Int64Attribute("applies", int64(len(app))))
for _, ts := range rev { for _, ts := range rev {
// TODO: log error if h below gcconfidence // TODO: log error if h below gcconfidence
// revert height-based triggers // revert height-based triggers
revert := func(h uint64, ts *types.TipSet) { revert := func(h uint64, ts *types.TipSet) {
for _, tid := range e.htHeights[h] { for _, tid := range e.htHeights[h] {
err := e.heightTriggers[tid].revert(e.ctx, ts) ctx, span := trace.StartSpan(ctx, "events.HeightRevert")
err := e.heightTriggers[tid].revert(ctx, ts)
span.End()
if err != nil { if err != nil {
log.Errorf("reverting chain trigger (@H %d): %s", h, err) log.Errorf("reverting chain trigger (@H %d): %s", h, err)
} }
@ -77,7 +89,13 @@ func (e *heightEvents) headChangeAt(rev, app []*types.TipSet) error {
return err return err
} }
if err := hnd.handle(e.ctx, incTs, h); err != nil { ctx, span := trace.StartSpan(ctx, "events.HeightApply")
span.AddAttributes(trace.BoolAttribute("immediate", false))
err = hnd.handle(ctx, incTs, h)
span.End()
if err != nil {
log.Errorf("chain trigger (@H %d, called @ %d) failed: %s", triggerH, ts.Height(), err) log.Errorf("chain trigger (@H %d, called @ %d) failed: %s", triggerH, ts.Height(), err)
} }
} }
@ -128,9 +146,16 @@ func (e *heightEvents) ChainAt(hnd HeightHandler, rev RevertHandler, confidence
} }
e.lk.Unlock() e.lk.Unlock()
if err := hnd(e.ctx, ts, bestH); err != nil { ctx, span := trace.StartSpan(e.ctx, "events.HeightApply")
span.AddAttributes(trace.BoolAttribute("immediate", true))
err = hnd(ctx, ts, bestH)
span.End()
if err != nil {
return err return err
} }
e.lk.Lock() e.lk.Lock()
bestH = e.tsc.best().Height() bestH = e.tsc.best().Height()
} }