From 9daa9a3d2529cc2daba8ff927027dcf896919a1e Mon Sep 17 00:00:00 2001 From: Jay Date: Fri, 24 Apr 2026 07:48:47 -0400 Subject: [PATCH] log debug if error is from a self-close --- transport/connection.go | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) diff --git a/transport/connection.go b/transport/connection.go index f364081..7b45f9f 100644 --- a/transport/connection.go +++ b/transport/connection.go @@ -299,8 +299,18 @@ func (c *Connection) startReader() { wrappedErr = fmt.Errorf("%w: %w", ErrPeerClosedUnexpected, err) } } else { + isLocalClose := false + select { + case <-c.done: + isLocalClose = true + default: + } if c.logger != nil { - c.logger.Error("read error", "error", err) + if isLocalClose { + c.logger.Debug("read loop terminated", "error", err) + } else { + c.logger.Error("read error", "error", err) + } } wrappedErr = fmt.Errorf("%w: %w", ErrReadError, err) }