Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 1e14c50e authored by William Escande's avatar William Escande Committed by Automerger Merge Worker
Browse files

Merge "Fix flaky test register_enqueue_with_half_empty_queue" am: be5ff256... 

Merge "Fix flaky test register_enqueue_with_half_empty_queue" am: be5ff256 am: cadc01ea am: df444668

Original change: https://android-review.googlesource.com/c/platform/packages/modules/Bluetooth/+/2424346



Change-Id: I343c31cc9f511582000b494b32f7061ee145b7d7
Signed-off-by: default avatarAutomerger Merge Worker <android-build-automerger-merge-worker@system.gserviceaccount.com>
parents 0281c53a df444668

system/gd/os/linux_generic/queue_unittest.cc

+9 −0
Original line number Diff line number Diff line
@@ -19,6 +19,7 @@ 
#include <sys/eventfd.h>



#include <atomic>

#include <chrono>

#include <future>

#include <unordered_map>
@@ -26,6 +27,8 @@ 
#include "gtest/gtest.h"

#include "os/reactor.h"



using namespace std::chrono_literals;



namespace bluetooth {

namespace os {

namespace {
@@ -60,6 +63,11 @@ class QueueTest : public ::testing::Test { 
  Handler* enqueue_handler_;

  Thread* dequeue_thread_;

  Handler* dequeue_handler_;



  void sync_enqueue_handler() {

    ASSERT(enqueue_thread_ != nullptr);

    ASSERT(enqueue_thread_->GetReactor()->WaitForIdle(2s));

  }

};



class TestEnqueueEnd {
@@ -338,6 +346,7 @@ TEST_F(QueueTest, register_enqueue_with_half_empty_queue) { 
  test_enqueue_end.RegisterEnqueue(&enqueue_promise_map);

  enqueue_future.wait();

  EXPECT_EQ(enqueue_future.get(), 0);

  sync_enqueue_handler();

}



// Enqueue end level : 1