refactor(http): adjust debug logs

src/http/conn.rs

@@ -97,6 +97,7 @@ impl<I: Io, T: Http1Transaction, K: KeepAlive> Conn<I, T, K> {
                             other => Err(io::Error::new(io::ErrorKind::UnexpectedEof, other)),
                         }
                     } else {
+                        debug!("socket read eof");
                         Ok(Async::Ready(None))
                     }
                 };

src/http/h1/encode.rs

@@ -59,7 +59,8 @@ impl Encoder {
                 }
 
                 *remaining -= n as u64;
-                trace!("sized write complete, remaining = {}", remaining);
+                debug!("encoded {} bytes", n);
+                trace!("encode sized complete, remaining = {}", remaining);
                 Ok(n)
             },
         }

src/http/io.rs

@@ -126,7 +126,11 @@ impl<T: Write> Write for Buffered<T> {
     }
 
     fn flush(&mut self) -> io::Result<()> {
-        self.write_buf.write_into(&mut self.io).and_then(|_n| {
+        if self.write_buf.remaining() == 0 {
+            Ok(())
+        } else {
+            self.write_buf.write_into(&mut self.io).and_then(|n| {
+                debug!("flushed {} bytes", n);
                 if self.write_buf.remaining() == 0 {
                     Ok(())
                 } else {
@@ -135,6 +139,7 @@ impl<T: Write> Write for Buffered<T> {
             })
         }
     }
+}
 
 fn parse<T: Http1Transaction<Incoming=I>, I>(rdr: &[u8]) -> ParseResult<I> {
     h1::parse::<T, I>(rdr)
@@ -290,6 +295,7 @@ impl WriteBuf {
             trace!("WriteBuf reserving initial {}", init);
             vec.reserve(init);
         } else if cap < MAX_BUFFER_SIZE {
+            trace!("maybe_reserve MAX={}, needed={}, cap={}", MAX_BUFFER_SIZE, needed, cap);
             vec.reserve(cmp::min(needed, MAX_BUFFER_SIZE - cap));
             trace!("WriteBuf reserved {}", vec.capacity() - cap);
         }