diff options
Diffstat (limited to 'system/gd/os/linux_generic/queue_unittest.cc')
-rw-r--r-- | system/gd/os/linux_generic/queue_unittest.cc | 41 |
1 files changed, 4 insertions, 37 deletions
diff --git a/system/gd/os/linux_generic/queue_unittest.cc b/system/gd/os/linux_generic/queue_unittest.cc index 9c1852797b..e0cd6e0a17 100644 --- a/system/gd/os/linux_generic/queue_unittest.cc +++ b/system/gd/os/linux_generic/queue_unittest.cc @@ -57,31 +57,13 @@ class QueueTest : public ::testing::Test { Handler* dequeue_handler_; }; -class QueueTestSingleThread : public ::testing::Test { - protected: - void SetUp() override { - reactor_ = new Reactor(); - enqueue_handler_ = new Handler(reactor_); - dequeue_handler_ = new Handler(reactor_); - } - void TearDown() override { - delete enqueue_handler_; - delete dequeue_handler_; - delete reactor_; - enqueue_handler_ = nullptr; - dequeue_handler_ = nullptr; - reactor_ = nullptr; - } - Reactor* reactor_; - Handler* enqueue_handler_; - Handler* dequeue_handler_; -}; - class TestEnqueueEnd { public: explicit TestEnqueueEnd(Queue<std::string>* queue, Handler* handler) : count(0), handler_(handler), queue_(queue), delay_(0) {} + ~TestEnqueueEnd() {} + void RegisterEnqueue(std::unordered_map<int, std::promise<int>>* promise_map) { promise_map_ = promise_map; handler_->Post([this] { queue_->RegisterEnqueue(handler_, [this] { return EnqueueCallbackForTest(); }); }); @@ -138,6 +120,8 @@ class TestDequeueEnd { explicit TestDequeueEnd(Queue<std::string>* queue, Handler* handler, int capacity) : count(0), handler_(handler), queue_(queue), capacity_(capacity), delay_(0) {} + ~TestDequeueEnd() {} + void RegisterDequeue(std::unordered_map<int, std::promise<int>>* promise_map) { promise_map_ = promise_map; handler_->Post([this] { queue_->RegisterDequeue(handler_, [this] { DequeueCallbackForTest(); }); }); @@ -711,23 +695,6 @@ TEST_F(QueueTest, pass_smart_pointer_and_unregister) { }); future.wait(); } - -TEST_F(QueueTestSingleThread, no_unregister_enqueue_death_test) { - Queue<std::string>* queue = new Queue<std::string>(kQueueSizeOne); - - queue->RegisterEnqueue(enqueue_handler_, - []() { return std::make_unique<std::string>("A string to fill the queue"); }); - - EXPECT_DEATH(delete queue, "nqueue"); -} - -TEST_F(QueueTestSingleThread, no_unregister_dequeue_death_test) { - Queue<std::string>* queue = new Queue<std::string>(kQueueSize); - - queue->RegisterDequeue(dequeue_handler_, []() {}); - - EXPECT_DEATH(delete queue, "equeue"); -} } // namespace } // namespace os } // namespace bluetooth |