| /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_;
|
| /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/core/adb/fdevent/ |
| 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 …]
|
| /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()
100 acl_queue_handler->second.queue_->GetDownEnd()->RegisterDequeue( in start_round_robin()
116 auto packet = acl_queue_handler->second.queue_->GetDownEnd()->TryDequeue(); in buffer_packet()
148 acl_queue_handler->second.queue_->GetDownEnd()->UnregisterDequeue(); in unregister_all_connections()
|
| D | le_acl_connection.cc | 70 : queue_(std::move(queue)), tracker(le_acl_connection_interface, std::move(disconnect)) {} in impl()
78 std::shared_ptr<Queue> queue_; member
|
| D | round_robin_scheduler.h | 41 std::shared_ptr<acl_manager::AclConnection::Queue> queue_; member
|
| D | classic_acl_connection.cc | 288 : tracker(acl_connection_interface), queue_(std::move(queue)) {} in impl()
297 std::shared_ptr<Queue> queue_; member
|