leyoda/rqbit
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

DHT broadcast lagging...

Browse source
This commit is contained in:
Igor Katson 2021-07-14 14:03:42 +01:00
parent 65d2e5b87f
commit 9340c231ba
1 changed files with 3 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

4
crates/dht/src/dht.rs
View file

@ -251,7 +251,9 @@ impl DhtState {
Entry::Vacant(v) => { Entry::Vacant(v) => {
// DHT sends peers REALLY fast, so the consumer of this broadcast should not lag behind. // DHT sends peers REALLY fast, so the consumer of this broadcast should not lag behind.
// That's why capacity is so high. // That's why capacity is so high.
let (tx, rx) = tokio::sync::broadcast::channel(1000); //
// What could be done is we could re-send all known peers once someone lags. Maybe do that...
let (tx, rx) = tokio::sync::broadcast::channel(20000);
v.insert(tx); v.insert(tx);
// We don't need to allocate/collect here, but the borrow checker is not happy otherwise. // We don't need to allocate/collect here, but the borrow checker is not happy otherwise.