| # Copyright (c) 2012 The Chromium OS Authors. All rights reserved. |
| # Use of this source code is governed by a BSD-style license that can be |
| # found in the LICENSE file. |
| |
| """ |
| Repository module to handle different types of repositories the Builders use. |
| """ |
| |
| import constants |
| import logging |
| import os |
| import re |
| import shutil |
| |
| from chromite.buildbot import configure_repo |
| from chromite.lib import cros_build_lib |
| from chromite.lib import osutils |
| from chromite.lib import rewrite_git_alternates |
| |
| # File that marks a buildroot as being used by a trybot |
| _TRYBOT_MARKER = '.trybot' |
| |
| |
| class SrcCheckOutException(Exception): |
| """Exception gets thrown for failure to sync sources""" |
| pass |
| |
| |
| def InARepoRepository(directory, require_project=False): |
| """Returns True if directory is part of a repo checkout. |
| |
| Args: |
| directory: Path to check. |
| require_project: Whether to require that directory is inside a valid |
| project in the repo root. |
| """ |
| directory = os.path.abspath(directory) |
| while not os.path.isdir(directory): |
| directory = os.path.dirname(directory) |
| |
| if require_project: |
| cmd = ['repo', 'forall', '.', '-c', 'true'] |
| else: |
| cmd = ['repo'] |
| |
| output = cros_build_lib.RunCommand( |
| cmd, error_code_ok=True, redirect_stdout=True, redirect_stderr=True, |
| cwd=directory, print_cmd=False) |
| return output.returncode == 0 |
| |
| |
| def IsARepoRoot(directory): |
| """Returns True if directory is the root of a repo checkout.""" |
| # Check for the underlying git-repo checkout. If it exists, it's |
| # definitely the repo root. If it doesn't, it may be an aborted |
| # checkout- either way it isn't usable. |
| repo_dir = os.path.join(directory, '.repo') |
| return (os.path.isdir(os.path.join(repo_dir, 'repo')) and |
| os.path.isdir(os.path.join(repo_dir, 'manifests'))) |
| |
| |
| def IsInternalRepoCheckout(root): |
| """Returns whether root houses an internal 'repo' checkout.""" |
| manifest_dir = os.path.join(root, '.repo', 'manifests') |
| manifest_url = cros_build_lib.RunGitCommand( |
| manifest_dir, ['config', 'remote.origin.url']).output.strip() |
| return (os.path.splitext(os.path.basename(manifest_url))[0] |
| == os.path.splitext(os.path.basename(constants.MANIFEST_INT_URL))[0]) |
| |
| |
| def CloneGitRepo(working_dir, repo_url, reference=None, bare=False, |
| mirror=False, retries=2): |
| """Clone given git repo |
| Args: |
| repo_url: git repo to clone |
| repo_dir: location where it should be cloned to |
| reference: If given, pathway to a git repository to access git objects |
| from. Note that the reference must exist as long as the newly created |
| repo is to be usable. |
| bare: Clone a bare checkout. |
| mirror: Clone a mirror checkout. |
| retries: If error code 128 is encountered, how many times to retry. When |
| 128 is returned from git, it's essentially a server error- specifically |
| common to manifest-versions and gerrit. |
| """ |
| osutils.SafeMakedirs(working_dir) |
| cmd = ['git', 'clone', repo_url, working_dir] |
| if reference: |
| cmd += ['--reference', reference] |
| if bare: |
| cmd += ['--bare'] |
| if mirror: |
| cmd += ['--mirror'] |
| cros_build_lib.RunCommandWithRetries( |
| retries, cmd, cwd=working_dir, redirect_stdout=True, redirect_stderr=True, |
| retry_on=[128]) |
| |
| |
| def GetTrybotMarkerPath(buildroot): |
| """Get path to trybot marker file given the buildroot.""" |
| return os.path.join(buildroot, _TRYBOT_MARKER) |
| |
| |
| def CreateTrybotMarker(buildroot): |
| """Create the file that identifies a buildroot as being used by a trybot.""" |
| osutils.WriteFile(GetTrybotMarkerPath(buildroot), '') |
| |
| def ClearBuildRoot(buildroot, preserve_paths=()): |
| """Remove and recreate the buildroot while preserving the trybot marker.""" |
| trybot_root = os.path.exists(GetTrybotMarkerPath(buildroot)) |
| if os.path.exists(buildroot): |
| cmd = ['find', buildroot, '-mindepth', '1', '-maxdepth', '1'] |
| |
| ignores = [] |
| for path in preserve_paths: |
| if ignores: |
| ignores.append('-a') |
| ignores += ['!', '-name', path] |
| cmd.extend(ignores) |
| |
| cmd += ['-exec', 'rm', '-rf', '{}', '+'] |
| cros_build_lib.SudoRunCommand(cmd) |
| else: |
| os.makedirs(buildroot) |
| if trybot_root: |
| CreateTrybotMarker(buildroot) |
| |
| |
| class RepoRepository(object): |
| """ A Class that encapsulates a repo repository. |
| Args: |
| repo_url: gitserver URL to fetch repo manifest from. |
| directory: local path where to checkout the repository. |
| branch: Branch to check out the manifest at. |
| """ |
| DEFAULT_MANIFEST = 'default' |
| # Use our own repo, in case android.kernel.org (the default location) is down. |
| _INIT_CMD = ['repo', 'init', '--repo-url', constants.REPO_URL] |
| |
| def __init__(self, repo_url, directory, branch=None, referenced_repo=None, |
| manifest=None, depth=None): |
| self.repo_url = repo_url |
| self.directory = directory |
| self.branch = branch |
| |
| # It's perfectly acceptable to pass in a reference pathway that isn't |
| # usable. Detect it, and suppress the setting so that any depth |
| # settings aren't disabled due to it. |
| if referenced_repo is not None and not IsARepoRoot(referenced_repo): |
| referenced_repo = None |
| self._referenced_repo = referenced_repo |
| self._manifest = manifest |
| |
| # If the repo exists already, force a selfupdate as the first step. |
| self._repo_update_needed = IsARepoRoot(self.directory) |
| if not self._repo_update_needed and InARepoRepository(self.directory): |
| raise ValueError('Given directory %s is not the root of a repository.' |
| % self.directory) |
| |
| if depth is not None and referenced_repo is None: |
| depth = int(depth) |
| self._depth = depth |
| |
| def _SwitchToLocalManifest(self, local_manifest): |
| """Reinitializes the repository if the manifest has changed.""" |
| logging.debug('Moving to manifest defined by %s', local_manifest) |
| # TODO: use upstream repo's manifest logic when we bump repo version. |
| manifest_path = self.GetRelativePath('.repo/manifest.xml') |
| os.unlink(manifest_path) |
| shutil.copyfile(local_manifest, manifest_path) |
| |
| def Initialize(self, local_manifest=None, extra_args=()): |
| """Initializes a repository. Optionally forces a local manifest. |
| |
| Args: |
| local_manifest: The absolute path to a custom manifest to use. This will |
| replace .repo/manifest.xml. |
| extra_args: Extra args to pass to 'repo init' |
| """ |
| # Wipe local_manifest.xml if it exists- it can interfere w/ things in |
| # bad ways (duplicate projects, etc); we control this repository, thus |
| # we can destroy it. |
| osutils.SafeUnlink(os.path.join(self.directory, 'local_manifest.xml')) |
| |
| # Force a repo self update first; during reinit, repo doesn't do the |
| # update itself, but we could be doing the init on a repo version less |
| # then v1.9.4, which didn't have proper support for doing reinit that |
| # involved changing the manifest branch in use; thus selfupdate. |
| # Additionally, if the self update fails for *any* reason, wipe the repo |
| # innards and force repo init to redownload it; same end result, just |
| # less efficient. |
| # Additionally, note that this method may be called multiple times; |
| # thus code appropriately. |
| if self._repo_update_needed: |
| try: |
| cros_build_lib.RunCommand(['repo', 'selfupdate'], cwd=self.directory) |
| except cros_build_lib.RunCommandError: |
| osutils.RmDir(os.path.join(self.directory, '.repo', 'repo'), |
| ignore_missing=True) |
| self._repo_update_needed = False |
| |
| init_cmd = self._INIT_CMD + ['--manifest-url', self.repo_url] |
| if self._referenced_repo: |
| init_cmd.extend(['--reference', self._referenced_repo]) |
| if self._manifest: |
| init_cmd.extend(['--manifest-name', self._manifest]) |
| if self._depth is not None: |
| init_cmd.extend(['--depth', str(self._depth)]) |
| init_cmd.extend(extra_args) |
| # Handle branch / manifest options. |
| if self.branch: |
| init_cmd.extend(['--manifest-branch', self.branch]) |
| |
| cros_build_lib.RunCommand(init_cmd, cwd=self.directory, input='\n\ny\n') |
| if local_manifest and local_manifest != self.DEFAULT_MANIFEST: |
| self._SwitchToLocalManifest(local_manifest) |
| |
| @property |
| def _ManifestConfig(self): |
| return os.path.join(self.directory, '.repo', 'manifests.git', 'config') |
| |
| def _EnsureMirroring(self, post_sync=False): |
| """Ensure git is usable from w/in the chroot if --references is enabled |
| |
| repo init --references hardcodes the abspath to parent; this pathway |
| however isn't usable from the chroot (it doesn't exist). As such the |
| pathway is rewritten to use relative pathways pointing at the root of |
| the repo, which via I84988630 enter_chroot sets up a helper bind mount |
| allowing git/repo to access the actual referenced repo. |
| |
| This has to be invoked prior to a repo sync of the target trybot to |
| fix any pathways that may have been broken by the parent repo moving |
| on disk, and needs to be invoked after the sync has completed to rewrite |
| any new project's abspath to relative. |
| """ |
| |
| if not self._referenced_repo: |
| return |
| |
| proj_root = os.path.join(self.directory, '.repo', 'projects') |
| if not os.path.exists(proj_root): |
| # Not yet synced, nothing to be done. |
| return |
| |
| rewrite_git_alternates.RebuildRepoCheckout(self.directory, |
| self._referenced_repo) |
| |
| if post_sync: |
| chroot_path = os.path.join(self._referenced_repo, '.repo', 'chroot', |
| 'external') |
| chroot_path = cros_build_lib.ReinterpretPathForChroot(chroot_path) |
| rewrite_git_alternates.RebuildRepoCheckout( |
| self.directory, self._referenced_repo, chroot_path) |
| |
| # Finally, force the git config marker that enter_chroot looks for |
| # to know when to do bind mounting trickery; this normally will exist, |
| # but if we're converting a pre-existing repo checkout, it's possible |
| # that it was invoked w/out the reference arg. Note this must be |
| # an absolute path to the source repo- enter_chroot uses that to know |
| # what to bind mount into the chroot. |
| cros_build_lib.RunCommand( |
| ['git', 'config', '--file', self._ManifestConfig, 'repo.reference', |
| self._referenced_repo]) |
| |
| def Sync(self, local_manifest=None, jobs=None, cleanup=True): |
| """Sync/update the source. Changes manifest if specified. |
| |
| Args: |
| local_manifest: If set, checks out source to manifest. DEFAULT_MANIFEST |
| may be used to set it back to the default manifest. |
| jobs: may be set to override the default sync parallelism defined by |
| the manifest. |
| """ |
| try: |
| # Always re-initialize to the current branch. |
| self.Initialize(local_manifest) |
| # Fix existing broken mirroring configurations. |
| self._EnsureMirroring() |
| |
| if cleanup: |
| configure_repo.FixBrokenExistingRepos(self.directory) |
| |
| cmd = ['repo', '--time', 'sync'] |
| if jobs: |
| cmd += ['--jobs', str(jobs)] |
| # Do the network half of the sync; retry as necessary to get the content. |
| cros_build_lib.RunCommandWithRetries(2, cmd + ['-n'], cwd=self.directory) |
| |
| # Do the local sync; note that there is a couple of corner cases where |
| # the new manifest cannot transition from the old checkout cleanly- |
| # primarily involving git submodules. Thus we intercept, and do |
| # a forced wipe, then a retry. |
| try: |
| cros_build_lib.RunCommand(cmd + ['-l'], cwd=self.directory) |
| except cros_build_lib.RunCommandError: |
| manifest = cros_build_lib.ManifestCheckout.Cached(self.directory) |
| targets = set(project['path'].split('/', 1)[0] |
| for project in manifest.projects.itervalues()) |
| if not targets: |
| # No directories to wipe, thus nothing we can fix. |
| raise |
| cros_build_lib.SudoRunCommand(['rm', '-rf'] + sorted(targets), |
| cwd=self.directory) |
| |
| # Retry the sync now; if it fails, let the exception propagate. |
| cros_build_lib.RunCommand(cmd + ['-l'], cwd=self.directory) |
| |
| # Setup gerrit remote for any new repositories. |
| configure_repo.SetupGerritRemote(self.directory) |
| |
| # We do a second run to fix any new repositories created by repo to |
| # use relative object pathways. Note that cros_sdk also triggers the |
| # same cleanup- we however kick it erring on the side of caution. |
| self._EnsureMirroring(True) |
| |
| except cros_build_lib.RunCommandError, e: |
| err_msg = e.Stringify(error=False, output=False) |
| logging.error(err_msg) |
| raise SrcCheckOutException(err_msg) |
| |
| def GetRelativePath(self, path): |
| """Returns full path including source directory of path in repo.""" |
| return os.path.join(self.directory, path) |
| |
| def ExportManifest(self, mark_revision=False, revisions=True): |
| """Export the revision locked manifest |
| |
| Args: |
| mark_revision: If True, then the sha1 of manifest.git is recorded |
| into the resultant manifest tag as a version attribute. |
| Specifically, if manifests.git is at 1234, <manifest> becomes |
| <manifest revision="1234">. |
| revisions: If True, then rewrite all branches/tags into a specific |
| sha1 revision. If False, don't. |
| Returns: |
| The manifest as a string. |
| """ |
| cmd = ['repo', 'manifest', '-o', '-'] |
| if revisions: |
| cmd += ['-r'] |
| output = cros_build_lib.RunCommandCaptureOutput( |
| cmd, cwd=self.directory, print_cmd=False, |
| extra_env={'PAGER':'cat'}).output |
| |
| if not mark_revision: |
| return output |
| modified = cros_build_lib.RunGitCommand( |
| os.path.join(self.directory, '.repo/manifests'), |
| ['rev-list', '-n1', 'HEAD']) |
| assert modified.output |
| return output.replace("<manifest>", '<manifest revision="%s">' % |
| modified.output.strip()) |
| |
| def IsManifestDifferent(self, other_manifest): |
| """Checks whether this manifest is different than another. |
| |
| May blacklists certain repos as part of the diff. |
| |
| Args: |
| other_manfiest: Second manifest file to compare against. |
| Returns: |
| True: If the manifests are different |
| False: If the manifests are same |
| """ |
| logging.debug('Calling IsManifestDifferent against %s', other_manifest) |
| |
| black_list = ['="chromium/'] |
| blacklist_pattern = re.compile(r'|'.join(black_list)) |
| manifest_revision_pattern = re.compile(r'<manifest revision="[a-f0-9]+">', |
| re.I) |
| |
| current = self.ExportManifest() |
| with open(other_manifest, 'r') as manifest2_fh: |
| for (line1, line2) in zip(current.splitlines(), manifest2_fh): |
| line1 = line1.strip() |
| line2 = line2.strip() |
| if blacklist_pattern.search(line1): |
| logging.debug('%s ignored %s', line1, line2) |
| continue |
| |
| if line1 != line2: |
| logging.debug('Current and other manifest differ.') |
| logging.debug('current: "%s"', line1) |
| logging.debug('other : "%s"', line2) |
| |
| # Ignore revision differences on the manifest line. The revision of |
| # the manifest.git repo is uninteresting when determining if the |
| # current manifest describes the same sources as the other manifest. |
| if manifest_revision_pattern.search(line2): |
| logging.debug('Ignoring difference in manifest revision.') |
| continue |
| |
| return True |
| |
| return False |
