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

Merge pull request #3284 from filecoin-project/misc/stats-gas-limit

Browse Source 
Add gas_limit_uniq_total to stats
This commit is contained in:
Łukasz Magiera 2020-08-25 17:49:59 +02:00 committed by GitHub
commit 9d67c16ab9
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
tools/stats/metrics.go
View File

@ -138,6 +138,8 @@ func RecordTipsetPoints(ctx context.Context, api api.FullNode, pl *PointList, ti
pl.AddPoint(p) pl.AddPoint(p)
totalGasLimit := int64(0) totalGasLimit := int64(0)
totalUniqGasLimit := int64(0)
seen := make(map[cid.Cid]struct{})
for _, blockheader := range tipset.Blocks() { for _, blockheader := range tipset.Blocks() {
bs, err := blockheader.Serialize() bs, err := blockheader.Serialize()
if err != nil { if err != nil {
@ -155,14 +157,26 @@ func RecordTipsetPoints(ctx context.Context, api api.FullNode, pl *PointList, ti
return xerrors.Errorf("ChainGetBlockMessages failed: %w", msgs) return xerrors.Errorf("ChainGetBlockMessages failed: %w", msgs)
} }
for _, m := range msgs.BlsMessages { for _, m := range msgs.BlsMessages {
c := m.Cid()
totalGasLimit += m.GasLimit totalGasLimit += m.GasLimit
if _, ok := seen[c]; !ok {
totalUniqGasLimit += m.GasLimit
seen[c] = struct{}{}
}
} }
for _, m := range msgs.SecpkMessages { for _, m := range msgs.SecpkMessages {
c := m.Cid()
totalGasLimit += m.Message.GasLimit totalGasLimit += m.Message.GasLimit
if _, ok := seen[c]; !ok {
totalUniqGasLimit += m.Message.GasLimit
seen[c] = struct{}{}
}
} }
} }
p = NewPoint("chain.gas_limit_total", totalGasLimit) p = NewPoint("chain.gas_limit_total", totalGasLimit)
pl.AddPoint(p) pl.AddPoint(p)
p = NewPoint("chain.gas_limit_uniq_total", totalUniqGasLimit)
pl.AddPoint(p)
return nil return nil
} }