Loading system/btif/test/btif_profile_queue_test.cc +1 −0 Original line number Diff line number Diff line Loading @@ -19,6 +19,7 @@ #include <base/bind.h> #include "base/location.h" #include "btif/include/btif_profile_queue.h" #include "stack_manager.h" #include "types/raw_address.h" Loading system/osi/src/alarm.cc +2 −1 Original line number Diff line number Diff line Loading @@ -651,7 +651,8 @@ static void callback_dispatch(UNUSED_ATTR void* context) { } alarm->closure.i.Reset(Bind(alarm_ready_mloop, alarm)); get_message_loop()->PostTask(FROM_HERE, alarm->closure.i.callback()); get_message_loop()->task_runner()->PostTask(FROM_HERE, alarm->closure.i.callback()); } else { fixed_queue_enqueue(alarm->queue, alarm); } Loading system/osi/test/alarm_test.cc +2 −1 Original line number Diff line number Diff line Loading @@ -347,7 +347,8 @@ TEST_F(AlarmTest, test_callback_ordering_on_mloop) { for (int i = 0; i < 100; i++) alarm_free(alarms[i]); message_loop_->PostTask(FROM_HERE, run_loop_->QuitWhenIdleClosure()); message_loop_->task_runner()->PostTask(FROM_HERE, run_loop_->QuitWhenIdleClosure()); thread_free(message_loop_thread_); EXPECT_FALSE(WakeLockHeld()); } Loading system/service/adapter.cc +6 −5 Original line number Diff line number Diff line Loading @@ -330,9 +330,9 @@ class AdapterImpl : public Adapter, public hal::BluetoothInterface::Observer { } lock_guard<mutex> lock(observers_lock_); FOR_EACH_OBSERVER( Adapter::Observer, observers_, OnDeviceConnectionStateChanged(this, device_address, connected)); for (auto& observer : observers_) { observer.OnDeviceConnectionStateChanged(this, device_address, connected); } } // Sends a request to set the given HAL adapter property type and value. Loading Loading @@ -362,8 +362,9 @@ class AdapterImpl : public Adapter, public hal::BluetoothInterface::Observer { if (prev_state == new_state) return; lock_guard<mutex> lock(observers_lock_); FOR_EACH_OBSERVER(Adapter::Observer, observers_, OnAdapterStateChanged(this, prev_state, new_state)); for (auto& observer : observers_) { observer.OnAdapterStateChanged(this, prev_state, new_state); } } private: Loading system/service/daemon.cc +2 −1 Original line number Diff line number Diff line Loading @@ -19,6 +19,7 @@ #include <memory> #include <base/logging.h> #include <base/run_loop.h> #include "service/adapter.h" #include "service/hal/bluetooth_gatt_interface.h" Loading @@ -44,7 +45,7 @@ class DaemonImpl : public Daemon, public ipc::IPCManager::Delegate { CleanUpBluetoothStack(); } void StartMainLoop() override { message_loop_->Run(); } void StartMainLoop() override { base::RunLoop().Run(); } Settings* GetSettings() const override { return settings_.get(); } Loading Loading
system/btif/test/btif_profile_queue_test.cc +1 −0 Original line number Diff line number Diff line Loading @@ -19,6 +19,7 @@ #include <base/bind.h> #include "base/location.h" #include "btif/include/btif_profile_queue.h" #include "stack_manager.h" #include "types/raw_address.h" Loading
system/osi/src/alarm.cc +2 −1 Original line number Diff line number Diff line Loading @@ -651,7 +651,8 @@ static void callback_dispatch(UNUSED_ATTR void* context) { } alarm->closure.i.Reset(Bind(alarm_ready_mloop, alarm)); get_message_loop()->PostTask(FROM_HERE, alarm->closure.i.callback()); get_message_loop()->task_runner()->PostTask(FROM_HERE, alarm->closure.i.callback()); } else { fixed_queue_enqueue(alarm->queue, alarm); } Loading
system/osi/test/alarm_test.cc +2 −1 Original line number Diff line number Diff line Loading @@ -347,7 +347,8 @@ TEST_F(AlarmTest, test_callback_ordering_on_mloop) { for (int i = 0; i < 100; i++) alarm_free(alarms[i]); message_loop_->PostTask(FROM_HERE, run_loop_->QuitWhenIdleClosure()); message_loop_->task_runner()->PostTask(FROM_HERE, run_loop_->QuitWhenIdleClosure()); thread_free(message_loop_thread_); EXPECT_FALSE(WakeLockHeld()); } Loading
system/service/adapter.cc +6 −5 Original line number Diff line number Diff line Loading @@ -330,9 +330,9 @@ class AdapterImpl : public Adapter, public hal::BluetoothInterface::Observer { } lock_guard<mutex> lock(observers_lock_); FOR_EACH_OBSERVER( Adapter::Observer, observers_, OnDeviceConnectionStateChanged(this, device_address, connected)); for (auto& observer : observers_) { observer.OnDeviceConnectionStateChanged(this, device_address, connected); } } // Sends a request to set the given HAL adapter property type and value. Loading Loading @@ -362,8 +362,9 @@ class AdapterImpl : public Adapter, public hal::BluetoothInterface::Observer { if (prev_state == new_state) return; lock_guard<mutex> lock(observers_lock_); FOR_EACH_OBSERVER(Adapter::Observer, observers_, OnAdapterStateChanged(this, prev_state, new_state)); for (auto& observer : observers_) { observer.OnAdapterStateChanged(this, prev_state, new_state); } } private: Loading
system/service/daemon.cc +2 −1 Original line number Diff line number Diff line Loading @@ -19,6 +19,7 @@ #include <memory> #include <base/logging.h> #include <base/run_loop.h> #include "service/adapter.h" #include "service/hal/bluetooth_gatt_interface.h" Loading @@ -44,7 +45,7 @@ class DaemonImpl : public Daemon, public ipc::IPCManager::Delegate { CleanUpBluetoothStack(); } void StartMainLoop() override { message_loop_->Run(); } void StartMainLoop() override { base::RunLoop().Run(); } Settings* GetSettings() const override { return settings_.get(); } Loading