Skip to content

Commit 72984df

Browse files
committed
fix: return a grpc error when discard failed
Signed-off-by: ningmingxiao <ning.mingxiao@zte.com.cn>
1 parent ea3d589 commit 72984df

1 file changed

Lines changed: 1 addition & 2 deletions

File tree

channel.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -125,9 +125,8 @@ func (ch *channel) recv() (messageHeader, []byte, error) {
125125

126126
if mh.Length > uint32(messageLengthMax) {
127127
if _, err := ch.br.Discard(int(mh.Length)); err != nil {
128-
return mh, nil, fmt.Errorf("failed to discard after receiving oversized message: %w", err)
128+
return mh, nil, status.Errorf(codes.ResourceExhausted, "failed to discard after receiving oversized message: %s (message length %v maximum message size %v)", err.Error(), mh.Length, messageLengthMax)
129129
}
130-
131130
return mh, nil, status.Errorf(codes.ResourceExhausted, "message length %v exceed maximum message size of %v", mh.Length, messageLengthMax)
132131
}
133132

0 commit comments

Comments
 (0)