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

Commit 5a3ea7e7 authored by Treehugger Robot's avatar Treehugger Robot Committed by Automerger Merge Worker
Browse files

Merge "RootCanal: Clean up device and phy allocations" am: 9e2fcf56 

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

Change-Id: Ie36f92f5d2cee98aeaebfb183b0ac959453c34da
parents 7d8100c0 9e2fcf56

system/test/rootcanal/bluetooth_hci.cc

+1 −0
Original line number Diff line number Diff line
@@ -224,6 +224,7 @@ Return<void> BluetoothHci::initialize_impl( 


Return<void> BluetoothHci::close() {

  LOG_INFO("%s", __func__);

  test_model_.Reset();

  return Void();

}

system/vendor_libs/test_vendor_lib/model/devices/beacon.cc

+2 −2
Original line number Diff line number Diff line
@@ -70,7 +70,7 @@ void Beacon::TimerTick() { 
    std::shared_ptr<model::packets::LinkLayerPacketBuilder> to_send =

        std::move(ad);



    for (const auto& phy : phy_layers_[Phy::Type::LOW_ENERGY]) {

    for (const auto& phy : phy_layers_) {

      phy->Send(to_send);

    }

  }
@@ -87,7 +87,7 @@ void Beacon::IncomingPacket(model::packets::LinkLayerPacketView packet) { 
    std::shared_ptr<model::packets::LinkLayerPacketBuilder> to_send =

        std::move(scan_response);



    for (const auto& phy : phy_layers_[Phy::Type::LOW_ENERGY]) {

    for (const auto& phy : phy_layers_) {

      phy->Send(to_send);

    }

  }

system/vendor_libs/test_vendor_lib/model/devices/device.cc

+17 −14
Original line number Diff line number Diff line
@@ -29,23 +29,22 @@ std::string Device::ToString() const { 
}



void Device::RegisterPhyLayer(std::shared_ptr<PhyLayer> phy) {

  phy_layers_[phy->GetType()].push_back(phy);

  phy_layers_.push_back(std::move(phy));

}



void Device::UnregisterPhyLayers() {

  for (auto phy_pair : phy_layers_) {

    auto phy_list = std::get<1>(phy_pair);

    for (auto phy : phy_list) {

  for (const auto& phy : phy_layers_) {

    phy->Unregister();

  }

  }

  phy_layers_.clear();

}



void Device::UnregisterPhyLayer(Phy::Type phy_type, uint32_t factory_id) {

  for (const auto phy_layer : phy_layers_[phy_type]) {

    if (phy_layer->IsFactoryId(factory_id)) {

      phy_layer->Unregister();

      phy_layers_[phy_type].remove(phy_layer);

  for (const auto& phy : phy_layers_) {

    if (phy->GetType() == phy_type && phy->IsFactoryId(factory_id)) {

      phy->Unregister();

      phy_layers_.remove(phy);

      break;

    }

  }

}
@@ -58,17 +57,21 @@ bool Device::IsAdvertisementAvailable() const { 
void Device::SendLinkLayerPacket(

    std::shared_ptr<model::packets::LinkLayerPacketBuilder> to_send,

    Phy::Type phy_type) {

  for (const auto& phy : phy_layers_[phy_type]) {

  for (const auto& phy : phy_layers_) {

    if (phy->GetType() == phy_type) {

      phy->Send(to_send);

    }

  }

}



void Device::SendLinkLayerPacket(model::packets::LinkLayerPacketView to_send,

                                 Phy::Type phy_type) {

  for (const auto& phy : phy_layers_[phy_type]) {

  for (const auto& phy : phy_layers_) {

    if (phy->GetType() == phy_type) {

      phy->Send(to_send);

    }

  }

}



void Device::SetAddress(Address) {

  LOG_INFO("%s does not implement %s", GetTypeString().c_str(), __func__);

system/vendor_libs/test_vendor_lib/model/devices/device.h

+1 −1
Original line number Diff line number Diff line
@@ -87,7 +87,7 @@ class Device { 
                                   Phy::Type phy_type);



 protected:

  std::map<Phy::Type, std::list<std::shared_ptr<PhyLayer>>> phy_layers_;

  std::list<std::shared_ptr<PhyLayer>> phy_layers_;



  std::chrono::steady_clock::time_point last_advertisement_;

system/vendor_libs/test_vendor_lib/model/devices/hci_socket_device.cc

+1 −1
Original line number Diff line number Diff line
@@ -88,8 +88,8 @@ HciSocketDevice::HciSocketDevice(int file_descriptor) : socket_file_descriptor_( 
      },

      [this]() {

        LOG_INFO("HCI socket device disconnected");

        close_callback_();

        socket_file_descriptor_ = -1;

        close_callback_();

      });



  RegisterEventChannel([this](std::shared_ptr<std::vector<uint8_t>> packet) {