mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-08-17 17:33:47 +00:00
Merge 0fa3b44064 into 4e61ed02e2
This commit is contained in:
commit
fb2ca5bad0
1 changed files with 25 additions and 0 deletions
|
|
@ -892,3 +892,28 @@ func TestBloom(t *testing.T) {
|
||||||
t.Fatalf("retireved wrong bloom filter")
|
t.Fatalf("retireved wrong bloom filter")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestBloomFilterIsChanged(t *testing.T) {
|
||||||
|
w := New(&DefaultConfig)
|
||||||
|
w.SetBloomFilter(make([]byte, 64))
|
||||||
|
filter1, err := generateFilter(t, true)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatalf("failed generateMessageParams with seed %d: %s.", seed, err)
|
||||||
|
}
|
||||||
|
bloom := w.BloomFilter()
|
||||||
|
id, err := w.Subscribe(filter1)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
bloomSubscribed := w.BloomFilter()
|
||||||
|
if bloomFilterMatch(bloom, bloomSubscribed) {
|
||||||
|
t.Fatalf("expected %v != %v", bloom, bloomSubscribed)
|
||||||
|
}
|
||||||
|
if err := w.Unsubscribe(id); err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
bloomUnsub := w.BloomFilter()
|
||||||
|
if bloomFilterMatch(bloomUnsub, bloomSubscribed) {
|
||||||
|
t.Fatalf("expected %v != %v", bloomUnsub, bloomSubscribed)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue