diff --git a/src/server/emulation_task.rs b/src/server/emulation_task.rs index 7312cd1..ce9613a 100644 --- a/src/server/emulation_task.rs +++ b/src/server/emulation_task.rs @@ -156,13 +156,13 @@ async fn do_emulation_session( 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() => { match emulate_event.expect("channel closed") { EmulationEvent::Create(h) => emulation.create(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(()), diff --git a/src/server/resolver_task.rs b/src/server/resolver_task.rs index 10b8f75..f90ed1d 100644 --- a/src/server/resolver_task.rs +++ b/src/server/resolver_task.rs @@ -45,7 +45,7 @@ async fn do_dns( if let Some((_, s)) = server.client_manager.borrow_mut().get_mut(handle) { s.resolving = true; } - notify_state_change(&frontend, &server, handle).await; + notify_state_change(&frontend, server, handle).await; let ips = match resolver.resolve(&host).await { Ok(ips) => ips, @@ -64,7 +64,7 @@ async fn do_dns( s.ips = addrs; s.resolving = false; } - notify_state_change(&frontend, &server, handle).await; + notify_state_change(&frontend, server, handle).await; } }