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

only alert on actual error

Browse Source
This commit is contained in:
Ferdinand Schober
2025-03-22 22:12:17 +01:00
parent 6e66f47887
commit 42521a1997
1 changed files with 15 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
src/listen.rs
View File

@@ -52,7 +52,6 @@ pub(crate) struct LanMouseListener {
listen_rx: Receiver<ListenEvent>, listen_rx: Receiver<ListenEvent>,
listen_tx: Sender<ListenEvent>, listen_tx: Sender<ListenEvent>,
listen_task: JoinHandle<()>, listen_task: JoinHandle<()>,
connection_attempts: Arc<Mutex<VecDeque<String>>>,
conns: Rc<AsyncMutex<Vec<(SocketAddr, ArcConn)>>>, conns: Rc<AsyncMutex<Vec<(SocketAddr, ArcConn)>>>,
request_port_change: Sender<u16>, request_port_change: Sender<u16>,
port_changed: Receiver<Result<u16, ListenerCreationError>>, port_changed: Receiver<Result<u16, ListenerCreationError>>,
@@ -139,8 +138,21 @@ impl LanMouseListener {
spawn_local(read_loop(conns_clone.clone(), addr, conn, listen_tx.clone())); spawn_local(read_loop(conns_clone.clone(), addr, conn, listen_tx.clone()));
}, },
Err(e) => { Err(e) => {
if let Some(fingerprint) = connection_attempts.lock().expect("lock").pop_front() { if let Error::Std(ref e) = e {
listen_tx.send(ListenEvent::Rejected { fingerprint }).expect("channel closed"); if let Some(e) = e.0.downcast_ref::<webrtc_dtls::Error>() {
match e {
webrtc_dtls::Error::ErrVerifyDataMismatch => {
if let Some(fingerprint) = connection_attempts.lock().expect("lock").pop_front() {
listen_tx.send(ListenEvent::Rejected { fingerprint }).expect("channel closed");
}
}
_ => log::warn!("accept: {e}"),
}
} else {
log::warn!("accept: {e:?}");
}
} else {
log::warn!("accept: {e:?}");
} }
} }
}, },
@@ -166,7 +178,6 @@ impl LanMouseListener {
Ok(Self { Ok(Self {
conns, conns,
connection_attempts,
listen_rx, listen_rx,
listen_tx, listen_tx,
listen_task, listen_task,