artin/tauri
1
0
Fork 0
mirror of https://github.com/tauri-apps/tauri.git synced 2026-02-06 11:22:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor(server): improve error handling for TcpListener binding

Browse Source 
- Added error handling for TcpListener binding to provide clearer feedback on failure.
- Simplified the server loop structure while maintaining functionality.
This commit is contained in:
Sam Maister 2026-02-06 00:37:59 +00:00
parent 8d67af37b6
commit c843649416
No known key found for this signature in database
1 changed files with 30 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
crates/tauri-driver/src/server.rs
View File

@ -203,34 +203,38 @@ pub async fn run(args: Args, mut _driver: Child) -> Result<(), Error> {
.build_http();
// set up a http1 server that uses the service we just created
let srv = async move {
if let Ok(listener) = TcpListener::bind(address).await {
loop {
let client = client.clone();
let args = args.clone();
if let Ok((stream, _)) = listener.accept().await {
let io = TokioIo::new(stream);
let listener = match TcpListener::bind(address).await {
Ok(l) => l,
Err(e) => {
eprintln!("can not listen to address: {address:?}: {e}");
std::process::exit(1);
}
};
tokio::task::spawn(async move {
if let Err(err) = auto::Builder::new(TokioExecutor::new())
.http1()
.title_case_headers(true)
.preserve_header_case(true)
.serve_connection(
io,
service_fn(|request| handle(client.clone(), request, args.clone())),
)
.await
{
println!("Error serving connection: {err:?}");
}
});
} else {
println!("accept new stream fail, ignore here");
}
let srv = async move {
loop {
let client = client.clone();
let args = args.clone();
if let Ok((stream, _)) = listener.accept().await {
let io = TokioIo::new(stream);
tokio::task::spawn(async move {
if let Err(err) = auto::Builder::new(TokioExecutor::new())
.http1()
.title_case_headers(true)
.preserve_header_case(true)
.serve_connection(
io,
service_fn(|request| handle(client.clone(), request, args.clone())),
)
.await
{
println!("Error serving connection: {err:?}");
}
});
} else {
println!("accept new stream fail, ignore here");
}
} else {
println!("can not listen to address: {address:?}");
}
};
srv.await;