test fix port

This commit is contained in:
Ferdinand Schober
2024-09-04 18:06:26 +02:00
parent e7166d4373
commit 4c000fa6d4

View File

@@ -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<RefCell<Receiver<(ProtoEvent, SocketAddr)>>>) {
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());