Don't leak decompressor in gRPC v2.

We don't use the decompressor at all in gRPC v2, but it may still have
resources that should be close()d.
-------------
Created by MOE: http://code.google.com/p/moe-java
MOE_MIGRATED_REVID=81271990
This commit is contained in:
ejona 2014-12-03 12:55:39 -08:00 committed by Eric Anderson
parent 751a4df52a
commit fb09bba456
2 changed files with 3 additions and 0 deletions

View File

@ -104,6 +104,9 @@ public abstract class AbstractStream<IdT> implements Stream {
new GrpcDeframer(decompressor, inboundMessageHandler, deframerExecutor, listener); new GrpcDeframer(decompressor, inboundMessageHandler, deframerExecutor, listener);
this.deframer2 = null; this.deframer2 = null;
} else { } else {
if (decompressor != null) {
decompressor.close();
}
framer = new MessageFramer2(outboundFrameHandler, 4096); framer = new MessageFramer2(outboundFrameHandler, 4096);
this.deframer = null; this.deframer = null;
this.deframer2 = new MessageDeframer2(inboundMessageHandler, deframerExecutor, listener); this.deframer2 = new MessageDeframer2(inboundMessageHandler, deframerExecutor, listener);

Binary file not shown.