opensource/grpc-go
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

change the error code when the required decompressor is not installed

Browse Source
This commit is contained in:
iamqizhao
2016-05-11 10:46:23 -07:00
parent 113bf2f219
commit b506f13d5b
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
rpc_util.go
View File

@ -285,7 +285,7 @@ func checkRecvPayload(pf payloadFormat, recvCompress string, dc Decompressor) er
case compressionNone: case compressionNone:
case compressionMade: case compressionMade:
if recvCompress == "" { 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() { if dc == nil || recvCompress != dc.Type() {
return transport.StreamErrorf(codes.Unimplemented, "grpc: Decompressor is not installed for grpc-encoding %q", recvCompress) return transport.StreamErrorf(codes.Unimplemented, "grpc: Decompressor is not installed for grpc-encoding %q", recvCompress)