| /packages/modules/Virtualization/pvmfw/src/ |
| D | bootargs.rs | 38 if let Some(n) = self.equal_sign { in name()
47 Some(&self.arg[self.equal_sign?..]) in value()
97 Some('=') => { in next()
99 (&arg[..value_end], Some(name_end)) in next()
104 Some(BootArg { arg, equal_sign }) in next()
154 check(cstr!("foo=bar"), Ok(&[("foo", Some("=bar"))])); in single_with_value()
155 check(cstr!(" foo=bar"), Ok(&[("foo", Some("=bar"))])); in single_with_value()
156 check(cstr!("foo=bar "), Ok(&[("foo", Some("=bar"))])); in single_with_value()
157 check(cstr!(" foo=bar "), Ok(&[("foo", Some("=bar"))])); in single_with_value()
159 check(cstr!("foo="), Ok(&[("foo", Some("="))])); in single_with_value()
[all …]
|
| D | fdt.rs | 87 if let Some(config) = fdt.node(cstr!("/config"))? { in read_kernel_range_from()
88 if let (Some(addr), Some(size)) = (config.getprop_u32(addr)?, config.getprop_u32(size)?) { in read_kernel_range_from()
92 return Ok(Some(addr..(addr + size))); in read_kernel_range_from()
105 if let Some(chosen) = fdt.chosen()? { in read_initrd_range_from()
106 if let (Some(start), Some(end)) = (chosen.getprop_u32(start)?, chosen.getprop_u32(end)?) { in read_initrd_range_from()
107 return Ok(Some((start as usize)..(end as usize))); in read_initrd_range_from()
125 if let Some(chosen) = fdt.chosen()? { in read_bootargs_from()
126 if let Some(bootargs) = chosen.getprop_str(cstr!("bootargs"))? { in read_bootargs_from()
130 return Ok(Some(copy)); in read_bootargs_from()
237 let Some(cpu_map) = fdt.node(cstr!("/cpus/cpu-map"))? else { in read_cpu_map_from() localVariable
[all …]
|
| D | device_assignment.rs | 182 if path.to_bytes().first() != Some(&b'/') { in new()
217 self.tokens.get(1) == Some(&&b"__overlay__"[..]) in is_overlayable_node()
344 let Some(phandle) = node.get_phandle()? else { in parse_physical_iommus() localVariable
347 let Some(iommu) = PhysIommu::parse(&node)? else { in parse_physical_iommus() localVariable
389 let Some(info) = PhysicalDeviceInfo::parse(&node, phys_iommus)? else { in parse_physical_devices_with_iommus() localVariable
402 let Some(physical_node) = self.as_ref().node(cstr!("/host"))? else { in parse_physical_devices() localVariable
413 let Some(subnode) = node.subnode_with_name_bytes(token)? else { in node() localVariable
418 Ok(Some(node)) in node()
431 if let Some(phandle) = node.get_phandle()? { in collect_overlayable_nodes_with_phandle()
446 let Some(local_fixups) = vm_dtbo.node(cstr!("/__local_fixups__"))? else { in collect_phandle_references_from_overlayable_nodes() localVariable
[all …]
|
| /packages/modules/Bluetooth/tools/rootcanal/rust/src/ |
| D | packets.rs | 64 LinkKeyRequestReply(packet) => Some(packet.get_bd_addr()), in command_remote_device_address()
65 LinkKeyRequestNegativeReply(packet) => Some(packet.get_bd_addr()), in command_remote_device_address()
66 PinCodeRequestReply(packet) => Some(packet.get_bd_addr()), in command_remote_device_address()
67 PinCodeRequestNegativeReply(packet) => Some(packet.get_bd_addr()), in command_remote_device_address()
68 IoCapabilityRequestReply(packet) => Some(packet.get_bd_addr()), in command_remote_device_address()
69 IoCapabilityRequestNegativeReply(packet) => Some(packet.get_bd_addr()), in command_remote_device_address()
70 UserConfirmationRequestReply(packet) => Some(packet.get_bd_addr()), in command_remote_device_address()
71 UserConfirmationRequestNegativeReply(packet) => Some(packet.get_bd_addr()), in command_remote_device_address()
72 UserPasskeyRequestReply(packet) => Some(packet.get_bd_addr()), in command_remote_device_address()
73 UserPasskeyRequestNegativeReply(packet) => Some(packet.get_bd_addr()), in command_remote_device_address()
[all …]
|
| /packages/modules/Bluetooth/system/gd/rust/linux/utils/src/ |
| D | at_command_parser.rs | 83 Some(command) => command, in parse_at_command_data()
88 AT_COMMAND_VENDOR_XAPL => Some(AT_COMMAND_VENDOR_APPLE.to_string()), in parse_at_command_data()
89 AT_COMMAND_VENDOR_IPHONEACCEV => Some(AT_COMMAND_VENDOR_APPLE.to_string()), in parse_at_command_data()
90 AT_COMMAND_VENDOR_XEVENT => Some(AT_COMMAND_VENDOR_PLANTRONICS.to_string()), in parse_at_command_data()
94 Some(arg_string) => { in parse_at_command_data()
98 Some( in parse_at_command_data()
109 (Some(args), AT_COMMAND_VENDOR_IPHONEACCEV) => Some(extract_iphoneaccev_data(args)?), in parse_at_command_data()
110 (Some(args), AT_COMMAND_VENDOR_XEVENT) => Some(extract_xevent_data(args)?), in parse_at_command_data()
111 (Some(_), _) => None, in parse_at_command_data()
128 Some(data) => { in calculate_battery_percent()
[all …]
|
| /packages/modules/Bluetooth/floss/hcidoc/src/groups/ |
| D | collisions.rs | 67 Some(CollisionSignal::InquiryAndConnection) in get_signal_type()
71 Some(CollisionSignal::RnrAndConnection) in get_signal_type()
75 Some(CollisionSignal::InquirySelf) in get_signal_type()
79 Some(CollisionSignal::RnrAndInquiry) in get_signal_type()
83 Some(CollisionSignal::InquiryAndConnection) in get_signal_type()
87 Some(CollisionSignal::RnrAndInquiry) in get_signal_type()
91 Some(CollisionSignal::RnrAndConnection) in get_signal_type()
113 OpCode::CreateConnection => Some(CollisionState::ConnectionActive), in process()
114 OpCode::Inquiry => Some(CollisionState::InquiryActive), in process()
116 Some(CollisionState::RemoteNameReqActive) in process()
[all …]
|
| /packages/modules/Bluetooth/system/gd/rust/linux/stack/src/ |
| D | bluetooth_media.rs | 568 if let Some(connected_profiles) = self.connected_profiles.get(addr) { in is_any_profile_connected()
617 Some(group_id) => group_id, in remove_device_from_group()
625 Some(group) => { in remove_device_from_group()
643 self.adapter = Some(adapter); in set_adapter()
665 if let Some(a2dp) = &mut self.a2dp { in enable_profile()
670 if let Some(avrcp) = &mut self.avrcp { in enable_profile()
675 if let Some(hfp) = &mut self.hfp { in enable_profile()
680 if let Some(le_audio) = &mut self.le_audio { in enable_profile()
685 if let Some(vc) = &mut self.vc { in enable_profile()
690 if let Some(csis) = &mut self.csis { in enable_profile()
[all …]
|
| D | bluetooth_gatt.rs | 99 Some(conn) => Some(conn.address), in get_address_by_conn_id()
106 Some(conn) => self.get_by_client_id(conn.client_id), in get_client_by_conn_id()
113 Some(conn) => conn.client_id, in get_client_by_conn_id_mut()
137 if let Some(c) = self.get_by_client_id(id) { in remove()
150 if let Some(client) = self.clients.iter_mut().find(|client| client.uuid == *uuid) { in set_client_id()
151 client.id = Some(id); in set_client_id()
174 Some(conn) => Some(conn.conn_id), in get_conn_id_from_address()
280 if let Some(cbid) = self.get_by_server_id(id).map(|server| server.cbid) { in remove()
293 if let Some(s) = server { in set_server_id()
294 s.id = Some(id); in set_server_id()
[all …]
|
| D | socket_manager.rs | 99 psm: Some(DYNAMIC_PSM_NO_SDP), in make_l2cap_channel()
129 channel: Some(DYNAMIC_CHANNEL), in make_default_rfcomm_channel()
130 name: Some(name), in make_default_rfcomm_channel()
131 uuid: Some(uuid), in make_default_rfcomm_channel()
156 Ok(v) => Some(v), in to_connecting_socket()
170 (Some(psm), Some(cn)) => format!("psm {} | cn {}", psm, cn), in fmt()
171 (None, Some(cn)) => format!("cn {}", cn), in fmt()
172 (Some(psm), None) => format!("psm {}", psm), in fmt()
178 Some(u) => DisplayUuid(&u).to_string(), in fmt()
245 uuid: Some(uuid), in make_rfcomm_channel()
[all …]
|
| D | bluetooth_adv.rs | 554 Some(Box::new(AdvertiseManagerImpl::new(self.tx.clone(), gatt, adapter))) in initialize()
557 Some(Box::new(SoftwareRotationAdvertiseManagerImpl::new( in initialize()
602 if let Some(old) = self.sets.insert(s.reg_id(), s) { in add()
624 if s.adv_id == Some(adv_id) { in find_reg_id()
625 return Some(s.reg_id()); in find_reg_id()
646 if let Some(reg_id) = self.find_reg_id(adv_id) { in get_mut_by_advertiser_id()
654 if let Some(reg_id) = self.find_reg_id(adv_id) { in get_by_advertiser_id()
671 if let Some(reg_id) = self.find_reg_id(adv_id) { in remove_by_advertiser_id()
920 if let Some(d) = scan_response { d.make_with(&device_name) } else { Vec::<u8>::new() }; in start_advertising_set()
925 let periodic_params = if let Some(p) = periodic_parameters { in start_advertising_set()
[all …]
|
| D | battery_service.rs | 143 self.client_id = Some(client_id); in handle_action()
151 Some(id) => id, in handle_action()
172 if let Some(BatteryServiceStatus::BatteryServiceNotSupported) = status { in handle_action()
185 Some(id) => id, in handle_action()
203 Some(stored_handle) => { in handle_action()
260 Some(id) => id, in init_device()
286 Some(client_id) => { in drop_device()
300 (Some(bas_uuid), Some(battery_level_uuid)) => (bas_uuid, battery_level_uuid), in get_battery_level_handle()
307 Some(bas) => bas, in get_battery_level_handle()
308 None => return Err(Some(BatteryServiceStatus::BatteryServiceNotSupported)), in get_battery_level_handle()
[all …]
|
| /packages/modules/Bluetooth/system/rust/src/gatt/server/ |
| D | isolation_manager.rs | 37 if let Some(old) = old { in associate_server_with_advertiser()
78 let Some(advertiser) = advertiser else { in on_le_connect() localVariable
82 let Some(server_id) = self.advertiser_to_server.get(&advertiser).copied() else { in on_le_connect() localVariable
116 isolation_manager.on_le_connect(TCB_IDX, Some(ADVERTISER_ID)); in test_non_isolated_connect()
127 isolation_manager.on_le_connect(TCB_IDX, Some(ADVERTISER_ID)); in test_isolated_connect()
130 assert_eq!(server_id, Some(SERVER_ID)); in test_isolated_connect()
138 isolation_manager.on_le_connect(TCB_IDX, Some(ANOTHER_ADVERTISER_ID)); in test_non_isolated_connect_with_isolated_advertiser()
152 isolation_manager.on_le_connect(TCB_IDX, Some(ADVERTISER_ID)); in test_advertiser_id_reuse()
168 isolation_manager.on_le_connect(TCB_IDX, Some(ADVERTISER_ID)); in test_server_closed()
179 isolation_manager.on_le_connect(TCB_IDX, Some(ADVERTISER_ID)); in test_connection_isolated_after_advertiser_stops()
[all …]
|
| /packages/modules/Bluetooth/system/gd/rust/linux/mgmt/src/ |
| D | migrate.rs | 352 floss_conf.set(addr_lower.as_str(), "HidAttrMask", Some("0".into())); in convert_from_bluez_device()
374 Some(format!("{}{:02x}{}", irk, addr_type, addr_lower.replace(":", ""))), in convert_from_bluez_device()
384 Some(ltk.try_into_penc().unwrap_or_default()), in convert_from_bluez_device()
394 Some(lltk.try_into_lenc().unwrap_or_default()), in convert_from_bluez_device()
499 Some(keys) => { in convert_from_bluez_device()
513 floss_conf.set(addr_lower.as_str(), key.key, Some(new_val)); in convert_from_bluez_device()
591 conf.set(ADAPTER_SECTION_NAME, "Address", Some(adapter.clone())); in migrate_bluez_devices()
662 Some(addr) => addr.to_uppercase(), in convert_floss_conf()
774 Some(reverse_endianness(val[0..32].to_string(), true).unwrap_or_default()), in convert_floss_conf()
797 bluez_info.set(section_name, "Key", Some(format!("{:032X}", ltk.key))); in convert_floss_conf()
[all …]
|
| D | state_machine.rs | 217 Some(a) => call(&a), in get_state()
223 self.get_state(hci, move |a: &AdapterState| Some(a.state)).unwrap_or(ProcessState::Off) in get_process_state()
297 if let Some(val) = &name { in event_name_to_string()
298 if let Some(strval) = val.to_str() { in event_name_to_string()
299 return Some(strval.to_string()); in event_name_to_string()
317 Message::PidChange(inotify::EventMask::CREATE, Some(file)), in configure_pid()
427 if let Some(p) = packet { in configure_hci()
444 if let Some(d) = config_util::get_devpath_for_hci(hci) { in configure_hci()
466 if let Some(d) = config_util::get_devpath_for_hci(hci) { in configure_hci()
705 Some(v) => context in mainloop()
[all …]
|
| D | service_watcher.rs | 32 self.service_owner = Some(owner); in set_owner()
72 Some(owner) in get_dbus_owner_of_service()
117 if let (Some(name), Some(old_owner), Some(new_owner)) = in monitor_name_owner_changed()
151 if let Some(owner) = self.get_dbus_owner_of_service().await { in start_watch()
178 if let Some(owner) = self.get_dbus_owner_of_service().await { in start_watch_interface()
180 if let Some(path) = self.get_path_of_interface(interface.clone()).await { in start_watch_interface()
211 if let (Some(sender), Some(owner)) = in start_watch_interface()
|
| D | powerd_suspend_manager.rs | 77 Some(proto_bytes) in generate_proto_bytes()
91 if let Some(suspend_readiness_info_proto) = generate_proto_bytes(&suspend_readiness_info) { in send_handle_suspend_readiness()
133 if let (Some(pending_suspend_imminent), Some(powerd_session)) = in on_suspend_ready()
141 } else if let (Some(adapter_suspend_dbus), None) = in on_suspend_ready()
305 if let Some(bytes) = msg.get1::<Vec<u8>>() { in init()
338 if let Some(bytes) = msg.get1::<Vec<u8>>() { in init()
366 if let Some(msg) = m { in mainloop()
405 if let Some(register_suspend_delay_proto) = generate_proto_bytes(&request) { in on_powerd_started()
429 Some(PowerdSession { delay_id: reply.get_delay_id(), powerd_proxy }); in on_powerd_started()
447 Some(_) => context.powerd_session = None, in on_powerd_stopped()
[all …]
|
| /packages/modules/Virtualization/vm/src/ |
| D | run.rs | 51 Some(path) => parse_extra_apk_list(&config.apk, path)?, in command_run_app()
106 let storage = if let Some(ref path) = config.microdroid.storage { in command_run_app()
115 Some(open_parcel_file(path, true)?) in command_run_app()
126 let payload = if let Some(config_path) = config.config_path { in command_run_app()
131 } else if let Some(payload_binary_name) = config.payload_binary_name { in command_run_app()
143 let os_name = if let Some(ver) = config.microdroid.gki() { in command_run_app()
179 customConfig: Some(custom_config), in command_run_app()
202 Some(path) => Ok(path), in find_empty_payload_apk_path()
234 payload_binary_name: Some("MicrodroidEmptyPayloadJniLib.so".to_owned()), in command_run_microdroid()
251 if let Some(mem) = config.common.mem { in command_run()
[all …]
|
| /packages/modules/Virtualization/virtualizationmanager/src/ |
| D | crosvm.rs | 182 renderer_use_egl: Some(raw_config.rendererUseEgl), in new()
183 renderer_use_gles: Some(raw_config.rendererUseGles), in new()
184 renderer_use_glx: Some(raw_config.rendererUseGlx), in new()
185 renderer_use_surfaceless: Some(raw_config.rendererUseSurfaceless), in new()
186 renderer_use_vulkan: Some(raw_config.rendererUseVulkan), in new()
280 if let Some(tap_file) = &config.tap { Some(tap_file.try_clone()?) } else { None }; in start()
294 let monitor_vm_exit_thread = Some(thread::spawn(move || { in start()
421 vm_metric.start_timestamp = Some(SystemTime::now()); in start()
444 if let Some(exit_status_code) = status.code() { in monitor_vm_exit()
497 if let Some(tap_file) = tap { in monitor_vm_exit()
[all …]
|
| D | payload.rs | 131 if let Some(info) = need_to_add { in override_staged_apex()
178 if let Some(staged_apex_info) = in get_apex_list()
220 apk: Some(ApkPayload { in make_metadata_file()
227 payload: Some(payload_metadata), in make_metadata_file()
290 image: Some(metadata_file), in make_payload_disk()
298 image: Some(apex_file), in make_payload_disk()
304 image: Some(ParcelFileDescriptor::new(apk_file)), in make_payload_disk()
309 image: Some(ParcelFileDescriptor::new(idsig_file)), in make_payload_disk()
320 image: Some(ParcelFileDescriptor::new(extra_apk_file)), in make_payload_disk()
326 image: Some(ParcelFileDescriptor::new( in make_payload_disk()
[all …]
|
| /packages/modules/Virtualization/libs/libfdt/src/ |
| D | lib.rs | 138 if let Some(offset) = self.fdt.next_property_offset(self.offset)? { in next_property()
139 Ok(Some(Self::new(self.fdt, offset)?)) in next_property()
175 if let Some(cells) = self.getprop_cells(cstr!("reg"))? { in reg()
181 Ok(Some(RegIterator::new(cells, addr_cells, size_cells))) in reg()
189 if let Some(cells) = self.getprop_cells(cstr!("ranges"))? { in ranges()
194 Ok(Some(RangesIterator::<A, P, S>::new( in ranges()
213 if let Some(bytes) = self.getprop(name)? { in getprop_str()
214 Ok(Some(CStr::from_bytes_with_nul(bytes).map_err(|_| FdtError::BadValue)?)) in getprop_str()
222 if let Some(cells) = self.getprop(name)? { in getprop_cells()
223 Ok(Some(CellIterator::new(cells))) in getprop_cells()
[all …]
|
| /packages/modules/Virtualization/virtualizationservice/src/ |
| D | remote_provisioning.rs | 59 uniqueId: Some(String::from("AVF Remote Provisioning 1")), in getHardwareInfo()
74 Some("generateEcdsaP256KeyPair does not support test mode in IRPC v3+ HAL."), in generateEcdsaP256KeyPair()
103 Some("This method was deprecated in v3 of the interface."), in generateCertificateRequest()
122 return Err(Status::new_service_specific_error_str(STATUS_FAILED, Some(message))) in generateCertificateRequestV2()
141 Some("Protected VM support is missing for this operation"), in check_remote_attestation_is_supported()
148 Some("Remote attestation is disabled"), in check_remote_attestation_is_supported()
164 Status::new_service_specific_error_str(STATUS_INVALID_MAC, Some(format!("{e}"))) in to_service_specific_error()
168 Some(format!("Failed to process request: {e}.")), in to_service_specific_error()
173 Some(format!("Incorrect response type: {other:?}")), in to_service_specific_error()
|
| D | aidl.rs | 207 state.display_service = Some(ibinder.clone()); in setDisplayService()
301 Some( in enableTestAttestation()
342 Some( in requestAttestation()
352 Some("AVF remotely provisioned component service is not declared"), in requestAttestation()
389 Some("The certificate chain should contain at least 1 certificate"), in requestAttestation()
432 Some(VfioDev { sysfsPath: x.sysfs_path, dtboLabel: x.dtbo_label }) in bindDevicesToVfioDriver()
459 if let Some(sk_state) = &mut state.sk_state {
473 if let Some(sk_state) = &mut state.sk_state {
492 if let Some(sk_state) = &mut state.sk_state {
518 Some("createTapInterface is not supported with the network feature disabled"), in createTapInterface()
[all …]
|
| /packages/modules/Bluetooth/tools/rootcanal/rust/src/lmp/ |
| D | manager.rs | 56 assert!(self.hci.replace(Some(command)).is_none(), "HCI flow control violation"); in ingest_hci()
62 if let Some(command) = command.clone().and_then(|c| c.try_into().ok()) { in poll_hci_command()
74 if let Some(packet) = packet { in poll_lmp_packet()
122 if let Some(link) = self.get_link(from) { in ingest_lmp()
251 if let Some(link) = link { in ingest_hci()
262 if let Some(index) = index { in add_link()
265 self.procedures.borrow_mut()[index] = Some(Box::pin(procedure::run(context))); in add_link()
275 if let Some(index) = index { in remove_link()
304 if let Some(manager) = self.manager.upgrade() { in poll_hci_command()
312 if let Some(manager) = self.manager.upgrade() { in poll_lmp_packet()
[all …]
|
| /packages/modules/DnsResolver/doh/ |
| D | config.rs | 60 Some(path) => { in from_key()
105 self.latest = Some(config); in keep_alive()
146 if let Some(config) = self.state.read().unwrap().get_config(key) { in get()
161 if let Some(config) = state.get_config(key) { in get()
187 cert_path: Some("data/local/tmp/".to_string()), in create_quiche_config()
214 Key { cert_path: Some("a".to_string()), max_idle_timeout: 1000, enable_early_data: false }; in different_keys()
216 Key { cert_path: Some("a".to_string()), max_idle_timeout: 5000, enable_early_data: false }; in different_keys()
218 Key { cert_path: Some("a".to_string()), max_idle_timeout: 5000, enable_early_data: true }; in different_keys()
240 Key { cert_path: Some("a".to_string()), max_idle_timeout: 1000, enable_early_data: true }; in lifetimes()
242 Key { cert_path: Some("b".to_string()), max_idle_timeout: 1000, enable_early_data: true }; in lifetimes()
|
| /packages/modules/Virtualization/compos/common/ |
| D | compos_client.rs | 128 let custom_config = Some(CustomConfig { wantUpdatable: false, ..Default::default() });
132 apk: Some(apk_fd),
133 idsig: Some(idsig_fd),
135 instanceImage: Some(instance_fd),
155 Some(callback),
165 if let Some(death_reason) =
196 Some(DeathReason::Shutdown) => info!("VM has exited normally"), in wait_for_shutdown()
197 Some(reason) => warn!("VM died with reason {:?}", reason), in wait_for_shutdown()
217 Some(path) => Ok(path), in locate_config_apk()
|