Searched defs:mQueue (Results 1 - 6 of 6) sorted by relevance

/system/chre/core/include/chre/core/
H A Devent_ref_queue.h38 return mQueue.empty();
64 ArrayQueue<Event *, kMaxPendingEvents> mQueue; member in class:chre::EventRefQueue
/system/chre/util/include/chre/util/
H A Dfixed_size_blocking_queue.h73 ArrayQueue<ElementType, kSize> mQueue; member in class:chre::FixedSizeBlockingQueue
/system/libhidl/base/include/hidl/
H A DTaskRunner.h58 std::shared_ptr<SynchronizedQueue<Task>> mQueue; member in class:android::hardware::details::TaskRunner
H A DSynchronizedQueue.h51 std::queue<T> mQueue; member in struct:android::hardware::details::SynchronizedQueue
64 return !this->mQueue.empty();
67 T item = mQueue.front();
68 mQueue.pop();
78 if (mQueue.size() < mQueueLimit) {
79 mQueue.push(item);
94 return mQueue.size();
/system/libfmq/tests/
H A Dmq_test.cpp39 delete mQueue;
44 mQueue = new (std::nothrow) MessageQueueSync(kNumElementsInQueue);
45 ASSERT_NE(nullptr, mQueue);
46 ASSERT_TRUE(mQueue->isValid());
47 mNumMessagesMax = mQueue->getQuantumCount();
51 MessageQueueSync* mQueue = nullptr; member in class:SynchronizedReadWrites
58 delete mQueue;
63 mQueue = new (std::nothrow) MessageQueueUnsync(kNumElementsInQueue);
64 ASSERT_NE(nullptr, mQueue);
65 ASSERT_TRUE(mQueue
70 MessageQueueUnsync* mQueue = nullptr; member in class:UnsynchronizedWrite
92 MessageQueueSync* mQueue; member in class:BlockingReadWrites
118 MessageQueueSync* mQueue; member in class:QueueSizeOdd
[all...]
H A Dmsgq_test_client.cpp71 delete mQueue;
81 mQueue = new (std::nothrow) MessageQueueSync(in);
83 ASSERT_NE(nullptr, mQueue);
84 ASSERT_TRUE(mQueue->isValid());
85 mNumMessagesMax = mQueue->getQuantumCount();
89 MessageQueueSync* mQueue = nullptr; member in class:SynchronizedReadWriteClient
96 delete mQueue;
106 mQueue = new (std::nothrow) MessageQueueUnsync(in);
108 ASSERT_NE(nullptr, mQueue);
109 ASSERT_TRUE(mQueue
114 MessageQueueUnsync* mQueue = nullptr; member in class:UnsynchronizedWriteClient
[all...]

Completed in 127 milliseconds