Searched refs:enqueue_ (Results 1 – 4 of 4) sorted by relevance
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);48 to_unregister = enqueue_.reactable_;49 enqueue_.reactable_ = nullptr;50 enqueue_.handler_ = nullptr;101 enqueue_.reactive_semaphore_.Increase();[all …]
882 MockIQueueEnqueue enqueue_; member in bluetooth::os::__anon802956220110::EnqueueBufferTest883 EnqueueBuffer<int> enqueue_buffer_{&enqueue_};895 ASSERT_EQ(enqueue_.queue_.front(), i); in TEST_F()896 enqueue_.queue_.pop(); in TEST_F()898 ASSERT_FALSE(enqueue_.registered_); in TEST_F()902 enqueue_.dont_handle_register_enqueue_ = true; in TEST_F()907 ASSERT_TRUE(enqueue_.registered_); in TEST_F()909 ASSERT_FALSE(enqueue_.registered_); in TEST_F()
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()153 enqueue_.run_enqueue(1); in TEST_F()154 auto packet1 = std::move(enqueue_.enqueued.front()); in TEST_F()[all …]
101 QueueEndpoint enqueue_; variable