Method connectInternal

pkg/remote/conncontroller/conncontroller.go:953–997

returns (connect-error)

(ctx context.Context, connFlags *wconfig.ConnKeywords)

// returns (connect-error)
func (conn *SSHConn) connectInternal(ctx context.Context, connFlags *wconfig.ConnKeywords) error {
	conn.Infof(ctx, "connectInternal %s\n", conn.GetName())
	client, _, err := remote.ConnectToClient(ctx, conn.Opts, nil, 0, connFlags)
	if err != nil {
		conn.Infof(ctx, "ERROR ConnectToClient: %s\n", remote.SimpleMessageFromPossibleConnectionError(err))
		log.Printf("error: failed to connect to client %s: %s\n", conn.GetName(), err)
		return err
	}
	conn.WithLock(func() {
		if conn.Monitor != nil {
			conn.Monitor.Close()
			conn.Monitor = nil
		}
		conn.Client = client
		conn.ConnHealthStatus = ConnHealthStatus_Good
		conn.Monitor = MakeConnMonitor(conn, client)
	})
	go func() {
		defer func() {
			panichandler.PanicHandler("conncontroller:waitForDisconnect", recover())
		}()
		conn.waitForDisconnect()
	}()
	fmtAddr := knownhosts.Normalize(fmt.Sprintf("%s@%s", client.User(), client.RemoteAddr().String()))
	conn.Infof(ctx, "normalized knownhosts address: %s\n", fmtAddr)
	clientDisplayName := fmt.Sprintf("%s (%s)", conn.GetName(), fmtAddr)
	wshResult := conn.tryEnableWsh(ctx, clientDisplayName)
	if !wshResult.WshEnabled {
		if wshResult.WshError != nil {
			conn.Infof(ctx, "ERROR enabling wsh: %v\n", wshResult.WshError)
			conn.Infof(ctx, "will connect with wsh disabled\n")
		} else {
			conn.Infof(ctx, "wsh not enabled: %s\n", wshResult.NoWshReason)
		}
		telemetry.GoRecordTEventWrap(&telemetrydata.TEvent{
			Event: "conn:nowsh",
			Props: telemetrydata.TEventProps{
				ConnType:         "ssh",
				ConnWshErrorCode: wshResult.NoWshCode,
			},
		})
	}
	conn.persistWshInstalled(ctx, wshResult)
	return nil
}

func (conn *SSHConn) waitForDisconnect() {
	defer conn.FireConnChangeEvent()