Method start

supervisor/src/process.rs:174–282

(&self)

    }

    pub fn start(&self) -> Result<()> {
        if self.lock().is_running() {
            bail!("Process is already running");
        }

        // Create command and spawn process
        let mut command = Command::new(&self.config.command);
        command
            .stdout(Stdio::piped())
            .stderr(Stdio::piped())
            .args(&self.config.args)
            .envs(&self.config.env)
            .kill_on_drop(true);
        if !self.config.cwd.is_empty() {
            command.current_dir(&self.config.cwd);
        }
        if !self.config.stdout.is_empty() {
            command.stdout(Stdio::piped());
        } else {
            command.stdout(Stdio::null());
        }
        if !self.config.stderr.is_empty() {
            command.stderr(Stdio::piped());
        } else {
            command.stderr(Stdio::null());
        }

        let mut process = command.spawn()?;
        let pid = process.id();

        let (kill_tx, kill_rx) = oneshot::channel();

        // Update process state
        {
            let mut state = self.lock();
            state.started_at = Some(SystemTime::now());
            state.status = ProcessStatus::Running;
            state.pid = pid;
            state.kill_tx = Some(kill_tx);
            state.started = true;
        }

        // Handle IO redirection
        {
            let pidfile_path = self.config.pidfile.clone();
            if !pidfile_path.is_empty() {
                if let Err(err) =
                    fs_err::write(&pidfile_path, format!("{}", process.id().unwrap_or(0)))
                {
                    error!("Failed to write pidfile: {err}");
                }
            }

            let stdout = process.stdout.take();
            let stderr = process.stderr.take();
            let stdout_path = self.config.stdout.clone();
            let stderr_path = self.config.stderr.clone();