| /packages/modules/Bluetooth/system/blueberry/tests/topshim/lib/ |
| D | gatt_client.py | 44 async def close(self):
54 async def register_advertiser(self):
59 async def unregister_advertiser(self, advertiser_id):
66 async def get_own_address(self):
71 async def set_parameters(self):
76 async def set_data(self):
81 async def advertising_enable(self):
86 async def advertising_disable(self):
91 async def set_periodic_advertising_parameters(self):
96 async def set_periodic_advertising_data(self):
[all …]
|
| D | adapter_client.py | 43 async def close(self):
51 async def __get_next_event(self, event, future):
64 async def _listen_for_event(self, event):
76 async def _verify_adapter_started(self):
81 async def toggle_stack(self, is_start=True):
86 async def enable_inquiry_scan(self):
91 async def enable_page_scan(self):
96 async def disable_page_scan(self):
101 async def clear_event_filter(self):
104 async def clear_event_mask(self):
[all …]
|
| D | hfp_client.py | 42 async def close(self):
52 async def start_slc(self, address):
59 async def stop_slc(self, address):
66 async def connect_audio(self, address, is_sco_offload_enabled=False, force_cvsd=False):
74 async def disconnect_audio(self, address):
80 async def set_volume(self, address, volume):
86 async def wait_for_hfp_connection_state_change(self):
89 async def __get_next_event(self, event, future):
102 async def _listen_for_event(self, event):
|
| D | hf_client_client.py | 35 async def close(self):
38 async def start_slc(self, address):
44 async def stop_slc(self, address):
50 async def connect_audio(self, address):
56 async def disconnect_audio(self, address):
|
| D | topshim_device.py | 82 async def __le_rand_wrapper(self, async_fn):
98 async def close(self):
120 async def __discovery_mode_waiter(self, f):
184 async def __bond_change_waiter(self, f):
199 async def waiter(f):
209 async def waiter(f):
219 async def waiter(f):
233 async def waiter(f):
256 async def __hfp_connection_state_waiter(self, f):
|
| /packages/modules/Bluetooth/system/gd/rust/topshim/facade/src/ |
| D | gatt_service.rs | 175 ctx.spawn(async move { in register_advertiser()
183 ctx.spawn(async move { in unregister_advertiser()
191 ctx.spawn(async move { in get_own_address()
199 ctx.spawn(async move { in set_parameters()
207 ctx.spawn(async move { in set_data()
215 ctx.spawn(async move { in advertising_enable()
223 ctx.spawn(async move { in advertising_disable()
231 ctx.spawn(async move { in start_advertising()
248 ctx.spawn(async move { in start_advertising_set()
262 ctx.spawn(async move { in set_periodic_advertising_parameters()
[all …]
|
| D | adapter_service.rs | 116 ctx.spawn(async move { in fetch_events()
233 ctx.spawn(async move { in toggle_stack()
259 ctx.spawn(async move { in set_discovery_mode()
266 ctx.spawn(async move { in clear_event_filter()
273 ctx.spawn(async move { in clear_event_mask()
285 ctx.spawn(async move { in clear_filter_accept_list()
292 ctx.spawn(async move { in disconnect_all_acls()
299 ctx.spawn(async move { in le_rand()
306 ctx.spawn(async move { in allow_wake_by_hid()
318 ctx.spawn(async move { in restore_filter_accept_list()
[all …]
|
| /packages/modules/Bluetooth/system/rust/tests/ |
| D | gatt_callbacks_test.rs | 39 async fn pull_trans_id(events_rx: &mut UnboundedReceiver<MockCallbackEvents>) -> TransactionId { in pull_trans_id()
50 start_test(async { in test_read_characteristic_callback()
55 spawn_local(async move { in test_read_characteristic_callback()
73 start_test(async { in test_read_characteristic_response()
82 async move { datastore.read(TCB_IDX, HANDLE_1, OFFSET, BACKING_TYPE).await }, in test_read_characteristic_response()
95 start_test(async { in test_sequential_reads()
105 async move { datastore.read(TCB_IDX, HANDLE_1, OFFSET, BACKING_TYPE).await }, in test_sequential_reads()
115 async move { datastore.read(TCB_IDX, HANDLE_1, OFFSET, BACKING_TYPE).await }, in test_sequential_reads()
129 start_test(async { in test_concurrent_reads()
139 async move { datastore.read(TCB_IDX, HANDLE_1, OFFSET, BACKING_TYPE).await }, in test_concurrent_reads()
[all …]
|
| /packages/modules/Bluetooth/system/gd/rust/common/src/ |
| D | parameter_provider.rs | 39 pub async fn config_file_path(&self) -> String { in config_file_path()
47 pub async fn override_config_file_path(&mut self, path: &str) { in override_config_file_path()
54 pub async fn snoop_log_file_path(&mut self) -> String { in snoop_log_file_path()
62 pub async fn override_snoop_file_path(&mut self, path: &str) { in override_snoop_file_path()
69 pub async fn snooz_log_file_path(&mut self) -> String { in snooz_log_file_path()
77 pub async fn override_snooz_file_path(&mut self, path: &str) { in override_snooz_file_path()
84 pub async fn get_bt_keystore_interface(&mut self) -> *mut BluetoothKeystoreInterface { in get_bt_keystore_interface()
92 pub async fn set_bt_keystore_interface( in set_bt_keystore_interface()
102 pub async fn is_common_criteria_mode(&self) -> bool { in is_common_criteria_mode()
110 pub async fn set_common_criteria_mode(&mut self, enable: bool) { in set_common_criteria_mode()
[all …]
|
| D | time.rs | 34 pub async fn expired(&self) { in expired()
66 pub async fn tick(&mut self) { in tick()
95 runtime.block_on(async { in alarm_cancel_after_expired()
102 let ready_in_10_ms = async { in alarm_cancel_after_expired()
119 runtime.block_on(async { in alarm_clear_ready_after_expired()
124 let ready_in_10_ms = async { in alarm_clear_ready_after_expired()
138 runtime.block_on(async { in interval_schedule_and_then_drop()
|
| /packages/modules/Bluetooth/system/rust/src/gatt/ |
| D | callbacks.rs | 99 async fn read( in read()
108 async fn write( in write()
128 async fn execute( in execute()
140 async fn read( in read()
148 async fn write( in write()
160 async fn read( in read()
175 async fn write( in write()
204 async fn execute(&self, _: TransportIndex, _: TransactionDecision) -> Result<(), AttErrorCode> { in execute()
231 block_on_locally(async { in test_regular_read_invoke()
236 spawn_local(async move { in test_regular_read_invoke()
[all …]
|
| D | mtu.rs | 61 async move { pending_snapshot.await.as_deref().cloned() } in snapshot()
144 block_on_locally(async move { in test_mtu_blocking_snapshot_during_client_negotiation()
162 block_on_locally(async move { in test_receive_mtu_request()
178 block_on_locally(async move { in test_client_then_server_negotiation()
198 block_on_locally(async move { in test_server_negotiation_then_pending_client_default_value()
216 block_on_locally(async move { in test_server_negotiation_then_pending_client_finalized_value()
236 block_on_locally(async move { in test_mtu_dropped_while_pending()
|
| /packages/modules/Bluetooth/system/rust/src/gatt/server/ |
| D | indication_handler.rs | 52 pub async fn send( in send()
169 block_on_locally(async move { in test_indication_sent()
176 spawn_local(async move { in test_indication_sent()
201 block_on_locally(async move { in test_invalid_handle()
218 block_on_locally(async move { in test_unsupported_permission()
235 block_on_locally(async move { in test_confirmation_handled()
242 let pending_result = spawn_local(async move { in test_confirmation_handled()
261 block_on_locally(async move { in test_unblock_on_disconnect()
268 let pending_result = spawn_local(async move { in test_unblock_on_disconnect()
291 block_on_locally(async move { in test_spurious_confirmations()
[all …]
|
| D | att_server_bearer.rs | 128 async move { in send_indication()
164 let task = spawn_local(async move { in handle_request()
283 block_on_locally(async { in test_single_transaction()
298 block_on_locally(async { in test_sequential_transactions()
359 block_on_locally(async { in test_concurrent_transaction_failure()
395 block_on_locally(async { in test_indication_confirmation()
419 block_on_locally(async { in test_sequential_indications()
460 block_on_locally(async { in test_queued_indications_only_one_sent()
485 block_on_locally(async { in test_queued_indications_dequeue_second()
521 block_on_locally(async { in test_queued_indications_complete_both()
[all …]
|
| /packages/modules/Bluetooth/system/rust/src/connection/ |
| D | attempt_manager.rs | 102 f: async move { in register_direct_connection()
216 block_on_locally(async { in test_direct_connection()
233 block_on_locally(async { in test_cancel_direct_connection()
251 block_on_locally(async { in test_multiple_direct_connections()
266 block_on_locally(async { in test_two_direct_connection_cancel_one()
298 block_on_locally(async { in test_background_connection()
315 block_on_locally(async { in test_reject_duplicate_direct_connection()
330 block_on_locally(async { in test_reject_duplicate_background_connection()
345 block_on_locally(async { in test_resolved_direct_connection()
361 block_on_locally(async { in test_failed_direct_connection()
[all …]
|
| /packages/modules/Bluetooth/android/pandora/test/ |
| D | classic_ssp_test.py | 56 async def setup_class(self) -> None:
79 async def setup_test(self) -> None: # pytype: disable=wrong-arg-types
84 async def test_success_initiate_connection_initiate_pairing(
93 async def connect_and_pair() -> Tuple[SecureResponse, WaitSecurityResponse]:
112 async def test_success_initiate_connection_accept_pairing(
124 async def connect_and_pair() -> Tuple[SecureResponse, WaitSecurityResponse]:
143 async def test_success_accept_connection_initiate_pairing(
152 async def connect_and_pair() -> Tuple[SecureResponse, WaitSecurityResponse]:
171 async def test_success_accept_connection_accept_pairing(
180 async def connect_and_pair() -> Tuple[SecureResponse, WaitSecurityResponse]:
[all …]
|
| D | asha_test.py | 82 async def setup_test(self) -> None:
89 async def ref_advertise_asha(
109 … async def dut_scan_for_asha(self, dut_address_type: OwnAddressType, ear: Ear) -> ScanningResponse:
119 async for x in dut_scan
129 async def dut_connect_to_ref(
147 …async def is_device_connected(self, device: PandoraDevice, connection: Connection, timeout: float)…
209 async def test_advertising_advertisement_data(
235 async def test_advertising_scan_response(self) -> None:
269 async def test_pairing(
302 async def test_pairing_dual_device(
[all …]
|
| /packages/modules/Bluetooth/system/gd/rust/stack/src/ |
| D | lib.rs | 30 pub async fn new(rt: Arc<Runtime>) -> Self { in new()
38 pub async fn set_rootcanal_port(&self, port: Option<u16>) { in set_rootcanal_port()
45 pub async fn use_default_snoop(&self) { in use_default_snoop()
50 pub async fn configure_snoop(&self, path: Option<String>) { in configure_snoop()
60 pub async fn get<T: 'static + Clone + Send + Sync + Stoppable>(&self) -> T { in get()
70 pub async fn get_grpc<T: 'static + Clone + Send + Sync + GrpcFacade + Stoppable>( in get_grpc()
77 pub async fn stop(&mut self) { in stop()
|
| /packages/modules/Bluetooth/tools/rootcanal/rust/src/lmp/procedure/ |
| D | features.rs | 8 pub async fn initiate(ctx: &impl Context, features_page: u8) -> u64 { in initiate()
24 pub async fn respond(ctx: &impl Context) { in respond()
39 async fn supported_on_both_page(ctx: &impl Context, page_number: u8, feature_mask: u64) -> bool { in supported_on_both_page()
42 let peer_supported = async move { in supported_on_both_page()
53 pub async fn supported_on_both_page1( in supported_on_both_page1()
60 pub async fn supported_on_both_page2( in supported_on_both_page2()
|
| /packages/modules/Bluetooth/system/gd/rust/linux/mgmt/src/ |
| D | powerd_suspend_manager.rs | 92 tokio::spawn(async move { in send_handle_suspend_readiness()
202 pub async fn init(&mut self) { in init()
211 tokio::spawn(async move { in init()
217 tokio::spawn(async move { in init()
234 tokio::spawn(async move { in init()
240 tokio::spawn(async move { in init()
258 tokio::spawn(async move { in init()
264 tokio::spawn(async move { in init()
289 tokio::spawn(async move { in init()
322 tokio::spawn(async move { in init()
[all …]
|
| /packages/modules/DnsResolver/doh/network/ |
| D | driver.rs | 74 async fn build_connection( in build_connection()
96 pub async fn new( in new()
112 pub async fn drive(mut self) -> Result<()> { in drive()
130 async fn probe(&mut self, probe_timeout: Duration) -> Result<()> { in probe()
147 async fn force_probe(&mut self, probe_timeout: Duration) -> Result<()> { in force_probe()
152 let request = async { in force_probe()
180 async fn send_query(&mut self, query: Query) -> Result<()> { in send_query()
197 task::spawn(async move { in send_query()
|
| /packages/modules/Bluetooth/pandora/server/bumble_experimental/ |
| D | gatt.py | 71 …async def ExchangeMTU(self, request: ExchangeMTURequest, context: grpc.ServicerContext) -> Exchang…
85 …async def WriteAttFromHandle(self, request: WriteRequest, context: grpc.ServicerContext) -> WriteR…
102 async def DiscoverServiceByUuid(
114 async def feed_service(service: ServiceProxy) -> None:
150 async def DiscoverServices(
162 async def feed_service(service: ServiceProxy) -> None:
199 …async def ClearCache(self, request: ClearCacheRequest, context: grpc.ServicerContext) -> ClearCach…
204 async def ReadCharacteristicFromHandle(
224 async def ReadCharacteristicsFromUuid(
255 async def ReadCharacteristicDescriptorFromHandle(
|
| /packages/modules/Bluetooth/system/gd/rust/stack/src/hci/ |
| D | mod.rs | 57 async fn provide_hci(control: ControlHal, rt: Arc<Runtime>) -> Hci { in provide_hci()
97 pub async fn send(&mut self, cmd: CommandPacket) -> Result<EventPacket> { in send()
113 pub async fn send<T: Into<CommandPacket> + CommandExpectations>( in send()
130 pub async fn register(&mut self, code: EventCode, sender: Sender<EventPacket>) { in register()
149 pub async fn unregister(&mut self, code: EventCode) { in unregister()
154 pub async fn register_le(&mut self, code: SubeventCode, sender: Sender<LeMetaEventPacket>) { in register_le()
163 pub async fn unregister_le(&mut self, code: SubeventCode) { in unregister_le()
168 async fn dispatch( in dispatch()
248 async fn consume(evt_rx: &Arc<Mutex<Receiver<EventPacket>>>) -> Option<EventPacket> { in consume()
|
| D | facade.rs | 28 async fn provide_facade( in provide_facade()
73 pub async fn register_event(&mut self, code: u32) { in register_event()
78 pub async fn register_le_event(&mut self, code: u32) { in register_le_event()
96 ctx.spawn(async move { in send_command()
105 ctx.spawn(async move { in request_event()
118 ctx.spawn(async move { in request_le_subevent()
126 ctx.spawn(async move { in send_acl()
|
| /packages/modules/Bluetooth/system/rust/src/ |
| D | connection.rs | 190 Ok(async move { in direct_connection()
279 block_on_locally(async { in test_single_direct_connection()
296 block_on_locally(async { in test_failed_direct_connection()
312 block_on_locally(async { in test_single_background_connection()
329 block_on_locally(async { in test_resolved_connection()
345 block_on_locally(async { in test_resolved_background_connection()
361 block_on_locally(async { in test_resolved_direct_connection_after_disconnect()
378 block_on_locally(async { in test_resolved_background_connection_after_disconnect()
395 block_on_locally(async { in test_direct_connection_timeout()
414 block_on_locally(async { in test_stacked_direct_connections_timeout()
|