aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--core/bloombits/matcher.go12
-rw-r--r--core/bloombits/matcher_test.go5
2 files changed, 7 insertions, 10 deletions
diff --git a/core/bloombits/matcher.go b/core/bloombits/matcher.go
index df0967a12..f3ed405a6 100644
--- a/core/bloombits/matcher.go
+++ b/core/bloombits/matcher.go
@@ -17,6 +17,7 @@
package bloombits
import (
+ "bytes"
"errors"
"math"
"sort"
@@ -171,15 +172,6 @@ func (m *Matcher) Start(begin, end uint64, results chan uint64) (*MatcherSession
}
// Iterate over all the blocks in the section and return the matching ones
for i := first; i <= last; i++ {
- // If the bitset is nil, we're a special match-all cornercase
- if res.bitset == nil {
- select {
- case <-session.quit:
- return
- case results <- i:
- }
- continue
- }
// Skip the entire byte if no matches are found inside
next := res.bitset[(i-sectionStart)/8]
if next == 0 {
@@ -221,7 +213,7 @@ func (m *Matcher) run(begin, end uint64, buffer int, session *MatcherSession) ch
select {
case <-session.quit:
return
- case source <- &partialMatches{i, nil}:
+ case source <- &partialMatches{i, bytes.Repeat([]byte{0xff}, int(m.sectionSize/8))}:
}
}
}()
diff --git a/core/bloombits/matcher_test.go b/core/bloombits/matcher_test.go
index 177e1b792..f0198c4e3 100644
--- a/core/bloombits/matcher_test.go
+++ b/core/bloombits/matcher_test.go
@@ -51,6 +51,11 @@ func TestMatcherRandom(t *testing.T) {
}
}
+// Tests that matching on everything doesn't crash (special case internally).
+func TestWildcardMatcher(t *testing.T) {
+ testMatcherBothModes(t, nil, 10000, 0)
+}
+
// makeRandomIndexes generates a random filter system, composed on multiple filter
// criteria, each having one bloom list component for the address and arbitrarilly
// many topic bloom list components.