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

refactor(lib): fix remaining lint warnings (besides tests)

Browse Source
This commit is contained in:
Sean McArthur
2019-08-22 13:57:50 -07:00
parent 7b1d6d71b7
commit 49b12c415d
4 changed files with 9 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
src/proto/h1/dispatch.rs
View File

@@ -100,23 +100,6 @@ where
T::update_date();
ready!(self.poll_loop(cx))?;
loop {
self.poll_read(cx)?;
self.poll_write(cx)?;
self.poll_flush(cx)?;
// This could happen if reading paused before blocking on IO,
// such as getting to the end of a framed message, but then
// writing/flushing set the state back to Init. In that case,
// if the read buffer still had bytes, we'd want to try poll_read
// again, or else we wouldn't ever be woken up again.
//
// Using this instead of task::current() and notify() inside
// the Conn is noticeably faster in pipelined benchmarks.
if !self.conn.wants_read_again() {
break;
}
}
if self.is_done() {
if let Some(pending) = self.conn.pending_upgrade() {
@@ -139,9 +122,9 @@ where
// 16 was chosen arbitrarily, as that is number of pipelined requests
// benchmarks often use. Perhaps it should be a config option instead.
for _ in 0..16 {
self.poll_read(cx)?;
self.poll_write(cx)?;
self.poll_flush(cx)?;
let _ = self.poll_read(cx)?;
let _ = self.poll_write(cx)?;
let _ = self.poll_flush(cx)?;
// This could happen if reading paused before blocking on IO,
// such as getting to the end of a framed message, but then