| /packages/modules/Bluetooth/system/gd/os/ |
| D | handler_unittest.cc | 35 handler_ = new Handler(thread_); in SetUp()
38 delete handler_; in TearDown()
42 Handler* handler_; member in bluetooth::os::__anond0580a4a0111::HandlerTest
47 handler_->Clear(); in TEST_F()
61 handler_->Post(std::move(closure)); in TEST_F()
64 handler_->Clear(); in TEST_F()
75 handler_->Post(common::BindOnce( in TEST_F()
89 handler_->Post(common::BindOnce([]() { ASSERT_TRUE(false); })); in TEST_F()
91 handler_->Clear(); in TEST_F()
107 handler_->Clear(); in TEST_F()
[all …]
|
| D | queue.h | 92 : reactive_semaphore_(initial_value), handler_(nullptr), reactable_(nullptr) {} in QueueEndpoint()
94 Handler* handler_; variable
166 log::assert_that(enqueue_.handler_ == nullptr, "Enqueue is not unregistered"); in ~Queue()
167 log::assert_that(dequeue_.handler_ == nullptr, "Dequeue is not unregistered"); in ~Queue()
173 log::assert_that(enqueue_.handler_ == nullptr, "assert failed: enqueue_.handler_ == nullptr"); in RegisterEnqueue()
175 enqueue_.handler_ = handler; in RegisterEnqueue()
176 enqueue_.reactable_ = enqueue_.handler_->thread_->GetReactor()->Register( in RegisterEnqueue()
191 reactor = enqueue_.handler_->thread_->GetReactor(); in UnregisterEnqueue()
192 wait_for_unregister = (!enqueue_.handler_->thread_->IsSameThread()); in UnregisterEnqueue()
195 enqueue_.handler_ = nullptr; in UnregisterEnqueue()
[all …]
|
| D | queue_benchmark.cc | 60 : count_(count), handler_(handler), queue_(queue), promise_(promise) {} in TestEnqueueEnd()
63 …handler_->Post(common::BindOnce(&TestEnqueueEnd::handle_register_enqueue, common::Unretained(this)… in RegisterEnqueue()
97 Handler* handler_; member in bluetooth::os::TestEnqueueEnd
103 …queue_->RegisterEnqueue(handler_, common::Bind(&TestEnqueueEnd::EnqueueCallbackForTest, common::Un… in handle_register_enqueue()
110 : count_(count), handler_(handler), queue_(queue), promise_(promise) {} in TestDequeueEnd()
113 …handler_->Post(common::BindOnce(&TestDequeueEnd::handle_register_dequeue, common::Unretained(this)… in RegisterDequeue()
131 Handler* handler_; member in bluetooth::os::TestDequeueEnd
136 …queue_->RegisterDequeue(handler_, common::Bind(&TestDequeueEnd::DequeueCallbackForTest, common::Un… in handle_register_dequeue()
|
| D | thread_benchmark.cc | 64 handler_ = std::make_unique<Handler>(thread_.get()); in SetUp()
67 handler_ = nullptr; in TearDown()
73 std::unique_ptr<Handler> handler_; member in BM_ReactorThread
83 handler_->Post(BindOnce( in BENCHMARK_DEFINE_F()
104 handler_->Post( in BENCHMARK_DEFINE_F()
|
| /packages/modules/Bluetooth/system/gd/l2cap/internal/ |
| D | sender.cc | 33 : handler_(handler), link_(link), queue_end_(channel->GetQueueDownEnd()), scheduler_(scheduler), in Sender()
35 …r_(std::make_unique<BasicModeDataController>(channel_id_, remote_channel_id_, queue_end_, handler_, in Sender()
42 : handler_(handler), link_(link), queue_end_(channel->GetQueueDownEnd()), scheduler_(scheduler), in Sender()
46 …unique<BasicModeDataController>(channel_id_, remote_channel_id_, queue_end_, handler_, scheduler_); in Sender()
49 …e_unique<ErtmController>(link_, channel_id_, remote_channel_id_, queue_end_, handler_, scheduler_); in Sender()
52 handler_, scheduler_); in Sender()
80 …queue_end_->RegisterDequeue(handler_, common::Bind(&Sender::dequeue_callback, common::Unretained(t… in try_register_dequeue()
87 handler_->Post( in dequeue_callback()
102 …unique<BasicModeDataController>(channel_id_, remote_channel_id_, queue_end_, handler_, scheduler_); in UpdateClassicConfiguration()
107 …e_unique<ErtmController>(link_, channel_id_, remote_channel_id_, queue_end_, handler_, scheduler_); in UpdateClassicConfiguration()
|
| D | fixed_channel_allocator_test.cc | 40 handler_ = new os::Handler(thread_); in SetUp()
42 mock_classic_link_ = new MockLink(handler_, mock_parameter_provider_); in SetUp()
46 …::make_unique<FixedChannelAllocator<MockFixedChannelImpl, MockLink>>(mock_classic_link_, handler_); in SetUp()
53 handler_->Clear(); in TearDown()
54 delete handler_; in TearDown()
59 os::Handler* handler_{nullptr}; member in bluetooth::l2cap::internal::L2capFixedChannelAllocatorTest
|
| D | dynamic_channel_allocator_fuzz_test.cc | 47 handler_ = new os::Handler(thread_); in SetUp()
49 mock_classic_link_ = new NiceMock<MockLink>(handler_, mock_parameter_provider_, in SetUp()
52 channel_allocator_ = std::make_unique<DynamicChannelAllocator>(mock_classic_link_, handler_); in SetUp()
59 handler_->Clear(); in TearDown()
60 delete handler_; in TearDown()
73 os::Handler* handler_{nullptr}; member in bluetooth::l2cap::internal::L2capClassicDynamicChannelAllocatorFuzzTest
|
| D | dynamic_channel_allocator_test.cc | 38 handler_ = new os::Handler(thread_); in SetUp()
40 mock_classic_link_ = new MockLink(handler_, mock_parameter_provider_); in SetUp()
42 channel_allocator_ = std::make_unique<DynamicChannelAllocator>(mock_classic_link_, handler_); in SetUp()
49 handler_->Clear(); in TearDown()
50 delete handler_; in TearDown()
55 os::Handler* handler_{nullptr}; member in bluetooth::l2cap::internal::L2capClassicDynamicChannelAllocatorTest
|
| /packages/modules/Bluetooth/system/gd/hci/ |
| D | le_address_manager_test.cc | 78 handler_ = new Handler(thread_); in SetUp()
82 …common::Bind(&LeAddressManagerTest::enqueue_command, common::Unretained(this)), handler_, address,… in SetUp()
89 handler_->Post(common::BindOnce(&std::promise<void>::set_value, common::Unretained(&promise))); in sync_handler()
95 sync_handler(handler_); in TearDown()
98 handler_->Clear(); in TearDown()
99 delete handler_; in TearDown()
113 handler_->BindOnce( in enqueue_command()
118 Handler* handler_; member in bluetooth::hci::__anon4857542e0111::LeAddressManagerTest
128 sync_handler(handler_); in TEST_F()
130 sync_handler(handler_); in TEST_F()
[all …]
|
| D | le_address_manager.cc | 67 handler_(handler), in LeAddressManager()
92 handler_->CallOn( in SetPrivacyPolicyForInitiatorAddress()
119 handler_->BindOnceOn(this, &LeAddressManager::resume_registered_clients)(); in SetPrivacyPolicyForInitiatorAddress()
137 handler_->Post(common::BindOnce(enqueue_command_, std::move(packet))); in SetPrivacyPolicyForInitiatorAddress()
147 address_rotation_alarm_ = std::make_unique<os::Alarm>(handler_); in SetPrivacyPolicyForInitiatorAddress()
189 handler_->Call(enqueue_command_, std::move(packet)); in SetPrivacyPolicyForInitiatorAddressForTest()
196 address_rotation_alarm_ = std::make_unique<os::Alarm>(handler_); in SetPrivacyPolicyForInitiatorAddressForTest()
211 handler_->BindOnceOn(this, &LeAddressManager::register_client, callback)(); in Register()
233 handler_->BindOnceOn(this, &LeAddressManager::unregister_client, callback)(); in Unregister()
253 handler_->BindOnceOn(this, &LeAddressManager::unregister_client, callback)(); in UnregisterSync()
[all …]
|
| D | remote_name_request.cc | 37 handler_ = module_.GetHandler(); in Start()
41 handler_->BindOn( in Start()
45 handler_->BindOn(this, &RemoteNameRequestModule::impl::on_remote_name_request_complete)); in Start()
70 handler_->BindOnceOn( in StartRemoteNameRequest()
78 handler_->BindOnce( in StartRemoteNameRequest()
93 address, handler_->BindOnceOn(this, &impl::actually_cancel_remote_name_request, address)); in CancelRemoteNameRequest()
126 handler_->BindOnceOn( in actually_start_remote_name_request()
161 handler_->BindOnceOn(this, &impl::check_cancel_status, address)); in actually_cancel_remote_name_request()
228 os::Handler* handler_; member
|
| /packages/modules/Bluetooth/system/test/headless/ |
| D | handler.cc | 32 handler_ = new os::Handler(thread_); in Handler()
36 handler_->Clear(); in ~Handler()
37 handler_->WaitUntilStopped(std::chrono::milliseconds(2000)); in ~Handler()
38 delete handler_; in ~Handler()
43 log::assert_that(handler_ != nullptr, "Handler is not valid"); in Post()
44 handler_->Post(std::move(closure)); in Post()
|
| /packages/modules/Bluetooth/system/gd/security/test/ |
| D | fake_l2cap_test.cc | 89 os::Handler* handler_ = new os::Handler(thread_); in TEST_F() local
99 enqueue_buffer.Enqueue(std::move(test_packet), handler_); in TEST_F()
102 sync_handler(handler_); in TEST_F()
111 bidi_queue.GetDownEnd()->RegisterDequeue(handler_, common::Bind(&my_enqueue_callback)); in TEST_F()
117 handler_); in TEST_F()
119 sync_handler(handler_); in TEST_F()
125 handler_->Clear(); in TEST_F()
126 delete handler_; in TEST_F()
|
| /packages/modules/Bluetooth/system/gd/l2cap/fuzz/ |
| D | shim_l2cap.h | 49 handler_->BindOn(this, &ShimL2capFuzz::OnConnectionComplete), in CreateConnection()
50 handler_->BindOnceOn(this, &ShimL2capFuzz::OnConnectionFail)); in CreateConnection()
71 handler_ = std::unique_ptr<os::Handler>(new os::Handler(&thread_)); in ShimL2capFuzz()
73 new l2cap::classic::internal::DynamicChannelServiceManagerImpl(handler_.get())); in ShimL2capFuzz()
75 new l2cap::classic::internal::FixedChannelServiceManagerImpl(handler_.get())); in ShimL2capFuzz()
78 …handler_.get(), acl_manager_, fixed_channel_impl.get(), dynamic_channel_impl.get(), parameter_prov… in ShimL2capFuzz()
82 handler_->Clear(); in ~ShimL2capFuzz()
94 std::unique_ptr<os::Handler> handler_; variable
|
| /packages/modules/Bluetooth/system/gd/l2cap/classic/internal/ |
| D | link_test.cc | 66 …handler_, common::Bind(&L2capClassicLinkTest::OnDequeueCallbackForTest, common::Unretained(this))); in EnqueueCallbackForTest()
76 handler_ = new os::Handler(thread_); in SetUp()
91 handler_->Clear(); in TearDown()
92 delete handler_; in TearDown()
98 os::Handler* handler_ = nullptr; member in bluetooth::l2cap::classic::internal::__anon086815270111::L2capClassicLinkTest
120 .on_open_callback_ = handler_->BindOn(this, &L2capClassicLinkTest::OnOpen), in TEST_F()
121 .on_fail_callback_ = handler_->BindOnceOn(this, &L2capClassicLinkTest::OnFail), in TEST_F()
|
| /packages/modules/Bluetooth/system/gd/ |
| D | stack_manager.cc | 41 handler_ = new Handler(management_thread_); in StartUp()
47 …handler_->Post(common::BindOnce(&StackManager::handle_start_up, common::Unretained(this), modules,… in StartUp()
75 …handler_->Post(common::BindOnce(&StackManager::handle_shut_down, common::Unretained(this), std::mo… in ShutDown()
88 handler_->Clear(); in ShutDown()
89 handler_->WaitUntilStopped(std::chrono::milliseconds(2000)); in ShutDown()
90 delete handler_; in ShutDown()
|
| D | module.cc | 35 log::assert_that(handler_ != nullptr, "Can't get handler when it's not started"); in GetHandler()
36 return handler_; in GetHandler()
80 instance->handler_ = new Handler(thread); in set_registry_and_handler()
117 instance->second->handler_->Clear(); in StopAll()
118 instance->second->handler_->WaitUntilStopped(kModuleStopTimeout); in StopAll()
126 delete instance->second->handler_; in StopAll()
|
| /packages/modules/Bluetooth/system/gd/common/ |
| D | bidi_queue_unittest.cc | 62 …explicit TestBidiQueueEnd(BidiQueueEnd<TA, TB>* end, Handler* handler) : handler_(handler), end_(e… in TestBidiQueueEnd()
65 handler_->Clear(); in ~TestBidiQueueEnd()
70 handler_->Post(BindOnce( in Send()
80 handler_->Post( in Receive()
88 handler_, in handle_send()
104 handler_, in handle_receive()
115 Handler* handler_; member in bluetooth::common::__anon5ce44f8f0111::TestBidiQueueEnd
|
| /packages/modules/Bluetooth/system/gd/l2cap/le/internal/ |
| D | signalling_manager.cc | 43 : handler_(handler), link_(link), data_pipeline_manager_(data_pipeline_manager), in LeSignallingManager()
45 log::assert_that(handler_ != nullptr, "assert failed: handler_ != nullptr"); in LeSignallingManager()
50 handler_, common::Bind(&LeSignallingManager::on_incoming_packet, common::Unretained(this))); in LeSignallingManager()
65 …handler_->BindOnceOn(this, &LeSignallingManager::on_security_result_for_outgoing, psm, local_cid, … in SendConnectionRequest()
106 enqueue_buffer_->Enqueue(std::move(builder), handler_); in SendConnectionParameterUpdateResponse()
112 enqueue_buffer_->Enqueue(std::move(builder), handler_); in SendCredit()
150 enqueue_buffer_->Enqueue(std::move(builder), handler_); in OnConnectionParameterUpdateRequest()
158 enqueue_buffer_->Enqueue(std::move(builder), handler_); in OnConnectionParameterUpdateRequest()
215 … handler_->BindOnceOn(this, &LeSignallingManager::on_security_result_for_incoming, psm, pending)); in OnConnectionRequest()
267 auto user_channel = std::make_unique<DynamicChannel>(new_channel, handler_, link_, actual_mtu); in on_security_result_for_incoming()
[all …]
|
| /packages/modules/Bluetooth/system/gd/common/testing/ |
| D | wired_pair_of_bidi_queues.h | 44 down_buffer_b_.Enqueue(A_TO_B(std::move(down_thing)), handler_); in dequeue_callback_a()
51 down_buffer_a_.Enqueue(A_TO_B(std::move(down_thing)), handler_); in dequeue_callback_b()
54 os::Handler* handler_; variable
61 WiredPairOfBiDiQueues(os::Handler* handler) : handler_(handler) { in WiredPairOfBiDiQueues()
63 … handler_, common::Bind(&WiredPairOfBiDiQueues::dequeue_callback_a, common::Unretained(this))); in WiredPairOfBiDiQueues()
65 … handler_, common::Bind(&WiredPairOfBiDiQueues::dequeue_callback_b, common::Unretained(this))); in WiredPairOfBiDiQueues()
|
| /packages/modules/Bluetooth/system/gd/os/linux_generic/ |
| D | wakelock_manager_unittest.cc | 76 handler_ = new Handler(thread_); in SetUp()
79 handler_->Clear(); in TearDown()
80 delete handler_; in TearDown()
87 handler_->Post( in SyncHandler()
93 Handler* handler_; member in testing::WakelockManagerTest
99 WakelockManager::Get().SetOsCallouts(&os_callouts, handler_); in TEST_F()
125 WakelockManager::Get().SetOsCallouts(&os_callouts, handler_); in TEST_F()
152 WakelockManager::Get().SetOsCallouts(&os_callouts, handler_); in TEST_F()
|
| D | alarm_unittest.cc | 38 handler_ = new Handler(thread_); in SetUp()
39 alarm_ = std::make_shared<Alarm>(handler_); in SetUp()
44 handler_->Clear(); in TearDown()
45 delete handler_; in TearDown()
51 handler_->Post(common::BindOnce(fake_timerfd_advance, ms)); in fake_timer_advance()
55 return std::make_shared<Alarm>(handler_); in get_new_alarm()
61 Handler* handler_; member in bluetooth::os::__anon2ff704340111::AlarmTest
|
| D | repeating_alarm_unittest.cc | 37 handler_ = new Handler(thread_); in SetUp()
38 alarm_ = new RepeatingAlarm(handler_); in SetUp()
43 handler_->Clear(); in TearDown()
44 delete handler_; in TearDown()
84 handler_->Post(common::BindOnce(fake_timerfd_advance, ms)); in fake_timer_advance()
93 Handler* handler_; member in bluetooth::os::__anon482b86720111::RepeatingAlarmTest
|
| /packages/modules/Bluetooth/system/gd/security/ |
| D | pairing_handler_le_unittest.cc | 76 handler_ = new os::Handler(thread_); in SetUp()
83 handler_, common::Bind(&PairingHandlerUnitTest::L2CAP_SendSmp, common::Unretained(this))); in SetUp()
90 handler_->Clear(); in TearDown()
91 delete handler_; in TearDown()
130 os::Handler* handler_; member in bluetooth::security::PairingHandlerUnitTest
160 initial_informations.l2cap_handler = handler_; in TEST_F()
161 initial_informations.user_interface_handler = handler_; in TEST_F()
184 initial_informations.l2cap_handler = handler_; in TEST_F()
185 initial_informations.user_interface_handler = handler_; in TEST_F()
302 initial_informations_trsi.l2cap_handler = handler_; in TEST_F()
[all …]
|
| /packages/modules/Bluetooth/system/gd/neighbor/ |
| D | name_db.cc | 39 os::Handler* handler_; member
64 os::Handler* handler_; member
92 handler_->BindOnce([](hci::ErrorCode /* status */) {}), in ReadRemoteNameRequest()
93 handler_->BindOnce([&](uint64_t /* features */) { in ReadRemoteNameRequest()
96 handler_->BindOnceOn(this, &NameDbModule::impl::OnRemoteNameResponse, address)); in ReadRemoteNameRequest()
110 it.handler_->Call(std::move(it.callback_), address, status == hci::ErrorCode::SUCCESS); in OnRemoteNameResponse()
153 handler_ = module_.GetHandler(); in Start()
|