From edd7158ca218e5d7a0938d46bfc63caa258f34c5 Mon Sep 17 00:00:00 2001 From: yukirij Date: Fri, 16 Aug 2024 15:13:40 -0700 Subject: [PATCH] Remove test prints. --- server/src/main.rs | 12 +++++++----- server/src/system/net/tls.rs | 8 -------- 2 files changed, 7 insertions(+), 13 deletions(-) diff --git a/server/src/main.rs b/server/src/main.rs index eb934d9..bb7c251 100644 --- a/server/src/main.rs +++ b/server/src/main.rs @@ -175,10 +175,12 @@ async fn main() match server.bind("0.0.0.0:38612").await { Ok(_) => { println!("Listener bind successful."); - while server.accept(handle_http, HttpServiceArgs { - bus:bus.connect().unwrap(), - cache:cache.clone(), - }).await.is_ok() { } + tokio::spawn(async move { + while server.accept(handle_http, HttpServiceArgs { + bus:bus.connect().unwrap(), + cache:cache.clone(), + }).await.is_ok() { } + }); } Err(_) => { println!("error: failed to bind port 38612."); @@ -190,5 +192,5 @@ async fn main() } } - //std::thread::park(); + loop { tokio::time::sleep(tokio::time::Duration::from_secs(10)).await; } } diff --git a/server/src/system/net/tls.rs b/server/src/system/net/tls.rs index 37a105d..702c56a 100644 --- a/server/src/system/net/tls.rs +++ b/server/src/system/net/tls.rs @@ -112,29 +112,21 @@ impl Server for TlsServer { Fut: std::future::Future> + Send + 'static, Args: Send + 'static { - println!("A"); match &self.listener { Some(listener) => { - println!("B"); if let Ok((socket, client_addr)) = listener.accept().await { let acceptor = LazyConfigAcceptor::new(Acceptor::default(), socket); let certificates = self.certificates.clone(); - println!("C"); Ok(tokio::spawn(async move { - println!("D"); match acceptor.await { Ok(hs) => { - println!("E"); let hello = hs.client_hello(); if let Some(server_name) = hello.server_name() { - println!("F"); match Self::get_server_config(certificates, server_name).await { Some(server_config) => { - println!("G"); match hs.into_stream(server_config).await { Ok(tlsstream) => { - println!("H"); callback(Self::Stream { stream:tlsstream }, client_addr, args).await } Err(_) => Err(())