diff --git a/src/server/network_task.rs b/src/server/network_task.rs index 67e6deb..46b2637 100644 --- a/src/server/network_task.rs +++ b/src/server/network_task.rs @@ -1,7 +1,7 @@ use local_channel::mpsc::{Receiver, Sender}; use std::{cell::RefCell, collections::HashMap, io, net::SocketAddr, rc::Rc, sync::Arc}; use webrtc_dtls::{ - config::{ClientAuthType, Config, ExtendedMasterSecretType}, + config::{Config, ExtendedMasterSecretType}, conn::DTLSConn, crypto::Certificate, listener::listen, @@ -78,6 +78,10 @@ async fn udp_sender(rx: Rc>>) { loop { log::error!("waiting for event to send ..."); let (event, addr) = rx.borrow_mut().recv().await.expect("channel closed"); + + // FIXME + let addr = SocketAddr::new(addr.ip(), 4242); + log::error!("{:20} ------>->->-> {addr}", event.to_string()); if !connection_pool.contains_key(&addr) { let socket = Arc::new(UdpSocket::bind("0.0.0.0:0").await.unwrap());