From d909d86660d98c57f48d5f4c2969f3c545a952a7 Mon Sep 17 00:00:00 2001 From: anaslimem Date: Tue, 31 Mar 2026 17:22:23 +0100 Subject: [PATCH] fix(rpc): handle write failures in handle_io loop --- src/agent-client-protocol/src/rpc.rs | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/agent-client-protocol/src/rpc.rs b/src/agent-client-protocol/src/rpc.rs index f10d4ef..9a1f21c 100644 --- a/src/agent-client-protocol/src/rpc.rs +++ b/src/agent-client-protocol/src/rpc.rs @@ -175,7 +175,8 @@ where log::trace!("send: {}", String::from_utf8_lossy(&outgoing_line)); outgoing_line.push(b'\n'); if let Err(e) = outgoing_bytes.write_all(&outgoing_line).await { - log::warn!("failed to send message to peer: {e}"); + log::error!("failed to send message to peer: {e}"); + break; } broadcast.outgoing(&message); } else { @@ -211,7 +212,8 @@ where log::trace!("send: {}", String::from_utf8_lossy(&outgoing_line)); outgoing_line.push(b'\n'); if let Err(e) = outgoing_bytes.write_all(&outgoing_line).await { - log::warn!("failed to send error response to peer: {e}"); + log::error!("failed to send error response to peer: {e}"); + break; } broadcast.outgoing(&error_response); }