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

Commit a53e611d authored by Yun-hao Chung's avatar Yun-hao Chung Committed by Automerger Merge Worker
Browse files

Merge "Floss: Don't crash when chipset is broken" into main am: bd27ec02 

Original change: https://android-review.googlesource.com/c/platform/packages/modules/Bluetooth/+/2691566



Change-Id: I962d28b7407235248206156edc9edc68f8b13743
Signed-off-by: default avatarAutomerger Merge Worker <android-build-automerger-merge-worker@system.gserviceaccount.com>
parents d6885a4c bd27ec02

system/gd/hal/hci_hal_host.cc

+20 −2
Original line number Diff line number Diff line
@@ -162,6 +162,9 @@ int waitHciDev(int hci_interface) { 
              break;

            }

          }



          // Chipset might be lost. Wait for index added event.

          LOG_ERROR("HCI interface(%d) not found in the MGMT lndex list", hci_interface);

        } else {

          // Unlikely event (probably developer error or driver shut down).

          LOG_ERROR("Failed to read index list: status(%d)", cc->status);
@@ -289,7 +292,14 @@ class HciHalHost : public HciHal { 
    std::lock_guard<std::mutex> lock(api_mutex_);

    ASSERT(sock_fd_ == INVALID_FD);

    sock_fd_ = ConnectToSocket();

    ASSERT(sock_fd_ != INVALID_FD);



    // We don't want to crash when the chipset is broken.

    if (sock_fd_ == INVALID_FD) {

      LOG_ERROR("Failed to connect to HCI socket. Aborting HAL initialization process.");

      raise(SIGINT);

      return;

    }



    reactable_ = hci_incoming_thread_.GetReactor()->Register(

        sock_fd_,

        common::Bind(&HciHalHost::incoming_packet_received, common::Unretained(this)),
@@ -370,7 +380,15 @@ class HciHalHost : public HciHal { 


    ssize_t received_size;

    RUN_NO_INTR(received_size = read(sock_fd_, buf, kBufSize));

    ASSERT_LOG(received_size != -1, "Can't receive from socket: %s", strerror(errno));



    // we don't want crash when the chipset is broken.

    if (received_size == -1) {

      LOG_ERROR("Can't receive from socket: %s", strerror(errno));

      close(sock_fd_);

      raise(SIGINT);

      return;

    }



    if (received_size == 0) {

      LOG_WARN("Can't read H4 header. EOF received");

      // First close sock fd before raising sigint

system/gd/rust/linux/service/src/main.rs

+16 −2
Original line number Diff line number Diff line
@@ -412,14 +412,21 @@ fn main() -> Result<(), Box<dyn Error>> { 
            // Install SIGTERM handler so that we can properly shutdown

            *SIG_DATA.lock().unwrap() = Some((tx.clone(), sig_notifier.clone()));



            let sig_action = signal::SigAction::new(

            let sig_action_term = signal::SigAction::new(

                signal::SigHandler::Handler(handle_sigterm),

                signal::SaFlags::empty(),

                signal::SigSet::empty(),

            );



            let sig_action_int = signal::SigAction::new(

                signal::SigHandler::Handler(handle_sigint),

                signal::SaFlags::empty(),

                signal::SigSet::empty(),

            );



            unsafe {

                signal::sigaction(signal::SIGTERM, &sig_action).unwrap();

                signal::sigaction(signal::SIGTERM, &sig_action_term).unwrap();

                signal::sigaction(signal::SIGINT, &sig_action_int).unwrap();

            }

        }
@@ -467,3 +474,10 @@ extern "C" fn handle_sigterm(_signum: i32) { 
    log::debug!("Sigterm completed");

    std::process::exit(0);

}



extern "C" fn handle_sigint(_signum: i32) {

    // Assumed this is from HAL Host, which is likely caused by chipset error.

    // In this case, don't crash the daemon and don't try to power off the adapter.

    log::debug!("Sigint completed");

    std::process::exit(0);

}