diff options
| author | gluk256 <gluk256@users.noreply.github.com> | 2018-02-09 23:25:23 +0800 |
|---|---|---|
| committer | Péter Szilágyi <peterke@gmail.com> | 2018-02-09 23:25:23 +0800 |
| commit | 42628ba7eda25830653763ced060f702861d0887 (patch) | |
| tree | cf0fc13c7fc9fa005c58e6f87841e210fac4a40d /whisper/whisperv6/whisper.go | |
| parent | ccf808353794f835422e02446384bd627f045f1a (diff) | |
| download | dexon-42628ba7eda25830653763ced060f702861d0887.tar.gz dexon-42628ba7eda25830653763ced060f702861d0887.tar.zst dexon-42628ba7eda25830653763ced060f702861d0887.zip | |
whisper: bloom filter refactoring (#16046)
* whisper: bloom filter refactoring
* whisper: fixed full node
Diffstat (limited to 'whisper/whisperv6/whisper.go')
| -rw-r--r-- | whisper/whisperv6/whisper.go | 7 |
1 files changed, 1 insertions, 6 deletions
diff --git a/whisper/whisperv6/whisper.go b/whisper/whisperv6/whisper.go index d75ad04ac..600f9cb28 100644 --- a/whisper/whisperv6/whisper.go +++ b/whisper/whisperv6/whisper.go @@ -710,11 +710,7 @@ func (whisper *Whisper) runMessageLoop(p *Peer, rw p2p.MsgReadWriter) error { log.Warn("failed to decode bloom filter exchange message, peer will be disconnected", "peer", p.peer.ID(), "err", err) return errors.New("invalid bloom filter exchange message") } - if isFullNode(bloom) { - p.bloomFilter = nil - } else { - p.bloomFilter = bloom - } + p.setBloomFilter(bloom) case p2pMessageCode: // peer-to-peer message, sent directly to peer bypassing PoW checks, etc. // this message is not supposed to be forwarded to other peers, and @@ -1049,7 +1045,6 @@ func isFullNode(bloom []byte) bool { func bloomFilterMatch(filter, sample []byte) bool { if filter == nil { - // full node, accepts all messages return true } |