| /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, disabled_codecs=0):
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):
|
| /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 | 38 async fn pull_trans_id(events_rx: &mut UnboundedReceiver<MockCallbackEvents>) -> TransactionId { in pull_trans_id()
49 start_test(async { in test_read_characteristic_callback()
54 spawn_local(async move { in test_read_characteristic_callback()
72 start_test(async { in test_read_characteristic_response()
81 async move { datastore.read(TCB_IDX, HANDLE_1, OFFSET, BACKING_TYPE).await }, in test_read_characteristic_response()
94 start_test(async { in test_sequential_reads()
104 async move { datastore.read(TCB_IDX, HANDLE_1, OFFSET, BACKING_TYPE).await }, in test_sequential_reads()
114 async move { datastore.read(TCB_IDX, HANDLE_1, OFFSET, BACKING_TYPE).await }, in test_sequential_reads()
128 start_test(async { in test_concurrent_reads()
138 async move { datastore.read(TCB_IDX, HANDLE_1, OFFSET, BACKING_TYPE).await }, in test_concurrent_reads()
[all …]
|
| /packages/modules/Bluetooth/floss/pandora/server/ |
| D | hfp.py | 42 …async def EnableSlc(self, request: hfp_pb2.EnableSlcRequest, context: grpc.ServicerContext) -> emp…
48 async def EnableSlcAsHandsfree(self, request: hfp_pb2.EnableSlcAsHandsfreeRequest,
54 …async def DisableSlc(self, request: hfp_pb2.DisableSlcRequest, context: grpc.ServicerContext) -> e…
59 async def DisableSlcAsHandsfree(self, request: hfp_pb2.DisableSlcAsHandsfreeRequest,
65 async def DeclineCall(self, request: hfp_pb2.DeclineCallRequest,
71 async def DeclineCallAsHandsfree(self, request: hfp_pb2.DeclineCallAsHandsfreeRequest,
77 async def SetBatteryLevel(self, request: hfp_pb2.SetBatteryLevelRequest,
85 async def ConnectToAudioAsHandsfree(self, request: hfp_pb2.ConnectToAudioAsHandsfreeRequest,
91 async def DisconnectFromAudioAsHandsfree(
98 async def SetVoiceRecognition(self, request: hfp_pb2.SetVoiceRecognitionRequest,
[all …]
|
| D | a2dp.py | 47 async def OpenSource(self, request: a2dp_pb2.OpenSourceRequest,
87 async def OpenSink(self, request: a2dp_pb2.OpenSinkRequest,
94 async def WaitSource(self, request: a2dp_pb2.WaitSourceRequest,
132 async def WaitSink(self, request: a2dp_pb2.WaitSinkRequest,
139 async def IsSuspended(self, request: a2dp_pb2.IsSuspendedRequest,
151 …async def Start(self, request: a2dp_pb2.StartRequest, context: grpc.ServicerContext) -> a2dp_pb2.S…
176 async def Suspend(self, request: a2dp_pb2.SuspendRequest,
195 …async def Close(self, request: a2dp_pb2.CloseRequest, context: grpc.ServicerContext) -> a2dp_pb2.C…
227 async def GetAudioEncoding(self, request: a2dp_pb2.GetAudioEncodingRequest,
233 async def PlaybackAudio(self, request: AsyncIterator[a2dp_pb2.PlaybackAudioRequest],
[all …]
|
| /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()
227 block_on_locally(async { in test_regular_read_invoke()
232 spawn_local(async move { in test_regular_read_invoke()
[all …]
|
| /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 …]
|
| /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/tools/rootcanal/rust/src/lmp/procedure/ |
| D | features.rs | 20 pub async fn initiate(ctx: &impl Context, features_page: u8) -> u64 { in initiate()
36 pub async fn respond(ctx: &impl Context) { in respond()
51 async fn supported_on_both_page(ctx: &impl Context, page_number: u8, feature_mask: u64) -> bool { in supported_on_both_page()
54 let peer_supported = async move { in supported_on_both_page()
65 pub async fn supported_on_both_page1( in supported_on_both_page1()
72 pub async fn supported_on_both_page2( in supported_on_both_page2()
|
| /packages/modules/Bluetooth/system/gd/rust/linux/stack/src/ |
| D | bluetooth_qa.rs | 114 tokio::spawn(async move { in add_media_player()
120 tokio::spawn(async move { in rfcomm_send_msc()
126 tokio::spawn(async move { in fetch_discoverable_mode()
132 tokio::spawn(async move { in fetch_connectable()
138 tokio::spawn(async move { in set_connectable()
144 tokio::spawn(async move { in fetch_alias()
153 tokio::spawn(async move { in get_hid_report()
159 tokio::spawn(async move { in set_hid_report()
165 tokio::spawn(async move { in send_hid_data()
|
| /packages/modules/Bluetooth/system/gd/rust/linux/mgmt/src/ |
| D | powerd_suspend_manager.rs | 92 tokio::spawn(async move { in send_handle_suspend_readiness()
146 tokio::spawn(async move { in on_suspend_ready()
226 pub async fn init(&mut self) { in init()
235 tokio::spawn(async move { in init()
241 tokio::spawn(async move { in init()
258 tokio::spawn(async move { in init()
264 tokio::spawn(async move { in init()
282 tokio::spawn(async move { in init()
288 tokio::spawn(async move { in init()
313 tokio::spawn(async move { in init()
[all …]
|
| D | time.rs | 29 pub async fn expired(&self) { in expired()
62 runtime.block_on(async { in alarm_cancel_after_expired()
69 let ready_in_10_ms = async { in alarm_cancel_after_expired()
86 runtime.block_on(async { in alarm_clear_ready_after_expired()
90 let ready_in_10_ms = async { in alarm_clear_ready_after_expired()
|
| /packages/modules/Bluetooth/android/pandora/test/ |
| D | asha_test.py | 88 async def setup_test(self) -> None:
95 async def ref_advertise_asha(
115 … async def dut_scan_for_asha(self, dut_address_type: OwnAddressType, ear: Ear) -> ScanningResponse:
125 async for x in dut_scan
135 async def dut_connect_to_ref(
153 …async def is_device_connected(self, device: PandoraDevice, connection: Connection, timeout: float)…
210 …async def get_audio_data(self, ref_asha: AioAsha, connection: Connection, timeout: int) -> ByteStr…
214 async for data in captured_data:
225 async def generate_sine(self, connection: Connection) -> AsyncIterator[PlaybackAudioRequest]:
248 async def test_advertising_advertisement_data(
[all …]
|
| /packages/modules/Bluetooth/service/src/ |
| D | AdapterStateTest.kt | 24 import kotlinx.coroutines.async
78 val waiter = async { mState.waitForState(100.days, state) } in <lambda>()
89 async(start = CoroutineStart.UNDISPATCHED) { mState.waitForState(100.days, state0) } in <lambda>()
91 async(start = CoroutineStart.UNDISPATCHED) { mState.waitForState(100.days, state1) } in <lambda>()
93 async(start = CoroutineStart.UNDISPATCHED) { mState.waitForState(100.days, state2) } in <lambda>()
95 async(start = CoroutineStart.UNDISPATCHED) { mState.waitForState(100.days, -1) } in <lambda>()
115 async(start = CoroutineStart.UNDISPATCHED) { mState.waitForState(100.days, state0) } in <lambda>()
|
| /packages/modules/Bluetooth/tools/rootcanal/py/ |
| D | controller.py | 160 async def start(self):
162 async def timer():
194 async def receive_evt(self):
200 async def receive_iso(self):
206 async def expect_evt(self, expected_evt: hci.Event):
217 async def receive_ll(self):
247 async def asyncSetUp(self):
267 …async def expect_evt(self, expected_evt: typing.Union[hci.Event, type], timeout: int = 3) -> hci.E…
288 async def expect_cmd_complete(self, expected_evt: type, timeout: int = 3) -> hci.Event:
294 async def expect_iso(self, expected_iso: hci.Iso, timeout: int = 3):
[all …]
|
| /packages/modules/Bluetooth/system/gd/rust/common/src/ |
| D | time.rs | 59 pub async fn expired(&self) { in expired()
91 pub async fn tick(&mut self) { in tick()
120 runtime.block_on(async { in alarm_cancel_after_expired()
127 let ready_in_10_ms = async { in alarm_cancel_after_expired()
144 runtime.block_on(async { in alarm_clear_ready_after_expired()
149 let ready_in_10_ms = async { in alarm_clear_ready_after_expired()
163 runtime.block_on(async { in interval_schedule_and_then_drop()
|
| /packages/modules/DnsResolver/doh/network/ |
| D | driver.rs | 75 async fn build_connection( in build_connection()
89 pub async fn new( in new()
106 pub async fn drive(mut self) -> Result<()> { in drive()
124 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()
203 task::spawn(async move { in send_query()
|
| /packages/modules/Bluetooth/tools/rootcanal/scripts/ |
| D | controller_info.py | 46 async def connect(self, ip: str, port: int):
51 async def _read(self, reader):
70 async def send_cmd(self, cmd: hci.Command):
75 async def recv_evt(self) -> hci.Event:
81 async def expect_evt(self, expected_evt: type) -> hci.Event:
92 async def br_edr_properties(host: Host):
118 async def le_properties(host: Host):
163 async def run(tcp_port: int):
|
| /packages/modules/Bluetooth/pandora/server/bumble_experimental/ |
| D | gatt.py | 81 …async def ExchangeMTU(self, request: ExchangeMTURequest, context: grpc.ServicerContext) -> Exchang…
95 …async def WriteAttFromHandle(self, request: WriteRequest, context: grpc.ServicerContext) -> WriteR…
112 async def DiscoverServiceByUuid(self, request: DiscoverServiceByUuidRequest,
123 async def feed_service(service: ServiceProxy) -> None:
154 async def DiscoverServices(self, request: DiscoverServicesRequest,
165 async def feed_service(service: ServiceProxy) -> None:
197 …async def ClearCache(self, request: ClearCacheRequest, context: grpc.ServicerContext) -> ClearCach…
202 async def ReadCharacteristicFromHandle(self, request: ReadCharacteristicRequest,
221 async def ReadCharacteristicsFromUuid(self, request: ReadCharacteristicsFromUuidRequest,
248 async def ReadCharacteristicDescriptorFromHandle(
[all …]
|
| /packages/apps/Settings/tests/robotests/src/com/android/settings/enterprise/ |
| D | AdminGrantedPermissionsPreferenceControllerBaseTest.java | 31 protected AdminGrantedPermissionsPreferenceControllerBase createController(boolean async) { in createController() argument
32 return new AdminGrantedPermissionsPreferenceControllerBaseTestable(async); in createController()
38 AdminGrantedPermissionsPreferenceControllerBaseTestable(boolean async) { in AdminGrantedPermissionsPreferenceControllerBaseTestable() argument
40 async, mPermissions); in AdminGrantedPermissionsPreferenceControllerBaseTestable()
|
| /packages/apps/TvSettings/Settings/src/com/android/tv/settings/enterprise/ |
| D | PrivacySettingsEnterprisePreference.java | 66 public List<AbstractPreferenceController> createPreferenceControllers(boolean async) { in createPreferenceControllers() argument
74 mContext, async)); in createPreferenceControllers()
76 new AdminGrantedLocationPermissionsPreferenceController(mContext, async)); in createPreferenceControllers()
78 new AdminGrantedMicrophonePermissionPreferenceController(mContext, async)); in createPreferenceControllers()
80 mContext, async)); in createPreferenceControllers()
|