summaryrefslogtreecommitdiffstats
path: root/vespajlib/src
diff options
context:
space:
mode:
authorTor Brede Vekterli <vekterli@yahoo-inc.com>2017-06-09 17:52:33 +0200
committerTor Brede Vekterli <vekterli@yahoo-inc.com>2017-06-12 15:16:33 +0200
commitd165ec86d13eb7ba8635db3408148e82b7456368 (patch)
treed798ba990ff6b6a91d5c6c8d4a550c931f096555 /vespajlib/src
parent9a6d1fc6f5635fe917d1a563149764be12822ffc (diff)
Compressor must only compress actual input range, not entire array
Diffstat (limited to 'vespajlib/src')
-rw-r--r--vespajlib/src/main/java/com/yahoo/compress/Compressor.java2
1 files changed, 1 insertions, 1 deletions
diff --git a/vespajlib/src/main/java/com/yahoo/compress/Compressor.java b/vespajlib/src/main/java/com/yahoo/compress/Compressor.java
index 681f95142ab..4cdade4de01 100644
--- a/vespajlib/src/main/java/com/yahoo/compress/Compressor.java
+++ b/vespajlib/src/main/java/com/yahoo/compress/Compressor.java
@@ -80,7 +80,7 @@ public class Compressor {
int dataSize = uncompressedSize.isPresent() ? uncompressedSize.get() : data.length;
if (dataSize < compressMinSizeBytes) return new Compression(CompressionType.INCOMPRESSIBLE, dataSize, data);
LZ4Compressor compressor = level < 7 ? factory.fastCompressor() : factory.highCompressor();
- byte[] compressedData = compressor.compress(data);
+ byte[] compressedData = compressor.compress(data, 0, dataSize);
if (compressedData.length + 8 >= dataSize * compressionThresholdFactor)
return new Compression(CompressionType.INCOMPRESSIBLE, dataSize, data);
return new Compression(CompressionType.LZ4, dataSize, compressedData);