From 204e00a91f51fe445e52c8bdf9c2640cf7e14975 Mon Sep 17 00:00:00 2001 From: alan <652732310@qq.com> Date: Fri, 19 Jul 2024 19:44:49 +0800 Subject: [PATCH] show more error detail for invalidMessageError --- rpc/server.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/rpc/server.go b/rpc/server.go index 52866004f8..8d2522abab 100644 --- a/rpc/server.go +++ b/rpc/server.go @@ -18,6 +18,7 @@ package rpc import ( "context" + "fmt" "io" "sync" "sync/atomic" @@ -152,7 +153,7 @@ func (s *Server) serveSingleRequest(ctx context.Context, codec ServerCodec) { reqs, batch, err := codec.readBatch() if err != nil { if err != io.EOF { - resp := errorMessage(&invalidMessageError{"parse error"}) + resp := errorMessage(&invalidMessageError{fmt.Sprintf("parse error: %s", err.Error())}) codec.writeJSON(ctx, resp, true) } return