Lines Matching defs:new
96 fn new(pty: Pty, child: Arc<Mutex<Child>>) -> Self {
112 let pty = match Pty::new() {
117 return Err(io::Error::new(io::ErrorKind::Other, msg));
126 return Err(io::Error::new(io::ErrorKind::Other, msg));
132 let mut command = PtyCommand::new(SHELL_PROG);
154 let mut proc = PtyCommand::new(SHELL_PROG);
159 Ok(PtyProcess::new(
161 Arc::new(Mutex::new(child)),
314 pub fn new(
322 crate::debug!("PtyTask new session_id {session_id}, channel_id {channel_id}");
358 .get_or_insert_with(|| Arc::new(Mutex::new(HashMap::new())))
393 .get_or_insert_with(|| Arc::new(Mutex::new(HashMap::new())))
410 let arc_pty_task = Arc::new(pty_task);
471 let mut result = String::new();
493 static ONCE: Once = Once::new();
497 SHELLEXECUTE_MAP = MaybeUninit::new(Mutex::new(HashMap::new()));
507 let arc_shell_execute_task = Arc::new(shell_execute_task);
556 return Err(Error::new(ErrorKind::Other, "pipe closed"));
571 let mut buffer = Vec::new();
584 let mut buffer = Vec::new();
611 let mut shell_cmd = Command::new(SHELL_PROG);
663 let mut child_out_reader = ylong_runtime::io::AsyncBufReader::new(child_out);
664 let mut child_err_reader = ylong_runtime::io::AsyncBufReader::new(child_err);
739 pub fn new(
747 crate::debug!("ShellExecuteTask new session_id {session_id}, channel_id {channel_id}");