| /packages/modules/Bluetooth/system/gd/common/ |
| D | blocking_queue_unittest.cc | 29 EXPECT_TRUE(queue_.empty()); in SetUp()
34 EXPECT_TRUE(queue_.empty()); in TearDown()
37 BlockingQueue<int> queue_; member in bluetooth::common::__anon7afe29c00111::BlockingQueueTest
41 EXPECT_TRUE(queue_.empty()); in TEST_F()
46 queue_.push(data); in TEST_F()
47 EXPECT_FALSE(queue_.empty()); in TEST_F()
48 EXPECT_EQ(queue_.take(), data); in TEST_F()
49 EXPECT_TRUE(queue_.empty()); in TEST_F()
54 queue_.push(data); in TEST_F()
55 EXPECT_FALSE(queue_.empty()); in TEST_F()
[all …]
|
| 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_;
|
| D | circular_buffer.h | 43 std::deque<T> queue_; variable
91 queue_.push_back(item); in Push()
92 while (queue_.size() > size_) { in Push()
93 queue_.pop_front(); in Push()
100 return std::vector<T>(queue_.cbegin(), queue_.cend()); in Pull()
106 …std::vector<T> items(std::make_move_iterator(queue_.begin()), std::make_move_iterator(queue_.end()… in Drain()
107 queue_.clear(); in Drain()
|
| /packages/modules/Bluetooth/system/common/ |
| 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()
116 if ((queue_.size() + 1) > capacity_) { in EnqueueWithPop()
117 std::unique_ptr<T> item = std::move(queue_.front()); in EnqueueWithPop()
118 queue_.pop(); in EnqueueWithPop()
122 queue_.push(std::move(item_ptr)); in EnqueueWithPop()
129 std::unique_ptr<T> item = std::move(queue_.front()); in Dequeue()
130 queue_.pop(); in Dequeue()
[all …]
|
| /packages/modules/Bluetooth/system/gd/os/fuzz/ |
| 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_;
|
| /packages/modules/Bluetooth/system/gd/os/ |
| 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()
|
| D | queue.h | 85 std::queue<std::unique_ptr<T>> queue_; variable
105 EnqueueBuffer(IQueueEnqueue<T>* queue) : queue_(queue) {} in EnqueueBuffer()
109 queue_->UnregisterEnqueue(); in ~EnqueueBuffer()
117 …queue_->RegisterEnqueue(handler, common::Bind(&EnqueueBuffer<T>::enqueue_callback, common::Unretai… in Enqueue()
124 queue_->UnregisterEnqueue(); in Clear()
146 queue_->UnregisterEnqueue(); in enqueue_callback()
155 IQueueEnqueue<T>* queue_; variable
238 if (queue_.empty()) { in TryDequeue()
244 std::unique_ptr<T> data = std::move(queue_.front()); in TryDequeue()
245 queue_.pop(); in TryDequeue()
[all …]
|
| /packages/modules/adb/fdevent/ |
| D | fdevent_test.cpp | 64 handler->queue_.push(c); in FdEventCallback()
69 ASSERT_FALSE(handler->queue_.empty()); in FdEventCallback()
70 char c = handler->queue_.front(); in FdEventCallback()
71 handler->queue_.pop(); in FdEventCallback()
73 if (handler->queue_.empty()) { in FdEventCallback()
87 handler->queue_.push(c); in FdEventNewCallback()
92 ASSERT_FALSE(handler->queue_.empty()); in FdEventNewCallback()
93 char c = handler->queue_.front(); in FdEventNewCallback()
94 handler->queue_.pop(); in FdEventNewCallback()
96 if (handler->queue_.empty()) { in FdEventNewCallback()
[all …]
|
| /packages/modules/Bluetooth/system/test/headless/utils/ |
| D | power_mode_client.h | 122 } queue_;
136 void remove_mode_event_promise() { queue_.PopFront(bd_addr_); } in remove_mode_event_promise()
166 queue_.CommandSent(bd_addr_, std::move(pwr_command)); in send_power_mode_command()
186 queue_.CallbackReceived(power_mode_callback_t{ in PowerMode()
|
| /packages/modules/Bluetooth/system/gd/os/linux_generic/ |
| D | queue_unittest.cc | 78 : count(0), handler_(handler), queue_(queue), delay_(0) {} in TestEnqueueEnd()
106 queue_->UnregisterEnqueue(); in EnqueueCallbackForTest()
127 Queue<std::string>* queue_; member in bluetooth::os::__anon8f59910c0111::TestEnqueueEnd
132 …queue_->RegisterEnqueue(handler_, common::Bind(&TestEnqueueEnd::EnqueueCallbackForTest, common::Un… in handle_register_enqueue()
136 queue_->UnregisterEnqueue(); in handle_unregister_enqueue()
144 : count(0), handler_(handler), queue_(queue), capacity_(capacity), delay_(0) {} in TestDequeueEnd()
168 std::unique_ptr<std::string> data = queue_->TryDequeue(); in DequeueCallbackForTest()
172 queue_->UnregisterDequeue(); in DequeueCallbackForTest()
191 Queue<std::string>* queue_; member in bluetooth::os::__anon8f59910c0111::TestDequeueEnd
197 …queue_->RegisterDequeue(handler_, common::Bind(&TestDequeueEnd::DequeueCallbackForTest, common::Un… in handle_register_dequeue()
[all …]
|
| /packages/modules/Bluetooth/system/gd/hci/acl_manager/ |
| D | round_robin_scheduler.cc | 71 acl_queue_handler.queue_->GetDownEnd()->UnregisterDequeue(); in Unregister()
128 acl_queue_handler->second.queue_->GetDownEnd()->RegisterDequeue( in start_round_robin()
150 auto packet = acl_queue_handler->second.queue_->GetDownEnd()->TryDequeue(); in buffer_packet()
188 acl_queue_handler->second.queue_->GetDownEnd()->UnregisterDequeue(); in unregister_all_connections()
|
| D | classic_acl_connection_test.cc | 252 queue_ = std::make_shared<hci::acl_manager::AclConnection::Queue>(kQueueSize); in SetUp()
272 std::shared_ptr<hci::acl_manager::AclConnection::Queue> queue_; member in bluetooth::hci::acl_manager::ClassicAclConnectionTest
281 new ClassicAclConnection(queue_, acl_connection_interface, kConnectionHandle, address_); in TEST_F()
292 …std::make_unique<ClassicAclConnection>(queue_, &acl_connection_interface_, kConnectionHandle, addr… in SetUp()
|
| D | le_acl_connection_test.cc | 179 queue_ = std::make_shared<LeAclConnection::Queue>(kQueueSize); in SetUp()
182 queue_, in SetUp()
210 std::shared_ptr<LeAclConnection::Queue> queue_; member in bluetooth::hci::acl_manager::__anonc5d659a60111::LeAclConnectionTest
|
| D | le_acl_connection.cc | 104 : queue_(std::move(queue)), tracker(le_acl_connection_interface, connection_handle) {} in impl()
114 std::shared_ptr<Queue> queue_; member
|
| D | round_robin_scheduler.h | 43 std::shared_ptr<acl_manager::AclConnection::Queue> queue_; member
|
| D | classic_acl_connection.cc | 336 : tracker(acl_connection_interface, address, connection_handle), queue_(std::move(queue)) {} in impl()
349 std::shared_ptr<Queue> queue_; member
|
| /packages/modules/Bluetooth/system/main/shim/ |
| D | acl.cc | 331 if (queue_.size() == max_size_) { in Push()
332 queue_.pop_front(); in Push()
334 queue_.push_back(std::move(element)); in Push()
339 for (auto& entry : queue_) { in ReadElementsAsString()
347 std::deque<T> queue_; member in __anon7fa7f9c60111::FixedQueue
409 if (!queue_.empty()) in ~ShimAclConnection()
413 handle_, queue_.size()); in ~ShimAclConnection()
421 queue_.push(std::move(packet)); in EnqueuePacket()
426 auto packet = std::move(queue_.front()); in handle_enqueue()
427 queue_.pop(); in handle_enqueue()
[all …]
|
| /packages/providers/MediaProvider/jni/ |
| D | FuseDaemon.cpp | 213 cv_.wait(lock, [this] { return !queue_.empty(); }); in MessageLoopImpl()
214 message = queue_.front(); in MessageLoopImpl()
215 queue_.pop(); in MessageLoopImpl()
242 queue_.push(message); in SendMessage()
249 std::queue<Message> queue_; member in FAdviser
|