perf(server): try to read from socket at keep-alive

In most situations, this should reduce the number of task wake ups by 1
per request, which can help if reading the request was small.
This commit is contained in:
Sean McArthur
2017-09-22 12:02:08 -07:00
parent dd54f20b55
commit 1a9f264826
2 changed files with 17 additions and 5 deletions

View File

@@ -228,6 +228,16 @@ where I: AsyncRead + AsyncWrite,
}
if !self.io.is_read_blocked() {
if self.io.read_buf().is_empty() {
match self.io.read_from_io() {
Ok(Async::Ready(_)) => (),
Ok(Async::NotReady) => return,
Err(e) => {
trace!("maybe_notify read_from_io error: {}", e);
self.state.close();
}
}
}
if let Some(ref task) = self.state.read_task {
task.notify();
}