Loading system/gd/hci/acl_manager.cc +0 −58 Original line number Diff line number Diff line Loading @@ -180,11 +180,6 @@ struct AclManager::impl { void Dump( std::promise<flatbuffers::Offset<AclManagerData>> promise, flatbuffers::FlatBufferBuilder* fb_builder) const; private: flatbuffers::Offset<LeAddressManagerData> DumpLeAddressManager( flatbuffers::FlatBufferBuilder* fb_builder) const; public: const AclManager& acl_manager_; classic_impl* classic_impl_ = nullptr; Loading Loading @@ -439,46 +434,10 @@ const ModuleFactory AclManager::Factory = ModuleFactory([]() { return new AclMan AclManager::~AclManager() = default; flatbuffers::Offset<LeAddressManagerData> AclManager::impl::DumpLeAddressManager( flatbuffers::FlatBufferBuilder* fb_builder) const { const std::vector<int> le_registered_client_states = (le_impl_ != nullptr) ? le_impl_->le_address_manager_->GetRegisteredClientStates() : std::vector<int>(); auto v_offset = fb_builder->CreateVector(le_registered_client_states); auto address_policy_string = [this]() -> std::string { switch (le_impl_->le_address_manager_->GetAddressPolicy()) { case LeAddressManager::POLICY_NOT_SET: return std::string("POLICY_NOT_SET"); case LeAddressManager::USE_PUBLIC_ADDRESS: return std::string("USE_PUBLIC_ADDRESS"); case LeAddressManager::USE_STATIC_ADDRESS: return std::string("USE_STATIC_ADDRESS"); case LeAddressManager::USE_NON_RESOLVABLE_ADDRESS: return std::string("USE_NON_RESOLVABLE_ADDRESS"); case LeAddressManager::USE_RESOLVABLE_ADDRESS: return std::string("USE_RESOLVABLE_ADDRESS"); default: return std::string("UNKNOWN"); } }(); auto fb_address_policy_string = fb_builder->CreateString(address_policy_string.c_str()); LeAddressManagerDataBuilder le_address_manager_data_builder(*fb_builder); le_address_manager_data_builder.add_address_policy(fb_address_policy_string); le_address_manager_data_builder.add_registered_client_states(v_offset); return le_address_manager_data_builder.Finish(); } void AclManager::impl::Dump( std::promise<flatbuffers::Offset<AclManagerData>> promise, flatbuffers::FlatBufferBuilder* fb_builder) const { const std::lock_guard<std::mutex> lock(dumpsys_mutex_); const auto connect_list = (le_impl_ != nullptr) ? le_impl_->connect_list : std::unordered_set<AddressWithType>(); const auto background_connect_list = (le_impl_ != nullptr) ? le_impl_->background_connections_ : std::unordered_set<AddressWithType>(); const auto le_connectability_state_text = (le_impl_ != nullptr) ? connectability_state_machine_text(le_impl_->connectability_state_) : "INDETERMINATE"; const auto le_create_connection_timeout_alarms_count = Loading @@ -488,10 +447,6 @@ void AclManager::impl::Dump( auto le_connectability_state = fb_builder->CreateString(le_connectability_state_text); flatbuffers::Offset<flatbuffers::String> strings[connect_list.size()]; flatbuffers::Offset<flatbuffers::String> background_connect_list_strings[background_connect_list.size()]; auto le_address_manager_data_offset = DumpLeAddressManager(fb_builder); size_t cnt = 0; for (const auto& it : connect_list) { Loading @@ -499,25 +454,12 @@ void AclManager::impl::Dump( } auto vecofstrings = fb_builder->CreateVector(strings, connect_list.size()); cnt = 0; for (const auto& it : background_connect_list) { strings[cnt++] = fb_builder->CreateString(it.ToString()); } auto background_connect_list_string_vector = fb_builder->CreateVector(background_connect_list_strings, background_connect_list.size()); AclManagerDataBuilder builder(*fb_builder); builder.add_title(title); builder.add_le_filter_accept_list_count(connect_list.size()); builder.add_le_filter_accept_list(vecofstrings); builder.add_le_background_connection_list(background_connect_list_string_vector); builder.add_le_connectability_state(le_connectability_state); builder.add_le_create_connection_timeout_alarms_count(le_create_connection_timeout_alarms_count); builder.add_address_manager_registered( (le_impl_ != nullptr) ? le_impl_->address_manager_registered : false); builder.add_ready_to_unregister((le_impl_ != nullptr) ? le_impl_->ready_to_unregister : false); builder.add_pause_connection((le_impl_ != nullptr) ? le_impl_->pause_connection : false); builder.add_le_address_manager(le_address_manager_data_offset); flatbuffers::Offset<AclManagerData> dumpsys_data = builder.Finish(); promise.set_value(dumpsys_data); Loading system/gd/hci/hci_acl_manager.fbs +0 −10 Original line number Diff line number Diff line Loading @@ -2,22 +2,12 @@ namespace bluetooth.hci; attribute "privacy"; table LeAddressManagerData { address_policy:string (privacy:"Any"); registered_client_states:[int] (privacy:"Any"); } table AclManagerData { title:string (privacy:"Any"); le_filter_accept_list_count:int (privacy:"Any"); le_filter_accept_list:[string] (privacy:"Any"); le_background_connection_list:[string] (privacy:"Any"); le_connectability_state:string (privacy:"Any"); le_create_connection_timeout_alarms_count:int (privacy:"Any"); address_manager_registered:bool (privacy:"Any"); ready_to_unregister:bool (privacy:"Any"); pause_connection:bool (privacy:"Any"); le_address_manager:LeAddressManagerData (privacy:"Any"); } root_type AclManagerData; system/gd/hci/le_address_manager.h +2 −14 Original line number Diff line number Diff line Loading @@ -104,18 +104,6 @@ class LeAddressManager { return cached_commands_.size(); } std::vector<int> GetRegisteredClientStates() const { std::vector<int> client_states(registered_clients_.size()); for (const auto& client : registered_clients_) { client_states.push_back(static_cast<int>(client.second)); } return client_states; } AddressPolicy GetAddressPolicy() const { return address_policy_; } protected: AddressPolicy address_policy_ = AddressPolicy::POLICY_NOT_SET; std::chrono::milliseconds minimum_rotation_time_; Loading Loading @@ -188,8 +176,8 @@ class LeAddressManager { Address public_address_; std::unique_ptr<os::Alarm> address_rotation_alarm_; crypto_toolbox::Octet16 rotation_irk_; const uint8_t connect_list_size_; const uint8_t resolving_list_size_; uint8_t connect_list_size_; uint8_t resolving_list_size_; std::queue<Command> cached_commands_; bool supports_ble_privacy_{false}; }; Loading Loading
system/gd/hci/acl_manager.cc +0 −58 Original line number Diff line number Diff line Loading @@ -180,11 +180,6 @@ struct AclManager::impl { void Dump( std::promise<flatbuffers::Offset<AclManagerData>> promise, flatbuffers::FlatBufferBuilder* fb_builder) const; private: flatbuffers::Offset<LeAddressManagerData> DumpLeAddressManager( flatbuffers::FlatBufferBuilder* fb_builder) const; public: const AclManager& acl_manager_; classic_impl* classic_impl_ = nullptr; Loading Loading @@ -439,46 +434,10 @@ const ModuleFactory AclManager::Factory = ModuleFactory([]() { return new AclMan AclManager::~AclManager() = default; flatbuffers::Offset<LeAddressManagerData> AclManager::impl::DumpLeAddressManager( flatbuffers::FlatBufferBuilder* fb_builder) const { const std::vector<int> le_registered_client_states = (le_impl_ != nullptr) ? le_impl_->le_address_manager_->GetRegisteredClientStates() : std::vector<int>(); auto v_offset = fb_builder->CreateVector(le_registered_client_states); auto address_policy_string = [this]() -> std::string { switch (le_impl_->le_address_manager_->GetAddressPolicy()) { case LeAddressManager::POLICY_NOT_SET: return std::string("POLICY_NOT_SET"); case LeAddressManager::USE_PUBLIC_ADDRESS: return std::string("USE_PUBLIC_ADDRESS"); case LeAddressManager::USE_STATIC_ADDRESS: return std::string("USE_STATIC_ADDRESS"); case LeAddressManager::USE_NON_RESOLVABLE_ADDRESS: return std::string("USE_NON_RESOLVABLE_ADDRESS"); case LeAddressManager::USE_RESOLVABLE_ADDRESS: return std::string("USE_RESOLVABLE_ADDRESS"); default: return std::string("UNKNOWN"); } }(); auto fb_address_policy_string = fb_builder->CreateString(address_policy_string.c_str()); LeAddressManagerDataBuilder le_address_manager_data_builder(*fb_builder); le_address_manager_data_builder.add_address_policy(fb_address_policy_string); le_address_manager_data_builder.add_registered_client_states(v_offset); return le_address_manager_data_builder.Finish(); } void AclManager::impl::Dump( std::promise<flatbuffers::Offset<AclManagerData>> promise, flatbuffers::FlatBufferBuilder* fb_builder) const { const std::lock_guard<std::mutex> lock(dumpsys_mutex_); const auto connect_list = (le_impl_ != nullptr) ? le_impl_->connect_list : std::unordered_set<AddressWithType>(); const auto background_connect_list = (le_impl_ != nullptr) ? le_impl_->background_connections_ : std::unordered_set<AddressWithType>(); const auto le_connectability_state_text = (le_impl_ != nullptr) ? connectability_state_machine_text(le_impl_->connectability_state_) : "INDETERMINATE"; const auto le_create_connection_timeout_alarms_count = Loading @@ -488,10 +447,6 @@ void AclManager::impl::Dump( auto le_connectability_state = fb_builder->CreateString(le_connectability_state_text); flatbuffers::Offset<flatbuffers::String> strings[connect_list.size()]; flatbuffers::Offset<flatbuffers::String> background_connect_list_strings[background_connect_list.size()]; auto le_address_manager_data_offset = DumpLeAddressManager(fb_builder); size_t cnt = 0; for (const auto& it : connect_list) { Loading @@ -499,25 +454,12 @@ void AclManager::impl::Dump( } auto vecofstrings = fb_builder->CreateVector(strings, connect_list.size()); cnt = 0; for (const auto& it : background_connect_list) { strings[cnt++] = fb_builder->CreateString(it.ToString()); } auto background_connect_list_string_vector = fb_builder->CreateVector(background_connect_list_strings, background_connect_list.size()); AclManagerDataBuilder builder(*fb_builder); builder.add_title(title); builder.add_le_filter_accept_list_count(connect_list.size()); builder.add_le_filter_accept_list(vecofstrings); builder.add_le_background_connection_list(background_connect_list_string_vector); builder.add_le_connectability_state(le_connectability_state); builder.add_le_create_connection_timeout_alarms_count(le_create_connection_timeout_alarms_count); builder.add_address_manager_registered( (le_impl_ != nullptr) ? le_impl_->address_manager_registered : false); builder.add_ready_to_unregister((le_impl_ != nullptr) ? le_impl_->ready_to_unregister : false); builder.add_pause_connection((le_impl_ != nullptr) ? le_impl_->pause_connection : false); builder.add_le_address_manager(le_address_manager_data_offset); flatbuffers::Offset<AclManagerData> dumpsys_data = builder.Finish(); promise.set_value(dumpsys_data); Loading
system/gd/hci/hci_acl_manager.fbs +0 −10 Original line number Diff line number Diff line Loading @@ -2,22 +2,12 @@ namespace bluetooth.hci; attribute "privacy"; table LeAddressManagerData { address_policy:string (privacy:"Any"); registered_client_states:[int] (privacy:"Any"); } table AclManagerData { title:string (privacy:"Any"); le_filter_accept_list_count:int (privacy:"Any"); le_filter_accept_list:[string] (privacy:"Any"); le_background_connection_list:[string] (privacy:"Any"); le_connectability_state:string (privacy:"Any"); le_create_connection_timeout_alarms_count:int (privacy:"Any"); address_manager_registered:bool (privacy:"Any"); ready_to_unregister:bool (privacy:"Any"); pause_connection:bool (privacy:"Any"); le_address_manager:LeAddressManagerData (privacy:"Any"); } root_type AclManagerData;
system/gd/hci/le_address_manager.h +2 −14 Original line number Diff line number Diff line Loading @@ -104,18 +104,6 @@ class LeAddressManager { return cached_commands_.size(); } std::vector<int> GetRegisteredClientStates() const { std::vector<int> client_states(registered_clients_.size()); for (const auto& client : registered_clients_) { client_states.push_back(static_cast<int>(client.second)); } return client_states; } AddressPolicy GetAddressPolicy() const { return address_policy_; } protected: AddressPolicy address_policy_ = AddressPolicy::POLICY_NOT_SET; std::chrono::milliseconds minimum_rotation_time_; Loading Loading @@ -188,8 +176,8 @@ class LeAddressManager { Address public_address_; std::unique_ptr<os::Alarm> address_rotation_alarm_; crypto_toolbox::Octet16 rotation_irk_; const uint8_t connect_list_size_; const uint8_t resolving_list_size_; uint8_t connect_list_size_; uint8_t resolving_list_size_; std::queue<Command> cached_commands_; bool supports_ble_privacy_{false}; }; Loading