Internal: Change LZFCompressedStreamOutput to use buffer recycler whe…

…n allocating encoder closes elastic#7613
mute · Oct 16, 2014 · 58c4a0b · 58c4a0b
1 parent e108610
commit 58c4a0b
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/src/main/java/org/elasticsearch/common/compress/lzf/LZFCompressedStreamOutput.java b/src/main/java/org/elasticsearch/common/compress/lzf/LZFCompressedStreamOutput.java
@@ -28,8 +28,6 @@
 
 import java.io.IOException;
 
-/**
- */
 public class LZFCompressedStreamOutput extends CompressedStreamOutput<LZFCompressorContext> {
 
     private final BufferRecycler recycler;
@@ -40,7 +38,7 @@ public LZFCompressedStreamOutput(StreamOutput out) throws IOException {
         this.recycler = BufferRecycler.instance();
         this.uncompressed = this.recycler.allocOutputBuffer(LZFChunk.MAX_CHUNK_LEN);
         this.uncompressedLength = LZFChunk.MAX_CHUNK_LEN;
-        this.encoder = ChunkEncoderFactory.safeInstance();
+        this.encoder = ChunkEncoderFactory.safeInstance(recycler);
     }
 
     @Override