pezkuwichain/pezkuwi-subxt
1
0
Fork 0
mirror of https://github.com/pezkuwichain/pezkuwi-subxt.git synced 2026-06-14 05:11:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

Sensible limits for known blocks and extrinsics (#4094)

Browse Source
This commit is contained in:
Arkadiy Paronyan
2019-11-12 16:57:03 +01:00
committed by Gavin Wood
parent efedac734d
commit 95d1bf0e41
1 changed files with 9 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
substrate/core/network/src/protocol.rs
+9 -4
View File
@@ -68,6 +68,11 @@ const TICK_TIMEOUT: time::Duration = time::Duration::from_millis(1100);
/// Interval at which we propagate exstrinsics; /// Interval at which we propagate exstrinsics;
const PROPAGATE_TIMEOUT: time::Duration = time::Duration::from_millis(2900); const PROPAGATE_TIMEOUT: time::Duration = time::Duration::from_millis(2900);
/// Maximim number of known block hashes to keep for a peer.
const MAX_KNOWN_BLOCKS: usize = 1024; // ~32kb per peer + LruHashSet overhead
/// Maximim number of known extrinsic hashes to keep for a peer.
const MAX_KNOWN_EXTRINSICS: usize = 4096; // ~128kb per peer + overhead
/// Current protocol version. /// Current protocol version.
pub(crate) const CURRENT_VERSION: u32 = 5; pub(crate) const CURRENT_VERSION: u32 = 5;
/// Lowest version we support /// Lowest version we support
@@ -973,8 +978,6 @@ impl<B: BlockT, S: NetworkSpecialization<B>, H: ExHashT> Protocol<B, S, H> {
} }
} }
let cache_limit = NonZeroUsize::new(1_000_000).expect("1_000_000 > 0; qed");
let info = match self.handshaking_peers.remove(&who) { let info = match self.handshaking_peers.remove(&who) {
Some(_handshaking) => { Some(_handshaking) => {
PeerInfo { PeerInfo {
@@ -993,8 +996,10 @@ impl<B: BlockT, S: NetworkSpecialization<B>, H: ExHashT> Protocol<B, S, H> {
let peer = Peer { let peer = Peer {
info, info,
block_request: None, block_request: None,
known_extrinsics: LruHashSet::new(cache_limit), known_extrinsics: LruHashSet::new(NonZeroUsize::new(MAX_KNOWN_EXTRINSICS)
known_blocks: LruHashSet::new(cache_limit), .expect("Constant is nonzero")),
known_blocks: LruHashSet::new(NonZeroUsize::new(MAX_KNOWN_BLOCKS)
.expect("Constant is nonzero")),
next_request_id: 0, next_request_id: 0,
obsolete_requests: HashMap::new(), obsolete_requests: HashMap::new(),
}; };