perf(http): prefer ErrorKind::WouldBlock
Improved codegen, without allocations or function calls
This commit is contained in:
@@ -202,7 +202,7 @@ impl Chunked {
|
||||
match *self {
|
||||
Chunked::Init |
|
||||
Chunked::End => Ok(msg.len()),
|
||||
_ => Err(io::Error::new(io::ErrorKind::WouldBlock, "chunked incomplete"))
|
||||
_ => Err(io::ErrorKind::WouldBlock.into())
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -132,7 +132,7 @@ impl<T: Write> Write for Buffered<T> {
|
||||
fn write(&mut self, data: &[u8]) -> io::Result<usize> {
|
||||
let n = self.write_buf.buffer(data);
|
||||
if n == 0 {
|
||||
Err(io::Error::from(io::ErrorKind::WouldBlock))
|
||||
Err(io::ErrorKind::WouldBlock.into())
|
||||
} else {
|
||||
Ok(n)
|
||||
}
|
||||
|
||||
@@ -107,7 +107,7 @@ impl<T: Read> Read for AsyncIo<T> {
|
||||
Err(err)
|
||||
} else if self.bytes_until_block == 0 {
|
||||
self.blocked = true;
|
||||
Err(io::Error::new(io::ErrorKind::WouldBlock, "mock block"))
|
||||
Err(io::ErrorKind::WouldBlock.into())
|
||||
} else {
|
||||
let n = cmp::min(self.bytes_until_block, buf.len());
|
||||
let n = try!(self.inner.read(&mut buf[..n]));
|
||||
@@ -122,7 +122,7 @@ impl<T: Write> Write for AsyncIo<T> {
|
||||
if let Some(err) = self.error.take() {
|
||||
Err(err)
|
||||
} else if self.bytes_until_block == 0 {
|
||||
Err(io::Error::new(io::ErrorKind::WouldBlock, "mock block"))
|
||||
Err(io::ErrorKind::WouldBlock.into())
|
||||
} else {
|
||||
trace!("AsyncIo::write() block_in = {}, data.len() = {}", self.bytes_until_block, data.len());
|
||||
self.flushed = false;
|
||||
|
||||
Reference in New Issue
Block a user