This commit is contained in:
Ferdinand Schober
2024-07-11 22:43:43 +02:00
parent d54e472498
commit 3014e404c3
4 changed files with 6 additions and 6 deletions

View File

@@ -508,7 +508,7 @@ async fn handle_ei_event(
} }
EiEvent::SeatRemoved(_) | /* EiEvent::DeviceAdded(_) | */ EiEvent::DeviceRemoved(_) => { EiEvent::SeatRemoved(_) | /* EiEvent::DeviceAdded(_) | */ EiEvent::DeviceRemoved(_) => {
log::debug!("releasing session: {ei_event:?}"); log::debug!("releasing session: {ei_event:?}");
release_session.notify_one(); release_session.notify_waiters();
} }
EiEvent::DevicePaused(_) | EiEvent::DeviceResumed(_) => {} EiEvent::DevicePaused(_) | EiEvent::DeviceResumed(_) => {}
EiEvent::DeviceStartEmulating(_) => log::debug!("START EMULATING"), EiEvent::DeviceStartEmulating(_) => log::debug!("START EMULATING"),
@@ -681,7 +681,7 @@ impl<'a> LanMouseInputCapture for LibeiInputCapture<'a> {
} }
async fn release(&mut self) -> Result<(), CaptureError> { async fn release(&mut self) -> Result<(), CaptureError> {
self.notify_release.notify_one(); self.notify_release.notify_waiters();
Ok(()) Ok(())
} }

View File

@@ -249,7 +249,7 @@ async fn handle_capture_event(
}; };
if start_timer { if start_timer {
timer_notify.notify_one(); timer_notify.notify_waiters();
} }
if enter { if enter {
spawn_hook_command(server, handle); spawn_hook_command(server, handle);

View File

@@ -257,7 +257,7 @@ async fn handle_udp_rx(
); );
// restart timer if necessary // restart timer if necessary
if restart_timer { if restart_timer {
timer_notify.notify_one(); timer_notify.notify_waiters();
} }
ignore_event ignore_event
} else { } else {

View File

@@ -127,11 +127,11 @@ async fn handle_frontend_event(
log::debug!("frontend: {event:?}"); log::debug!("frontend: {event:?}");
match event { match event {
FrontendRequest::EnableCapture => { FrontendRequest::EnableCapture => {
notify_capture.notify_one(); notify_capture.notify_waiters();
} }
FrontendRequest::EnableEmulation => { FrontendRequest::EnableEmulation => {
log::info!("received emulation enable request"); log::info!("received emulation enable request");
notify_emulation.notify_one(); notify_emulation.notify_waiters();
} }
FrontendRequest::Create => { FrontendRequest::Create => {
let handle = add_client(server, frontend).await; let handle = add_client(server, frontend).await;