ospab
/
ostp
mirror of https://github.com/ospab/ostp.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix Speedtest disconnects and Discord WebRTC

This commit is contained in:
ospab 2026-05-28 19:25:06 +03:00
parent 2ba9a3694d
commit 0334322aae
3 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
ostp-client/src/transport/xhttp.rs
View File

@ -180,8 +180,8 @@ where
R: tokio::io::AsyncRead + Unpin + Send + 'static, R: tokio::io::AsyncRead + Unpin + Send + 'static,
W: tokio::io::AsyncWrite + Unpin + Send + 'static, W: tokio::io::AsyncWrite + Unpin + Send + 'static,
{ {
let (app_tx, mut tx_rx) = mpsc::channel::<Bytes>(1024); let (app_tx, mut tx_rx) = mpsc::channel::<Bytes>(16384);
let (rx_tx, app_rx) = mpsc::channel::<Bytes>(1024); let (rx_tx, app_rx) = mpsc::channel::<Bytes>(16384);
// TX Loop (App -> UoT -> Network): prefix each frame with u16 BE length // TX Loop (App -> UoT -> Network): prefix each frame with u16 BE length
tokio::spawn(async move { tokio::spawn(async move {

2
ostp-server/src/relay.rs
View File

@ -133,7 +133,7 @@ pub async fn handle_relay_message(
if debug { if debug {
let _ = ui_event_tx.send(UiEvent::Log(format!("Relay UDP ASSOCIATE stream_id={stream_id}"))); let _ = ui_event_tx.send(UiEvent::Log(format!("Relay UDP ASSOCIATE stream_id={stream_id}")));
} }
let server_udp = match UdpSocket::bind("0.0.0.0:0").await { let server_udp = match UdpSocket::bind("[::]:0").await.or_else(|_| UdpSocket::bind("0.0.0.0:0").await) {
Ok(s) => std::sync::Arc::new(s), Ok(s) => std::sync::Arc::new(s),
Err(e) => { Err(e) => {
let _ = ui_event_tx.send(UiEvent::Log(format!("UDP bind failed: {e}"))); let _ = ui_event_tx.send(UiEvent::Log(format!("UDP bind failed: {e}")));

2
ostp-server/src/transport/uot.rs
View File

@ -116,7 +116,7 @@ where
info!("UoT client authenticated from {}", peer_addr); info!("UoT client authenticated from {}", peer_addr);
// Register this connection in the map // Register this connection in the map
let (tx, mut rx) = mpsc::channel::<Bytes>(1024); let (tx, mut rx) = mpsc::channel::<Bytes>(16384);
{ {
tcp_map.write().await.insert(peer_addr, tx); tcp_map.write().await.insert(peer_addr, tx);
} }