[pulsar] branch master updated: [improve][test] Use channel.advanceTimeBy instead of Thread.sleep (#19447)

[lhotari]

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

lhotari 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 88fa40b2d85 [improve][test] Use channel.advanceTimeBy instead of 
Thread.sleep (#19447)
88fa40b2d85 is described below

commit 88fa40b2d8593a15041ddec4610160fcedadca24
Author: Michael Marshall <mmarsh...@apache.org>
AuthorDate: Tue Feb 7 02:38:59 2023 -0600

    [improve][test] Use channel.advanceTimeBy instead of Thread.sleep (#19447)
---
 .../test/java/org/apache/pulsar/broker/service/ServerCnxTest.java   | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ServerCnxTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ServerCnxTest.java
index 2ee30ed1a81..b087e78eac0 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ServerCnxTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ServerCnxTest.java
@@ -307,7 +307,7 @@ public class ServerCnxTest {
         // Connection will be closed in 2 seconds, in the meantime give chance 
to run the cleanup logic
         for (int i = 0; i < 3; i++) {
             channel.runPendingTasks();
-            Thread.sleep(1000);
+            channel.advanceTimeBy(1, TimeUnit.SECONDS);
         }
 
         assertFalse(channel.isActive());
@@ -334,7 +334,7 @@ public class ServerCnxTest {
         // Connection will *not* be closed in 2 seconds
         for (int i = 0; i < 3; i++) {
             channel.runPendingTasks();
-            Thread.sleep(1000);
+            channel.advanceTimeBy(1, TimeUnit.SECONDS);
         }
         assertTrue(channel.isActive());
 
@@ -352,7 +352,7 @@ public class ServerCnxTest {
         // Connection will be closed in 2 seconds, in the meantime give chance 
to run the cleanup logic
         for (int i = 0; i < 3; i++) {
             channel.runPendingTasks();
-            Thread.sleep(1000);
+            channel.advanceTimeBy(1, TimeUnit.SECONDS);
         }
 
         assertFalse(channel.isActive());