Home
last modified time | relevance | path

Searched refs:mQueue (Results 1 – 9 of 9) sorted by relevance

/system/libfmq/tests/
Dmq_test.cpp39 delete mQueue; in TearDown()
44 mQueue = new (std::nothrow) MessageQueueSync(kNumElementsInQueue); in SetUp()
45 ASSERT_NE(nullptr, mQueue); in SetUp()
46 ASSERT_TRUE(mQueue->isValid()); in SetUp()
47 mNumMessagesMax = mQueue->getQuantumCount(); in SetUp()
51 MessageQueueSync* mQueue = nullptr; member in SynchronizedReadWrites
58 delete mQueue; in TearDown()
63 mQueue = new (std::nothrow) MessageQueueUnsync(kNumElementsInQueue); in SetUp()
64 ASSERT_NE(nullptr, mQueue); in SetUp()
65 ASSERT_TRUE(mQueue->isValid()); in SetUp()
[all …]
Dmsgq_test_client.cpp63 delete mQueue; in TearDown()
73 mQueue = new (std::nothrow) MessageQueueSync(in); in SetUp()
75 ASSERT_NE(nullptr, mQueue); in SetUp()
76 ASSERT_TRUE(mQueue->isValid()); in SetUp()
77 mNumMessagesMax = mQueue->getQuantumCount(); in SetUp()
81 MessageQueueSync* mQueue = nullptr; member in SynchronizedReadWriteClient
88 delete mQueue; in TearDown()
98 mQueue = new (std::nothrow) MessageQueueUnsync(in); in SetUp()
100 ASSERT_NE(nullptr, mQueue); in SetUp()
101 ASSERT_TRUE(mQueue->isValid()); in SetUp()
[all …]
/system/chre/core/
Devent_ref_queue.cc29 return mQueue.empty(); in empty()
35 bool pushed = mQueue.push(event); in push()
44 CHRE_ASSERT(!mQueue.empty()); in pop()
46 Event *event = mQueue.front(); in pop()
47 mQueue.pop(); in pop()
/system/libhidl/base/include/hidl/
DSynchronizedQueue.h51 std::queue<T> mQueue; member
64 return !this->mQueue.empty(); in wait_pop()
67 T item = mQueue.front(); in wait_pop()
68 mQueue.pop(); in wait_pop()
78 if (mQueue.size() < mQueueLimit) { in push()
79 mQueue.push(item); in push()
94 return mQueue.size(); in size()
DTaskRunner.h56 return (mQueue != nullptr) && (!!t) && this->mQueue->push(t); in push()
60 std::shared_ptr<SynchronizedQueue<Task>> mQueue;
/system/chre/util/include/chre/util/
Dfixed_size_blocking_queue_impl.h31 success = mQueue.push(element); in push()
42 while (mQueue.empty()) { in pop()
46 ElementType element(std::move(mQueue.front())); in pop()
47 mQueue.pop(); in pop()
54 return mQueue.empty(); in empty()
Dfixed_size_blocking_queue.h68 ArrayQueue<ElementType, kSize> mQueue; variable
/system/libhidl/base/
DTaskRunner.cpp28 mQueue = std::make_shared<SynchronizedQueue<Task>>(limit); in start()
32 std::thread{[q = mQueue] { in start()
41 if (mQueue) { in ~TaskRunner()
42 mQueue->push(nullptr); in ~TaskRunner()
/system/chre/core/include/chre/core/
Devent_ref_queue.h62 ArrayQueue<Event *, kMaxPendingEvents> mQueue; variable