OMGeeky/tarpc
1
0
Fork 0
mirror of https://github.com/OMGeeky/tarpc.git synced 2026-01-02 17:42:23 +01:00
Code Issues Packages Projects Releases Wiki Activity

Some logs to help with debugging

Browse Source
This commit is contained in:
Adam Wright
2016-01-26 20:42:18 -08:00
parent 288ce6a94a
commit b83a72a4ce
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
tarpc/src/protocol.rs
View File

@@ -164,9 +164,6 @@ impl<'a, S> ConnectionHandler<'a, S> where S: Serve {
Err(bincode::serde::DeserializeError::IoError(ref err))
if Self::timed_out(err.kind()) => {
if !shutdown.load(Ordering::SeqCst) {
info!("ConnectionHandler: read timed out ({:?}). Server not \
shutdown, so retrying read.",
err);
continue;
} else {
info!("ConnectionHandler: read timed out ({:?}). Server shutdown, so \
@@ -460,10 +457,15 @@ impl<Request, Reply> Client<Request, Reply>
err);
try!(self.requests.lock().unwrap().remove_tx(id));
}
debug!("finishing rpc({:?})", request);
drop(state);
debug!("recv");
match rx.recv() {
Ok(msg) => Ok(msg),
Err(_) => Err(self.requests.lock().unwrap().get_error()),
Err(_) => {
debug!("locking requests map");
let r = Err(self.requests.lock().unwrap().get_error());
}
}
}
}