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

bereng pushed a commit to branch cassandra-4.0
in repository https://gitbox.apache.org/repos/asf/cassandra.git


The following commit(s) were added to refs/heads/cassandra-4.0 by this push:
     new 9f97adf63c Test Failure: 
org.apache.cassandra.net.OutboundMessageQueueTest.testRemove-cdc
9f97adf63c is described below

commit 9f97adf63c67c8671a5477e7fc62dab75326bd6e
Author: Bereng <[email protected]>
AuthorDate: Wed Aug 10 08:27:01 2022 +0200

    Test Failure: 
org.apache.cassandra.net.OutboundMessageQueueTest.testRemove-cdc
    
    Patch by Berenguer Blasi; reviewed by Brandon Williams for CASSANDRA-17422
    
    Co-authored-by: shylaja kokoori <[email protected]>
    Co-authored-by: Berenguer Blasi <[email protected]>
---
 test/unit/org/apache/cassandra/net/OutboundMessageQueueTest.java | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/test/unit/org/apache/cassandra/net/OutboundMessageQueueTest.java 
b/test/unit/org/apache/cassandra/net/OutboundMessageQueueTest.java
index de64a26c7a..bb7dc6328b 100644
--- a/test/unit/org/apache/cassandra/net/OutboundMessageQueueTest.java
+++ b/test/unit/org/apache/cassandra/net/OutboundMessageQueueTest.java
@@ -61,12 +61,14 @@ public class OutboundMessageQueueTest
 
         CountDownLatch locked = new CountDownLatch(1);
         CountDownLatch lockUntil = new CountDownLatch(1);
+        CountDownLatch lockReleased = new CountDownLatch(1);
         new Thread(() -> {
             try (OutboundMessageQueue.WithLock lock = queue.lockOrCallback(0, 
() -> {}))
             {
                 locked.countDown();
                 Uninterruptibles.awaitUninterruptibly(lockUntil);
             }
+            lockReleased.countDown();
         }).start();
         Uninterruptibles.awaitUninterruptibly(locked);
 
@@ -86,6 +88,7 @@ public class OutboundMessageQueueTest
         lockUntil.countDown();
         Uninterruptibles.awaitUninterruptibly(finish);
 
+        Uninterruptibles.awaitUninterruptibly(lockReleased);
         try (OutboundMessageQueue.WithLock lock = queue.lockOrCallback(0, () 
-> {}))
         {
             Assert.assertNull(lock.peek());


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to