foster/denoland-deno
1
0
Fork 0
mirror of https://github.com/denoland/deno.git synced 2025-01-11 16:42:21 -05:00
Code Issues Packages 1 Wiki Activity

chore(ext/http): add env var to disable writev syscall (#19338)

Browse source
This commit is contained in:
Bartek Iwańczuk 2023-06-01 16:07:26 +02:00
parent ba7cffc896
commit b97d7ea921
No known key found for this signature in database
GPG key ID: 0C6BCDDC3B3AD750
1 changed files with 12 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
ext/http/http_next.rs
View file

@ -53,6 +53,7 @@ use hyper1::service::service_fn;
use hyper1::service::HttpService; use hyper1::service::HttpService;
use hyper1::StatusCode; use hyper1::StatusCode;
use once_cell::sync::Lazy;
use pin_project::pin_project; use pin_project::pin_project;
use pin_project::pinned_drop; use pin_project::pinned_drop;
use std::borrow::Cow; use std::borrow::Cow;
@ -68,6 +69,16 @@ use tokio::io::AsyncWriteExt;
type Request = hyper1::Request<Incoming>; type Request = hyper1::Request<Incoming>;
type Response = hyper1::Response<ResponseBytes>; type Response = hyper1::Response<ResponseBytes>;
static USE_WRITEV: Lazy<bool> = Lazy::new(|| {
let disable_writev = std::env::var("DENO_HYPER_USE_WRITEV").ok();
if let Some(val) = disable_writev {
return val != "0";
}
true
});
/// All HTTP/2 connections start with this byte string. /// All HTTP/2 connections start with this byte string.
/// ///
/// In HTTP/2, each endpoint is required to send a connection preface as a final confirmation /// In HTTP/2, each endpoint is required to send a connection preface as a final confirmation
@ -597,6 +608,7 @@ fn serve_http11_unconditional(
) -> impl Future<Output = Result<(), AnyError>> + 'static { ) -> impl Future<Output = Result<(), AnyError>> + 'static {
let conn = http1::Builder::new() let conn = http1::Builder::new()
.keep_alive(true) .keep_alive(true)
.writev(*USE_WRITEV)
.serve_connection(io, svc); .serve_connection(io, svc);
conn.with_upgrades().map_err(AnyError::from) conn.with_upgrades().map_err(AnyError::from)