aboutsummaryrefslogtreecommitdiffstats
path: root/core
diff options
context:
space:
mode:
authorgary rong <garyrong0905@gmail.com>2018-07-18 18:41:36 +0800
committerPéter Szilágyi <peterke@gmail.com>2018-07-18 18:41:36 +0800
commitdcdd57df6282a6cd43a6407e8626a5cdcca60482 (patch)
treefc4d937e39125f5308ec170cdafe29cb799b2792 /core
parent323428865f65be0c637dfc35fc9728f3108c040a (diff)
downloaddexon-dcdd57df6282a6cd43a6407e8626a5cdcca60482.tar.gz
dexon-dcdd57df6282a6cd43a6407e8626a5cdcca60482.tar.zst
dexon-dcdd57df6282a6cd43a6407e8626a5cdcca60482.zip
core, ethdb: two tiny fixes (#17183)
* ethdb: fix memory database * core: fix bloombits checking * core: minor polish
Diffstat (limited to 'core')
-rw-r--r--core/bloombits/generator.go30
1 files changed, 18 insertions, 12 deletions
diff --git a/core/bloombits/generator.go b/core/bloombits/generator.go
index 540085450..ae07481ad 100644
--- a/core/bloombits/generator.go
+++ b/core/bloombits/generator.go
@@ -22,16 +22,22 @@ import (
"github.com/ethereum/go-ethereum/core/types"
)
-// errSectionOutOfBounds is returned if the user tried to add more bloom filters
-// to the batch than available space, or if tries to retrieve above the capacity,
-var errSectionOutOfBounds = errors.New("section out of bounds")
+var (
+ // errSectionOutOfBounds is returned if the user tried to add more bloom filters
+ // to the batch than available space, or if tries to retrieve above the capacity.
+ errSectionOutOfBounds = errors.New("section out of bounds")
+
+ // errBloomBitOutOfBounds is returned if the user tried to retrieve specified
+ // bit bloom above the capacity.
+ errBloomBitOutOfBounds = errors.New("bloom bit out of bounds")
+)
// Generator takes a number of bloom filters and generates the rotated bloom bits
// to be used for batched filtering.
type Generator struct {
blooms [types.BloomBitLength][]byte // Rotated blooms for per-bit matching
sections uint // Number of sections to batch together
- nextBit uint // Next bit to set when adding a bloom
+ nextSec uint // Next section to set when adding a bloom
}
// NewGenerator creates a rotated bloom generator that can iteratively fill a
@@ -51,15 +57,15 @@ func NewGenerator(sections uint) (*Generator, error) {
// in memory accordingly.
func (b *Generator) AddBloom(index uint, bloom types.Bloom) error {
// Make sure we're not adding more bloom filters than our capacity
- if b.nextBit >= b.sections {
+ if b.nextSec >= b.sections {
return errSectionOutOfBounds
}
- if b.nextBit != index {
+ if b.nextSec != index {
return errors.New("bloom filter with unexpected index")
}
// Rotate the bloom and insert into our collection
- byteIndex := b.nextBit / 8
- bitMask := byte(1) << byte(7-b.nextBit%8)
+ byteIndex := b.nextSec / 8
+ bitMask := byte(1) << byte(7-b.nextSec%8)
for i := 0; i < types.BloomBitLength; i++ {
bloomByteIndex := types.BloomByteLength - 1 - i/8
@@ -69,7 +75,7 @@ func (b *Generator) AddBloom(index uint, bloom types.Bloom) error {
b.blooms[i][byteIndex] |= bitMask
}
}
- b.nextBit++
+ b.nextSec++
return nil
}
@@ -77,11 +83,11 @@ func (b *Generator) AddBloom(index uint, bloom types.Bloom) error {
// Bitset returns the bit vector belonging to the given bit index after all
// blooms have been added.
func (b *Generator) Bitset(idx uint) ([]byte, error) {
- if b.nextBit != b.sections {
+ if b.nextSec != b.sections {
return nil, errors.New("bloom not fully generated yet")
}
- if idx >= b.sections {
- return nil, errSectionOutOfBounds
+ if idx >= types.BloomBitLength {
+ return nil, errBloomBitOutOfBounds
}
return b.blooms[idx], nil
}