| /system/chre/util/include/chre/util/system/ |
| D | atomic_spsc_queue.h | 133 return mQueue.size(); in size()
145 mQueue.mTail = newTail; in emplace()
156 mQueue.mTail = newTail; in push()
163 mQueue.mTail = newTail; in push()
168 Producer(AtomicSpscQueue<ElementType, kCapacity> &q) : mQueue(q) {} in Producer()
170 AtomicSpscQueue<ElementType, kCapacity> &mQueue; variable
175 uint32_t tail = mQueue.mTail.load(); in nextStorage()
176 if (tail != 0 && tail == mQueue.mHead.load()) { in nextStorage()
184 mQueue.mTail = 0; in nextStorage()
185 mQueue.mHead = 0; in nextStorage()
[all …]
|
| /system/libhidl/base/ |
| D | TaskRunner.cpp | 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()
|
| D | SynchronizedQueue.h | 62 std::queue<T> mQueue; member
76 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()
|
| /system/libfmq/tests/ |
| D | fmq_unit_tests.cpp | 102 delete mQueue; in TearDown()
109 mQueue = new (std::nothrow) typename T::MQType(kNumElementsInQueue); in SetUp()
113 mQueue = new (std::nothrow) in SetUp()
117 ASSERT_NE(nullptr, mQueue); in SetUp()
118 ASSERT_TRUE(mQueue->isValid()); in SetUp()
119 mNumMessagesMax = mQueue->getQuantumCount(); in SetUp()
123 typename T::MQType* mQueue = nullptr; member in SynchronizedReadWrites
133 delete mQueue; in TearDown()
140 mQueue = new (std::nothrow) typename T::MQType(kNumElementsInQueue); in SetUp()
144 mQueue = new (std::nothrow) in SetUp()
[all …]
|
| D | msgq_test_client.cpp | 198 if (mQueue->isValid()) in newQueue()
199 return new (std::nothrow) AidlMessageQueueUnsync(mQueue->dupeDesc(), false); in newQueue()
205 AidlMessageQueueUnsync* mQueue = nullptr; member in ClientUnsyncTestBase
255 return new (std::nothrow) MessageQueueUnsync(*mQueue->getDesc(), false); in newQueue()
259 MessageQueueUnsync* mQueue = nullptr; member in ClientUnsyncTestBase
271 delete mQueue; in TearDown()
285 mQueue = new (std::nothrow) typename T::MQType( in SetUp()
288 ASSERT_NE(nullptr, mQueue); in SetUp()
289 ASSERT_TRUE(mQueue->isValid()); in SetUp()
290 ASSERT_EQ(mQueue->getQuantumCount(), kNumElementsInSyncQueue); in SetUp()
[all …]
|
| /system/chre/platform/linux/task_util/ |
| D | task_manager.cc | 27 : mQueue(std::greater<Task>()), in TaskManager()
53 success = mQueue.push(task); in addTask()
75 for (auto iter = mQueue.begin(); iter != mQueue.end(); ++iter) { in cancelTask()
89 while (!mQueue.empty()) { in flushTasks()
90 mQueue.pop(); in flushTasks()
102 while (!mQueue.empty()) { in flushAndStop()
103 mQueue.pop(); in flushAndStop()
120 return !mContinueRunningThread || !mQueue.empty(); in run()
126 task = mQueue.top(); in run()
143 mQueue.pop(); in run()
[all …]
|
| /system/chre/test/simulation/inc/ |
| D | test_event_queue.h | 64 mQueue.push({eventType}); in pushEvent()
86 mQueue.push({eventType, static_cast<void *>(ptr)}); in pushEvent()
93 auto event = mQueue.pop(); in waitForEvent()
110 auto event = mQueue.pop(); in waitForEvent()
125 while (!mQueue.empty()) { in flush()
126 auto event = mQueue.pop(); in flush()
133 FixedSizeBlockingQueue<TestEvent, kQueueCapacity> mQueue; variable
|
| /system/chre/core/ |
| D | event_ref_queue.cc | 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()
|
| /system/chre/host/tinysys/hal/ |
| D | tinysys_chre_connection.h | 147 if (mQueue.size() >= kMaxSynchronousMessageQueueSize) { in emplace()
151 mQueue.emplace(data, length); in emplace()
158 mQueue.pop(); in pop()
163 return mQueue.front(); in front()
168 mCv.wait(lock, [&]() { return !mQueue.empty(); }); in waitForMessage()
174 std::queue<ChreConnectionMessage> mQueue; variable
213 SynchronousMessageQueue mQueue; variable
|
| D | tinysys_chre_connection.cc | 152 chreConnection->mQueue.waitForMessage(); in messageSenderTask()
153 ChreConnectionMessage &message = chreConnection->mQueue.front(); in messageSenderTask()
159 chreConnection->mQueue.pop(); in messageSenderTask()
168 return mQueue.emplace(data, length); in sendMessage()
|
| /system/chre/core/include/chre/core/ |
| D | event_ref_queue.h | 38 return mQueue.empty(); in empty()
64 ArrayQueue<Event *, kMaxPendingEvents> mQueue; variable
|
| /system/libhidl/base/include/hidl/ |
| D | TaskRunner.h | 64 std::shared_ptr<SynchronizedQueue<Task>> mQueue;
|
| /system/chre/platform/linux/include/chre/platform/linux/task_util/ |
| D | task_manager.h | 104 PriorityQueue<Task, std::greater<Task>> mQueue; variable
|