| /system/bt/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::__anon2b4b652a0111::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 | 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()
|
| /system/bt/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 …]
|
| /system/bt/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_;
|
| /system/bt/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 | 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
|
| /system/bt/gd/os/linux_generic/ |
| 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));
|
| D | queue_unittest.cc | 68 : count(0), handler_(handler), queue_(queue), delay_(0) {} in TestEnqueueEnd()
96 queue_->UnregisterEnqueue(); in EnqueueCallbackForTest()
116 Queue<std::string>* queue_; member in bluetooth::os::__anon494e39b60111::TestEnqueueEnd
121 …queue_->RegisterEnqueue(handler_, common::Bind(&TestEnqueueEnd::EnqueueCallbackForTest, common::Un… in handle_register_enqueue()
125 queue_->UnregisterEnqueue(); in handle_unregister_enqueue()
133 : count(0), handler_(handler), queue_(queue), capacity_(capacity), delay_(0) {} in TestDequeueEnd()
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::__anon494e39b60111::TestDequeueEnd
186 …queue_->RegisterDequeue(handler_, common::Bind(&TestDequeueEnd::DequeueCallbackForTest, common::Un… in handle_register_dequeue()
[all …]
|
| /system/bt/gd/hci/acl_manager/ |
| 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()
|
| D | round_robin_scheduler.h | 42 std::shared_ptr<acl_manager::AclConnection::Queue> queue_; member
|
| 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
|
| 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
|
| /system/bt/main/shim/ |
| D | acl.cc | 193 if (queue_.size() == max_size_) { in Push()
194 queue_.pop_front(); in Push()
196 queue_.push_back(std::move(element)); in Push()
201 for (auto& entry : queue_) { in ReadElementsAsString()
209 std::deque<T> queue_; member in __anon7d607c300111::FixedQueue
269 if (!queue_.empty()) in ~ShimAclConnection()
272 handle_, queue_.size()); in ~ShimAclConnection()
279 queue_.push(std::move(packet)); in EnqueuePacket()
284 auto packet = std::move(queue_.front()); in handle_enqueue()
285 queue_.pop(); in handle_enqueue()
[all …]
|