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

Check error when calling compressor.Compress (#2274)

Browse Source 
Compress can return an error, which was not checked.
This commit is contained in:
Jelte Fennema
2018-09-14 17:57:13 +02:00
committed by dfawley
parent acd1429515
commit f2aaa9bf74
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
rpc_util.go
View File

@ -531,7 +531,10 @@ func compress(in []byte, cp Compressor, compressor encoding.Compressor) ([]byte,
} }
cbuf := &bytes.Buffer{} cbuf := &bytes.Buffer{}
if compressor != nil { if compressor != nil {
z, _ := compressor.Compress(cbuf) z, err := compressor.Compress(cbuf)
if err != nil {
return nil, wrapErr(err)
}
if _, err := z.Write(in); err != nil { if _, err := z.Write(in); err != nil {
return nil, wrapErr(err) return nil, wrapErr(err)
} }