From e9513cdae876144c5904116d1ba33816acbce791 Mon Sep 17 00:00:00 2001 From: yukirij Date: Fri, 16 Aug 2024 14:55:52 -0700 Subject: [PATCH] Add temporary debug prints. --- server/src/manager/data.rs | 2 ++ server/src/system/net/tls.rs | 8 ++++++++ 2 files changed, 10 insertions(+) diff --git a/server/src/manager/data.rs b/server/src/manager/data.rs index d0e55d8..f465b52 100644 --- a/server/src/manager/data.rs +++ b/server/src/manager/data.rs @@ -558,8 +558,10 @@ pub async fn thread_system(mut app:App, bus:Bus) } } + println!("sendblock"); if request.status != STATUS_ERROR { for packet in packets { + println!("sendto: {}", packet.id); app.send_response(packet).await; } diff --git a/server/src/system/net/tls.rs b/server/src/system/net/tls.rs index 702c56a..37a105d 100644 --- a/server/src/system/net/tls.rs +++ b/server/src/system/net/tls.rs @@ -112,21 +112,29 @@ 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(())