From b506f13d5bf8e5e7498c5676a4740a0484df8894 Mon Sep 17 00:00:00 2001 From: iamqizhao Date: Wed, 11 May 2016 10:46:23 -0700 Subject: [PATCH] change the error code when the required decompressor is not installed --- rpc_util.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/rpc_util.go b/rpc_util.go index 2b8ae7ba..a0873a0c 100644 --- a/rpc_util.go +++ b/rpc_util.go @@ -285,7 +285,7 @@ func checkRecvPayload(pf payloadFormat, recvCompress string, dc Decompressor) er case compressionNone: case compressionMade: if recvCompress == "" { - return transport.StreamErrorf(codes.Internal, "grpc: invalid grpc-encoding with compression enabled") + return transport.StreamErrorf(codes.Unimplemented, "grpc: invalid grpc-encoding with compression enabled") } if dc == nil || recvCompress != dc.Type() { return transport.StreamErrorf(codes.Unimplemented, "grpc: Decompressor is not installed for grpc-encoding %q", recvCompress)