Benign cargo Download

decode.rs

Contains an unbounded block loopRust test marker or harness

SHA-2560e9de0872534c2885617d8b648dbb052947034f081ac29371a5ba5a855e0d27e

Evidence

imports bytes::Bytes lines 1–12

1use std::usize;
2use std::io;
3
4use futures::{Async, Poll};
5use bytes::Bytes;
6use proto::io::MemRead;
7
8use self::Kind::{Length, Chunked, Eof};
9
10/// Decoders to handle different Transfer-Encodings.
11///
12/// If a message body does not include a Transf …

HTTP chunked transfer encoding literal in source lines 38–46

7… unked(ChunkedState, u64),
  /// A Reader used for responses that don't indicate a length or chunked.
  ///
  /// Note: This should only used for `Response`s. It is illegal for a
  /// `Request` to be made with both `Content-Length` and
  /// `Transfer-Encoding: chunked` missing, as explained from the spec:
  ///
  /// > If a Transfer-Encoding header field is present in a response and
  // …

Contains an unbounded block loop lines 103–108

5…         }
          Chunked(ref mut state, ref mut size) => {
              loop {
                  let mut buf = None;
                  // advances the chunked state
                  *state = try_read …

imports bytes::BytesMut lines 272–290

47… ind::InvalidInput, "Invalid chunk end LF")),
      }
  }
275}
276
277#[cfg(test)]
278mod tests {
  use std::error::Error;
  use std::io;
  use std::io::Write;
  use super::Decoder;
  use super::ChunkedState;
  use proto::io::MemRead;
  use futures::{Async, Poll};
  use bytes::{BytesMut, Bytes};
  use mock::AsyncIo;
288
  impl<'a> MemRead for &'a [u8] {
      fn read_mem(&mut self, len: usize) -> Poll<Bytes, …

Repeated Base64-alphabet Rust literals lines 421–427

43… .as_ref().to_vec()).expect("decode String");
      assert_eq!("1234567890abcdef", &result);
  }
424
  #[test]
  fn test_read_chunked_after_eof() {
      let mut mock_buf = &b"10\r\n1234567890abcdef\r\n0\ …