From 4c000fa6d44f4d6c60eb499ec4dc38da68ece349 Mon Sep 17 00:00:00 2001 From: Ferdinand Schober Date: Wed, 4 Sep 2024 18:06:26 +0200 Subject: [PATCH] test fix port --- src/server/network_task.rs | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) 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());