Method PrepareConnect

pkg/jobmanager/jobmanager.go:308–351

(msc *MainServerConn, data wshrpc.CommandJobPrepareConnectData)

}

func (jm *JobManager) PrepareConnect(msc *MainServerConn, data wshrpc.CommandJobPrepareConnectData) (*wshrpc.CommandJobConnectRtnData, error) {
	jm.lock.Lock()
	defer jm.lock.Unlock()

	if jm.Cmd == nil {
		return nil, fmt.Errorf("job not started")
	}

	err := jm.Cmd.SetTermSize(data.TermSize)
	if err != nil {
		log.Printf("PrepareConnect: failed to set term size: %v\n", err)
	}

	rtnData := &wshrpc.CommandJobConnectRtnData{}
	streamDone, streamError := jm.StreamManager.GetStreamDoneInfo()

	if streamDone {
		log.Printf("PrepareConnect: stream already done, skipping connection streamError=%q\n", streamError)
		rtnData.Seq = data.Seq
		rtnData.StreamDone = true
		rtnData.StreamError = streamError
	} else {
		corkedStreamMeta := data.StreamMeta
		corkedStreamMeta.RWnd = 0
		serverSeq, err := jm.connectToStreamHelper_withlock(msc, corkedStreamMeta, data.Seq)
		if err != nil {
			return nil, err
		}
		jm.pendingStreamMeta = &data.StreamMeta
		rtnData.Seq = serverSeq
		rtnData.StreamDone = false
	}

	hasExited, exitData := jm.Cmd.GetExitInfo()
	if hasExited && exitData != nil {
		rtnData.HasExited = true
		rtnData.ExitCode = exitData.ExitCode
		rtnData.ExitSignal = exitData.ExitSignal
		rtnData.ExitErr = exitData.ExitErr
	}

	log.Printf("PrepareConnect: streamid=%s clientSeq=%d serverSeq=%d streamDone=%v streamError=%q hasExited=%v\n", data.StreamMeta.Id, data.Seq, rtnData.Seq, rtnData.StreamDone, rtnData.StreamError, hasExited)
	return rtnData, nil
}

func (jm *JobManager) StartStream(msc *MainServerConn) error {
	jm.lock.Lock()