Kirisame/dzura
1
0
Fork 0
Code Issues 4 Pull Requests Packages Projects 1 Releases Wiki Activity

Add temporary debug prints.

Browse Source
This commit is contained in:
yukirij 2024-08-16 14:55:52 -07:00
parent 225cb34bab
commit e9513cdae8
2 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
server/src/manager/data.rs
View File

@ -558,8 +558,10 @@ pub async fn thread_system(mut app:App, bus:Bus<protocol::QRPacket>)
} }
} }
println!("sendblock");
if request.status != STATUS_ERROR { if request.status != STATUS_ERROR {
for packet in packets { for packet in packets {
println!("sendto: {}", packet.id);
app.send_response(packet).await; app.send_response(packet).await;
} }

8
server/src/system/net/tls.rs
View File

@ -112,21 +112,29 @@ impl Server for TlsServer {
Fut: std::future::Future<Output = Result<(),()>> + Send + 'static, Fut: std::future::Future<Output = Result<(),()>> + Send + 'static,
Args: Send + 'static Args: Send + 'static
{ {
println!("A");
match &self.listener { match &self.listener {
Some(listener) => { Some(listener) => {
println!("B");
if let Ok((socket, client_addr)) = listener.accept().await { if let Ok((socket, client_addr)) = listener.accept().await {
let acceptor = LazyConfigAcceptor::new(Acceptor::default(), socket); let acceptor = LazyConfigAcceptor::new(Acceptor::default(), socket);
let certificates = self.certificates.clone(); let certificates = self.certificates.clone();
println!("C");
Ok(tokio::spawn(async move { Ok(tokio::spawn(async move {
println!("D");
match acceptor.await { match acceptor.await {
Ok(hs) => { Ok(hs) => {
println!("E");
let hello = hs.client_hello(); let hello = hs.client_hello();
if let Some(server_name) = hello.server_name() { if let Some(server_name) = hello.server_name() {
println!("F");
match Self::get_server_config(certificates, server_name).await { match Self::get_server_config(certificates, server_name).await {
Some(server_config) => { Some(server_config) => {
println!("G");
match hs.into_stream(server_config).await { match hs.into_stream(server_config).await {
Ok(tlsstream) => { Ok(tlsstream) => {
println!("H");
callback(Self::Stream { stream:tlsstream }, client_addr, args).await callback(Self::Stream { stream:tlsstream }, client_addr, args).await
} }
Err(_) => Err(()) Err(_) => Err(())