Loading system/gd/hci/le_address_manager.cc +12 −2 Original line number Diff line number Diff line Loading @@ -440,10 +440,20 @@ void LeAddressManager::OnCommandComplete(bluetooth::hci::CommandCompleteView vie } } handler_->BindOnceOn(this, &LeAddressManager::check_cached_commands).Invoke(); } void LeAddressManager::check_cached_commands() { for (auto client : registered_clients_) { if (client.second != ClientState::PAUSED) { return; } } if (cached_commands_.empty()) { handler_->BindOnceOn(this, &LeAddressManager::resume_registered_clients).Invoke(); resume_registered_clients(); } else { handler_->BindOnceOn(this, &LeAddressManager::handle_next_command).Invoke(); handle_next_command(); } } Loading system/gd/hci/le_address_manager.h +1 −0 Original line number Diff line number Diff line Loading @@ -126,6 +126,7 @@ class LeAddressManager { hci::Address generate_rpa(); hci::Address generate_nrpa(); void handle_next_command(); void check_cached_commands(); common::Callback<void(std::unique_ptr<CommandBuilder>)> enqueue_command_; os::Handler* handler_; Loading Loading
system/gd/hci/le_address_manager.cc +12 −2 Original line number Diff line number Diff line Loading @@ -440,10 +440,20 @@ void LeAddressManager::OnCommandComplete(bluetooth::hci::CommandCompleteView vie } } handler_->BindOnceOn(this, &LeAddressManager::check_cached_commands).Invoke(); } void LeAddressManager::check_cached_commands() { for (auto client : registered_clients_) { if (client.second != ClientState::PAUSED) { return; } } if (cached_commands_.empty()) { handler_->BindOnceOn(this, &LeAddressManager::resume_registered_clients).Invoke(); resume_registered_clients(); } else { handler_->BindOnceOn(this, &LeAddressManager::handle_next_command).Invoke(); handle_next_command(); } } Loading
system/gd/hci/le_address_manager.h +1 −0 Original line number Diff line number Diff line Loading @@ -126,6 +126,7 @@ class LeAddressManager { hci::Address generate_rpa(); hci::Address generate_nrpa(); void handle_next_command(); void check_cached_commands(); common::Callback<void(std::unique_ptr<CommandBuilder>)> enqueue_command_; os::Handler* handler_; Loading