Searched refs:mQueue (Results 1 – 9 of 9) sorted by relevance
32 mQueue = std::make_shared<SynchronizedQueue<Task>>(limit); in start()36 if (mQueue) { in ~TaskRunner()37 mQueue->push(nullptr); in ~TaskRunner()42 if (mQueue == nullptr || !t) { in push()47 std::unique_lock<std::mutex> lock = mQueue->lock(); in push()49 if (!mQueue->isInitializedLocked()) { in push()52 std::thread{[q = mQueue] { in push()61 mQueue->setInitializedLocked(true); in push()65 return this->mQueue->push(t); in push()
62 std::queue<T> mQueue; member76 return !this->mQueue.empty(); in wait_pop()79 T item = mQueue.front(); in wait_pop()80 mQueue.pop(); in wait_pop()90 if (mQueue.size() < mQueueLimit) { in push()91 mQueue.push(item); in push()106 return mQueue.size(); in size()
100 delete mQueue; in TearDown()107 mQueue = new (std::nothrow) typename T::MQType(kNumElementsInQueue); in SetUp()111 mQueue = new (std::nothrow) in SetUp()115 ASSERT_NE(nullptr, mQueue); in SetUp()116 ASSERT_TRUE(mQueue->isValid()); in SetUp()117 mNumMessagesMax = mQueue->getQuantumCount(); in SetUp()121 typename T::MQType* mQueue = nullptr; member in SynchronizedReadWrites131 delete mQueue; in TearDown()138 mQueue = new (std::nothrow) typename T::MQType(kNumElementsInQueue); in SetUp()142 mQueue = new (std::nothrow) in SetUp()[all …]
186 if (mQueue->isValid()) in newQueue()187 return new (std::nothrow) AidlMessageQueueUnsync(mQueue->dupeDesc()); in newQueue()193 AidlMessageQueueUnsync* mQueue = nullptr; member in ClientUnsyncTestBase237 return new (std::nothrow) MessageQueueUnsync(*mQueue->getDesc()); in newQueue()241 MessageQueueUnsync* mQueue = nullptr; member in ClientUnsyncTestBase253 delete mQueue; in TearDown()267 mQueue = new (std::nothrow) typename T::MQType( in SetUp()270 ASSERT_NE(nullptr, mQueue); in SetUp()271 ASSERT_TRUE(mQueue->isValid()); in SetUp()272 ASSERT_EQ(mQueue->getQuantumCount(), kNumElementsInSyncQueue); in SetUp()[all …]
31 success = mQueue.push(element); in push()44 success = mQueue.push(std::move(element)); in push()55 while (mQueue.empty()) { in pop()59 ElementType element(std::move(mQueue.front())); in pop()60 mQueue.pop(); in pop()67 return mQueue.empty(); in empty()73 return mQueue.size(); in size()79 return mQueue.remove(index); in remove()86 return mQueue[index];93 return mQueue[index];
105 ArrayQueue<ElementType, kSize> mQueue; variable
32 bool pushed = mQueue.push(event); in push()41 CHRE_ASSERT(!mQueue.empty()); in pop()43 Event *event = mQueue.front(); in pop()44 mQueue.pop(); in pop()
38 return mQueue.empty(); in empty()64 ArrayQueue<Event *, kMaxPendingEvents> mQueue; variable
63 std::shared_ptr<SynchronizedQueue<Task>> mQueue;