aboutsummaryrefslogtreecommitdiff
path: root/jsonrpc/src/client
diff options
context:
space:
mode:
authorhozan23 <hozan23@karyontech.net>2024-05-30 02:07:50 +0200
committerhozan23 <hozan23@karyontech.net>2024-05-30 02:07:50 +0200
commita06239ccc5e21fd20182ec3046cf9174ecc58a43 (patch)
tree12bf68067ba377f8bb081e98c3e3a4ac4fcd13b7 /jsonrpc/src/client
parent34f528a3b4063b4a25915e60d7f22ee1fb2d1bd9 (diff)
jsonrpc/server: use queue with condvar instead of async channels
Diffstat (limited to 'jsonrpc/src/client')
-rw-r--r--jsonrpc/src/client/mod.rs7
1 files changed, 6 insertions, 1 deletions
diff --git a/jsonrpc/src/client/mod.rs b/jsonrpc/src/client/mod.rs
index 326252a..3a4505c 100644
--- a/jsonrpc/src/client/mod.rs
+++ b/jsonrpc/src/client/mod.rs
@@ -149,7 +149,12 @@ impl Client {
async move {
loop {
let msg = selfc.conn.recv().await?;
- selfc.handle_msg(msg).await?;
+ if let Err(err) = selfc.handle_msg(msg).await {
+ error!(
+ "Failed to handle a new received msg from the connection {} : {err}",
+ selfc.conn.peer_endpoint()?
+ );
+ }
}
},
on_failure,