forked/hyper
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor(http1): adjust a few tracing event outputs

Browse Source
This commit is contained in:
Sean McArthur
2021-10-13 17:05:34 -07:00
parent 55a61c072d
commit e48519a1e2
2 changed files with 3 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/proto/h1/io.rs
View File

@@ -223,6 +223,7 @@ where
match Pin::new(&mut self.io).poll_read(cx, &mut buf) { match Pin::new(&mut self.io).poll_read(cx, &mut buf) {
Poll::Ready(Ok(_)) => { Poll::Ready(Ok(_)) => {
let n = buf.filled().len(); let n = buf.filled().len();
trace!("received {} bytes", n);
unsafe { unsafe {
// Safety: we just read that many bytes into the // Safety: we just read that many bytes into the
// uninitialized part of the buffer, so this is okay. // uninitialized part of the buffer, so this is okay.

13
src/proto/h1/role.rs
View File

@@ -120,11 +120,7 @@ impl Http1Transaction for Server {
/* SAFETY: it is safe to go from MaybeUninit array to array of MaybeUninit */ /* SAFETY: it is safe to go from MaybeUninit array to array of MaybeUninit */
let mut headers: [MaybeUninit<httparse::Header<'_>>; MAX_HEADERS] = let mut headers: [MaybeUninit<httparse::Header<'_>>; MAX_HEADERS] =
unsafe { MaybeUninit::uninit().assume_init() }; unsafe { MaybeUninit::uninit().assume_init() };
trace!( trace!(bytes = buf.len(), "Request.parse");
"Request.parse([Header; {}], [u8; {}])",
headers.len(),
buf.len()
);
let mut req = httparse::Request::new(&mut []); let mut req = httparse::Request::new(&mut []);
let bytes = buf.as_ref(); let bytes = buf.as_ref();
match req.parse_with_uninit_headers(bytes, &mut headers) { match req.parse_with_uninit_headers(bytes, &mut headers) {
@@ -144,7 +140,6 @@ impl Http1Transaction for Server {
is_http_11 = false; is_http_11 = false;
Version::HTTP_10 Version::HTTP_10
}; };
trace!("headers: {:?}", &req.headers);
record_header_indices(bytes, &req.headers, &mut headers_indices)?; record_header_indices(bytes, &req.headers, &mut headers_indices)?;
headers_len = req.headers.len(); headers_len = req.headers.len();
@@ -879,11 +874,7 @@ impl Http1Transaction for Client {
// SAFETY: We can go safely from MaybeUninit array to array of MaybeUninit // SAFETY: We can go safely from MaybeUninit array to array of MaybeUninit
let mut headers: [MaybeUninit<httparse::Header<'_>>; MAX_HEADERS] = let mut headers: [MaybeUninit<httparse::Header<'_>>; MAX_HEADERS] =
unsafe { MaybeUninit::uninit().assume_init() }; unsafe { MaybeUninit::uninit().assume_init() };
trace!( trace!(bytes = buf.len(), "Response.parse");
"Response.parse([Header; {}], [u8; {}])",
headers.len(),
buf.len()
);
let mut res = httparse::Response::new(&mut []); let mut res = httparse::Response::new(&mut []);
let bytes = buf.as_ref(); let bytes = buf.as_ref();
match ctx.h1_parser_config.parse_response_with_uninit_headers( match ctx.h1_parser_config.parse_response_with_uninit_headers(