refactor(all): adjust some logging

This commit is contained in:
Sean McArthur
2015-05-09 22:18:05 -07:00
parent 38f40c7f6a
commit a3637d5f73
4 changed files with 6 additions and 4 deletions

View File

@@ -53,11 +53,13 @@ impl<R: Read> BufReader<R> {
pub fn read_into_buf(&mut self) -> io::Result<usize> { pub fn read_into_buf(&mut self) -> io::Result<usize> {
self.maybe_reserve(); self.maybe_reserve();
let v = &mut self.buf; let v = &mut self.buf;
trace!("read_into_buf pos={}, cap={}", self.cap, v.capacity());
if self.cap < v.capacity() { if self.cap < v.capacity() {
let nread = try!(self.inner.read(&mut v[self.cap..])); let nread = try!(self.inner.read(&mut v[self.cap..]));
self.cap += nread; self.cap += nread;
Ok(nread) Ok(nread)
} else { } else {
trace!("read_into_buf at full capacity");
Ok(0) Ok(0)
} }
} }

View File

@@ -237,7 +237,7 @@ impl<'a, U: IntoUrl> RequestBuilder<'a, U> {
if res.status.class() != Redirection { if res.status.class() != Redirection {
return Ok(res) return Ok(res)
} }
debug!("redirect code {:?} for {:?}", res.status, url); debug!("redirect code {:?} for {}", res.status, url);
let loc = { let loc = {
// punching borrowck here // punching borrowck here
@@ -257,9 +257,7 @@ impl<'a, U: IntoUrl> RequestBuilder<'a, U> {
} }
}; };
url = match loc { url = match loc {
Ok(u) => { Ok(u) => u,
inspect!("Location", u)
},
Err(e) => { Err(e) => {
debug!("Location header had invalid URI: {:?}", e); debug!("Location header had invalid URI: {:?}", e);
return Ok(res); return Ok(res);

View File

@@ -104,6 +104,7 @@ impl<C: NetworkConnector<Stream=S>, S: NetworkStream + Send> NetworkConnector fo
let mut should_remove = false; let mut should_remove = false;
let conn = match locked.conns.get_mut(&key) { let conn = match locked.conns.get_mut(&key) {
Some(ref mut vec) => { Some(ref mut vec) => {
trace!("Pool had connection, using");
should_remove = vec.len() == 1; should_remove = vec.len() == 1;
vec.pop().unwrap() vec.pop().unwrap()
} }

View File

@@ -32,6 +32,7 @@ impl Response {
/// Creates a new response from a server. /// Creates a new response from a server.
pub fn new(stream: Box<NetworkStream + Send>) -> ::Result<Response> { pub fn new(stream: Box<NetworkStream + Send>) -> ::Result<Response> {
trace!("Response::new");
let mut stream = BufReader::new(stream); let mut stream = BufReader::new(stream);
let head = try!(http::parse_response(&mut stream)); let head = try!(http::parse_response(&mut stream));