This is an automated email from the ASF dual-hosted git repository.

penghui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 9a9f88f9867 [cleanup][common] Use TestNG instead of JUnit (#15582)
9a9f88f9867 is described below

commit 9a9f88f9867ec9636ca1633d7caac1ceb2c17ade
Author: Zixuan Liu <[email protected]>
AuthorDate: Sat May 14 10:19:17 2022 +0800

    [cleanup][common] Use TestNG instead of JUnit (#15582)
---
 .../apache/pulsar/common/nar/NarUnpackerTest.java  |  2 +-
 .../ConcurrentLongLongPairHashMapTest.java         | 40 +++++++++++-----------
 2 files changed, 21 insertions(+), 21 deletions(-)

diff --git 
a/pulsar-common/src/test/java/org/apache/pulsar/common/nar/NarUnpackerTest.java 
b/pulsar-common/src/test/java/org/apache/pulsar/common/nar/NarUnpackerTest.java
index 1d2acd0fa4e..1f97b1b1b69 100644
--- 
a/pulsar-common/src/test/java/org/apache/pulsar/common/nar/NarUnpackerTest.java
+++ 
b/pulsar-common/src/test/java/org/apache/pulsar/common/nar/NarUnpackerTest.java
@@ -18,8 +18,8 @@
  */
 package org.apache.pulsar.common.nar;
 
-import static org.junit.Assert.assertTrue;
 import static org.testng.Assert.assertEquals;
+import static org.testng.Assert.assertTrue;
 import java.io.File;
 import java.io.FileOutputStream;
 import java.io.IOException;
diff --git 
a/pulsar-common/src/test/java/org/apache/pulsar/common/util/collections/ConcurrentLongLongPairHashMapTest.java
 
b/pulsar-common/src/test/java/org/apache/pulsar/common/util/collections/ConcurrentLongLongPairHashMapTest.java
index 98a96804d25..1245784e1a0 100644
--- 
a/pulsar-common/src/test/java/org/apache/pulsar/common/util/collections/ConcurrentLongLongPairHashMapTest.java
+++ 
b/pulsar-common/src/test/java/org/apache/pulsar/common/util/collections/ConcurrentLongLongPairHashMapTest.java
@@ -18,11 +18,11 @@
  */
 package org.apache.pulsar.common.util.collections;
 
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertFalse;
-import static org.junit.Assert.assertTrue;
-import static org.junit.Assert.fail;
-
+import static org.testng.Assert.assertEquals;
+import static org.testng.Assert.assertFalse;
+import static org.testng.Assert.assertNull;
+import static org.testng.Assert.assertTrue;
+import static org.testng.Assert.fail;
 import com.google.common.collect.Lists;
 
 import java.util.ArrayList;
@@ -35,7 +35,7 @@ import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.Future;
 import 
org.apache.pulsar.common.util.collections.ConcurrentLongLongPairHashMap.LongPair;
-import org.junit.Test;
+import org.testng.annotations.Test;
 
 /**
  * Test the concurrent long-long pair hashmap class.
@@ -93,8 +93,8 @@ public class ConcurrentLongLongPairHashMapTest {
 
         assertTrue(map.remove(1, 1));
         assertEquals(map.size(), 2);
-        assertEquals(map.get(1, 1), null);
-        assertEquals(map.get(5, 5), null);
+        assertNull(map.get(1, 1));
+        assertNull(map.get(5, 5));
         assertEquals(map.size(), 2);
 
         assertTrue(map.put(1, 1, 11, 11));
@@ -129,15 +129,15 @@ public class ConcurrentLongLongPairHashMapTest {
                 .autoShrink(true)
                 .mapIdleFactor(0.25f)
                 .build();
-        assertTrue(map.capacity() == 4);
+        assertEquals(map.capacity(), 4);
 
         assertTrue(map.put(1, 1, 11, 11));
         assertTrue(map.put(2, 2, 22, 22));
         assertTrue(map.put(3, 3, 33, 33));
 
-        assertTrue(map.capacity() == 8);
+        assertEquals(map.capacity(), 8);
         map.clear();
-        assertTrue(map.capacity() == 4);
+        assertEquals(map.capacity(), 4);
     }
 
     @Test
@@ -153,24 +153,24 @@ public class ConcurrentLongLongPairHashMapTest {
         assertTrue(map.put(3, 3, 33, 33));
 
         // expand hashmap
-        assertTrue(map.capacity() == 8);
+        assertEquals(map.capacity(), 8);
 
         assertTrue(map.remove(1, 1, 11, 11));
         // not shrink
-        assertTrue(map.capacity() == 8);
+        assertEquals(map.capacity(), 8);
         assertTrue(map.remove(2, 2, 22, 22));
         // shrink hashmap
-        assertTrue(map.capacity() == 4);
+        assertEquals(map.capacity(), 4);
 
         // expand hashmap
         assertTrue(map.put(4, 4, 44, 44));
         assertTrue(map.put(5, 5, 55, 55));
-        assertTrue(map.capacity() == 8);
+        assertEquals(map.capacity(), 8);
 
         //verify that the map does not keep shrinking at every remove() 
operation
         assertTrue(map.put(6, 6, 66, 66));
         assertTrue(map.remove(6, 6, 66, 66));
-        assertTrue(map.capacity() == 8);
+        assertEquals(map.capacity(), 8);
     }
 
     @Test
@@ -181,13 +181,13 @@ public class ConcurrentLongLongPairHashMapTest {
                 .build();
 
         map.put(0, 0, 0, 0);
-        assertEquals(1, map.getUsedBucketCount());
+        assertEquals(map.getUsedBucketCount(), 1);
         map.put(0, 0, 1, 1);
-        assertEquals(1, map.getUsedBucketCount());
+        assertEquals(map.getUsedBucketCount(), 1);
         map.remove(0, 0);
-        assertEquals(0, map.getUsedBucketCount());
+        assertEquals(map.getUsedBucketCount(), 0);
         map.remove(0, 0);
-        assertEquals(0, map.getUsedBucketCount());
+        assertEquals(map.getUsedBucketCount(), 0);
     }
 
     @Test

Reply via email to