jleony/nanoreth
1
0
Fork 0
mirror of https://github.com/hl-archive-node/nanoreth.git synced 2025-12-06 10:59:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: shrink session buffers (#3360)

Browse Source
This commit is contained in:
Matthias Seitz
2023-06-23 19:33:27 +02:00
committed by GitHub
parent faeb612553
commit cff4aa7b2b
1 changed files with 18 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
crates/net/network/src/session/active.rs
View File

@ -109,6 +109,12 @@ impl ActiveSession {
id
}
/// Shrinks the capacity of the internal buffers.
pub fn shrink_to_fit(&mut self) {
self.received_requests_from_remote.shrink_to_fit();
self.queued_outgoing.shrink_to_fit();
}
/// Handle a message read from the connection.
///
/// Returns an error if the message is considered to be in violation of the protocol.
@ -437,17 +443,6 @@ impl ActiveSession {
}
}
/// Calculates a new timeout using an updated estimation of the RTT
#[inline]
fn calculate_new_timeout(current_timeout: Duration, estimated_rtt: Duration) -> Duration {
let new_timeout = estimated_rtt.mul_f64(SAMPLE_IMPACT) * TIMEOUT_SCALING;
// this dampens sudden changes by taking a weighted mean of the old and new values
let smoothened_timeout = current_timeout.mul_f64(1.0 - SAMPLE_IMPACT) + new_timeout;
smoothened_timeout.clamp(MINIMUM_TIMEOUT, MAXIMUM_TIMEOUT)
}
impl Future for ActiveSession {
type Output = ();
@ -605,6 +600,8 @@ impl Future for ActiveSession {
}
}
this.shrink_to_fit();
return Poll::Pending
}
}
@ -703,6 +700,16 @@ impl From<EthBroadcastMessage> for OutgoingMessage {
}
}
/// Calculates a new timeout using an updated estimation of the RTT
#[inline]
fn calculate_new_timeout(current_timeout: Duration, estimated_rtt: Duration) -> Duration {
let new_timeout = estimated_rtt.mul_f64(SAMPLE_IMPACT) * TIMEOUT_SCALING;
// this dampens sudden changes by taking a weighted mean of the old and new values
let smoothened_timeout = current_timeout.mul_f64(1.0 - SAMPLE_IMPACT) + new_timeout;
smoothened_timeout.clamp(MINIMUM_TIMEOUT, MAXIMUM_TIMEOUT)
}
#[cfg(test)]
mod tests {
#![allow(dead_code)]