Searched refs:enqueue_ (Results 1 – 4 of 4) sorted by relevance
18 Queue<T>::Queue(size_t capacity) : enqueue_(capacity), dequeue_(0){};22 ASSERT_LOG(enqueue_.handler_ == nullptr, "Enqueue is not unregistered");29 ASSERT(enqueue_.handler_ == nullptr);30 ASSERT(enqueue_.reactable_ == nullptr);31 enqueue_.handler_ = handler;32 enqueue_.reactable_ = enqueue_.handler_->thread_->GetReactor()->Register(33 enqueue_.reactive_semaphore_.GetFd(),45 ASSERT(enqueue_.reactable_ != nullptr);46 reactor = enqueue_.handler_->thread_->GetReactor();47 wait_for_unregister = (!enqueue_.handler_->thread_->IsSameThread());[all …]
892 MockIQueueEnqueue enqueue_; member in bluetooth::os::__anon88dae3f10111::EnqueueBufferTest893 EnqueueBuffer<int> enqueue_buffer_{&enqueue_};905 ASSERT_EQ(enqueue_.queue_.front(), i); in TEST_F()906 enqueue_.queue_.pop(); in TEST_F()908 ASSERT_FALSE(enqueue_.registered_); in TEST_F()912 enqueue_.dont_handle_register_enqueue_ = true; in TEST_F()917 ASSERT_TRUE(enqueue_.registered_); in TEST_F()919 ASSERT_FALSE(enqueue_.registered_); in TEST_F()
83 os::MockIQueueEnqueue<Scheduler::LowerEnqueue> enqueue_; member in bluetooth::l2cap::internal::__anon4bb6dbef0111::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 …]
97 QueueEndpoint enqueue_; variable