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

upnp tick strategy updated

Browse source
This commit is contained in:
Igor Katson 2024-08-16 10:08:48 +01:00
parent 45779da900
commit 1414a28aaf
No known key found for this signature in database
GPG key ID: B4EC22B66D61A3F5
1 changed files with 3 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

3
crates/upnp/src/lib.rs
View file

@ -377,6 +377,7 @@ impl UpnpPortForwarder {
async fn discovery(&self, tx: UnboundedSender<UpnpDiscoverResponse>) -> anyhow::Result<()> { async fn discovery(&self, tx: UnboundedSender<UpnpDiscoverResponse>) -> anyhow::Result<()> {
let mut discover_interval = tokio::time::interval(self.opts.discover_interval); let mut discover_interval = tokio::time::interval(self.opts.discover_interval);
discover_interval.set_missed_tick_behavior(tokio::time::MissedTickBehavior::Delay);
loop { loop {
discover_interval.tick().await; discover_interval.tick().await;
@ -389,6 +390,8 @@ impl UpnpPortForwarder {
async fn manage_port(&self, control_url: Url, local_ip: Ipv4Addr, port: u16) -> ! { async fn manage_port(&self, control_url: Url, local_ip: Ipv4Addr, port: u16) -> ! {
let lease_duration = self.opts.lease_duration; let lease_duration = self.opts.lease_duration;
let mut interval = tokio::time::interval(lease_duration / 2); let mut interval = tokio::time::interval(lease_duration / 2);
interval.set_missed_tick_behavior(tokio::time::MissedTickBehavior::Delay);
loop { loop {
interval.tick().await; interval.tick().await;
if let Err(e) = forward_port(control_url.clone(), local_ip, port, lease_duration).await if let Err(e) = forward_port(control_url.clone(), local_ip, port, lease_duration).await