TheLanc3/lan-mouse
1
0
Fork 0
mirror of https://github.com/feschber/lan-mouse.git synced 2026-04-15 10:31:28 +03:00
Code Issues Packages Projects Releases Wiki Activity

clippy

Browse Source
This commit is contained in:
Ferdinand Schober
2024-07-12 01:04:44 +02:00
parent 335a1fc3e2
commit 39d6a3cace
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/server/emulation_task.rs
View File

@@ -156,13 +156,13 @@ async fn do_emulation_session(
continue; continue;
} }
}; };
handle_udp_rx(&server, &capture_tx, emulation, &sender_tx, &mut last_ignored, udp_event).await?; handle_udp_rx(server, capture_tx, emulation, sender_tx, &mut last_ignored, udp_event).await?;
} }
emulate_event = rx.recv() => { emulate_event = rx.recv() => {
match emulate_event.expect("channel closed") { match emulate_event.expect("channel closed") {
EmulationEvent::Create(h) => emulation.create(h).await, EmulationEvent::Create(h) => emulation.create(h).await,
EmulationEvent::Destroy(h) => emulation.destroy(h).await, EmulationEvent::Destroy(h) => emulation.destroy(h).await,
EmulationEvent::ReleaseKeys(c) => release_keys(&server, emulation, c).await?, EmulationEvent::ReleaseKeys(c) => release_keys(server, emulation, c).await?,
} }
} }
_ = server.notifies.cancel.cancelled() => break Ok(()), _ = server.notifies.cancel.cancelled() => break Ok(()),

4
src/server/resolver_task.rs
View File

@@ -45,7 +45,7 @@ async fn do_dns(
if let Some((_, s)) = server.client_manager.borrow_mut().get_mut(handle) { if let Some((_, s)) = server.client_manager.borrow_mut().get_mut(handle) {
s.resolving = true; s.resolving = true;
} }
notify_state_change(&frontend, &server, handle).await; notify_state_change(&frontend, server, handle).await;
let ips = match resolver.resolve(&host).await { let ips = match resolver.resolve(&host).await {
Ok(ips) => ips, Ok(ips) => ips,
@@ -64,7 +64,7 @@ async fn do_dns(
s.ips = addrs; s.ips = addrs;
s.resolving = false; s.resolving = false;
} }
notify_state_change(&frontend, &server, handle).await; notify_state_change(&frontend, server, handle).await;
} }
} }