Home
last modified time | relevance | path

Searched refs:command_queue_ (Results 1 – 11 of 11) sorted by relevance

/packages/modules/Bluetooth/system/gd/hci/
Dhci_layer.cc115 command_queue_.clear(); in ~impl()
148 command_queue_.emplace_back(std::move(command), std::move(on_response)); in enqueue_command()
184 !command_queue_.empty(), in handle_command_response()
203 if (is_vendor_specific && (is_status && !command_queue_.front().waiting_for_status_) && in handle_command_response()
211 command_queue_.front().GetCallback<CommandCompleteView>()->Invoke( in handle_command_response()
215 command_queue_.front().waiting_for_status_ == is_status, in handle_command_response()
221 command_queue_.front().GetCallback<TResponse>()->Invoke(std::move(response_view)); in handle_command_response()
224 command_queue_.pop_front(); in handle_command_response()
237 LOG_ERROR("Flushing %zd waiting commands", command_queue_.size()); in on_hci_timeout()
239 command_queue_.clear(); in on_hci_timeout()
[all …]
Dhci_layer_fake.cc62 command_queue_.push(std::move(command)); in EnqueueCommand()
65 if (command_queue_.size() == 1) { in EnqueueCommand()
75 command_queue_.push(std::move(command)); in EnqueueCommand()
78 if (command_queue_.size() == 1) { in EnqueueCommand()
89 if (command_queue_.empty()) { in GetCommand()
94 auto last = std::move(command_queue_.front()); in GetCommand()
95 command_queue_.pop(); in GetCommand()
97 if (command_queue_.empty()) { in GetCommand()
Dle_periodic_sync_manager_test.cc47 command_queue_.push(std::move(command)); in EnqueueCommand()
59 command_queue_.push(std::move(command)); in EnqueueCommand()
75 if (command_queue_.empty()) { in GetLastCommand()
78 auto last = std::move(command_queue_.front()); in GetLastCommand()
79 command_queue_.pop(); in GetLastCommand()
84 if (!command_queue_.empty()) { in GetCommand()
96 …!command_queue_.empty(), "Expecting command %s but command queue was empty", OpCodeText(op_code).c… in GetCommand()
124 std::queue<std::unique_ptr<CommandBuilder>> command_queue_; member in bluetooth::hci::__anonc7c5f6b80111::TestLeScanningInterface
Dle_address_manager_test.cc57 command_queue_.push(std::move(command)); in EnqueueCommand()
73 if (command_queue_.size() == 0) { in GetLastCommand()
76 auto last = std::move(command_queue_.front()); in GetLastCommand()
77 command_queue_.pop(); in GetLastCommand()
82 if (!command_queue_.empty()) { in GetCommand()
94 …!command_queue_.empty(), "Expecting command %s but command queue was empty", OpCodeText(op_code).c… in GetCommand()
121 std::queue<std::unique_ptr<CommandBuilder>> command_queue_; member in bluetooth::hci::__anon9e20fc930211::TestHciLayer
Dacl_manager_unittest.cc135 command_queue_.push(std::move(command)); in EnqueueCommand()
143 command_queue_.push(std::move(command)); in EnqueueCommand()
160 if (command_queue_.size() == 0) { in GetLastCommand()
163 auto last = std::move(command_queue_.front()); in GetLastCommand()
164 command_queue_.pop(); in GetLastCommand()
172 if (command_queue_.empty()) { in GetCommand()
184 if (!command_queue_.empty() && command_future_ != nullptr) { in GetLastCommand()
191 if (command_queue_.empty()) { in GetLastCommand()
203 if (command_queue_.empty()) { in GetLastOutgoingCommand()
335 std::queue<std::unique_ptr<CommandBuilder>> command_queue_; member in bluetooth::hci::acl_manager::__anone57cfdcd0111::TestHciLayer
Dcontroller_test.cc212 command_queue_.push(command); in HandleCommand()
258 while (command_queue_.size() == 0UL) { in GetCommand()
263 if (command_queue_.empty()) { in GetCommand()
266 CommandView command = command_queue_.front(); in GetCommand()
267 command_queue_.pop(); in GetCommand()
284 std::queue<CommandView> command_queue_; member in bluetooth::hci::__anona98ecf870211::TestHciLayer
Dhci_layer_fake.h96 std::queue<std::unique_ptr<CommandBuilder>> command_queue_; variable
/packages/modules/Bluetooth/system/gd/security/test/
Dfake_hci_layer.h69 command_queue_.push(std::move(command_queue_entry)); in EnqueueCommand()
76 command_queue_.push(std::move(command_queue_entry)); in EnqueueCommand()
80 EXPECT_FALSE(command_queue_.empty()); in GetLastCommand()
81 auto last = std::move(command_queue_.front()); in GetLastCommand()
82 command_queue_.pop(); in GetLastCommand()
109 std::queue<std::unique_ptr<CommandQueueEntry>> command_queue_; variable
/packages/modules/Bluetooth/system/gd/hci/acl_manager/
Dle_acl_connection_test.cc101 command_queue_.push(std::move(command)); in EnqueueCommand()
114 command_queue_.push(std::move(command)); in EnqueueCommand()
128 auto packet = std::move(command_queue_.front()); in DequeueCommand()
129 command_queue_.pop(); in DequeueCommand()
149 return command_queue_.empty(); in IsPacketQueueEmpty()
154 return command_queue_.size(); in NumberOfQueuedCommands()
160 std::queue<std::unique_ptr<hci::CommandBuilder>> command_queue_; member in bluetooth::hci::acl_manager::__anon514ad8eb0111::TestLeAclConnectionInterface
Dclassic_acl_connection_test.cc124 command_queue_.push(std::move(command)); in EnqueueCommand()
137 command_queue_.push(std::move(command)); in EnqueueCommand()
151 auto packet = std::move(command_queue_.front()); in DequeueCommand()
152 command_queue_.pop(); in DequeueCommand()
166 return command_queue_.empty(); in IsPacketQueueEmpty()
171 return command_queue_.size(); in NumberOfQueuedCommands()
177 std::queue<std::unique_ptr<hci::CommandBuilder>> command_queue_; member in TestAclConnectionInterface
Dle_impl_test.cc262 command_queue_.push(std::move(command)); in EnqueueCommand()
275 command_queue_.push(std::move(command)); in EnqueueCommand()
287 auto packet = std::move(command_queue_.front()); in DequeueCommand()
288 command_queue_.pop(); in DequeueCommand()
302 return command_queue_.empty(); in IsPacketQueueEmpty()
307 return command_queue_.size(); in NumberOfQueuedCommands()
317 if (command_queue_.empty()) { in GetLastCommand()
320 auto last = std::move(command_queue_.front()); in GetLastCommand()
321 command_queue_.pop(); in GetLastCommand()
326 if (!command_queue_.empty()) { in GetCommand()
[all …]