| /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::__anon00d4f5b60111::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::__anon8d64eae50111::AlarmTest
|
| 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()
|
| /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()
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
|
| 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()
|
| /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/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
|
| /system/bt/gd/ |
| D | stack_manager.cc | 42 handler_ = new Handler(management_thread_); in StartUp()
48 …handler_->Post(common::BindOnce(&StackManager::handle_start_up, common::Unretained(this), modules,… in StartUp()
77 …handler_->Post(common::BindOnce(&StackManager::handle_shut_down, common::Unretained(this), std::mo… in ShutDown()
89 handler_->Clear(); in ShutDown()
90 handler_->WaitUntilStopped(std::chrono::milliseconds(2000)); in ShutDown()
91 delete handler_; in ShutDown()
|
| /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::__anon1392d1f80111::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()
|
| /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 …]
|
| D | discoverability.cc | 55 os::Handler* handler_; member
96 …hci::WriteCurrentIacLapBuilder::Create(laps), handler_->BindOnceOn(this, &impl::OnCommandComplete)… in StartDiscoverability()
98 … hci::ReadCurrentIacLapBuilder::Create(), handler_->BindOnceOn(this, &impl::OnCommandComplete)); in StartDiscoverability()
117 handler_ = module_.GetHandler(); in Start()
120 … hci::ReadCurrentIacLapBuilder::Create(), handler_->BindOnceOn(this, &impl::OnCommandComplete)); in Start()
123 …hci::ReadNumberOfSupportedIacBuilder::Create(), handler_->BindOnceOn(this, &impl::OnCommandComplet… in Start()
|
| /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::__anon5cfa03a00111::TestBidiQueueEnd
|
| /system/bt/gd/hci/ |
| D | le_address_manager_test.cc | 156 handler_ = new Handler(thread_); in SetUp()
160 …common::Bind(&LeAddressManagerTest::enqueue_command, common::Unretained(this)), handler_, address,… in SetUp()
167 handler_->Post(common::BindOnce(&std::promise<void>::set_value, common::Unretained(&promise))); in sync_handler()
173 sync_handler(handler_); in TearDown()
176 handler_->Clear(); in TearDown()
177 delete handler_; in TearDown()
191 …handler_->BindOnce(&LeAddressManager::OnCommandComplete, common::Unretained(le_address_manager_))); in enqueue_command()
195 Handler* handler_; member in bluetooth::hci::LeAddressManagerTest
205 sync_handler(handler_); in TEST_F()
207 sync_handler(handler_); in TEST_F()
[all …]
|
| D | le_address_manager.cc | 34 handler_(handler), in LeAddressManager()
61 handler_->BindOnceOn(this, &LeAddressManager::resume_registered_clients).Invoke(); in SetPrivacyPolicyForInitiatorAddress()
77 handler_->Post(common::BindOnce(enqueue_command_, std::move(packet))); in SetPrivacyPolicyForInitiatorAddress()
85 address_rotation_alarm_ = std::make_unique<os::Alarm>(handler_); in SetPrivacyPolicyForInitiatorAddress()
122 handler_->Call(enqueue_command_, std::move(packet)); in SetPrivacyPolicyForInitiatorAddressForTest()
129 address_rotation_alarm_ = std::make_unique<os::Alarm>(handler_); in SetPrivacyPolicyForInitiatorAddressForTest()
140 handler_->BindOnceOn(this, &LeAddressManager::register_client, callback).Invoke(); in Register()
164 handler_->BindOnceOn(this, &LeAddressManager::unregister_client, callback).Invoke(); in Unregister()
175 handler_->BindOnceOn(this, &LeAddressManager::ack_pause, callback).Invoke(); in AckPause()
179 handler_->BindOnceOn(this, &LeAddressManager::ack_resume, callback).Invoke(); in AckResume()
[all …]
|
| /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()
146 enqueue_buffer_->Enqueue(std::move(builder), handler_); in OnConnectionParameterUpdateRequest()
154 enqueue_buffer_->Enqueue(std::move(builder), handler_); in OnConnectionParameterUpdateRequest()
211 … handler_->BindOnceOn(this, &LeSignallingManager::on_security_result_for_incoming, psm, pending)); in OnConnectionRequest()
263 auto user_channel = std::make_unique<DynamicChannel>(new_channel, handler_, link_, actual_mtu); 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
157 initial_informations.l2cap_handler = handler_; in TEST_F()
158 initial_informations.user_interface_handler = handler_; in TEST_F()
181 initial_informations.l2cap_handler = handler_; in TEST_F()
182 initial_informations.user_interface_handler = handler_; in TEST_F()
299 initial_informations_trsi.l2cap_handler = handler_; in TEST_F()
[all …]
|