|
| 1 | +name: 'Download and configure Kernel Source code' |
| 2 | + |
| 3 | +inputs: |
| 4 | + source_location: |
| 5 | + description: 'Folder path to save Kernel source' |
| 6 | + required: true |
| 7 | + type: string |
| 8 | + github_token: |
| 9 | + description: 'GitHub Token' |
| 10 | + required: true |
| 11 | + debug: |
| 12 | + description: 'Enable Logs' |
| 13 | + required: false |
| 14 | + type: boolean |
| 15 | + default: false |
| 16 | + |
| 17 | +runs: |
| 18 | + using: 'composite' |
| 19 | + steps: |
| 20 | + - name: Download and Prepare Manifest |
| 21 | + shell: bash |
| 22 | + working-directory: ${{ inputs.source_location }} |
| 23 | + run: | |
| 24 | + # Download and Prepare Manifest |
| 25 | + if [[ "$OP_MANIFEST" == https://* ]]; then |
| 26 | + curl --fail --show-error --location --proto '=https' "$OP_MANIFEST" -o manifest.xml |
| 27 | + elif [[ "$OP_BRANCH" == wild/* ]]; then |
| 28 | + cp "../manifests/$(echo "$OP_OS_VERSION" | tr '[:upper:]' '[:lower:]')/$OP_MANIFEST" manifest.xml |
| 29 | + else |
| 30 | + curl --fail --show-error --location --proto '=https' "https://raw.githubusercontent.com/OnePlusOSS/kernel_manifest/refs/heads/$OP_BRANCH/$OP_MANIFEST" -o manifest.xml |
| 31 | + fi |
| 32 | +
|
| 33 | + - name: Download Manifest Archives |
| 34 | + shell: python |
| 35 | + env: |
| 36 | + PYTHONUNBUFFERED: "1" |
| 37 | + GITHUB_TOKEN: ${{ inputs.github_token }} |
| 38 | + DEBUG: ${{ inputs.debug }} |
| 39 | + working-directory: ${{ inputs.source_location }} |
| 40 | + run: | |
| 41 | + # Download Manifest Archives |
| 42 | + import xml.etree.ElementTree as ET |
| 43 | + import subprocess |
| 44 | + import os, shutil |
| 45 | + import time |
| 46 | + import glob |
| 47 | + from concurrent.futures import ThreadPoolExecutor |
| 48 | + import requests |
| 49 | + |
| 50 | + MAX_WORKERS = (os.cpu_count() or 2) * 4 |
| 51 | + TARGET_REPO = "${{ github.repository }}" |
| 52 | + TOOLCHAIN_KEYWORDS = ["clang", "rust"] |
| 53 | + DEBUG = os.environ.get("DEBUG", "false").lower() == "true" |
| 54 | + aria_quiet_flags = "--quiet --summary-interval=0" if not DEBUG else "" |
| 55 | + |
| 56 | + print("::group::Download Manifest Archives") |
| 57 | + |
| 58 | + def get_release_parts(label, rev): |
| 59 | + url = f"https://api.github.com/repos/{TARGET_REPO}/releases" |
| 60 | + headers = { |
| 61 | + "Authorization": f"token {os.environ['GITHUB_TOKEN']}", |
| 62 | + "Accept": "application/vnd.github.v3+json" |
| 63 | + } |
| 64 | + |
| 65 | + for attempt in range(3): |
| 66 | + try: |
| 67 | + response = requests.get(url, headers=headers) |
| 68 | + response.raise_for_status() |
| 69 | + releases = response.json() |
| 70 | + release = next((r for r in releases if r['name'] == "Toolchains Mirror Cache" or r['tag_name'] == "toolchain-cache"), None) |
| 71 | + if not release: return [] |
| 72 | + |
| 73 | + prefix = f"{label}-{rev}.tar.gz" |
| 74 | + return [(a['name'], a['url']) for a in release['assets'] if a['name'].startswith(prefix)] |
| 75 | + except Exception as e: |
| 76 | + print(f" [RETRY {attempt+1}] API failed: {e}") |
| 77 | + time.sleep(2) |
| 78 | + return [] |
| 79 | + |
| 80 | + def sync_project(task): |
| 81 | + name, path, url, strip, rev = task |
| 82 | + if path not in ["./", "."]: |
| 83 | + os.makedirs(path, exist_ok=True) |
| 84 | + |
| 85 | + headers = ( |
| 86 | + "-H 'User-Agent: Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36' " |
| 87 | + "-H 'Accept: text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,*/*;q=0.8' " |
| 88 | + "-H 'Accept-Encoding: gzip, deflate, br' " |
| 89 | + "-H 'Connection: keep-alive' " |
| 90 | + "--tcp-fastopen" |
| 91 | + ) |
| 92 | + |
| 93 | + print(f"Syncing: {name} -> {path}") |
| 94 | + start_time = time.time() |
| 95 | + print(f" [PENDING] {name}") |
| 96 | + try: |
| 97 | + match = next((x for x in TOOLCHAIN_KEYWORDS if x in name.lower()), None) |
| 98 | + if match: |
| 99 | + label = match |
| 100 | + base_filename = f"{label}-{rev}.tar.gz" |
| 101 | + |
| 102 | + asset_data = get_release_parts(label, rev) |
| 103 | + |
| 104 | + if not asset_data: |
| 105 | + print(f" [ERROR] No assets found for {base_filename} in release!") |
| 106 | + return False |
| 107 | + |
| 108 | + if DEBUG: |
| 109 | + print(f" [CACHE] Fetching {label} toolchain: {base_filename}...") |
| 110 | + |
| 111 | + for asset_name, api_url in asset_data: |
| 112 | + aria_cmd = ( |
| 113 | + f"aria2c -x16 -s16 -k1M --file-allocation=none {aria_quiet_flags} " |
| 114 | + f"--header='Authorization: token {os.environ['GITHUB_TOKEN']}' " |
| 115 | + f"--header='Accept: application/octet-stream' " |
| 116 | + f"-o {asset_name} {api_url}" |
| 117 | + ) |
| 118 | + subprocess.run(aria_cmd, shell=True, check=True, capture_output=not DEBUG) |
| 119 | + |
| 120 | + parts = sorted(glob.glob(f"{base_filename}.part*")) |
| 121 | + if parts: |
| 122 | + if DEBUG: |
| 123 | + print(f" [MERGE] Combining {len(parts)} parts for {rev}...") |
| 124 | + subprocess.run(f"cat {base_filename}.part* | tar -I pigz -x --no-same-owner --no-same-permissions -C {path} {strip}", shell=True, check=True) |
| 125 | + subprocess.run(f"rm {base_filename}.part*", shell=True, check=True) |
| 126 | + else: |
| 127 | + if os.path.exists(base_filename): |
| 128 | + if DEBUG: |
| 129 | + print(f" [EXTRACT] Single file detected...") |
| 130 | + subprocess.run(f"tar -I pigz -x --no-same-owner --no-same-permissions -f {base_filename} -C {path} {strip}", shell=True, check=True) |
| 131 | + os.remove(base_filename) |
| 132 | + else: |
| 133 | + print(f" [ERROR] {base_filename} missing after download!") |
| 134 | + return False |
| 135 | + else: |
| 136 | + cmd = f"curl -LfsS {headers} --retry 5 --connect-timeout 30 '{url}' | tar -I pigz -x -C {path} {strip}" |
| 137 | + subprocess.run(cmd, shell=True, check=True) |
| 138 | + |
| 139 | + duration = time.time() - start_time |
| 140 | + print(f"Synced {name} successfully! ({duration:.2f}s)") |
| 141 | + return True |
| 142 | + except subprocess.CalledProcessError as e: |
| 143 | + print(f" [ERROR] Command failed for {name}: {e.cmd}") |
| 144 | + print(f" Stderr: {e.stderr.decode() if e.stderr else 'No stderr'}") |
| 145 | + return False |
| 146 | + except Exception as e: |
| 147 | + print(f" [ERROR] Failed to sync {name}") |
| 148 | + return False |
| 149 | + |
| 150 | + global_start = time.time() |
| 151 | + |
| 152 | + with open('manifest.xml', 'r') as f: |
| 153 | + manifest_content = f.read() |
| 154 | + |
| 155 | + root = ET.fromstring(manifest_content) |
| 156 | + top_dir = os.getcwd() |
| 157 | + |
| 158 | + remotes = {r.get('name'): r.get('fetch').rstrip('/') for r in root.findall('remote')} |
| 159 | + default = root.find('default') |
| 160 | + def_remote = default.get('remote') if default is not None else None |
| 161 | + def_rev = default.get('revision') if default is not None else None |
| 162 | + |
| 163 | + sync_tasks = [] |
| 164 | + post_process_data = [] |
| 165 | + |
| 166 | + for project in root.findall('project'): |
| 167 | + name = project.get('name') |
| 168 | + path = project.get('path', name) |
| 169 | + remote_name = project.get('remote', def_remote) |
| 170 | + rev = project.get('revision', def_rev) |
| 171 | + base_url = remotes.get(remote_name) |
| 172 | + |
| 173 | + if not base_url: continue |
| 174 | + |
| 175 | + if "github.com" in base_url: |
| 176 | + url = f"{base_url}/{name}/archive/{rev}.tar.gz" |
| 177 | + strip = "--strip-components=1" |
| 178 | + elif "googlesource.com" in base_url: |
| 179 | + url = f"{base_url}/{name}/+archive/{rev}.tar.gz" |
| 180 | + strip = "" |
| 181 | + elif "git.codelinaro.org" in base_url: |
| 182 | + url = f"{base_url}/{name}/-/archive/{rev}.tar.gz" |
| 183 | + strip = "--strip-components=1" |
| 184 | + else: |
| 185 | + continue |
| 186 | + |
| 187 | + sync_tasks.append((name, path, url, strip, rev)) |
| 188 | + |
| 189 | + for child in project: |
| 190 | + if child.tag in ['linkfile', 'copyfile']: |
| 191 | + post_process_data.append((path, child)) |
| 192 | + |
| 193 | + if DEBUG: |
| 194 | + print(f"Starting parallel sync of {len(sync_tasks)} projects...") |
| 195 | + with ThreadPoolExecutor(max_workers=MAX_WORKERS) as executor: |
| 196 | + success_list = list(executor.map(sync_project, sync_tasks)) |
| 197 | + |
| 198 | + if not all(success_list): |
| 199 | + print("::error::One or more projects failed to sync!") |
| 200 | + print("::endgroup::") |
| 201 | + exit(1) |
| 202 | + |
| 203 | + print("Processing linkfiles and copyfiles...") |
| 204 | + for path, child in post_process_data: |
| 205 | + src_rel = child.get('src') |
| 206 | + dest_rel = child.get('dest') |
| 207 | + if not src_rel or not dest_rel: continue |
| 208 | + |
| 209 | + src_path = os.path.join(top_dir, path, src_rel) |
| 210 | + dest_path = os.path.join(top_dir, dest_rel) |
| 211 | + os.makedirs(os.path.dirname(dest_path), exist_ok=True) |
| 212 | + |
| 213 | + if child.tag == 'linkfile': |
| 214 | + if os.path.lexists(dest_path): os.remove(dest_path) |
| 215 | + rel_target = os.path.relpath(src_path, os.path.dirname(dest_path)) |
| 216 | + os.symlink(rel_target, dest_path) |
| 217 | + print(f" [Link] {dest_rel} -> {src_rel}") |
| 218 | + elif child.tag == 'copyfile': |
| 219 | + shutil.copy2(src_path, dest_path) |
| 220 | + print(f" [Copy] {dest_rel} from {src_rel}") |
| 221 | + |
| 222 | + |
| 223 | + total_duration = time.time() - global_start |
| 224 | + minutes = int(total_duration // 60) |
| 225 | + seconds = total_duration % 60 |
| 226 | + print(f"Kernel Sync completed in {minutes}m {seconds:.2f}s") |
| 227 | + print("::endgroup::") |
0 commit comments