mirror of
https://gitlab.com/veloren/veloren.git
synced 2024-08-30 18:12:32 +00:00
383482a36e
- locally we open a stream, our local Drain is sending OpenStream - remote Sink will know this and notify remote Drain - remote side sends a message - local sink does not know about the Stream. as there is (and CANT) be a wat to notify local Sink from local Drain (it could introduce race conditions). One of the possible solutions was, that the remote drain will copy the OpenStream Msg ON the Quic::stream before first data is send. This would work but is complicated. Instead we now just mark such streams as "potentially open" and we listen for the first DataHeader to get it's SID. add support for unreliable messages in quic protocol, benchmarks
47 lines
1.2 KiB
Rust
47 lines
1.2 KiB
Rust
use core::hash::Hash;
|
|
use std::{collections::HashMap, time::Instant};
|
|
use tracing::Level;
|
|
|
|
/// used to collect multiple traces and not spam the console
|
|
pub(crate) struct DeferredTracer<T: Eq + Hash> {
|
|
level: Level,
|
|
items: HashMap<T, u64>,
|
|
last: Instant,
|
|
last_cnt: u32,
|
|
}
|
|
|
|
impl<T: Eq + Hash> DeferredTracer<T> {
|
|
pub(crate) fn new(level: Level) -> Self {
|
|
Self {
|
|
level,
|
|
items: HashMap::new(),
|
|
last: Instant::now(),
|
|
last_cnt: 0,
|
|
}
|
|
}
|
|
|
|
pub(crate) fn log(&mut self, t: T) {
|
|
if tracing::level_enabled!(self.level) {
|
|
*self.items.entry(t).or_default() += 1;
|
|
self.last = Instant::now();
|
|
self.last_cnt += 1;
|
|
} else {
|
|
}
|
|
}
|
|
|
|
pub(crate) fn print(&mut self) -> Option<HashMap<T, u64>> {
|
|
const MAX_LOGS: u32 = 10_000;
|
|
const MAX_SECS: u64 = 1;
|
|
if tracing::level_enabled!(self.level)
|
|
&& (self.last_cnt > MAX_LOGS || self.last.elapsed().as_secs() >= MAX_SECS)
|
|
{
|
|
if self.last_cnt > MAX_LOGS {
|
|
tracing::debug!("this seems to be logged continuesly");
|
|
}
|
|
Some(std::mem::take(&mut self.items))
|
|
} else {
|
|
None
|
|
}
|
|
}
|
|
}
|