Merge pull request #17 from mulugetam/v1.1.1

Bug fix: polling mode should match what the user specified.

Author: mulugetam

jmh/qat-java-bench/pom.xml

@@ -60,7 +60,7 @@ THE POSSIBILITY OF SUCH DAMAGE.
         <dependency>
             <groupId>com.intel.qat</groupId>
             <artifactId>qat-java</artifactId>
-            <version>1.1.0</version>
+            <version>1.1.1</version>
         </dependency>
         <dependency>
             <groupId>com.github.luben</groupId>

pom.xml

@@ -5,7 +5,7 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>com.intel.qat</groupId>
     <artifactId>qat-java</artifactId>
-    <version>1.1.0</version>
+    <version>1.1.1</version>
     <packaging>jar</packaging>
     <name>qat-java</name>
     <description>Qat-Java is a compression library that uses Intel® QAT to accelerate compression and decompression.</description>

src/main/jni/com_intel_qat_InternalJNI.c

@@ -53,7 +53,7 @@ static int setup_deflate_session(QzSession_T *qz_session, int level,
   deflate_params.common_params.comp_lvl = level;
   deflate_params.common_params.sw_backup = sw_backup;
   deflate_params.common_params.polling_mode =
-      polling_mode ? QZ_BUSY_POLLING : QZ_PERIODICAL_POLLING;
+      polling_mode == 0 ? QZ_BUSY_POLLING : QZ_PERIODICAL_POLLING;
 
   return qzSetupSessionDeflate(qz_session, &deflate_params);
 }
@@ -75,7 +75,7 @@ static int setup_lz4_session(QzSession_T *qz_session, int level,
   lz4_params.common_params.comp_lvl = level;
   lz4_params.common_params.sw_backup = sw_backup;
   lz4_params.common_params.polling_mode =
-      polling_mode ? QZ_BUSY_POLLING : QZ_PERIODICAL_POLLING;
+      polling_mode == 0 ? QZ_BUSY_POLLING : QZ_PERIODICAL_POLLING;
 
   return qzSetupSessionLZ4(qz_session, &lz4_params);
 }

src/test/java/com/intel/qat/QatZipperTests.java

@@ -704,40 +704,6 @@ public void testCompressionDecompressionWithByteArray(Mode mode, Algorithm algo,
     }
   }
 
-  @ParameterizedTest
-  @MethodSource("provideModeAlgorithmLengthParams")
-  public void testCompressionWithInsufficientDestBuff(Mode mode, Algorithm algo, int len) {
-    try {
-      qzip = new QatZipper(algo, mode);
-
-      byte[] src = getRandomBytes(len);
-      byte[] dst = new byte[src.length / 10];
-
-      qzip.compress(src, 0, src.length, dst, 0, dst.length);
-    } catch (QatException | IndexOutOfBoundsException e) {
-      assertTrue(true);
-    }
-  }
-
-  @ParameterizedTest
-  @MethodSource("provideModeAlgorithmLengthParams")
-  public void testDecompressionWithInsufficientDestBuff(Mode mode, Algorithm algo, int len) {
-    try {
-      qzip = new QatZipper(algo, mode);
-
-      byte[] src = getRandomBytes(len);
-      byte[] dec = new byte[src.length / 2];
-      byte[] dst = new byte[src.length];
-
-      qzip.compress(src, 0, src.length, dst, 0, dst.length);
-      qzip.decompress(dst, 0, dst.length, dec, 0, dec.length);
-
-      fail();
-    } catch (QatException | IndexOutOfBoundsException e) {
-      assertTrue(true);
-    }
-  }
-
   @ParameterizedTest
   @MethodSource("provideModeAlgorithmLengthParams")
   public void testCompressionDecompressionWithDirectByteBuffer(Mode mode, Algorithm algo, int len) {