Searched refs:enqueue_ (Results 1 – 3 of 3) sorted by relevance
98 QueueEndpoint enqueue_; variable162 Queue<T>::Queue(size_t capacity) : enqueue_(capacity), dequeue_(0){}; in Queue()166 log::assert_that(enqueue_.handler_ == nullptr, "Enqueue is not unregistered"); in ~Queue()173 log::assert_that(enqueue_.handler_ == nullptr, "assert failed: enqueue_.handler_ == nullptr"); in RegisterEnqueue()174 log::assert_that(enqueue_.reactable_ == nullptr, "assert failed: enqueue_.reactable_ == nullptr"); in RegisterEnqueue()175 enqueue_.handler_ = handler; in RegisterEnqueue()176 enqueue_.reactable_ = enqueue_.handler_->thread_->GetReactor()->Register( in RegisterEnqueue()177 enqueue_.reactive_semaphore_.GetFd(), in RegisterEnqueue()190 enqueue_.reactable_ != nullptr, "assert failed: enqueue_.reactable_ != nullptr"); in UnregisterEnqueue()191 reactor = enqueue_.handler_->thread_->GetReactor(); in UnregisterEnqueue()[all …]
83 os::MockIQueueEnqueue<Scheduler::LowerEnqueue> enqueue_; member in bluetooth::l2cap::internal::__anon0861372a0111::L2capSchedulerFifoTest84 …common::BidiQueueEnd<Scheduler::LowerEnqueue, Scheduler::LowerDequeue> queue_end_{&enqueue_, &dequ…97 enqueue_.run_enqueue(); in TEST_F()98 auto&& packet = enqueue_.enqueued.front(); in TEST_F()105 enqueue_.enqueued.pop(); in TEST_F()121 enqueue_.run_enqueue(2); in TEST_F()122 auto packet1 = std::move(enqueue_.enqueued.front()); in TEST_F()129 enqueue_.enqueued.pop(); in TEST_F()131 auto packet2 = std::move(enqueue_.enqueued.front()); in TEST_F()138 enqueue_.enqueued.pop(); in TEST_F()[all …]
894 MockIQueueEnqueue enqueue_; member in bluetooth::os::__anon8f59910c0111::EnqueueBufferTest895 EnqueueBuffer<int> enqueue_buffer_{&enqueue_};907 ASSERT_EQ(enqueue_.queue_.front(), i); in TEST_F()908 enqueue_.queue_.pop(); in TEST_F()910 ASSERT_FALSE(enqueue_.registered_); in TEST_F()914 enqueue_.dont_handle_register_enqueue_ = true; in TEST_F()919 ASSERT_TRUE(enqueue_.registered_); in TEST_F()921 ASSERT_FALSE(enqueue_.registered_); in TEST_F()