From 4db54932d800c89e5286be2d2be71ccb542772fc Mon Sep 17 00:00:00 2001
From: Adam Wright <aawright@google.com>
Date: Tue, 26 Jan 2016 20:48:21 -0800
Subject: [PATCH] Fix brokenness and add another log

---
 tarpc/src/protocol.rs | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/tarpc/src/protocol.rs b/tarpc/src/protocol.rs
index bba02b9..ea9a88b 100644
--- a/tarpc/src/protocol.rs
+++ b/tarpc/src/protocol.rs
@@ -139,6 +139,7 @@ impl<'a, S> ConnectionHandler<'a, S> where S: Serve {
             loop {
                 match Self::read(read_stream, timeout) {
                     Ok(Packet { rpc_id, message, }) => {
+                        debug!("ConnectionHandler: serving request, id: {}, message: {:?}", rpc_id, message);
                         inflight_rpcs.increment();
                         scope.spawn(move || {
                             let reply = server.serve(message);
@@ -457,14 +458,14 @@ impl<Request, Reply> Client<Request, Reply>
                   err);
             try!(self.requests.lock().unwrap().remove_tx(id));
         }
-        debug!("finishing rpc({:?})", request);
+        debug!("Client: finishing rpc({:?})", request);
         drop(state);
-        debug!("recv");
+        debug!("Client: recv");
         match rx.recv() {
             Ok(msg) => Ok(msg),
             Err(_) => {
                 debug!("locking requests map");
-                let r = Err(self.requests.lock().unwrap().get_error());
+                Err(self.requests.lock().unwrap().get_error())
             }
         }
     }