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

add some tracing to the vm's blockstore copy

Browse Source
This commit is contained in:
whyrusleeping 2020-09-23 20:19:20 -07:00
parent b4e03d1759
commit 38e256cece
1 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
chain/vm/vm.go
View File

@ -546,7 +546,7 @@ func (vm *VM) Flush(ctx context.Context) (cid.Cid, error) {
return cid.Undef, xerrors.Errorf("flushing vm: %w", err) return cid.Undef, xerrors.Errorf("flushing vm: %w", err)
} }
if err := Copy(from, to, root); err != nil { if err := Copy(ctx, from, to, root); err != nil {
return cid.Undef, xerrors.Errorf("copying tree: %w", err) return cid.Undef, xerrors.Errorf("copying tree: %w", err)
} }
@ -600,9 +600,18 @@ func linksForObj(blk block.Block, cb func(cid.Cid)) error {
} }
} }
func Copy(from, to blockstore.Blockstore, root cid.Cid) error { func Copy(ctx context.Context, from, to blockstore.Blockstore, root cid.Cid) error {
ctx, span := trace.StartSpan(ctx, "vm.Copy")
defer span.End()
var numBlocks int
var totalCopySize int
var batch []block.Block var batch []block.Block
batchCp := func(blk block.Block) error { batchCp := func(blk block.Block) error {
numBlocks++
totalCopySize += len(blk.RawData())
batch = append(batch, blk) batch = append(batch, blk)
if len(batch) > 100 { if len(batch) > 100 {
if err := to.PutMany(batch); err != nil { if err := to.PutMany(batch); err != nil {
@ -623,6 +632,11 @@ func Copy(from, to blockstore.Blockstore, root cid.Cid) error {
} }
} }
span.AddAttributes(
trace.Int64Attribute("numBlocks", int64(numBlocks)),
trace.Int64Attribute("copySize", int64(totalCopySize)),
)
return nil return nil
} }