From 23849d3831fbd09e367843bc736bdd8fd4837503 Mon Sep 17 00:00:00 2001
From: Piotr Findeisen <piotr.findeisen@gmail.com>
Date: Tue, 12 Apr 2022 11:45:59 +0200
Subject: [PATCH] Mark skipped tests as such

---
 .../compress/AbstractTestCompression.java       | 17 +++++++++--------
 1 file changed, 9 insertions(+), 8 deletions(-)

diff --git a/src/test/java/io/airlift/compress/AbstractTestCompression.java b/src/test/java/io/airlift/compress/AbstractTestCompression.java
index f1355a85..cd0036d1 100644
--- a/src/test/java/io/airlift/compress/AbstractTestCompression.java
+++ b/src/test/java/io/airlift/compress/AbstractTestCompression.java
@@ -15,6 +15,7 @@
 
 import com.google.common.primitives.Bytes;
 import io.airlift.compress.benchmark.DataSet;
+import org.testng.SkipException;
 import org.testng.annotations.DataProvider;
 import org.testng.annotations.Guice;
 import org.testng.annotations.Test;
@@ -147,7 +148,7 @@ public void testDecompressByteBufferHeapToHeap(DataSet dataSet)
             throws Exception
     {
         if (!isByteBufferSupported()) {
-            return;
+            throw new SkipException("ByteBuffer not supported");
         }
 
         byte[] uncompressedOriginal = dataSet.getUncompressed();
@@ -166,7 +167,7 @@ public void testDecompressByteBufferHeapToDirect(DataSet dataSet)
             throws Exception
     {
         if (!isByteBufferSupported()) {
-            return;
+            throw new SkipException("ByteBuffer not supported");
         }
 
         byte[] uncompressedOriginal = dataSet.getUncompressed();
@@ -185,7 +186,7 @@ public void testDecompressByteBufferDirectToHeap(DataSet dataSet)
             throws Exception
     {
         if (!isByteBufferSupported()) {
-            return;
+            throw new SkipException("ByteBuffer not supported");
         }
 
         byte[] uncompressedOriginal = dataSet.getUncompressed();
@@ -204,7 +205,7 @@ public void testDecompressByteBufferDirectToDirect(DataSet dataSet)
             throws Exception
     {
         if (!isByteBufferSupported()) {
-            return;
+            throw new SkipException("ByteBuffer not supported");
         }
 
         byte[] uncompressedOriginal = dataSet.getUncompressed();
@@ -250,7 +251,7 @@ public void testCompressByteBufferHeapToHeap(DataSet dataSet)
             throws Exception
     {
         if (!isByteBufferSupported()) {
-            return;
+            throw new SkipException("ByteBuffer not supported");
         }
 
         byte[] uncompressedOriginal = dataSet.getUncompressed();
@@ -268,7 +269,7 @@ public void testCompressByteBufferHeapToDirect(DataSet dataSet)
             throws Exception
     {
         if (!isByteBufferSupported()) {
-            return;
+            throw new SkipException("ByteBuffer not supported");
         }
 
         byte[] uncompressedOriginal = dataSet.getUncompressed();
@@ -286,7 +287,7 @@ public void testCompressByteBufferDirectToHeap(DataSet dataSet)
             throws Exception
     {
         if (!isByteBufferSupported()) {
-            return;
+            throw new SkipException("ByteBuffer not supported");
         }
 
         byte[] uncompressedOriginal = dataSet.getUncompressed();
@@ -304,7 +305,7 @@ public void testCompressByteBufferDirectToDirect(DataSet dataSet)
             throws Exception
     {
         if (!isByteBufferSupported()) {
-            return;
+            throw new SkipException("ByteBuffer not supported");
         }
 
         byte[] uncompressedOriginal = dataSet.getUncompressed();