From d7290fa5c7cdac5a92c56d140c28924545098a3f Mon Sep 17 00:00:00 2001 From: pnvaidya Date: Fri, 24 Feb 2017 10:44:46 -0500 Subject: [PATCH] fix API issues --- .../com/intel/gkl/compression/IntelDeflater.java | 4 ++-- .../com/intel/gkl/compression/IntelInflater.java | 16 ++++++++++++++-- .../intel/gkl/compression/DeflaterUnitTest.java | 3 +-- 3 files changed, 17 insertions(+), 6 deletions(-) diff --git a/src/main/java/com/intel/gkl/compression/IntelDeflater.java b/src/main/java/com/intel/gkl/compression/IntelDeflater.java index 4953e547..9b2d5736 100644 --- a/src/main/java/com/intel/gkl/compression/IntelDeflater.java +++ b/src/main/java/com/intel/gkl/compression/IntelDeflater.java @@ -96,6 +96,7 @@ public IntelDeflater(int level, boolean nowrap) { this.level = level; this.nowrap = nowrap; strategy = DEFAULT_STRATEGY; + } /** @@ -135,6 +136,7 @@ public void reset() { */ @Override public void setInput(byte[] b, int off, int len) throws NullPointerException { + if(lz_stream == 0) reset(); if(b == null) { throw new NullPointerException("Input is null"); } @@ -144,8 +146,6 @@ public void setInput(byte[] b, int off, int len) throws NullPointerException { inputBuffer = b; inputBufferLength = len; - - } /** diff --git a/src/main/java/com/intel/gkl/compression/IntelInflater.java b/src/main/java/com/intel/gkl/compression/IntelInflater.java index f19c3929..9b74869e 100644 --- a/src/main/java/com/intel/gkl/compression/IntelInflater.java +++ b/src/main/java/com/intel/gkl/compression/IntelInflater.java @@ -88,6 +88,7 @@ public synchronized boolean load(File tempDir) { public IntelInflater(boolean nowrap) { // initFieldsNative(); this.nowrap = nowrap; + } /** @@ -116,6 +117,7 @@ public void reset() { */ @Override public void setInput(byte[] b, int off, int len) throws NullPointerException { + if(lz_stream == 0) reset(); if(b == null) { throw new NullPointerException("Input is null"); } @@ -125,6 +127,7 @@ public void setInput(byte[] b, int off, int len) throws NullPointerException { inputBuffer = b; inputBufferOffset = off; inputBufferLength = len; + } /** @@ -152,7 +155,7 @@ public int inflate (byte[] b, int off, int len ) { */ @Override public int inflate (byte[] b ) { - return inflateNative( b, 0, 0); + return inflateNative( b, 0, b.length); } /** @@ -175,6 +178,15 @@ public boolean finished() { */ @Override public void end() { - endNative(); + + if(lz_stream !=0) + { + endNative(); + lz_stream=0; + } } + + @Override + protected void finalize() {} + } \ No newline at end of file diff --git a/src/test/java/com/intel/gkl/compression/DeflaterUnitTest.java b/src/test/java/com/intel/gkl/compression/DeflaterUnitTest.java index 5673ec71..6a3f7e03 100644 --- a/src/test/java/com/intel/gkl/compression/DeflaterUnitTest.java +++ b/src/test/java/com/intel/gkl/compression/DeflaterUnitTest.java @@ -82,7 +82,6 @@ public void randomDNATest() { randomDNA(input); - deflater.reset(); deflater.setInput(input, 0, input.length); deflater.finish(); @@ -98,7 +97,7 @@ public void randomDNATest() { try { - inflater.reset(); + inflater.setInput(compressed, 0, compressedBytes); final long start = System.currentTimeMillis(); inflater.inflate(result, 0, LEN);