| /system/bt/gd/os/linux_generic/ |
| D | handler_unittest.cc | 37 handler_ = new Handler(thread_); in SetUp()
40 delete handler_; in TearDown()
44 Handler* handler_; member in bluetooth::os::__anon9a1419ef0111::HandlerTest
49 handler_->Clear(); in TEST_F()
63 handler_->Post(std::move(closure)); in TEST_F()
66 handler_->Clear(); in TEST_F()
75 handler_->Post(common::BindOnce( in TEST_F()
84 handler_->Post(common::BindOnce([]() { ASSERT_TRUE(false); })); in TEST_F()
86 handler_->Clear(); in TEST_F()
101 handler_->Clear(); in TEST_F()
[all …]
|
| D | queue.tpp | 22 ASSERT_LOG(enqueue_.handler_ == nullptr, "Enqueue is not unregistered");
23 ASSERT_LOG(dequeue_.handler_ == nullptr, "Dequeue is not unregistered");
29 ASSERT(enqueue_.handler_ == nullptr);
31 enqueue_.handler_ = handler;
32 enqueue_.reactable_ = enqueue_.handler_->thread_->GetReactor()->Register(
46 reactor = enqueue_.handler_->thread_->GetReactor();
47 wait_for_unregister = (!enqueue_.handler_->thread_->IsSameThread());
50 enqueue_.handler_ = nullptr;
61 ASSERT(dequeue_.handler_ == nullptr);
63 dequeue_.handler_ = handler;
[all …]
|
| D | alarm_unittest.cc | 34 handler_ = new Handler(thread_); in SetUp()
35 alarm_ = new Alarm(handler_); in SetUp()
40 handler_->Clear(); in TearDown()
41 delete handler_; in TearDown()
47 Handler* handler_; member in bluetooth::os::__anone9ebacde0111::AlarmTest
|
| /system/bt/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()
79 …queue_end_->RegisterDequeue(handler_, common::Bind(&Sender::dequeue_callback, common::Unretained(t… in try_register_dequeue()
86 handler_->Post( in dequeue_callback()
100 …unique<BasicModeDataController>(channel_id_, remote_channel_id_, queue_end_, handler_, scheduler_); in UpdateClassicConfiguration()
105 …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
|
| D | receiver.cc | 30 …: link_queue_up_end_(link_queue_up_end), handler_(handler), data_pipeline_manager_(data_pipeline_m… in Receiver()
31 ASSERT(link_queue_up_end_ != nullptr && handler_ != nullptr); in Receiver()
32 link_queue_up_end_->RegisterDequeue(handler_, in Receiver()
|
| D | scheduler_fifo.cc | 29 …ipeline_manager_(data_pipeline_manager), link_queue_up_end_(link_queue_up_end), handler_(handler) { in Fifo()
30 ASSERT(link_queue_up_end_ != nullptr && handler_ != nullptr); in Fifo()
72 link_queue_up_end_->RegisterEnqueue(handler_, in try_register_link_queue_enqueue()
|
| /system/bt/gd/ |
| D | stack_manager.cc | 37 handler_ = new Handler(management_thread_); in StartUp()
41 …handler_->Post(common::BindOnce(&StackManager::handle_start_up, common::Unretained(this), modules,… in StartUp()
58 …handler_->Post(common::BindOnce(&StackManager::handle_shut_down, common::Unretained(this), std::mo… in ShutDown()
63 handler_->Clear(); in ShutDown()
64 handler_->WaitUntilStopped(std::chrono::milliseconds(2000)); in ShutDown()
65 delete handler_; in ShutDown()
|
| D | module.cc | 34 ASSERT_LOG(handler_ != nullptr, "Can't get handler when it's not started"); in GetHandler()
35 return handler_; in GetHandler()
75 instance->handler_ = new Handler(thread); in set_registry_and_handler()
104 instance->second->handler_->Clear(); in StopAll()
105 instance->second->handler_->WaitUntilStopped(kModuleStopTimeout); in StopAll()
112 delete instance->second->handler_; in StopAll()
|
| /system/bt/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()
|
| /system/bt/gd/common/testing/ |
| D | wired_pair_of_bidi_queues.h | 41 down_buffer_b_.Enqueue(A_TO_B(std::move(down_thing)), handler_); in dequeue_callback_a()
48 down_buffer_a_.Enqueue(A_TO_B(std::move(down_thing)), handler_); in dequeue_callback_b()
51 os::Handler* handler_; variable
58 WiredPairOfBiDiQueues(os::Handler* handler) : handler_(handler) { in WiredPairOfBiDiQueues()
60 … handler_, common::Bind(&WiredPairOfBiDiQueues::dequeue_callback_a, common::Unretained(this))); in WiredPairOfBiDiQueues()
62 … handler_, common::Bind(&WiredPairOfBiDiQueues::dequeue_callback_b, common::Unretained(this))); in WiredPairOfBiDiQueues()
|
| /system/bt/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::__anon00f1d3110111::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()
|
| D | link_manager.cc | 38 pending_fixed_channel_connection.handler_->Post(common::BindOnce( in ConnectFixedChannelServices()
63 pending_fixed_channel_connection.handler_->Post(common::BindOnce( in ConnectFixedChannelServices()
174 : handler_(handler), link_manager_(link_manager), remote_(link->GetDevice().GetAddress()) {} in LinkSecurityInterfaceImpl()
181 handler_->CallOn(link_manager_, &LinkManager::handle_link_security_hold, remote_); in Hold()
185 handler_->CallOn(link_manager_, &LinkManager::handle_link_security_release, remote_); in Release()
189 handler_->CallOn(link_manager_, &LinkManager::handle_link_security_disconnect, remote_); in Disconnect()
193 … handler_->CallOn(link_manager_, &LinkManager::handle_link_security_ensure_authenticated, remote_); in EnsureAuthenticated()
196 os::Handler* handler_; member in bluetooth::l2cap::classic::internal::LinkSecurityInterfaceImpl
258 pending_fixed_channel_connection.handler_->Post(common::BindOnce( in OnConnectFail()
|
| /system/bt/gd/neighbor/ |
| D | page.cc | 56 os::Handler* handler_; member
113 handler_ = module_.GetHandler(); in Start()
116 … hci::ReadPageScanActivityBuilder::Create(), handler_->BindOnceOn(this, &impl::OnCommandComplete)); in Start()
119 hci::ReadPageScanTypeBuilder::Create(), handler_->BindOnceOn(this, &impl::OnCommandComplete)); in Start()
122 hci::ReadPageTimeoutBuilder::Create(), handler_->BindOnceOn(this, &impl::OnCommandComplete)); in Start()
133 handler_->BindOnceOn(this, &impl::OnCommandComplete)); in SetScanActivity()
136 … hci::ReadPageScanActivityBuilder::Create(), handler_->BindOnceOn(this, &impl::OnCommandComplete)); in SetScanActivity()
151 …hci::WritePageScanTypeBuilder::Create(scan_type), handler_->BindOnceOn(this, &impl::OnCommandCompl… in SetScanType()
154 hci::ReadPageScanTypeBuilder::Create(), handler_->BindOnceOn(this, &impl::OnCommandComplete)); in SetScanType()
160 …hci::WritePageTimeoutBuilder::Create(timeout), handler_->BindOnceOn(this, &impl::OnCommandComplete… in SetTimeout()
[all …]
|
| /system/bt/gd/hci/ |
| D | le_address_manager_test.cc | 148 handler_ = new Handler(thread_); in SetUp()
152 …common::Bind(&LeAddressManagerTest::enqueue_command, common::Unretained(this)), handler_, address,… in SetUp()
159 handler_->Post(common::BindOnce(&std::promise<void>::set_value, common::Unretained(&promise))); in sync_handler()
165 sync_handler(handler_); in TearDown()
168 handler_->Clear(); in TearDown()
169 delete handler_; in TearDown()
183 …handler_->BindOnce(&LeAddressManager::OnCommandComplete, common::Unretained(le_address_manager_))); in enqueue_command()
187 Handler* handler_; member in bluetooth::hci::LeAddressManagerTest
197 sync_handler(handler_); in TEST_F()
199 sync_handler(handler_); in TEST_F()
[all …]
|
| D | le_address_manager.cc | 17 handler_(handler), in LeAddressManager()
59 handler_->Post(common::BindOnce(enqueue_command_, std::move(packet))); in SetPrivacyPolicyForInitiatorAddress()
66 address_rotation_alarm_ = std::make_unique<os::Alarm>(handler_); in SetPrivacyPolicyForInitiatorAddress()
102 handler_->Call(enqueue_command_, std::move(packet)); in SetPrivacyPolicyForInitiatorAddressForTest()
109 address_rotation_alarm_ = std::make_unique<os::Alarm>(handler_); in SetPrivacyPolicyForInitiatorAddressForTest()
117 handler_->BindOnceOn(this, &LeAddressManager::register_client, callback).Invoke(); in Register()
130 handler_->BindOnceOn(this, &LeAddressManager::unregister_client, callback).Invoke(); in Unregister()
141 handler_->BindOnceOn(this, &LeAddressManager::ack_pause, callback).Invoke(); in AckPause()
145 handler_->BindOnceOn(this, &LeAddressManager::ack_resume, callback).Invoke(); in AckResume()
238 handler_->BindOnceOn(this, &LeAddressManager::resume_registered_clients).Invoke(); in on_le_set_random_address_complete()
[all …]
|
| /system/bt/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::__anon3d9865f90111::TestBidiQueueEnd
|
| /system/bt/gd/os/fuzz/ |
| D | fuzz_inject_queue.h | 28 FuzzInjectQueue(IQueueEnqueue<T>* queue, Handler* handler) : handler_(handler) { in FuzzInjectQueue()
36 buffer_->Enqueue(std::move(data), handler_); in Inject()
41 Handler* handler_; variable
|
| D | dev_null_queue.h | 29 DevNullQueue(IQueueDequeue<T>* queue, Handler* handler) : queue_(queue), handler_(handler) {} in DevNullQueue()
33 queue_->RegisterDequeue(handler_, common::Bind(&DevNullQueue::Dump, common::Unretained(this))); in Start()
46 Handler* handler_; variable
|
| /system/bt/gd/os/ |
| 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()
|
| 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()
|
| /system/bt/gd/l2cap/le/internal/ |
| D | signalling_manager.cc | 41 : handler_(handler), link_(link), data_pipeline_manager_(data_pipeline_manager), in LeSignallingManager()
43 ASSERT(handler_ != nullptr); in LeSignallingManager()
48 handler_, common::Bind(&LeSignallingManager::on_incoming_packet, common::Unretained(this))); in LeSignallingManager()
63 …handler_->BindOnceOn(this, &LeSignallingManager::on_security_result_for_outgoing, psm, local_cid, … in SendConnectionRequest()
104 enqueue_buffer_->Enqueue(std::move(builder), handler_); in SendConnectionParameterUpdateResponse()
110 enqueue_buffer_->Enqueue(std::move(builder), handler_); in SendCredit()
139 enqueue_buffer_->Enqueue(std::move(builder), handler_); in OnConnectionParameterUpdateRequest()
147 enqueue_buffer_->Enqueue(std::move(builder), handler_); in OnConnectionParameterUpdateRequest()
210 … handler_->BindOnceOn(this, &LeSignallingManager::on_security_result_for_incoming, psm, pending)); in OnConnectionRequest()
261 auto user_channel = std::make_unique<DynamicChannel>(new_channel, handler_, link_); in on_security_result_for_incoming()
[all …]
|
| /system/bt/gd/security/ |
| D | pairing_handler_le_unittest.cc | 73 handler_ = new os::Handler(thread_); in SetUp()
80 handler_, common::Bind(&PairingHandlerUnitTest::L2CAP_SendSmp, common::Unretained(this))); in SetUp()
87 handler_->Clear(); in TearDown()
88 delete handler_; in TearDown()
127 os::Handler* handler_; member in bluetooth::security::PairingHandlerUnitTest
154 initial_informations.l2cap_handler = handler_; in TEST_F()
155 initial_informations.user_interface_handler = handler_; in TEST_F()
178 initial_informations.l2cap_handler = handler_; in TEST_F()
179 initial_informations.user_interface_handler = handler_; in TEST_F()
293 initial_informations_trsi.l2cap_handler = handler_; in TEST_F()
[all …]
|