| /aosp12/system/bt/gd/common/ |
| H A D | blocking_queue_unittest.cc | 46 queue_.push(data); in TEST_F()
54 queue_.push(data); in TEST_F()
63 queue_.push(data); in TEST_F()
74 queue_.push(data); in TEST_F()
77 queue_.clear(); in TEST_F()
84 queue_.push(data); in TEST_F()
95 queue_.push(data); in TEST_F()
97 queue_.clear(); in TEST_F()
103 queue_.push(data); in TEST_F()
105 queue_.clear(); in TEST_F()
[all …]
|
| H A D | blocking_queue.h | 32 queue_.push(std::move(data)); in push()
33 if (queue_.size() == 1) { in push()
40 while (queue_.empty()) { in take()
43 T data = queue_.front(); in take()
44 queue_.pop(); in take()
51 while (queue_.empty()) { in wait_to_take()
61 return queue_.empty(); in empty()
67 std::swap(queue_, empty); in clear()
71 std::queue<T> queue_;
|
| H A D | circular_buffer.h | 42 std::deque<T> queue_; variable
90 queue_.push_back(item); in Push()
91 while (queue_.size() > size_) { in Push()
92 queue_.pop_front(); in Push()
99 return std::vector<T>(queue_.cbegin(), queue_.cend()); in Pull()
105 …std::vector<T> items(std::make_move_iterator(queue_.begin()), std::make_move_iterator(queue_.end()… in Drain()
106 queue_.clear(); in Drain()
|
| /aosp12/system/bt/common/ |
| H A D | leaky_bonded_queue.h | 85 std::queue<std::unique_ptr<T>> queue_;
105 if ((queue_.size() + 1) > capacity_) { in Enqueue()
106 queue_.pop(); in Enqueue()
109 queue_.push(std::move(item_ptr)); in Enqueue()
118 queue_.pop(); in EnqueueWithPop()
122 queue_.push(std::move(item_ptr)); in EnqueueWithPop()
130 queue_.pop(); in Dequeue()
137 while (!queue_.empty()) { in Clear()
139 queue_.pop(); in Clear()
146 return queue_.size(); in Length()
[all …]
|
| /aosp12/system/bt/gd/os/fuzz/ |
| H A D | dev_null_queue.h | 29 DevNullQueue(IQueueDequeue<T>* queue, Handler* handler) : queue_(queue), handler_(handler) {} in DevNullQueue()
33 queue_->RegisterDequeue(handler_, common::Bind(&DevNullQueue::Dump, common::Unretained(this))); in Start()
37 queue_->UnregisterDequeue(); in Stop()
41 queue_->TryDequeue(); in Dump()
45 IQueueDequeue<T>* queue_;
|
| /aosp12/frameworks/native/libs/gui/ |
| H A D | BufferHubProducer.cpp | 30 producer->queue_ = queue; in Create()
552 value = int32_t(queue_->default_width()); in query()
555 value = int32_t(queue_->default_height()); in query()
613 if (!queue_->is_connected()) { in connect()
626 output->width = queue_->default_width(); in connect()
764 if (!queue_->is_connected()) { in TakeAsParcelable()
771 auto status = queue_->TakeAsParcelable(); in TakeAsParcelable()
793 auto producer_buffer = queue_->GetBuffer(slot); in AllocateBuffer()
804 auto status = queue_->RemoveBuffer(slot); in RemoveBuffer()
830 auto status = queue_->FreeAllBuffers(); in FreeAllBuffers()
[all …]
|
| /aosp12/system/bt/gd/os/ |
| H A D | queue_benchmark.cc | 60 : count_(count), handler_(handler), queue_(queue), promise_(promise) {} in TestEnqueueEnd()
82 queue_->UnregisterEnqueue(); in EnqueueCallbackForTest()
98 Queue<std::string>* queue_; member in bluetooth::os::TestEnqueueEnd
103 …queue_->RegisterEnqueue(handler_, common::Bind(&TestEnqueueEnd::EnqueueCallbackForTest, common::Un… in handle_register_enqueue()
110 : count_(count), handler_(handler), queue_(queue), promise_(promise) {} in TestDequeueEnd()
117 std::string data = *(queue_->TryDequeue()); in DequeueCallbackForTest()
122 queue_->UnregisterDequeue(); in DequeueCallbackForTest()
132 Queue<std::string>* queue_; member in bluetooth::os::TestDequeueEnd
136 …queue_->RegisterDequeue(handler_, common::Bind(&TestDequeueEnd::DequeueCallbackForTest, common::Un… in handle_register_dequeue()
|
| H A D | queue.h | 86 std::queue<std::unique_ptr<T>> queue_; variable
108 EnqueueBuffer(IQueueEnqueue<T>* queue) : queue_(queue) {} in EnqueueBuffer()
112 queue_->UnregisterEnqueue(); in ~EnqueueBuffer()
120 …queue_->RegisterEnqueue(handler, common::Bind(&EnqueueBuffer<T>::enqueue_callback, common::Unretai… in Enqueue()
127 queue_->UnregisterEnqueue(); in Clear()
149 queue_->UnregisterEnqueue(); in enqueue_callback()
158 IQueueEnqueue<T>* queue_; variable
|
| /aosp12/packages/modules/adb/fdevent/ |
| H A D | fdevent_test.cpp | 61 handler->queue_.push(c); in FdEventCallback()
66 ASSERT_FALSE(handler->queue_.empty()); in FdEventCallback()
67 char c = handler->queue_.front(); in FdEventCallback()
68 handler->queue_.pop(); in FdEventCallback()
70 if (handler->queue_.empty()) { in FdEventCallback()
84 handler->queue_.push(c); in FdEventNewCallback()
89 ASSERT_FALSE(handler->queue_.empty()); in FdEventNewCallback()
90 char c = handler->queue_.front(); in FdEventNewCallback()
91 handler->queue_.pop(); in FdEventNewCallback()
93 if (handler->queue_.empty()) { in FdEventNewCallback()
[all …]
|
| /aosp12/frameworks/base/tools/aapt2/compile/ |
| H A D | InlineXmlFormatParser.h | 53 return queue_; in GetExtractedInlineXmlDocuments()
59 std::vector<std::unique_ptr<xml::XmlResource>> queue_; variable
|
| H A D | InlineXmlFormatParser.cpp | 180 queue_.push_back(std::move(new_doc)); in Consume()
|
| /aosp12/system/bt/gd/os/linux_generic/ |
| H A D | queue_unittest.cc | 96 queue_->UnregisterEnqueue(); in EnqueueCallbackForTest()
116 Queue<std::string>* queue_; member in bluetooth::os::__anon802956220110::TestEnqueueEnd
125 queue_->UnregisterEnqueue(); in handle_unregister_enqueue()
157 std::unique_ptr<std::string> data = queue_->TryDequeue(); in DequeueCallbackForTest()
161 queue_->UnregisterDequeue(); in DequeueCallbackForTest()
180 Queue<std::string>* queue_; member in bluetooth::os::__anon802956220110::TestDequeueEnd
190 queue_->UnregisterDequeue(); in handle_unregister_dequeue()
848 queue_.push(*front); in handle_register_enqueue()
859 std::queue<int> queue_; member in bluetooth::os::__anon802956220110::MockIQueueEnqueue
895 ASSERT_EQ(enqueue_.queue_.front(), i); in TEST_F()
[all …]
|
| H A D | queue.tpp | 92 if (queue_.empty()) {
98 std::unique_ptr<T> data = std::move(queue_.front());
99 queue_.pop();
112 queue_.push(std::move(data));
|
| /aosp12/system/bt/gd/hci/acl_manager/ |
| H A D | round_robin_scheduler.cc | 64 acl_queue_handler.queue_->GetDownEnd()->UnregisterDequeue(); in Unregister()
120 acl_queue_handler->second.queue_->GetDownEnd()->RegisterDequeue( in start_round_robin()
136 auto packet = acl_queue_handler->second.queue_->GetDownEnd()->TryDequeue(); in buffer_packet()
174 acl_queue_handler->second.queue_->GetDownEnd()->UnregisterDequeue(); in unregister_all_connections()
|
| H A D | le_acl_connection.cc | 87 : queue_(std::move(queue)), tracker(le_acl_connection_interface, connection_handle) {} in impl()
95 std::shared_ptr<Queue> queue_; member
|
| H A D | round_robin_scheduler.h | 42 std::shared_ptr<acl_manager::AclConnection::Queue> queue_; member
|
| H A D | classic_acl_connection.cc | 329 : tracker(acl_connection_interface, address, connection_handle), queue_(std::move(queue)) {} in impl()
338 std::shared_ptr<Queue> queue_; member
|
| /aosp12/system/bt/main/shim/ |
| H A D | acl.cc | 193 if (queue_.size() == max_size_) { in Push()
194 queue_.pop_front(); in Push()
201 for (auto& entry : queue_) { in ReadElementsAsString()
209 std::deque<T> queue_; member in __anonfd94cd1c0110::FixedQueue
269 if (!queue_.empty()) in ~ShimAclConnection()
272 handle_, queue_.size()); in ~ShimAclConnection()
279 queue_.push(std::move(packet)); in EnqueuePacket()
285 queue_.pop(); in handle_enqueue()
286 if (queue_.empty()) { in handle_enqueue()
340 if (!queue_.empty()) in Disconnect()
[all …]
|
| /aosp12/art/runtime/mirror/ |
| H A D | reference.h | 58 return OFFSET_OF_OBJECT_MEMBER(Reference, queue_); in QueueOffset()
109 HeapReference<Object> queue_; variable
|
| /aosp12/hardware/qcom/sm7250/display/composer/ |
| H A D | hwc_session_services.cpp | 1022 bool post_future = !queue_.size(); in PostBuffer()
1025 queue_.push(node); in PostBuffer()
1052 if (!queue_.size()) { in ProcessRequests()
1056 node = queue_.front(); in ProcessRequests()
1109 queue_.pop(); in ProcessRequests()
1111 if (!queue_.size()) { in ProcessRequests()
|
| H A D | hwc_session.h | 341 std::queue<QueueNode *> queue_; variable
|
| /aosp12/frameworks/native/libs/gui/include/gui/ |
| H A D | BufferHubProducer.h | 173 std::shared_ptr<dvr::ProducerQueue> queue_; variable
|
| /aosp12/packages/providers/MediaProvider/jni/ |
| H A D | FuseDaemon.cpp | 198 cv_.wait(lock, [this] { return !queue_.empty(); }); in MessageLoopImpl()
199 message = queue_.front(); in MessageLoopImpl()
200 queue_.pop(); in MessageLoopImpl()
227 queue_.push(message); in SendMessage()
234 std::queue<Message> queue_; member in FAdviser
|
| /aosp12/art/runtime/ |
| H A D | class_linker_test.cc | 701 addOffset(OFFSETOF_MEMBER(mirror::Reference, queue_), "queue"); in ReferenceOffsets()
|