| /developtools/hdc/hdc_rust/src/common/ |
| D | filemanager.rs | 37 path: Some(file_path), in new()
45 if let Some(path) = &self.path { in open()
49 self.file = Some(f); in open()
63 if let Some(f) = &self.file { in file_size()
84 if let Some(path) = &self.path { in buffer_read()
|
| D | base.rs | 114 while len >= 0 && chars.clone().nth(len as usize) == Some(Self::get_path_sep()) { in get_file_name()
118 while len >= 0 && chars.clone().nth(len as usize) != Some(Self::get_path_sep()) { in get_file_name()
124 Some(result) in get_file_name()
206 let Some(tag) = tlv.get(cur_index..(cur_index + TLV_TAG_LEN)) else { in tlv_to_stringmap() localVariable
212 let Some(svlen) = tlv.get(cur_index..(cur_index + TLV_VAL_LEN)) else { in tlv_to_stringmap() localVariable
222 let Some(val) = tlv.get(cur_index..(cur_index + vlen)) else { in tlv_to_stringmap() localVariable
230 Some(tlvmap) in tlv_to_stringmap()
|
| D | hdcfile.rs | 136 let Some(task) = FileTaskMap::get(session_id, channel_id).await else { in check_local_path() localVariable
202 let Some(task) = FileTaskMap::get(session_id, channel_id).await else { in begin_transfer() localVariable
229 let Some(task) = FileTaskMap::get(session_id, channel_id).await else { in set_master_parameters() localVariable
311 if let Some(pp) = parent_path { in get_base_path()
319 let Some(task) = FileTaskMap::get(session_id, channel_id).await else { in put_file_check() localVariable
332 let Some(task) = FileTaskMap::get(session_id, channel_id).await else { in check_slaver() localVariable
394 let Some(task) = FileTaskMap::get(session_id, channel_id).await else { in transfer_next() localVariable
401 let Some(local_path) = task.transfer.task_queue.pop() else { in transfer_next() localVariable
415 let Some(task) = FileTaskMap::get(session_id, channel_id).await else { in on_all_transfer_finish() localVariable
461 let Some(task) = FileTaskMap::get(session_id, channel_id).await else { in do_file_finish() localVariable
[all …]
|
| D | forward.rs | 185 let Some(arc_rd) = map.get(&cid) else { in read() localVariable
243 let Some(arc_wr) = map.get(&id) else { in write() localVariable
254 if let Some(arc_wr) = map.remove(&id) { in end()
285 if let Some(arc_listener) = map.remove(&id) { in end()
346 Some(task) => Some(task.clone()), in get()
363 return Some(*_channel_id); in get_channel_id()
541 let Some(task) = ForwardTaskMap::get(session_id, channel_id).await else { in check_command() localVariable
597 let Some(task) = ForwardTaskMap::get(session_id, channel_id).await else { in detech_forward_type() localVariable
745 let Some(task) = ForwardTaskMap::get(session_id, channel_id).await else { in deamon_read_socket_msg() localVariable
775 let Some(task) = ForwardTaskMap::get(session_id, channel_id).await else { in free_context() localVariable
[all …]
|
| D | jdwp.rs | 83 if let Some(node) = v { in send_fd_to_target()
135 if let Some(v) = value { in get_process_list()
148 if let Some(v) = value { in get_process_list_with_pkg_name()
251 if let Some(n) = node_map_value.get(k) { in start_data_looper()
|
| D | hdctransfer.rs | 134 transfer.is_local_dir_exsit = Some(true); in check_local_path()
143 transfer.is_local_dir_exsit = Some(false); in check_local_path()
160 if let Some(false) = transfer.is_local_dir_exsit { in check_local_path()
183 Some(index) => { in check_local_path()
354 let Some(handler) = queue.pop_front() else { in read_and_send_data() localVariable
|
| /developtools/hdc/hdc_rust/src/transfer/ |
| D | uart_wrapper.rs | 85 if let Some(w) = waiter { in wait_response()
94 if let Some(w) = waiter { in wakeup_response_wait()
103 if let Some(w) = waiter { in wait_empty()
112 if let Some(w) = waiter { in wakeup_empty_wait()
182 if let Some(vec) = data_map.get(&session_id) { in get_package()
185 let Some(arc) = vec.get(index) else { in get_package() localVariable
190 return Some(data_mtx.clone()); in get_package()
200 if let Some(vec) = data_map.get(&session_id) { in put_package()
217 if let Some(vec) = data_map.get(&session_id) { in update_package()
220 let Some(arc) = vec.get(index) else { in update_package() localVariable
[all …]
|
| D | buffer.rs | 108 let Some(arc_wr) = map.get(&session_id) else { in put() localVariable
131 if let Some(guard) = map.get(&channel_id) { in send_channel_message()
150 if let Some(arc_wr) = map.remove(&id) { in end()
181 Some(_wr) => { in put()
183 let Some(arc_wr) = map.get(&session_id) else { in put() localVariable
257 let Some(arc_wr) = map.get(&session_id) else { in put() localVariable
280 Some(ConnectType::Tcp) => { in put()
283 Some(ConnectType::Usb(_mount_point)) => { in put()
288 Some(ConnectType::Uart) => { in put()
291 Some(ConnectType::Bt) => {} in put()
[all …]
|
| D | uart.rs | 137 self.head = Some(head.clone()); in check_protocol_head()
145 if let Some(head) = head { in process_head()
|
| /developtools/hdc/hdc_rust/src/daemon/ |
| D | shell.rs | 91 Some(mut cmd) => { in init_pty_process()
96 Some(cmd_res) => cmd_res.to_string(), in init_pty_process()
100 Some(cmd_res) => cmd_res.to_string(), in init_pty_process()
233 Ok(Some(exit_status)) => { in subprocess_task()
356 if let Some(pty_child) = map.get(&(session_id, channel_id)) { in get()
357 return Some(pty_child.clone()); in get()
391 if let Some(pty_task) = map.get(&(session_id, channel_id)) { in get()
392 return Some(pty_task.clone()); in get()
421 if let Some(pty_child) = PtyChildProcessMap::get(session_id, _iter.0 .1).await { in stop_task()
468 if let Some(pty_child) = PtyChildProcessMap::get(session_id, _iter.0 .1).await { in clear()
[all …]
|
| D | daemon_app.rs | 84 let Some(task) = map.get(&(session_id, channel_id)) else { in get() localVariable
92 Some(task.clone()) in get()
126 let Some(arc) = AppTaskMap::get(session_id, channel_id).await else { in do_app_check() localVariable
183 let Some(arc) = AppTaskMap::get(session_id, channel_id).await else { in put_app_finish() localVariable
277 let Some(arc) = AppTaskMap::get(session_id, channel_id).await else { in do_app_install() localVariable
322 let Some(arc) = AppTaskMap::get(session_id, channel_id).await else { in on_transfer_finish() localVariable
369 let Some(arc) = AppTaskMap::get(session_id, channel_id).await else { in command_dispatch() localVariable
|
| D | task.rs | 51 Some(cmd), in daemon_shell_task()
75 if let Some(pty_task) = PtyMap::get(session_id, channel_id).await { in daemon_shell_task()
94 if let Some(pty_task) = PtyMap::get(session_id, channel_id).await { in remove_task()
247 Some(cmd), in daemon_hilog_task()
258 Some("hidumper".to_string()), in daemon_bug_report_task()
|
| D | main.rs | 240 let Some(head) = rd.head.clone() else { in uart_handshake() localVariable
296 let Some(head) = rd.head.clone() else { in uart_handle_client() localVariable
|
| D | auth.rs | 353 if let Some((hostname, pubkey)) = buf.split_once(HDC_HOST_DAEMON_BUF_SEPARATOR) { in get_host_pubkey_info()
800 Some(result) => match result.trim() { in require_user_permittion()
|
| /developtools/hdc/hdc_rust/src/host/ |
| D | unittest.rs | 31 command: Some(HdcCommand::FileInit), in if_parse_cmd_param_works()
51 command: Some(HdcCommand::KernelCheckServer), in if_parse_opt_cmd_works()
67 command: Some(HdcCommand::FileInit), in if_parse_opt_cmd_param_works()
|
| D | server.rs | 256 parsed.command = Some(HdcCommand::ShellData); in handle_client()
260 if parsed.command == Some(HdcCommand::UnityExecute) { in handle_client()
263 parsed.command = Some(HdcCommand::ShellInit); in handle_client()
271 if let Some(cmd) = parsed.command { in handle_client()
316 Some(p) => p, in unpack_channel_handshake()
|
| D | parser.rs | 91 if let Some(command) = CMD_MAP.get(cmd.as_str()) { in split_opt_and_cmd()
93 cmd_opt = Some(command.to_owned()); in split_opt_and_cmd()
129 if let Some(HdcCommand::UnityReboot) = parsed.command { in exchange_parsed_for_daemon()
|
| D | task.rs | 192 if let Some(_channel_id) = forward_channel_id { in channel_forward_remove()
214 if let Some(key) = connect_key { in channel_forward_list()
374 Some(seid) => seid, in channel_unity_task()
932 Some(guard.session_id) in get_session_id()
941 return Some(key.clone()); in get_connect_key()
950 Some(session_id) => Ok(session_id), in get_valid_session_id()
|
| D | host_app.rs | 231 if let Some(index) = local_path.rfind('.') { in install_single()
|
| /developtools/hdc/hdc_rust/src/daemon_lib/ |
| D | bridge.rs | 153 let Some(arc_wr) = map.get(&session_id) else { in put() localVariable
175 if let Some(guard) = map.get(&channel_id) { in send_channel_message()
194 if let Some(arc_wr) = map.remove(&id) { in end()
|
| /developtools/profiler/tools/smaps_show/src/ |
| D | main.rs | 72 Some(s) => s.parse().unwrap_or(-1), in main()
76 Some(s) => s, in main()
|
| /developtools/hdc/hdc_rust/src/host_transfer/ |
| D | host_usb.rs | 339 if let Some(guard) = map.get(&channel_id) { in send_channel_message()
|