sync: blocked filter
This commit is contained in:
@@ -413,13 +413,13 @@ impl StateSync {
|
|||||||
.and_then(|(_, addr)| *addr);
|
.and_then(|(_, addr)| *addr);
|
||||||
let peer = available_pibd_peers()
|
let peer = available_pibd_peers()
|
||||||
.outbound()
|
.outbound()
|
||||||
.non_blocked()
|
.with_filter(|p| !peers.is_blocked(p.info.addr))
|
||||||
.exclude(excluded_peer)
|
.exclude(excluded_peer)
|
||||||
.choose_random()
|
.choose_random()
|
||||||
.or_else(|| {
|
.or_else(|| {
|
||||||
available_pibd_peers()
|
available_pibd_peers()
|
||||||
.inbound()
|
.inbound()
|
||||||
.non_blocked()
|
.with_filter(|p| !peers.is_blocked(p.info.addr))
|
||||||
.exclude(excluded_peer)
|
.exclude(excluded_peer)
|
||||||
.choose_random()
|
.choose_random()
|
||||||
.or_else(|| {
|
.or_else(|| {
|
||||||
|
|||||||
Reference in New Issue
Block a user