diff options
| author | Artem Vorotnikov <artem@vorotnikov.me> | 2019-12-21 23:28:57 +0300 |
|---|---|---|
| committer | Carl Lerche <me@carllerche.com> | 2019-12-21 12:28:57 -0800 |
| commit | 8656b7b8eb6f3635ec40694eb71f14fb84211e05 (patch) | |
| tree | e2fd1f95216660edeaadebbce87144e95ccfffde /tokio/src/net/tcp/stream.rs | |
| parent | f309b295bb0bdee5862a0ab8359a5f0622a588b9 (diff) | |
chore: fix formatting, remove old rustfmt.toml (#2007)
`cargo fmt` has a bug where it does not format modules scoped with
feature flags.
Diffstat (limited to 'tokio/src/net/tcp/stream.rs')
| -rw-r--r-- | tokio/src/net/tcp/stream.rs | 84 |
1 files changed, 66 insertions, 18 deletions
diff --git a/tokio/src/net/tcp/stream.rs b/tokio/src/net/tcp/stream.rs index 343c6c5d..d35f1620 100644 --- a/tokio/src/net/tcp/stream.rs +++ b/tokio/src/net/tcp/stream.rs @@ -674,22 +674,70 @@ impl TcpStream { // IoSlice isn't Copy, so we must expand this manually ;_; let mut slices: [IoSlice<'_>; MAX_BUFS] = [ - IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), - IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), - IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), - IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), - IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), - IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), - IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), - IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), - IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), - IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), - IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), - IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), - IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), - IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), - IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), - IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), + IoSlice::new(S), ]; let cnt = buf.bytes_vectored(&mut slices); @@ -703,11 +751,11 @@ impl TcpStream { Ok(n) => { buf.advance(n); Poll::Ready(Ok(n)) - }, + } Err(ref e) if e.kind() == io::ErrorKind::WouldBlock => { self.io.clear_write_ready(cx)?; Poll::Pending - }, + } Err(e) => Poll::Ready(Err(e)), } } |