| /packages/modules/Bluetooth/system/gd/rust/linux/client/src/ |
| D | command_handler.rs | 605 .as_mut() in cmd_adapter()
622 .as_mut() in cmd_adapter()
635 .as_mut() in cmd_adapter()
647 self.lock_context().qa_dbus.as_mut().unwrap().set_connectable(true); in cmd_adapter()
650 self.lock_context().qa_dbus.as_mut().unwrap().set_connectable(false); in cmd_adapter()
687 self.lock_context().adapter_dbus.as_mut().unwrap().start_discovery(); in cmd_discovery()
690 self.lock_context().adapter_dbus.as_mut().unwrap().cancel_discovery(); in cmd_discovery()
796 .as_mut() in cmd_bond()
810 self.lock_context().adapter_dbus.as_mut().unwrap().remove_bond(device); in cmd_bond()
818 self.lock_context().adapter_dbus.as_mut().unwrap().cancel_bond_process(device); in cmd_bond()
[all …]
|
| D | main.rs | 538 .as_mut() in handle_client_command()
587 .as_mut() in handle_client_command()
602 .as_mut() in handle_client_command()
619 .as_mut() in handle_client_command()
636 .as_mut() in handle_client_command()
653 .as_mut() in handle_client_command()
669 .as_mut() in handle_client_command()
687 .as_mut() in handle_client_command()
702 context.lock().unwrap().suspend_dbus.as_mut().unwrap().register_callback(Box::new( in handle_client_command()
714 .as_mut() in handle_client_command()
[all …]
|
| D | bt_adv.rs | 76 let reg_id = context.gatt_dbus.as_mut().unwrap().start_advertising_set( in start()
96 context.gatt_dbus.as_mut().unwrap().stop_advertising_set(adv_id); in stop_all()
|
| /packages/modules/Virtualization/pvmfw/src/ |
| D | entry.rs | 97 let range = MEMORY.lock().as_mut().unwrap().alloc_mut(fdt, fdt_size).map_err(|e| { in new()
114 MEMORY.lock().as_mut().unwrap().shrink(&memory_range).map_err(|e| { in new()
124 MEMORY.lock().as_mut().unwrap().init_dynamic_shared_pool(granule).map_err(|e| { in new()
134 MEMORY.lock().as_mut().unwrap().init_static_shared_pool(range).map_err(|e| { in new()
141 MEMORY.lock().as_mut().unwrap().alloc_range(&r).map_err(|e| { in new()
153 MEMORY.lock().as_mut().unwrap().alloc(kernel, kernel_size).map_err(|e| { in new()
168 let r = MEMORY.lock().as_mut().unwrap().alloc_range(&r).map_err(|e| { in new()
252 MEMORY.lock().as_mut().unwrap().unshare_all_mmio().map_err(|e| { in main_wrapper()
257 MEMORY.lock().as_mut().unwrap().unshare_all_memory(); in main_wrapper()
|
| D | device_assignment.rs | 557 fn as_mut(&mut self) -> &mut Fdt { in as_mut() method
1024 let vm_dtbo = vm_dtbo.as_mut(); in filter()
1334 let vm_dtbo = vm_dtbo.as_mut(); in device_info_filter()
1377 platform_dt.apply_overlay(vm_dtbo.as_mut()).unwrap(); in device_info_patch()
1428 platform_dt.apply_overlay(vm_dtbo.as_mut()).unwrap(); in device_info_patch_no_pviommus()
1463 platform_dt.apply_overlay(vm_dtbo.as_mut()).unwrap(); in device_info_overlay_iommu()
1511 platform_dt.apply_overlay(vm_dtbo.as_mut()).unwrap(); in device_info_multiple_devices_iommus()
1558 platform_dt.apply_overlay(vm_dtbo.as_mut()).unwrap(); in device_info_iommu_sharing()
1749 platform_dt.apply_overlay(vm_dtbo.as_mut()).unwrap(); in device_info_dependency()
1779 platform_dt.apply_overlay(vm_dtbo.as_mut()).unwrap(); in device_info_multiple_dependencies()
[all …]
|
| /packages/modules/Virtualization/rialto/src/ |
| D | main.rs | 103 .as_mut() in try_main()
112 MEMORY.lock().as_mut().unwrap().shrink(&memory_range).map_err(|e| { in try_main()
119 MEMORY.lock().as_mut().unwrap().init_dynamic_shared_pool(granule).map_err(|e| { in try_main()
128 MEMORY.lock().as_mut().unwrap().init_static_shared_pool(range).map_err(|e| { in try_main()
134 MEMORY.lock().as_mut().unwrap().init_heap_shared_pool().map_err(|e| { in try_main()
154 MEMORY.lock().as_mut().unwrap().alloc_range_outside_main_memory(&dice_range) in try_main()
172 let mut pci_root = pci::initialize(pci_info, MEMORY.lock().as_mut().unwrap()) in try_main()
|
| /packages/modules/Bluetooth/system/gd/rust/linux/stack/src/ |
| D | bluetooth_media.rs | 1681 match self.hfp.as_mut() { in dispatch_hfp_callbacks()
1706 match self.hfp.as_mut() { in dispatch_hfp_callbacks()
2115 match self.hfp.as_mut() { in set_hfp_mic_volume()
2575 match self.a2dp.as_mut() { in start_audio_request_impl()
2585 match self.a2dp.as_mut() { in suspend_audio_request_impl()
2629 let hfp = self.hfp.as_mut().ok_or("Uninitialized HFP to start the sco call")?; in start_sco_call_impl()
2647 if let Some(hfp) = self.hfp.as_mut() { in stop_sco_call_impl()
2655 match self.hfp.as_mut() { in device_status_notification()
2682 match self.hfp.as_mut() { in phone_state_change()
2716 match self.hfp.as_mut() { in simple_at_response()
[all …]
|
| D | lib.rs | 267 dispatch_base_callbacks(bluetooth.lock().unwrap().as_mut(), b.clone()); in dispatch()
268 dispatch_base_callbacks(suspend.lock().unwrap().as_mut(), b); in dispatch()
299 dispatch_gatt_client_callbacks(bluetooth_gatt.lock().unwrap().as_mut(), m); in dispatch()
303 dispatch_gatt_server_callbacks(bluetooth_gatt.lock().unwrap().as_mut(), m); in dispatch()
319 dispatch_le_scanner_callbacks(bluetooth_gatt.lock().unwrap().as_mut(), m); in dispatch()
324 bluetooth_gatt.lock().unwrap().as_mut(), in dispatch()
334 dispatch_le_adv_callbacks(bluetooth_gatt.lock().unwrap().as_mut(), m); in dispatch()
342 dispatch_hid_host_callbacks(bluetooth.lock().unwrap().as_mut(), h); in dispatch()
346 dispatch_sdp_callbacks(bluetooth.lock().unwrap().as_mut(), s); in dispatch()
|
| D | bluetooth.rs | 731 self.hh.as_mut().unwrap().activate_hidp(false); in disable_profile()
735 self.hh.as_mut().unwrap().activate_hogp(false); in disable_profile()
758 self.hh.as_mut().unwrap().activate_hidp(true); in enable_profile()
762 self.hh.as_mut().unwrap().activate_hogp(true); in enable_profile()
822 if self.hh.as_mut().unwrap().configure_enabled_profiles() { in toggle_enabled_profiles()
823 self.hh.as_mut().unwrap().disable(); in toggle_enabled_profiles()
837 self.hh.as_mut().unwrap().enable(); in enable_hidhost()
845 self.sdp.as_mut().unwrap().initialize(SdpCallbacksDispatcher { in init_profiles()
856 self.hh.as_mut().unwrap().initialize(HHCallbacksDispatcher { in init_profiles()
1060 self.hh.as_mut().unwrap().get_report( in get_hid_report_internal()
[all …]
|
| D | bluetooth_gatt.rs | 3382 self.server_context_map.get_callback_from_callback_id(cbid).as_mut() in register_server_cb()
3405 self.server_context_map.get_callback_from_callback_id(cbid).as_mut() in connection_cb()
3433 self.server_context_map.get_callback_from_callback_id(cbid).as_mut() in service_added_cb()
3456 if let Some(cb) = self.server_context_map.get_callback_from_callback_id(cbid).as_mut() { in service_deleted_cb()
3476 if let Some(cb) = self.server_context_map.get_callback_from_callback_id(cbid).as_mut() { in request_read_characteristic_cb()
3496 if let Some(cb) = self.server_context_map.get_callback_from_callback_id(cbid).as_mut() { in request_read_descriptor_cb()
3519 if let Some(cb) = self.server_context_map.get_callback_from_callback_id(cbid).as_mut() { in request_write_characteristic_cb()
3544 if let Some(cb) = self.server_context_map.get_callback_from_callback_id(cbid).as_mut() { in request_write_descriptor_cb()
3564 if let Some(cb) = self.server_context_map.get_callback_from_callback_id(cbid).as_mut() { in request_exec_write_cb()
3585 if let Some(cb) = self.server_context_map.get_callback_from_callback_id(cbid).as_mut() { in indication_sent_cb()
[all …]
|
| /packages/modules/Virtualization/libs/bssl/src/ |
| D | ec_key.rs | 315 let ec_key = unsafe { EC_KEY_parse_private_key(cbs.as_mut(), ec_group) }; in from_ec_private_key()
330 let mut cbb = CbbFixed::new(buf.as_mut()); in ec_private_key()
335 unsafe { EC_KEY_marshal_private_key(cbb.as_mut(), self.0.as_ptr(), enc_flags) }; in ec_private_key()
340 check_int_result(unsafe { CBB_flush(cbb.as_mut()) }, ApiName::CBB_flush)?; in ec_private_key()
387 unsafe { ECDSA_SIG_set0(self.0.as_mut(), r.as_mut_ptr(), s.as_mut_ptr()) }, in load_from_cose()
467 unsafe { ECDSA_SIG_free(self.0.as_mut()) }; in drop()
|
| D | evp.rs | 84 let mut cbb = CbbFixed::new(buf.as_mut()); in subject_public_key_info()
89 let ret = unsafe { EVP_marshal_public_key(cbb.as_mut(), self.pkey.as_ptr()) }; in subject_public_key_info()
93 check_int_result(unsafe { CBB_flush(cbb.as_mut()) }, ApiName::CBB_flush)?; in subject_public_key_info()
|
| D | cbs.rs | 52 fn as_mut(&mut self) -> &mut CBS { in as_mut() method
|
| D | cbb.rs | 50 fn as_mut(&mut self) -> &mut CBB { in as_mut() method
|
| /packages/modules/Virtualization/vmbase/src/ |
| D | console.rs | 44 CONSOLE.lock().as_mut().unwrap().write_str(s).unwrap(); in write_str()
51 write(CONSOLE.lock().as_mut().unwrap(), format_args).unwrap(); in write_args()
|
| /packages/modules/DnsResolver/doh/tests/doh_frontend/src/ |
| D | client.rs | 87 let h3_conn = self.h3_conn.as_mut().unwrap(); in handle_http3_request()
146 let h3_conn = self.h3_conn.as_mut().unwrap(); in handle_backend_message()
178 let h3_conn = self.h3_conn.as_mut().unwrap(); in process_pending_answers()
|
| /packages/modules/Bluetooth/tools/rootcanal/rust/src/lmp/test/ |
| D | sequence.rs | 29 let poll = crate::lmp::test::poll($ctx.1.as_mut());
49 let poll = crate::lmp::test::poll($ctx.1.as_mut());
|
| /packages/modules/DnsResolver/doh/connection/ |
| D | driver.rs | 292 Ok((size, from)) = self.socket.recv_from(self.buffer.as_mut()) => { in drive_once()
315 let send_buf = self.buffer.as_mut(); in flush_tx()
377 Ok((size, from)) = self.driver.socket.recv_from(self.driver.buffer.as_mut()) => { in drive_once()
474 match self.h3_conn.recv_dgram(&mut self.driver.quiche_conn, self.driver.buffer.as_mut()) in discard_datagram()
|
| /packages/modules/Virtualization/libs/devicemapper/src/ |
| D | lib.rs | 103 spec.target_type.as_mut().write_all(target_type.as_bytes())?; in new()
116 data.name.as_mut().write_all(name.as_bytes())?; in new()
121 let mut dst = self.uuid.as_mut(); in set_uuid()
|
| /packages/modules/Virtualization/vmbase/src/memory/ |
| D | shared.rs | 464 } else if let Some(shared_memory) = SHARED_MEMORY.lock().as_mut() { in try_shared_alloc()
554 let memory = guard.as_mut().ok_or(HandleExceptionError::PageTableNotInitialized)?; in handle_translation_fault()
562 let memory = guard.as_mut().ok_or(HandleExceptionError::PageTableNotInitialized)?; in handle_permission_fault()
|
| /packages/modules/Bluetooth/tools/rootcanal/rust/src/lmp/ |
| D | manager.rs | 287 for procedures in self.procedures.borrow_mut().iter_mut().filter_map(Option::as_mut) { in tick()
288 let _ = procedures.as_mut().poll(&mut Context::from_waker(&waker)); in tick()
|
| /packages/modules/Bluetooth/tools/rootcanal/rust/src/lmp/procedure/ |
| D | mod.rs | 137 $(assert!(self.$idx.as_mut().poll(cx).is_pending());)+
|
| /packages/modules/Virtualization/service_vm/requests/src/ |
| D | rkp.rs | 143 kdf(dice_artifacts.cdi_seal(), &HMAC_KEY_SALT, HMAC_KEY_INFO, key.as_mut()).map_err(|e| {
|
| /packages/modules/Bluetooth/system/gd/rust/topshim/src/profiles/ |
| D | hf_client.rs | 104 let cb_ptr = LTCheckedPtrMut::from(self.callbacks.as_mut().unwrap()); in enable()
|
| /packages/modules/Bluetooth/system/rust/src/gatt/ |
| D | arbiter.rs | 52 f(ARBITER.read().unwrap().as_ref().expect("Rust stack is not started").lock().as_mut().unwrap()) in with_arbiter()
|