CURATOR-487 - Rename unit test
Project: http://git-wip-us.apache.org/repos/asf/curator/repo Commit: http://git-wip-us.apache.org/repos/asf/curator/commit/ec702086 Tree: http://git-wip-us.apache.org/repos/asf/curator/tree/ec702086 Diff: http://git-wip-us.apache.org/repos/asf/curator/diff/ec702086 Branch: refs/heads/CURATOR-487 Commit: ec7020861a724446e663156a7939555623fd70dd Parents: 388787c Author: Cam McKenzie <cammcken...@apache.org> Authored: Mon Dec 10 09:43:34 2018 +1100 Committer: Cam McKenzie <cammcken...@apache.org> Committed: Mon Dec 10 09:43:34 2018 +1100 ---------------------------------------------------------------------- .../imps/GzipCompressionProviderTest.java | 125 ------------------- .../imps/TestGzipCompressionProvider.java | 125 +++++++++++++++++++ 2 files changed, 125 insertions(+), 125 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/curator/blob/ec702086/curator-framework/src/test/java/org/apache/curator/framework/imps/GzipCompressionProviderTest.java ---------------------------------------------------------------------- diff --git a/curator-framework/src/test/java/org/apache/curator/framework/imps/GzipCompressionProviderTest.java b/curator-framework/src/test/java/org/apache/curator/framework/imps/GzipCompressionProviderTest.java deleted file mode 100644 index 51edaba..0000000 --- a/curator-framework/src/test/java/org/apache/curator/framework/imps/GzipCompressionProviderTest.java +++ /dev/null @@ -1,125 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -package org.apache.curator.framework.imps; - -import org.testng.Assert; -import org.testng.annotations.Test; - -import java.io.ByteArrayOutputStream; -import java.io.IOException; -import java.util.Arrays; -import java.util.concurrent.ThreadLocalRandom; -import java.util.zip.GZIPOutputStream; - -public class GzipCompressionProviderTest -{ - @Test - public void testSimple() throws IOException - { - GzipCompressionProvider provider = new GzipCompressionProvider(); - byte[] data = "Hello, world!".getBytes(); - byte[] compressedData = provider.compress(null, data); - byte[] jdkCompressedData = jdkCompress(data); - Assert.assertTrue(Arrays.equals(compressedData, jdkCompressedData)); - byte[] decompressedData = provider.decompress(null, compressedData); - Assert.assertTrue(Arrays.equals(decompressedData, data)); - } - - @Test - public void testEmpty() throws IOException - { - GzipCompressionProvider provider = new GzipCompressionProvider(); - byte[] compressedData = provider.compress(null, new byte[0]); - byte[] compressedData2 = GzipCompressionProvider.doCompress(new byte[0]); - byte[] jdkCompress = jdkCompress(new byte[0]); - // Ensures GzipCompressionProvider.COMPRESSED_EMPTY_BYTES value is valid - Assert.assertTrue(Arrays.equals(compressedData, compressedData2)); - Assert.assertTrue(Arrays.equals(compressedData, jdkCompress)); - byte[] decompressedData = provider.decompress(null, compressedData); - Assert.assertEquals(0, decompressedData.length); - } - - /** - * This test ensures that in the face of corrupt data, specifically IOException is thrown, rather some other kind - * of runtime exception. Users of {@link GzipCompressionProvider#decompress(String, byte[])} may depend on this. - */ - @Test - public void testDecompressCorrupt() - { - GzipCompressionProvider provider = new GzipCompressionProvider(); - try { - provider.decompress(null, new byte[100]); - Assert.fail("Expected IOException"); - } catch (IOException ignore) { - // expected - } - byte[] compressedData = provider.compress(null, new byte[0]); - for (int i = 0; i < compressedData.length; i++) - { - try { - provider.decompress(null, Arrays.copyOf(compressedData, i)); - } catch (IOException ignore) { - // expected - } - for (int change = 1; change < 256; change++) - { - byte b = compressedData[i]; - compressedData[i] = (byte) (b + change); - try { - provider.decompress(null, compressedData); - // No exception is OK - } catch (IOException ignore) { - // expected - } - // reset value back - compressedData[i] = b; - } - } - } - - @Test - public void smokeTestRandomDataWithJdk() throws IOException - { - GzipCompressionProvider provider = new GzipCompressionProvider(); - ThreadLocalRandom random = ThreadLocalRandom.current(); - for (int len = 1; len < 100; len++) - { - byte[] data = new byte[len]; - for (int i = 0; i < 100; i++) { - byte[] compressedData = provider.compress(null, data); - byte[] jdkCompressedData = jdkCompress(data); - Assert.assertTrue(Arrays.equals(compressedData, jdkCompressedData)); - byte[] decompressedData = provider.decompress(null, compressedData); - Assert.assertTrue(Arrays.equals(decompressedData, data)); - // in the end of the iteration to test empty array first - random.nextBytes(data); - } - } - } - - private static byte[] jdkCompress(byte[] data) throws IOException - { - ByteArrayOutputStream bytes = new ByteArrayOutputStream(); - try (GZIPOutputStream out = new GZIPOutputStream(bytes)) { - out.write(data); - out.finish(); - } - return bytes.toByteArray(); - } -} http://git-wip-us.apache.org/repos/asf/curator/blob/ec702086/curator-framework/src/test/java/org/apache/curator/framework/imps/TestGzipCompressionProvider.java ---------------------------------------------------------------------- diff --git a/curator-framework/src/test/java/org/apache/curator/framework/imps/TestGzipCompressionProvider.java b/curator-framework/src/test/java/org/apache/curator/framework/imps/TestGzipCompressionProvider.java new file mode 100644 index 0000000..2856b4d --- /dev/null +++ b/curator-framework/src/test/java/org/apache/curator/framework/imps/TestGzipCompressionProvider.java @@ -0,0 +1,125 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +package org.apache.curator.framework.imps; + +import org.testng.Assert; +import org.testng.annotations.Test; + +import java.io.ByteArrayOutputStream; +import java.io.IOException; +import java.util.Arrays; +import java.util.concurrent.ThreadLocalRandom; +import java.util.zip.GZIPOutputStream; + +public class TestGzipCompressionProvider +{ + @Test + public void testSimple() throws IOException + { + GzipCompressionProvider provider = new GzipCompressionProvider(); + byte[] data = "Hello, world!".getBytes(); + byte[] compressedData = provider.compress(null, data); + byte[] jdkCompressedData = jdkCompress(data); + Assert.assertTrue(Arrays.equals(compressedData, jdkCompressedData)); + byte[] decompressedData = provider.decompress(null, compressedData); + Assert.assertTrue(Arrays.equals(decompressedData, data)); + } + + @Test + public void testEmpty() throws IOException + { + GzipCompressionProvider provider = new GzipCompressionProvider(); + byte[] compressedData = provider.compress(null, new byte[0]); + byte[] compressedData2 = GzipCompressionProvider.doCompress(new byte[0]); + byte[] jdkCompress = jdkCompress(new byte[0]); + // Ensures GzipCompressionProvider.COMPRESSED_EMPTY_BYTES value is valid + Assert.assertTrue(Arrays.equals(compressedData, compressedData2)); + Assert.assertTrue(Arrays.equals(compressedData, jdkCompress)); + byte[] decompressedData = provider.decompress(null, compressedData); + Assert.assertEquals(0, decompressedData.length); + } + + /** + * This test ensures that in the face of corrupt data, specifically IOException is thrown, rather some other kind + * of runtime exception. Users of {@link GzipCompressionProvider#decompress(String, byte[])} may depend on this. + */ + @Test + public void testDecompressCorrupt() + { + GzipCompressionProvider provider = new GzipCompressionProvider(); + try { + provider.decompress(null, new byte[100]); + Assert.fail("Expected IOException"); + } catch (IOException ignore) { + // expected + } + byte[] compressedData = provider.compress(null, new byte[0]); + for (int i = 0; i < compressedData.length; i++) + { + try { + provider.decompress(null, Arrays.copyOf(compressedData, i)); + } catch (IOException ignore) { + // expected + } + for (int change = 1; change < 256; change++) + { + byte b = compressedData[i]; + compressedData[i] = (byte) (b + change); + try { + provider.decompress(null, compressedData); + // No exception is OK + } catch (IOException ignore) { + // expected + } + // reset value back + compressedData[i] = b; + } + } + } + + @Test + public void smokeTestRandomDataWithJdk() throws IOException + { + GzipCompressionProvider provider = new GzipCompressionProvider(); + ThreadLocalRandom random = ThreadLocalRandom.current(); + for (int len = 1; len < 100; len++) + { + byte[] data = new byte[len]; + for (int i = 0; i < 100; i++) { + byte[] compressedData = provider.compress(null, data); + byte[] jdkCompressedData = jdkCompress(data); + Assert.assertTrue(Arrays.equals(compressedData, jdkCompressedData)); + byte[] decompressedData = provider.decompress(null, compressedData); + Assert.assertTrue(Arrays.equals(decompressedData, data)); + // in the end of the iteration to test empty array first + random.nextBytes(data); + } + } + } + + private static byte[] jdkCompress(byte[] data) throws IOException + { + ByteArrayOutputStream bytes = new ByteArrayOutputStream(); + try (GZIPOutputStream out = new GZIPOutputStream(bytes)) { + out.write(data); + out.finish(); + } + return bytes.toByteArray(); + } +}