optimize: add origin error in log when write reply failed

ppzqh · Aug 29, 2024 · 7676880 · 7676880
1 parent ebd3dfe
commit 7676880
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/pkg/remote/trans/default_server_handler.go b/pkg/remote/trans/default_server_handler.go
@@ -299,7 +299,7 @@ func (t *svrTransHandler) writeErrorReplyIfNeeded(
 	}
 	ctx, err = t.transPipe.Write(ctx, conn, errMsg)
 	if err != nil {
-		klog.CtxErrorf(ctx, "KITEX: write error reply failed, remote=%s, error=%s", conn.RemoteAddr(), err.Error())
+		klog.CtxErrorf(ctx, "KITEX: write error reply failed, remote=%s, error=%s, origin error=%s", conn.RemoteAddr(), err.Error(), transErr.Error())
 		return true
 	}
 	return

diff --git a/pkg/remote/trans/netpollmux/server_handler.go b/pkg/remote/trans/netpollmux/server_handler.go
@@ -431,7 +431,7 @@ func (t *svrTransHandler) writeErrorReplyIfNeeded(
 	}
 	ctx, err = t.transPipe.Write(ctx, conn, errMsg)
 	if err != nil {
-		klog.CtxErrorf(ctx, "KITEX: write error reply failed, remote=%s, error=%s", conn.RemoteAddr(), err.Error())
+		klog.CtxErrorf(ctx, "KITEX: write error reply failed, remote=%s, error=%s, origin error=%s", conn.RemoteAddr(), err.Error(), transErr.Error())
 		return true
 	}
 	return