mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-08-17 09:23:48 +00:00
whisper: bloom filter logic introduced
This commit is contained in:
parent
3f40b22dac
commit
aef7580bea
1 changed files with 15 additions and 3 deletions
|
|
@ -113,17 +113,29 @@ func (api *PublicWhisperAPI) Info(ctx context.Context) Info {
|
||||||
// SetMaxMessageSize sets the maximum message size that is accepted.
|
// SetMaxMessageSize sets the maximum message size that is accepted.
|
||||||
// Upper limit is defined by MaxMessageSize.
|
// Upper limit is defined by MaxMessageSize.
|
||||||
func (api *PublicWhisperAPI) SetMaxMessageSize(ctx context.Context, size uint32) (bool, error) {
|
func (api *PublicWhisperAPI) SetMaxMessageSize(ctx context.Context, size uint32) (bool, error) {
|
||||||
return true, api.w.SetMaxMessageSize(size)
|
err := api.w.SetMaxMessageSize(size)
|
||||||
|
if err != nil {
|
||||||
|
return false, err
|
||||||
|
}
|
||||||
|
return true, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// SetMinPow sets the minimum PoW, and notifies the peers.
|
// SetMinPow sets the minimum PoW, and notifies the peers.
|
||||||
func (api *PublicWhisperAPI) SetMinPoW(ctx context.Context, pow float64) (bool, error) {
|
func (api *PublicWhisperAPI) SetMinPoW(ctx context.Context, pow float64) (bool, error) {
|
||||||
return true, api.w.SetMinimumPoW(pow)
|
err := api.w.SetMinimumPoW(pow)
|
||||||
|
if err != nil {
|
||||||
|
return false, err
|
||||||
|
}
|
||||||
|
return true, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// SetBloomFilter sets the new value of bloom filter, and notifies the peers.
|
// SetBloomFilter sets the new value of bloom filter, and notifies the peers.
|
||||||
func (api *PublicWhisperAPI) SetBloomFilter(ctx context.Context, bloom hexutil.Bytes) (bool, error) {
|
func (api *PublicWhisperAPI) SetBloomFilter(ctx context.Context, bloom hexutil.Bytes) (bool, error) {
|
||||||
return true, api.w.SetBloomFilter(bloom)
|
err := api.w.SetBloomFilter(bloom)
|
||||||
|
if err != nil {
|
||||||
|
return false, err
|
||||||
|
}
|
||||||
|
return true, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// MarkTrustedPeer marks a peer trusted, which will allow it to send historic (expired) messages.
|
// MarkTrustedPeer marks a peer trusted, which will allow it to send historic (expired) messages.
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue