OMGeeky/tarpc
1
0
Fork 0
mirror of https://github.com/OMGeeky/tarpc.git synced 2025-12-31 08:33:51 +01:00
Code Issues Packages Projects Releases Wiki Activity

Fix brokenness and add another log

Browse Source
This commit is contained in:
Adam Wright
2016-01-26 20:48:21 -08:00
parent b83a72a4ce
commit 4db54932d8
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
tarpc/src/protocol.rs
View File

@@ -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())
}
}
}