/developtools/hdc/hdc_rust/src/daemon/ |
D | main.rs | 279 let _ = rx.recv().await; in uart_handle_client() localVariable 356 let _ = usb_handle_client(config_fd, bulkin_fd, bulkout_fd).await; in usb_daemon_start() localVariable 485 let _ = ylong_runtime::builder::RuntimeBuilder::new_multi_thread() in main() localVariable 526 let _ = tcp_task.await; in main() localVariable 528 let _ = usb_task.await; in main() localVariable 530 let _ = uart_task.await; in main() localVariable 532 let _ = bridge_task.await; in main() localVariable 533 let _ = jdwp_server_task.await; in main() localVariable
|
D | task.rs | 69 let _ = daemon_channel_close(message, session_id).await; in daemon_shell_task() localVariable 76 let _ = &pty_task.tx.send(task_message.payload.clone()).await; in daemon_shell_task() localVariable 95 let _ = &pty_task.tx.send(vec![0x04_u8]).await; in remove_task() localVariable
|
D | daemon_app.rs | 138 let _ = transconfig.parse(_payload.to_owned()); in do_app_check() localVariable 158 let _ = create_dir_all(tmp_dir); in do_app_check() localVariable 298 let _ = FileManager::remove_file(local_path.as_str()); in do_app_install() localVariable
|
D | auth.rs | 722 let _ = match std::fs::File::options().append(true).open(file_name) { in write_known_hosts_pubkey() localVariable
|
/developtools/hdc/hdc_rust/src/host/ |
D | main.rs | 50 let _ = ylong_runtime::builder::RuntimeBuilder::new_multi_thread() in main() localVariable 78 let _ = server::run_server_mode(parsed_cmd.server_addr).await; in main() localVariable
|
D | client.rs | 181 let _ = self.wr.write_all(msg.as_slice()).await; in send() localVariable 228 let _ = utils::print_msg(recv).await; in shell_task() localVariable 232 let _ = recover_terminal(termios_clone); in shell_task() localVariable 263 let _ = recover_terminal(termios); in shell_task() localVariable 283 let _ = utils::print_msg(recv).await; in general_task() localVariable
|
D | task.rs | 182 let _ = transfer::send_channel_msg( in channel_forward_remove() localVariable 309 let _ = host_app::command_dispatch( in channel_file_task() localVariable 508 let _ = in start_usb_device_loop() localVariable 555 let _ = transfer::send_channel_msg( in start_tcp_daemon_session() localVariable 657 let _ = transfer::send_channel_msg( in session_task_dispatch() localVariable 718 let _ = forward::on_forward_success(task_message.clone(), session_id).await; in session_forward_success() localVariable 725 let _ = host_app::command_dispatch( in session_file_task() localVariable 805 let _ = task_.command_dispatch(command, &cmd[..], cmd.len() as u16); in session_file_task() localVariable
|
D | host_app.rs | 122 let _ = echo_client(channel_id, message).await; in check_install_continue() localVariable 124 let _ = echo_client(channel_id, String::from("AppMod finish")).await; in check_install_continue() localVariable 163 let _ = send_to_client(channel_id, EchoLevel::FAIL, message).await; in get_sub_app_files_resurively() localVariable 174 let _ = send_to_client(channel_id, EchoLevel::FAIL, message).await; in get_sub_app_files_resurively() localVariable 311 let _ = in command_dispatch() localVariable
|
D | auth.rs | 176 let _ = std::fs::create_dir_all(&path); in create_prikey() localVariable
|
/developtools/hdc/hdc_rust/src/transfer/ |
D | base.rs | 112 let _ = tx in unpack_task_message_lock() localVariable 134 let _ = tx in unpack_task_message_lock() localVariable 151 let _ = tx in unpack_task_message_lock() localVariable 209 let _ = tx in unpack_task_message() localVariable
|
D | buffer.rs | 71 let _ = map.remove(&session_id); in del() localVariable 113 let _ = wr.write_all(send.as_slice()).await; in put() localVariable 133 let _ = wr.write_all(send.as_slice()).await; in send_channel_message() localVariable 152 let _ = wr.shutdown().await; in end() localVariable 234 let _ = map.remove(&session_id); in end() localVariable 309 let _ = TcpMap::send_channel_message(channel_id, data).await; in send_channel_data() localVariable
|
/developtools/hdc/hdc_rust/src/ |
D | utils.rs | 45 let _ = stdout.write(&buf).await; in print_msg() localVariable 46 let _ = stdout.flush().await; in print_msg() localVariable
|
/developtools/integration_verification/DeployDevice/resource/common/ |
D | push_code.py | 23 sta,_ = getstatusoutput(item) variable
|
/developtools/hdc/hdc_rust/src/host_transfer/ |
D | host_usb.rs | 251 let _ = tx in unpack_task_message() localVariable 341 let _ = wr.write_all(send); in send_channel_message() localVariable 364 let _ = map.remove(&id); in end() localVariable
|
/developtools/hdc/hdc_rust/src/daemon_lib/ |
D | bridge.rs | 157 let _ = wr.write_all(send); in put() localVariable 177 let _ = wr.write_all(send); in send_channel_message() localVariable
|
/developtools/hdc/hdc_rust/src/common/ |
D | hdctransfer.rs | 218 let _ = file.seek(std::io::SeekFrom::Start(pos)); in spawn_handler() localVariable 385 let _ = header.parse(_data[..FILE_PACKAGE_HEAD].to_vec()); in recv_and_write_file() localVariable 417 let _ = file.seek(std::io::SeekFrom::Start(file_index)); in recv_and_write_file() localVariable
|
D | forward.rs | 248 let _ = wr.write_all(data.as_slice()).await; in write() localVariable 256 let _ = wr.shutdown().await; in end() localVariable 338 let _ = map.remove(&(session_id, channel_id)); in remove() localVariable 576 let _ = on_forward_success(forward_success_message, session_id).await; in check_command() localVariable 1099 let _ = in echo_client() localVariable 1161 let _ = fs::remove_file(s_node_cfg.clone()); in setup_file_point() localVariable
|
D | hdcfile.rs | 342 let _ = transconfig.parse(_payload.to_owned()); in check_slaver() localVariable 440 let _ = in on_all_transfer_finish() localVariable
|
/developtools/integration_verification/DeployDevice/src/util/ |
D | time_info.py | 88 def _(*args, **kwargs): function
|
/developtools/ace_ets2bundle/compiler/server/ |
D | build_pipe_server.js | 21 const _ = require('lodash'); constant
|
/developtools/ace_ets2bundle/compiler/codegen/ |
D | codegen_ets.js | 15 …ction]",v="[object GeneratorFunction]",P="[object Map]",b="[object Number]",_="[object Object]",N=… function
|