Function download_toolchain

ci/util/toolchain_downloader.py:102–200

Download a single toolchain package. Args: package: Package information cache_dir: Cache directory for downloads downloader: ResumableDownloader instance Returns: ToolchainDownloadResult with download status

(
    package: PackageInfo, cache_dir: Path, downloader: ResumableDownloader
)

def download_toolchain(
    package: PackageInfo, cache_dir: Path, downloader: ResumableDownloader
) -> ToolchainDownloadResult:
    """
    Download a single toolchain package.

    Args:
        package: Package information
        cache_dir: Cache directory for downloads
        downloader: ResumableDownloader instance

    Returns:
        ToolchainDownloadResult with download status
    """
    result = ToolchainDownloadResult(package_name=package.name, url="")

    # Get download URL from package
    try:
        download_url = package.get_download_url()
    except KeyboardInterrupt as ki:
        handle_keyboard_interrupt(ki)
        raise
    except Exception as e:
        result.error_message = f"Failed to resolve download URL: {e}"
        return result

    if not download_url:
        result.error_message = "No download URL available"
        return result

    result.url = download_url

    # Try to convert GitHub URLs to zip format
    converted_url, needs_manual = convert_github_url_to_zip(download_url)

    if needs_manual:
        result.needs_manual_install = True
        result.error_message = "Requires manual git installation"
        return result

    # Use converted URL if available, otherwise use original
    final_url = converted_url if converted_url else download_url
    result.converted_url = final_url if converted_url else None

    # Acquire fine-grained lock for this specific artifact (5-second timeout with stale detection)
    try:
        with acquire_artifact_lock(
            cache_dir, final_url, operation="download", timeout=5.0
        ):
            # Check cache again (another process might have completed while we waited for lock)
            cached_artifact = check_cached_download(
                cache_dir, final_url, expected_filename="toolchain.zip"
            )

            if cached_artifact:
                logger.info(f"✅ Using cached toolchain: {package.name}")
                result.success = True
                result.cache_dir = cached_artifact