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

perf(http): reduce server loops when headers and body are ready

Browse Source
This commit is contained in:
Sean McArthur
2016-08-06 00:11:45 -07:00
parent 523b890a19
commit a3a815c09c
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/http/conn.rs
View File

@@ -324,7 +324,7 @@ impl<K: Key, T: Transport, H: MessageHandler<T>> ConnInner<K, T, H> {
} }
}; };
let mut head = http::MessageHead::default(); let mut head = http::MessageHead::default();
let interest = handler.on_outgoing(&mut head); let mut interest = handler.on_outgoing(&mut head);
if head.version == HttpVersion::Http11 { if head.version == HttpVersion::Http11 {
let mut buf = Vec::new(); let mut buf = Vec::new();
let keep_alive = self.keep_alive_enabled && head.should_keep_alive(); let keep_alive = self.keep_alive_enabled && head.should_keep_alive();
@@ -339,6 +339,7 @@ impl<K: Key, T: Transport, H: MessageHandler<T>> ConnInner<K, T, H> {
bytes: buf, bytes: buf,
pos: 0 pos: 0
}); });
interest = handler.on_encode(&mut Encoder::h1(&mut encoder, &mut self.transport));
Writing::Ready(encoder) Writing::Ready(encoder)
}, },
_ => Writing::Chunk(Chunk { _ => Writing::Chunk(Chunk {
@@ -370,7 +371,7 @@ impl<K: Key, T: Transport, H: MessageHandler<T>> ConnInner<K, T, H> {
} }
Writing::Head => { Writing::Head => {
let mut head = http::MessageHead::default(); let mut head = http::MessageHead::default();
let interest = handler.on_outgoing(&mut head); let mut interest = handler.on_outgoing(&mut head);
// if the request wants to close, server cannot stop it // if the request wants to close, server cannot stop it
if *keep_alive { if *keep_alive {
// if the request wants to stay alive, then it depends // if the request wants to stay alive, then it depends
@@ -389,6 +390,7 @@ impl<K: Key, T: Transport, H: MessageHandler<T>> ConnInner<K, T, H> {
bytes: buf, bytes: buf,
pos: 0 pos: 0
}); });
interest = handler.on_encode(&mut Encoder::h1(&mut encoder, &mut self.transport));
Writing::Ready(encoder) Writing::Ready(encoder)
}, },
_ => Writing::Chunk(Chunk { _ => Writing::Chunk(Chunk {