| /system/bt/gd/os/linux_generic/ |
| D | handler_unittest.cc | 36 handler_ = new Handler(thread_); in SetUp()
39 delete handler_; in TearDown()
43 Handler* handler_; member in bluetooth::os::__anondb8435da0111::HandlerTest
48 handler_->Clear(); in TEST_F()
61 handler_->Post(std::move(closure)); in TEST_F()
64 handler_->Clear(); in TEST_F()
73 handler_->Post(common::BindOnce( in TEST_F()
80 handler_->Post(common::BindOnce([]() { ASSERT_TRUE(false); })); in TEST_F()
82 handler_->Clear(); in TEST_F()
97 handler_->Clear(); in TEST_F()
[all …]
|
| D | queue.tpp | 22 ASSERT(enqueue_.handler_ == nullptr);
23 ASSERT(dequeue_.handler_ == nullptr);
29 ASSERT(enqueue_.handler_ == nullptr);
31 enqueue_.handler_ = handler;
32 enqueue_.reactable_ = enqueue_.handler_->thread_->GetReactor()->Register(
42 enqueue_.handler_->thread_->GetReactor()->Unregister(enqueue_.reactable_);
44 enqueue_.handler_ = nullptr;
50 ASSERT(dequeue_.handler_ == nullptr);
52 dequeue_.handler_ = handler;
53 …dequeue_.reactable_ = dequeue_.handler_->thread_->GetReactor()->Register(dequeue_.reactive_semapho…
[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::__anonce3dd2090111::AlarmTest
|
| D | repeating_alarm_unittest.cc | 34 handler_ = new Handler(thread_); in SetUp()
35 alarm_ = new RepeatingAlarm(handler_); in SetUp()
40 handler_->Clear(); in TearDown()
41 delete handler_; in TearDown()
76 Handler* handler_; member in bluetooth::os::__anon293962870111::RepeatingAlarmTest
|
| D | repeating_alarm.cc | 36 RepeatingAlarm::RepeatingAlarm(Handler* handler) : handler_(handler), fd_(timerfd_create(ALARM_CLOC… in RepeatingAlarm()
39 token_ = handler_->thread_->GetReactor()->Register( in RepeatingAlarm()
44 handler_->thread_->GetReactor()->Unregister(token_); in ~RepeatingAlarm()
|
| /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()
98 …unique<BasicModeDataController>(channel_id_, remote_channel_id_, queue_end_, handler_, scheduler_); in UpdateClassicConfiguration()
103 …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()
50 …new NiceMock<MockLink>(handler_, mock_parameter_provider_, std::make_unique<NiceMock<MockAclConnec… 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()
69 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(20)); 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()
70 instance->handler_ = new Handler(thread); in set_registry_and_handler()
98 instance->second->handler_->Clear(); in StopAll()
99 instance->second->handler_->WaitUntilStopped(kModuleStopTimeout); in StopAll()
102 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/l2cap/classic/internal/ |
| D | link_test.cc | 64 …handler_, common::Bind(&L2capClassicLinkTest::OnDequeueCallbackForTest, common::Unretained(this))); in EnqueueCallbackForTest()
74 handler_ = new os::Handler(thread_); in SetUp()
89 handler_->Clear(); in TearDown()
90 delete handler_; in TearDown()
96 os::Handler* handler_ = nullptr; member in bluetooth::l2cap::classic::internal::__anon6f889d9c0111::L2capClassicLinkTest
117 .handler_ = 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/hci/ |
| D | acl_manager.cc | 65 : address_with_type_(address_with_type), handler_(handler) {} in acl_connection()
68 os::Handler* handler_; member
144 …handler_, common::Bind(&AclManager::acl_connection::on_incoming_data_ready, common::Unretained(thi… in on_incoming_packet()
158 handler_ = acl_manager_.GetHandler(); in Start()
164 common::Bind(&impl::incoming_acl_credits, common::Unretained(this)), handler_); in Start()
170 …handler_, common::Bind(&impl::dequeue_and_route_acl_packet_to_connection, common::Unretained(this)… in Start()
172 … Bind(&impl::on_connection_complete, common::Unretained(this)), handler_); in Start()
174 … Bind(&impl::on_disconnection_complete, common::Unretained(this)), handler_); in Start()
176 … Bind(&impl::on_incoming_connection, common::Unretained(this)), handler_); in Start()
178 … Bind(&impl::on_le_connection_complete, common::Unretained(this)), handler_); in Start()
[all …]
|
| /system/bt/gd/common/ |
| D | bidi_queue_unittest.cc | 65 : handler_(handler), end_(end) {} in TestBidiQueueEnd()
68 handler_->Clear(); in ~TestBidiQueueEnd()
73 …handler_->Post(BindOnce(&TestBidiQueueEnd<TA, TB>::handle_send, common::Unretained(this), common::… in Send()
80 handler_->Post( in Receive()
87 …end_->RegisterEnqueue(handler_, Bind(&TestBidiQueueEnd<TA, TB>::handle_register_enqueue, common::U… in handle_send()
98 …end_->RegisterDequeue(handler_, Bind(&TestBidiQueueEnd<TA, TB>::handle_register_dequeue, common::U… in handle_receive()
108 Handler* handler_; member in bluetooth::common::__anonecf8e4440111::TestBidiQueueEnd
|
| /system/bt/gd/neighbor/ |
| D | page.cc | 55 os::Handler* handler_; member
112 handler_ = module_.GetHandler(); in Start()
115 … common::BindOnce(&impl::OnCommandComplete, common::Unretained(this)), handler_); in Start()
118 … common::BindOnce(&impl::OnCommandComplete, common::Unretained(this)), handler_); in Start()
121 … common::BindOnce(&impl::OnCommandComplete, common::Unretained(this)), handler_); in Start()
131 … common::BindOnce(&impl::OnCommandComplete, common::Unretained(this)), handler_); in SetScanActivity()
134 … common::BindOnce(&impl::OnCommandComplete, common::Unretained(this)), handler_); in SetScanActivity()
145 … common::BindOnce(&impl::OnCommandComplete, common::Unretained(this)), handler_); in SetScanType()
148 … common::BindOnce(&impl::OnCommandComplete, common::Unretained(this)), handler_); in SetScanType()
154 … common::BindOnce(&impl::OnCommandComplete, common::Unretained(this)), handler_); in SetTimeout()
[all …]
|
| D | discoverability.cc | 54 os::Handler* handler_; member
95 … common::BindOnce(&impl::OnCommandComplete, common::Unretained(this)), handler_); in StartDiscoverability()
97 … common::BindOnce(&impl::OnCommandComplete, common::Unretained(this)), handler_); in StartDiscoverability()
116 handler_ = module_.GetHandler(); in Start()
119 … common::BindOnce(&impl::OnCommandComplete, common::Unretained(this)), handler_); in Start()
122 … common::BindOnce(&impl::OnCommandComplete, common::Unretained(this)), handler_); in Start()
|
| /system/bt/gd/os/ |
| D | thread_benchmark.cc | 65 handler_ = std::make_unique<Handler>(thread_.get()); in SetUp()
68 handler_ = nullptr; in TearDown()
74 std::unique_ptr<Handler> handler_; member in BM_ReactorThread
84 handler_->Post(BindOnce(&BM_ReactorThread_batch_enque_dequeue_Benchmark::callback_batch, in BENCHMARK_DEFINE_F()
105 handler_->Post( in BENCHMARK_DEFINE_F()
|
| D | queue_benchmark.cc | 61 : count_(count), handler_(handler), queue_(queue), promise_(promise) {} in TestEnqueueEnd()
64 …handler_->Post(common::BindOnce(&TestEnqueueEnd::handle_register_enqueue, common::Unretained(this)… in RegisterEnqueue()
98 Handler* handler_; member in bluetooth::os::TestEnqueueEnd
104 …queue_->RegisterEnqueue(handler_, common::Bind(&TestEnqueueEnd::EnqueueCallbackForTest, common::Un… in handle_register_enqueue()
111 : count_(count), handler_(handler), queue_(queue), promise_(promise) {} in TestDequeueEnd()
114 …handler_->Post(common::BindOnce(&TestDequeueEnd::handle_register_dequeue, common::Unretained(this)… in RegisterDequeue()
132 Handler* handler_; member in bluetooth::os::TestDequeueEnd
137 …queue_->RegisterDequeue(handler_, common::Bind(&TestDequeueEnd::DequeueCallbackForTest, common::Un… in handle_register_dequeue()
|
| D | alarm_benchmark.cc | 40 handler_ = std::make_unique<Handler>(thread_.get()); in SetUp()
41 alarm_ = std::make_unique<Alarm>(handler_.get()); in SetUp()
42 repeating_alarm_ = std::make_unique<RepeatingAlarm>(handler_.get()); in SetUp()
54 handler_ = nullptr; in TearDown()
83 std::unique_ptr<Handler> handler_; member in BM_ReactableAlarm
|
| /system/bt/gd/security/ |
| D | pairing_handler_le_unittest.cc | 83 handler_ = new os::Handler(thread_); in SetUp()
90 handler_, common::Bind(&PairingHandlerUnitTest::L2CAP_SendSmp, common::Unretained(this))); in SetUp()
97 handler_->Clear(); in TearDown()
98 delete handler_; in TearDown()
116 os::Handler* handler_; member in bluetooth::security::PairingHandlerUnitTest
141 initial_informations.l2cap_handler = handler_; in TEST_F()
142 initial_informations.user_interface_handler = handler_; in TEST_F()
163 initial_informations.l2cap_handler = handler_; in TEST_F()
164 initial_informations.user_interface_handler = handler_; in TEST_F()
274 initial_informations_trsi.l2cap_handler = handler_; in TEST_F()
[all …]
|
| /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()
47 handler_, common::Bind(&LeSignallingManager::on_incoming_packet, common::Unretained(this))); in LeSignallingManager()
87 enqueue_buffer_->Enqueue(std::move(builder), handler_); in SendConnectionParameterUpdateResponse()
93 enqueue_buffer_->Enqueue(std::move(builder), handler_); in SendCredit()
171 auto user_channel = std::make_unique<DynamicChannel>(new_channel, handler_); in OnConnectionRequest()
206 …:unique_ptr<DynamicChannel> user_channel = std::make_unique<DynamicChannel>(new_channel, handler_); in OnConnectionResponse()
221 enqueue_buffer_->Enqueue(std::move(builder), handler_); in OnDisconnectionRequest()
354 enqueue_buffer_->Enqueue(std::move(builder), handler_); in on_incoming_packet()
364 enqueue_buffer_->Enqueue(std::move(builder), handler_); in send_connection_response()
[all …]
|