YGGverse/aquatic
1
0
Fork 0
mirror of https://github.com/YGGverse/aquatic.git synced 2026-04-01 18:25:30 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

aquatic_udp: glommio: add yield_if_needed(), add comment

Browse source
This commit is contained in:
Joakim Frostegård 2021-10-19 02:11:27 +02:00
parent 93907822f8
commit 9dc615a8f9
2 changed files with 5 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

3
aquatic_udp/src/lib/glommio/handlers.rs
View file

@ -3,6 +3,7 @@ use std::net::{IpAddr, Ipv4Addr, Ipv6Addr, SocketAddr};
use futures_lite::stream::empty; use futures_lite::stream::empty;
use futures_lite::StreamExt; use futures_lite::StreamExt;
use glommio::channels::channel_mesh::{MeshBuilder, Partial, Role}; use glommio::channels::channel_mesh::{MeshBuilder, Partial, Role};
use glommio::prelude::*;
use rand::prelude::SmallRng; use rand::prelude::SmallRng;
use rand::SeedableRng; use rand::SeedableRng;
@ -56,5 +57,7 @@ pub async fn run_request_worker(
if let Err(err) = response_senders.try_send_to(producer_index, (response, addr)) { if let Err(err) = response_senders.try_send_to(producer_index, (response, addr)) {
::log::warn!("response_sender.try_send: {:?}", err); ::log::warn!("response_sender.try_send: {:?}", err);
} }
yield_if_needed().await;
} }
} }

3
aquatic_udp/src/lib/glommio/network.rs
View file

@ -65,9 +65,10 @@ async fn read_requests(
) { ) {
let mut rng = StdRng::from_entropy(); let mut rng = StdRng::from_entropy();
let valid_until = ValidUntil::new(config.cleaning.max_connection_age);
let access_list_mode = config.access_list.mode; let access_list_mode = config.access_list.mode;
// Needs to be updated periodically: use timer?
let valid_until = ValidUntil::new(config.cleaning.max_connection_age);
// Needs to be updated periodically: use timer? // Needs to be updated periodically: use timer?
let access_list = AccessList::default(); let access_list = AccessList::default();
// Needs to be cleaned periodically: use timer? // Needs to be cleaned periodically: use timer?