We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c5eb4ca commit 2c82bb0Copy full SHA for 2c82bb0
msg-transport/src/tcp/metered.rs
@@ -16,13 +16,14 @@ use crate::MeteredIo;
16
impl MeteredIo<TcpStream, TcpMetrics, SocketAddr> {
17
#[inline]
18
fn maybe_refresh(&mut self) {
19
- if self.next_refresh <= Instant::now() {
+ let now = Instant::now();
20
+ if self.next_refresh <= now {
21
match TcpMetrics::gather(&self.inner) {
22
Ok(metrics) => *self.metrics.write().unwrap() = metrics,
23
Err(e) => tracing::error!(err = ?e, "failed to gather TCP metrics"),
24
}
25
- self.next_refresh = Instant::now() + self.refresh_interval;
26
+ self.next_refresh = now + self.refresh_interval;
27
28
29
0 commit comments