Debug

Author: koic

conformance/expected_failures.yml

@@ -5,5 +5,3 @@ server:
   - tools-call-elicitation
   - elicitation-sep1034-defaults
   - elicitation-sep1330-enums
-  # Fails on CI (Ubuntu, Ruby 4.0) but passes locally. Root cause under investigation.
-  - tools-call-with-logging

lib/mcp/server/transports/streamable_http_transport.rb

@@ -58,7 +58,7 @@ def send_notification(method, params = nil, session_id: nil)
               begin
                 send_to_stream(session[:stream], notification)
                 true
-              rescue IOError, Errno::EPIPE => e
+              rescue IOError, Errno::EPIPE, Errno::ECONNRESET => e
                 MCP.configuration.exception_reporter.call(
                   e,
                   { session_id: session_id, error: "Failed to send notification" },
@@ -77,7 +77,7 @@ def send_notification(method, params = nil, session_id: nil)
                 begin
                   send_to_stream(session[:stream], notification)
                   sent_count += 1
-                rescue IOError, Errno::EPIPE => e
+                rescue IOError, Errno::EPIPE, Errno::ECONNRESET => e
                   MCP.configuration.exception_reporter.call(
                     e,
                     { session_id: sid, error: "Failed to send notification" },
@@ -289,7 +289,7 @@ def send_response_to_stream(stream, response, session_id)
           message = JSON.parse(response)
           send_to_stream(stream, message)
           [200, { "Content-Type" => "application/json" }, [{ accepted: true }.to_json]]
-        rescue IOError, Errno::EPIPE => e
+        rescue IOError, Errno::EPIPE, Errno::ECONNRESET => e
           MCP.configuration.exception_reporter.call(
             e,
             { session_id: session_id, error: "Stream closed during response" },
@@ -366,7 +366,7 @@ def send_keepalive_ping(session_id)
               send_ping_to_stream(@sessions[session_id][:stream])
             end
           end
-        rescue IOError, Errno::EPIPE => e
+        rescue IOError, Errno::EPIPE, Errno::ECONNRESET => e
           MCP.configuration.exception_reporter.call(
             e,
             { session_id: session_id, error: "Stream closed" },