archive/tuic
1
0
Fork 0
Code

try to fix #75

Browse Source
This commit is contained in:
EAimTY 2022-07-30 23:30:22 +09:00
parent 310419f682
commit ba014f2895
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
server/src/connection/udp.rs
View File

@ -136,10 +136,12 @@ impl UdpSession {
let (send_pkt_tx, send_pkt_rx) = mpsc::channel(1);
tokio::spawn(async move {
match tokio::select!(
res = Self::listen_send_packet(socket.clone(), send_pkt_rx) => res,
res = Self::listen_receive_packet(socket, assoc_id, recv_pkt_tx,max_pkt_size) => res,
) {
let res = tokio::select! {
res = tokio::spawn(Self::listen_send_packet(socket.clone(), send_pkt_rx)) => res,
res = tokio::spawn(Self::listen_receive_packet(socket, assoc_id, recv_pkt_tx, max_pkt_size)) => res,
};
match res.unwrap() {
Ok(()) => (),
Err(err) => log::warn!("[{src_addr}] [udp-session] [{assoc_id}] {err}"),
}