| indygreg |
| hg-reviewers |
We will be reusing this in an upcoming patch, so better to refactor it into a
separate function. Also the underlying handling deserves a function of it's own.
| Automatic diff as part of commit; lint not applicable. |
| Automatic diff as part of commit; unit tests not applicable. |
| # functions defined in loaded extensions are called. | # functions defined in loaded extensions are called. | ||||
| # | # | ||||
| # The function receives a set of requirement strings that the repository | # The function receives a set of requirement strings that the repository | ||||
| # is capable of opening. Functions will typically add elements to the | # is capable of opening. Functions will typically add elements to the | ||||
| # set to reflect that the extension knows how to handle that requirements. | # set to reflect that the extension knows how to handle that requirements. | ||||
| featuresetupfuncs = set() | featuresetupfuncs = set() | ||||
| def _getsharedvfs(hgvfs, requirements): | |||||
| """ returns the vfs object pointing to root of shared source | |||||
| repo for a shared repository | |||||
| hgvfs is vfs pointing at .hg/ of current repo (shared one) | |||||
| requirements is a set of requirements of current repo (shared one) | |||||
| """ | |||||
| # The ``shared`` or ``relshared`` requirements indicate the | |||||
| # store lives in the path contained in the ``.hg/sharedpath`` file. | |||||
| # This is an absolute path for ``shared`` and relative to | |||||
| # ``.hg/`` for ``relshared``. | |||||
| sharedpath = hgvfs.read(b'sharedpath').rstrip(b'\n') | |||||
| if b'relshared' in requirements: | |||||
| sharedpath = hgvfs.join(sharedpath) | |||||
| sharedvfs = vfsmod.vfs(sharedpath, realpath=True) | |||||
| if not sharedvfs.exists(): | |||||
| raise error.RepoError( | |||||
| _(b'.hg/sharedpath points to nonexistent directory %s') | |||||
| % sharedvfs.base | |||||
| ) | |||||
| return sharedvfs | |||||
| def makelocalrepository(baseui, path, intents=None): | def makelocalrepository(baseui, path, intents=None): | ||||
| """Create a local repository object. | """Create a local repository object. | ||||
| Given arguments needed to construct a local repository, this function | Given arguments needed to construct a local repository, this function | ||||
| performs various early repository loading functionality (such as | performs various early repository loading functionality (such as | ||||
| reading the ``.hg/requires`` and ``.hg/hgrc`` files), validates that | reading the ``.hg/requires`` and ``.hg/hgrc`` files), validates that | ||||
| the repository can be opened, derives a type suitable for representing | the repository can be opened, derives a type suitable for representing | ||||
| that repository, and returns an instance of it. | that repository, and returns an instance of it. | ||||
| ui.copy = baseui.copy | ui.copy = baseui.copy | ||||
| # Working directory VFS rooted at repository root. | # Working directory VFS rooted at repository root. | ||||
| wdirvfs = vfsmod.vfs(path, expandpath=True, realpath=True) | wdirvfs = vfsmod.vfs(path, expandpath=True, realpath=True) | ||||
| # Main VFS for .hg/ directory. | # Main VFS for .hg/ directory. | ||||
| hgpath = wdirvfs.join(b'.hg') | hgpath = wdirvfs.join(b'.hg') | ||||
| hgvfs = vfsmod.vfs(hgpath, cacheaudited=True) | hgvfs = vfsmod.vfs(hgpath, cacheaudited=True) | ||||
| # Whether this repository is shared one or not | |||||
| shared = False | |||||
| # If this repository is shared, vfs pointing to shared repo | |||||
| sharedvfs = None | |||||
| # The .hg/ path should exist and should be a directory. All other | # The .hg/ path should exist and should be a directory. All other | ||||
| # cases are errors. | # cases are errors. | ||||
| if not hgvfs.isdir(): | if not hgvfs.isdir(): | ||||
| try: | try: | ||||
| hgvfs.stat() | hgvfs.stat() | ||||
| except OSError as e: | except OSError as e: | ||||
| if e.errno != errno.ENOENT: | if e.errno != errno.ENOENT: | ||||
| # that shared store since it has an unknown-to-us requirement. | # that shared store since it has an unknown-to-us requirement. | ||||
| # At this point, we know we should be capable of opening the repository. | # At this point, we know we should be capable of opening the repository. | ||||
| # Now get on with doing that. | # Now get on with doing that. | ||||
| features = set() | features = set() | ||||
| # The "store" part of the repository holds versioned data. How it is | # The "store" part of the repository holds versioned data. How it is | ||||
| # accessed is determined by various requirements. The ``shared`` or | # accessed is determined by various requirements. If `shared` or | ||||
| # ``relshared`` requirements indicate the store lives in the path contained | # `relshared` requirements are present, this indicates current repository | ||||
| # in the ``.hg/sharedpath`` file. This is an absolute path for | # is a share and store exists in path mentioned in `.hg/sharedpath` | ||||
| # ``shared`` and relative to ``.hg/`` for ``relshared``. | shared = b'shared' in requirements or b'relshared' in requirements | ||||
| if b'shared' in requirements or b'relshared' in requirements: | if shared: | ||||
| sharedpath = hgvfs.read(b'sharedpath').rstrip(b'\n') | sharedvfs = _getsharedvfs(hgvfs, requirements) | ||||
| if b'relshared' in requirements: | |||||
| sharedpath = hgvfs.join(sharedpath) | |||||
| sharedvfs = vfsmod.vfs(sharedpath, realpath=True) | |||||
| if not sharedvfs.exists(): | |||||
| raise error.RepoError( | |||||
| _(b'.hg/sharedpath points to nonexistent directory %s') | |||||
| % sharedvfs.base | |||||
| ) | |||||
| features.add(repository.REPO_FEATURE_SHARED_STORAGE) | |||||
| storebasepath = sharedvfs.base | storebasepath = sharedvfs.base | ||||
| cachepath = sharedvfs.join(b'cache') | cachepath = sharedvfs.join(b'cache') | ||||
| features.add(repository.REPO_FEATURE_SHARED_STORAGE) | |||||
| else: | else: | ||||
| storebasepath = hgvfs.base | storebasepath = hgvfs.base | ||||
| cachepath = hgvfs.join(b'cache') | cachepath = hgvfs.join(b'cache') | ||||
| wcachepath = hgvfs.join(b'wcache') | wcachepath = hgvfs.join(b'wcache') | ||||
| # The store has changed over time and the exact layout is dictated by | # The store has changed over time and the exact layout is dictated by | ||||
| # requirements. The store interface abstracts differences across all | # requirements. The store interface abstracts differences across all | ||||
| # of them. | # of them. | ||||