move to pulsar-common

Author: BewareMyPower

pulsar-broker/src/main/java/org/apache/pulsar/broker/service/TopicLoadingContext.java

@@ -24,7 +24,7 @@
 import lombok.Getter;
 import lombok.Setter;
 import org.apache.pulsar.common.naming.TopicName;
-import org.apache.pulsar.utils.LatencyTracer;
+import org.apache.pulsar.common.util.LatencyTracer;
 import org.jspecify.annotations.Nullable;
 
 public class TopicLoadingContext extends LatencyTracer {

…g/apache/pulsar/utils/LatencyTracer.java …he/pulsar/common/util/LatencyTracer.javapulsar-broker/src/main/java/org/apache/pulsar/utils/LatencyTracer.java renamed to pulsar-common/src/main/java/org/apache/pulsar/common/util/LatencyTracer.java pulsar-broker/src/main/java/org/apache/pulsar/utils/LatencyTracer.java renamed to pulsar-common/src/main/java/org/apache/pulsar/common/util/LatencyTracer.java

@@ -16,8 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-
-package org.apache.pulsar.utils;
+package org.apache.pulsar.common.util;
 
 import com.google.common.annotations.VisibleForTesting;
 import java.util.ArrayList;

…ache/pulsar/utils/LatencyTracerTest.java …ulsar/common/util/LatencyTracerTest.javapulsar-broker/src/test/java/org/apache/pulsar/utils/LatencyTracerTest.java renamed to pulsar-common/src/test/java/org/apache/pulsar/common/util/LatencyTracerTest.java pulsar-broker/src/test/java/org/apache/pulsar/utils/LatencyTracerTest.java renamed to pulsar-common/src/test/java/org/apache/pulsar/common/util/LatencyTracerTest.java

@@ -16,14 +16,16 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package org.apache.pulsar.utils;
+package org.apache.pulsar.common.util;
 
 import static org.testng.Assert.assertEquals;
 import static org.testng.Assert.assertNotSame;
 import static org.testng.Assert.assertSame;
 import static org.testng.Assert.assertTrue;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.TimeUnit;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
 import org.testng.annotations.Test;
 
 @Test(groups = "utils")
@@ -60,7 +62,6 @@ public void testZeroMs() {
         tracer.trace("A", 999_999);
         tracer.trace("B", 2_000_000);
         tracer.trace("C", 2_100_000);
-        System.out.println(tracer);
         assertEquals(tracer.latencyString(), "total: 2 ms, A: 999 us, B: 1 ms, C: 100 us");
         assertEquals(tracer.latencyInMillis(), 2);
     }
@@ -78,7 +79,9 @@ public void testTraceFuture() throws Exception {
         assertNotSame(tracedFuture, future2);
         assertEquals(tracedFuture.get(), 1);
         String s = tracer.latencyString();
-        System.out.println("DEBUG: latencyString = " + s);
-        assertTrue(s.matches("total: [5-9][0-9]{2} ms, A: [5-9][0-9]{2} ms"));
+        Matcher m = Pattern.compile("total: (\\d+) ms, A: (\\d+) ms").matcher(s);
+        assertTrue(m.matches());
+        assertTrue(Long.parseLong(m.group(1)) >= 500);
+        assertEquals(m.group(2), m.group(1));
     }
 }