Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit e680540f authored by Hansong Zhang's avatar Hansong Zhang Committed by Automerger Merge Worker
Browse files

Add callbacks in LE link manager am: 599fd2db 

Original change: https://android-review.googlesource.com/c/platform/system/bt/+/1550430

MUST ONLY BE SUBMITTED BY AUTOMERGER

Change-Id: I11fb82b9edaf9290ff886fad6e2048a770b26ed7
parents 43416d64 599fd2db

system/gd/l2cap/le/internal/link_manager.cc

+18 −2
Original line number Diff line number Diff line
@@ -105,11 +105,22 @@ void LinkManager::OnLeConnectSuccess(hci::AddressWithType connecting_address_wit 
                                     std::unique_ptr<hci::acl_manager::LeAclConnection> acl_connection) {

  // Same link should not be connected twice

  hci::AddressWithType connected_address_with_type = acl_connection->GetRemoteAddress();

  uint16_t handle = acl_connection->GetHandle();

  ASSERT_LOG(GetLink(connected_address_with_type) == nullptr, "%s is connected twice without disconnection",

             acl_connection->GetRemoteAddress().ToString().c_str());

  links_.try_emplace(connected_address_with_type, l2cap_handler_, std::move(acl_connection), parameter_provider_,

                     dynamic_channel_service_manager_, fixed_channel_service_manager_, this);

  auto* link = GetLink(connected_address_with_type);



  if (link_property_callback_handler_ != nullptr) {

    link_property_callback_handler_->CallOn(

        link_property_listener_,

        &LinkPropertyListener::OnLinkConnected,

        connected_address_with_type,

        handle,

        link->GetRole());

  }



  // Allocate and distribute channels for all registered fixed channel services

  auto fixed_channel_services = fixed_channel_service_manager_->GetRegisteredServices();

  for (auto& fixed_channel_service : fixed_channel_services) {
@@ -132,8 +143,8 @@ void LinkManager::OnLeConnectSuccess(hci::AddressWithType connecting_address_wit 
void LinkManager::OnLeConnectFail(hci::AddressWithType address_with_type, hci::ErrorCode reason) {

  // Notify all pending links for this device

  auto pending_link = pending_links_.find(address_with_type);

  if (pending_link == pending_links_.end()) {

    // There is no pending link, exit

  if (pending_link == pending_links_.end() && reason != hci::ErrorCode::UNKNOWN_CONNECTION) {

    // There is no pending link, exit; UNKNOWN_CONNECTION means we cancelled

    LOG_INFO("Connection to %s failed without a pending link", address_with_type.ToString().c_str());

    return;

  }
@@ -162,6 +173,11 @@ void LinkManager::OnDisconnect(bluetooth::hci::AddressWithType address_with_type 
  ASSERT_LOG(link != nullptr, "Device %s is disconnected but not in local database",

             address_with_type.ToString().c_str());

  links_.erase(address_with_type);



  if (link_property_callback_handler_ != nullptr) {

    link_property_callback_handler_->CallOn(

        link_property_listener_, &LinkPropertyListener::OnLinkDisconnected, address_with_type);

  }

}



void LinkManager::RegisterLinkPropertyListener(os::Handler* handler, LinkPropertyListener* listener) {