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

asdf

Browse Source
This commit is contained in:
Ferdinand Schober
2024-09-04 23:53:11 +02:00
parent 4c000fa6d4
commit 90561744a0
1 changed files with 0 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/server/network_task.rs
View File

@@ -78,11 +78,7 @@ async fn udp_sender(rx: Rc<RefCell<Receiver<(ProtoEvent, SocketAddr)>>>) {
loop { loop {
log::error!("waiting for event to send ..."); log::error!("waiting for event to send ...");
let (event, addr) = rx.borrow_mut().recv().await.expect("channel closed"); let (event, addr) = rx.borrow_mut().recv().await.expect("channel closed");
// FIXME
let addr = SocketAddr::new(addr.ip(), 4242); let addr = SocketAddr::new(addr.ip(), 4242);
log::error!("{:20} ------>->->-> {addr}", event.to_string());
if !connection_pool.contains_key(&addr) { if !connection_pool.contains_key(&addr) {
let socket = Arc::new(UdpSocket::bind("0.0.0.0:0").await.unwrap()); let socket = Arc::new(UdpSocket::bind("0.0.0.0:0").await.unwrap());
socket.connect(addr).await.unwrap(); socket.connect(addr).await.unwrap();
@@ -100,10 +96,7 @@ async fn udp_sender(rx: Rc<RefCell<Receiver<(ProtoEvent, SocketAddr)>>>) {
connection_pool.insert(addr, conn); connection_pool.insert(addr, conn);
}; };
let conn = connection_pool.get(&addr).unwrap(); let conn = connection_pool.get(&addr).unwrap();
log::error!("{:20} ------>->->-> {addr}", event.to_string());
let (data, len): ([u8; lan_mouse_proto::MAX_EVENT_SIZE], usize) = event.into(); let (data, len): ([u8; lan_mouse_proto::MAX_EVENT_SIZE], usize) = event.into();
// When udp blocks, we dont want to block the event loop.
// Dropping events is better than potentially crashing the input capture.
conn.send(&data[..len]).await.unwrap(); conn.send(&data[..len]).await.unwrap();
} }
} }