Method StartJob

pkg/jobmanager/jobmanager.go:222–306

(msc *MainServerConn, data wshrpc.CommandStartJobData)

}

func (jm *JobManager) StartJob(msc *MainServerConn, data wshrpc.CommandStartJobData) (*wshrpc.CommandStartJobRtnData, error) {
	jm.lock.Lock()
	defer jm.lock.Unlock()

	if jm.Cmd != nil {
		log.Printf("StartJob: job already started")
		return nil, fmt.Errorf("job already started")
	}

	cmdDef := CmdDef{
		Cmd:      data.Cmd,
		Args:     data.Args,
		Env:      data.Env,
		TermSize: data.TermSize,
	}
	log.Printf("StartJob: creating job cmd for jobid=%s", jm.JobId)
	jobCmd, err := MakeJobCmd(jm.JobId, cmdDef)
	if err != nil {
		log.Printf("StartJob: failed to make job cmd: %v", err)
		return nil, fmt.Errorf("failed to start job: %w", err)
	}
	jm.Cmd = jobCmd
	log.Printf("StartJob: job cmd created successfully")

	if data.StreamMeta != nil {
		serverSeq, err := jm.connectToStreamHelper_withlock(msc, *data.StreamMeta, 0)
		if err != nil {
			return nil, fmt.Errorf("failed to connect stream: %w", err)
		}
		err = msc.WshRpc.StreamBroker.AttachStreamWriter(data.StreamMeta, jm.StreamManager)
		if err != nil {
			return nil, fmt.Errorf("failed to attach stream writer: %w", err)
		}
		log.Printf("StartJob: connected stream streamid=%s serverSeq=%d\n", data.StreamMeta.Id, serverSeq)
	}

	cmd, cmdPty := jobCmd.GetCmd()
	if cmdPty != nil {
		log.Printf("StartJob: attaching pty reader to stream manager")
		err = jm.StreamManager.AttachReader(cmdPty)
		if err != nil {
			log.Printf("StartJob: failed to attach reader: %v", err)
			return nil, fmt.Errorf("failed to attach reader to stream manager: %w", err)
		}
		log.Printf("StartJob: pty reader attached successfully")
	} else {
		log.Printf("StartJob: no pty to attach")
	}

	if cmd == nil || cmd.Process == nil {
		log.Printf("StartJob: cmd or process is nil")
		return nil, fmt.Errorf("cmd or process is nil")
	}
	cmdPid := cmd.Process.Pid
	cmdProc, err := process.NewProcess(int32(cmdPid))
	if err != nil {
		log.Printf("StartJob: failed to get cmd process: %v", err)
		return nil, fmt.Errorf("failed to get cmd process: %w", err)