commit 270512e0505cfe451ca61e935a96cda90389e53e
author Sergei Ryzhov <s.vi.ryzhov@gmail.com> Fri Jul 02 13:02:18 2021 +0300
committer GitHub <noreply@github.com> Fri Jul 02 13:02:18 2021 +0300
tree 72f2669b6af408f0da618ffbadd7ee4a73cf4b21
parent c0c2789aaf53d840dedf52f262389ff9b1e87d2b

IGNITE-15030 fixed SystemViewSelfTest#testCountDownLatch (#9212)

modules/core/src/test/java/org/apache/ignite/internal/metric/SystemViewSelfTest.java

diff --git a/modules/core/src/test/java/org/apache/ignite/internal/metric/SystemViewSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/metric/SystemViewSelfTest.java
index 3aa297a..d62cddf 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/metric/SystemViewSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/metric/SystemViewSelfTest.java
@@ -1089,7 +1089,7 @@
 
                     s2.close();
 
-                    assertTrue(s.removed());
+                    assertTrue(waitForCondition(s::removed, getTestTimeout()));
                 }
             }
 
@@ -1107,7 +1107,7 @@
 
             s1.close();
 
-            assertTrue(s.removed());
+            assertTrue(waitForCondition(s::removed, getTestTimeout()));
 
             assertEquals(0, seqs0.size());
             assertEquals(0, seqs1.size());
@@ -1149,7 +1149,7 @@
 
                     l2.close();
 
-                    assertTrue(l.removed());
+                    assertTrue(waitForCondition(l::removed, getTestTimeout()));
                 }
             }
 
@@ -1166,7 +1166,7 @@
 
             l1.close();
 
-            assertTrue(l.removed());
+            assertTrue(waitForCondition(l::removed, getTestTimeout()));
 
             assertEquals(0, longs0.size());
             assertEquals(0, longs1.size());
@@ -1208,7 +1208,7 @@
 
                     l2.close();
 
-                    assertTrue(r.removed());
+                    assertTrue(waitForCondition(r::removed, getTestTimeout()));
                 }
             }
 
@@ -1225,7 +1225,7 @@
 
             l1.close();
 
-            assertTrue(l.removed());
+            assertTrue(waitForCondition(l::removed, getTestTimeout()));
 
             assertEquals(0, refs0.size());
             assertEquals(0, refs1.size());
@@ -1270,7 +1270,7 @@
 
                     s2.close();
 
-                    assertTrue(s.removed());
+                    assertTrue(waitForCondition(s::removed, getTestTimeout()));
                 }
             }
 
@@ -1333,7 +1333,7 @@
                     l2.countDown();
                     l2.close();
 
-                    assertTrue(l.removed());
+                    assertTrue(waitForCondition(l::removed, getTestTimeout()));
                 }
 
                 assertEquals(grpName, l.groupName());
@@ -1357,7 +1357,7 @@
             l3.countDown();
             l3.close();
 
-            assertTrue(l.removed());
+            assertTrue(waitForCondition(l::removed, getTestTimeout()));
 
             assertEquals(0, latches0.size());
             assertEquals(0, latches1.size());
@@ -1419,7 +1419,7 @@
 
                     s2.close();
 
-                    assertTrue(s.removed());
+                    assertTrue(waitForCondition(s::removed, getTestTimeout()));
                 }
 
                 assertEquals(grpName, s.groupName());
@@ -1444,7 +1444,7 @@
 
             l3.close();
 
-            assertTrue(s.removed());
+            assertTrue(waitForCondition(s::removed, getTestTimeout()));
 
             assertEquals(0, semaphores0.size());
             assertEquals(0, semaphores1.size());
@@ -1505,7 +1505,7 @@
 
                     l2.close();
 
-                    assertTrue(l.removed());
+                    assertTrue(waitForCondition(l::removed, getTestTimeout()));
                 }
 
                 assertEquals(grpName, l.groupName());
@@ -1532,7 +1532,7 @@
 
             l3.close();
 
-            assertTrue(s.removed());
+            assertTrue(waitForCondition(s::removed, getTestTimeout()));
 
             assertEquals(0, locks0.size());
             assertEquals(0, locks1.size());