Armael/tricot
1
0
Fork 0
forked from Deuxfleurs/tricot
Code Pull requests Activity

Enable upgrades on http module

Browse source
This commit is contained in:
Alex 2022-05-10 12:11:59 +02:00
parent cbf7a03836
commit 698236cdb4
Signed by untrusted user: lx
GPG key ID: 0E496D15096376BE
1 changed files with 11 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
src/https.rs
View file

@ -77,14 +77,17 @@ pub async fn serve_https(
match tls_acceptor.accept(socket).await { match tls_acceptor.accept(socket).await {
Ok(stream) => { Ok(stream) => {
debug!("TLS handshake was successfull"); debug!("TLS handshake was successfull");
let http_conn = Http::new().serve_connection( let http_conn = Http::new()
stream, .serve_connection(
service_fn(move |req: Request<Body>| { stream,
let https_config = config.clone(); service_fn(move |req: Request<Body>| {
let proxy_config: Arc<ProxyConfig> = rx_proxy_config.borrow().clone(); let https_config = config.clone();
handle_outer(remote_addr, req, https_config, proxy_config) let proxy_config: Arc<ProxyConfig> =
}), rx_proxy_config.borrow().clone();
); handle_outer(remote_addr, req, https_config, proxy_config)
}),
)
.with_upgrades();
let timeout = tokio::time::sleep(MAX_CONNECTION_LIFETIME); let timeout = tokio::time::sleep(MAX_CONNECTION_LIFETIME);
tokio::pin!(http_conn, timeout); tokio::pin!(http_conn, timeout);
let http_result = loop { let http_result = loop {