17
17
use std:: sync:: { Arc , mpsc, atomic} ;
18
18
use std:: collections:: { HashMap , BTreeMap } ;
19
19
use std:: io;
20
- use std:: ops:: Range ;
20
+ use std:: ops:: RangeInclusive ;
21
21
use std:: time:: Duration ;
22
22
use bytes:: Bytes ;
23
23
use devp2p:: NetworkService ;
@@ -615,9 +615,7 @@ pub trait ManageNetwork : Send + Sync {
615
615
/// Stop network
616
616
fn stop_network ( & self ) ;
617
617
/// Returns the minimum and maximum peers.
618
- /// Note that `range.end` is *exclusive*.
619
- // TODO: Range should be changed to RangeInclusive once stable (https://github.com/rust-lang/rust/pull/50758)
620
- fn num_peers_range ( & self ) -> Range < u32 > ;
618
+ fn num_peers_range ( & self ) -> RangeInclusive < u32 > ;
621
619
/// Get network context for protocol.
622
620
fn with_proto_context ( & self , proto : ProtocolId , f : & mut FnMut ( & NetworkContext ) ) ;
623
621
}
@@ -656,7 +654,7 @@ impl ManageNetwork for EthSync {
656
654
self . stop ( ) ;
657
655
}
658
656
659
- fn num_peers_range ( & self ) -> Range < u32 > {
657
+ fn num_peers_range ( & self ) -> RangeInclusive < u32 > {
660
658
self . network . num_peers_range ( )
661
659
}
662
660
@@ -935,7 +933,7 @@ impl ManageNetwork for LightSync {
935
933
self . network . stop ( ) ;
936
934
}
937
935
938
- fn num_peers_range ( & self ) -> Range < u32 > {
936
+ fn num_peers_range ( & self ) -> RangeInclusive < u32 > {
939
937
self . network . num_peers_range ( )
940
938
}
941
939
@@ -948,12 +946,12 @@ impl LightSyncProvider for LightSync {
948
946
fn peer_numbers ( & self ) -> PeerNumbers {
949
947
let ( connected, active) = self . proto . peer_count ( ) ;
950
948
let peers_range = self . num_peers_range ( ) ;
951
- debug_assert ! ( peers_range. end > peers_range. start) ;
949
+ debug_assert ! ( peers_range. end( ) > peers_range. start( ) ) ;
952
950
PeerNumbers {
953
951
connected : connected,
954
952
active : active,
955
- max : peers_range. end as usize - 1 ,
956
- min : peers_range. start as usize ,
953
+ max : * peers_range. end ( ) as usize - 1 ,
954
+ min : * peers_range. start ( ) as usize ,
957
955
}
958
956
}
959
957
0 commit comments