Function runCoderConnectStdio

cli/ssh.go:1690–1713

(ctx context.Context, addr string, stdin io.Reader, stdout io.Writer, stack *closerStack, logger slog.Logger)

}

func runCoderConnectStdio(ctx context.Context, addr string, stdin io.Reader, stdout io.Writer, stack *closerStack, logger slog.Logger) error {
	dialer := testOrDefaultDialer(ctx)
	var conn net.Conn
	if err := retryWithInterval(ctx, logger, sshRetryInterval, sshMaxAttempts, func() error {
		var err error
		conn, err = dialer.DialContext(ctx, "tcp", addr)
		if err != nil {
			return xerrors.Errorf("dial coder connect host %q over tcp: %w", addr, err)
		}
		return nil
	}); err != nil {
		return err
	}
	if err := stack.push("tcp conn", conn); err != nil {
		return err
	}

	agentssh.Bicopy(ctx, conn, &StdioRwc{
		Reader: stdin,
		Writer: stdout,
	})

	return nil
}

type StdioRwc struct {
	io.Reader