SSLKEYLOGFILE

src/client.rs

@@ -122,6 +122,7 @@ pub async fn play(
 			} else {
 				config.resumption = Resumption::disabled();
 			}
+			config.key_log = Arc::new(tokio_rustls::rustls::KeyLogFile::new());
 			let config = Arc::new(config);
 			for (id, (server_name, records)) in records.iter() {
 				let connector = TlsConnector::from(config.clone());
@@ -322,7 +323,8 @@ pub async fn play(
 										)
 										.await
 										{
-											Ok(v) => v.unwrap().unwrap(),
+											Ok(None) => break,
+											Ok(Some(v)) => v.unwrap(),
 											Err(_e) => {
 												// TODO fix
 												println!(
@@ -350,6 +352,12 @@ pub async fn play(
 										//crate::http::decode_http(&mut buf, &mut stream).await;
 										//buf.clear();
 									}
+									if total_recv < reduced_len {
+										println!(
+											"({}) RECV NOT ENOUGH {} / {}",
+											id, total_recv, total_len
+										);
+									}
 								}
 							}
 						}

src/server.rs

@@ -141,6 +141,7 @@ pub async fn play(
 				.with_no_client_auth()
 				.with_cert_resolver(Arc::new(resolver));
 			config.max_early_data_size = 8192;
+			config.key_log = Arc::new(tokio_rustls::rustls::KeyLogFile::new());
 			let config = Arc::new(config);
 
 			let listener = TcpListener::bind(listen_addr).await.unwrap();