From bfbba26ba1b19e2649fd69c3a157c36886cee483 Mon Sep 17 00:00:00 2001 From: parazyd Date: Wed, 16 Nov 2022 20:32:07 +0100 Subject: [PATCH] rpc: Don't kill connections if the endpoint returns a JSON-RPC error. --- src/rpc/client.rs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/rpc/client.rs b/src/rpc/client.rs index b5e0ab211..d035fce51 100644 --- a/src/rpc/client.rs +++ b/src/rpc/client.rs @@ -81,13 +81,13 @@ impl RpcClient { let resp_id = r.id.as_u64(); if resp_id.is_none() { let e = JsonError::new(ErrorCode::InvalidId, None, r.id); - self.stop_signal.send(()).await?; + //self.stop_signal.send(()).await?; return Err(Error::JsonRpcError(e.error.message.to_string())) } if resp_id.unwrap() != req_id { let e = JsonError::new(ErrorCode::InvalidId, None, r.id); - self.stop_signal.send(()).await?; + //self.stop_signal.send(()).await?; return Err(Error::JsonRpcError(e.error.message.to_string())) } @@ -97,13 +97,13 @@ impl RpcClient { JsonResult::Error(e) => { debug!(target: "jsonrpc-client", "<-- {}", serde_json::to_string(&e)?); // Close the server connection - self.stop_signal.send(()).await?; + //self.stop_signal.send(()).await?; Err(Error::JsonRpcError(e.error.message.to_string())) } JsonResult::Notification(n) => { debug!(target: "jsonrpc-client", "<-- {}", serde_json::to_string(&n)?); // Close the server connection - self.stop_signal.send(()).await?; + //self.stop_signal.send(()).await?; Err(Error::JsonRpcError("Unexpected reply".to_string())) } }