allocate buffer for request payload extractors

cdt3 · Jul 15, 2018 · 3373847 · 3373847
1 parent 30c8478
commit 3373847
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/.travis.yml b/.travis.yml
@@ -36,7 +36,7 @@ script:
     fi
   - |
     if [[ "$TRAVIS_RUST_VERSION" == "stable" ]]; then
-    RUSTFLAGS="--cfg procmacro2_semver_exempt" cargo install cargo-tarpaulin
+    RUSTFLAGS="--cfg procmacro2_semver_exempt" cargo install -f cargo-tarpaulin
     cargo tarpaulin --features="alpn,tls" --out Xml --no-count
     bash <(curl -s https://codecov.io/bash)
     echo "Uploaded code coverage"

diff --git a/src/httpmessage.rs b/src/httpmessage.rs
@@ -286,7 +286,7 @@ impl<T: HttpMessage> Readlines<T> {
     fn err(req: &T, err: ReadlinesError) -> Self {
         Readlines {
             stream: req.payload(),
-            buff: BytesMut::with_capacity(262_144),
+            buff: BytesMut::new(),
             limit: 262_144,
             checked_buff: true,
             encoding: UTF_8,
@@ -472,7 +472,7 @@ where
                 .take()
                 .expect("Can not be used second time")
                 .from_err()
-                .fold(BytesMut::new(), move |mut body, chunk| {
+                .fold(BytesMut::with_capacity(8192), move |mut body, chunk| {
                     if (body.len() + chunk.len()) > limit {
                         Err(PayloadError::Overflow)
                     } else {
@@ -581,7 +581,7 @@ where
             .take()
             .expect("UrlEncoded could not be used second time")
             .from_err()
-            .fold(BytesMut::new(), move |mut body, chunk| {
+            .fold(BytesMut::with_capacity(8192), move |mut body, chunk| {
                 if (body.len() + chunk.len()) > limit {
                     Err(UrlencodedError::Overflow)
                 } else {

diff --git a/src/json.rs b/src/json.rs
@@ -320,7 +320,7 @@ impl<T: HttpMessage + 'static, U: DeserializeOwned + 'static> Future for JsonBod
             .take()
             .expect("JsonBody could not be used second time")
             .from_err()
-            .fold(BytesMut::new(), move |mut body, chunk| {
+            .fold(BytesMut::with_capacity(8192), move |mut body, chunk| {
                 if (body.len() + chunk.len()) > limit {
                     Err(JsonPayloadError::Overflow)
                 } else {