mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-07-23 05:06:43 +00:00
core/rawdb: add read meter
This commit is contained in:
parent
a86e67dfa8
commit
fb2e88623d
1 changed files with 3 additions and 0 deletions
|
|
@ -1148,6 +1148,7 @@ func (t *freezerTable) RetrieveBytes(item, offset, length uint64) ([]byte, error
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
t.readMeter.Mark(int64(length))
|
||||||
return buf, nil
|
return buf, nil
|
||||||
} else {
|
} else {
|
||||||
// If compressed, read the full item, decompress, then slice.
|
// If compressed, read the full item, decompress, then slice.
|
||||||
|
|
@ -1158,6 +1159,8 @@ func (t *freezerTable) RetrieveBytes(item, offset, length uint64) ([]byte, error
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
t.readMeter.Mark(int64(itemSize))
|
||||||
|
|
||||||
data, err := snappy.Decode(nil, buf)
|
data, err := snappy.Decode(nil, buf)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue