share.py
177 lines
| 6.2 KiB
| text/x-python
|
PythonLexer
/ hgext / share.py
|
r8801 | # Copyright 2006, 2007 Matt Mackall <mpm@selenic.com> | ||
# | ||||
# This software may be used and distributed according to the terms of the | ||||
|
r10263 | # GNU General Public License version 2 or any later version. | ||
|
r8801 | |||
|
r25761 | '''share a common history between several working directories | ||
Automatic Pooled Storage for Clones | ||||
----------------------------------- | ||||
When this extension is active, :hg:`clone` can be configured to | ||||
automatically share/pool storage across multiple clones. This | ||||
mode effectively converts :hg:`clone` to :hg:`clone` + :hg:`share`. | ||||
The benefit of using this mode is the automatic management of | ||||
store paths and intelligent pooling of related repositories. | ||||
The following ``share.`` config options influence this feature: | ||||
|
r25851 | ``share.pool`` | ||
|
r25761 | Filesystem path where shared repository data will be stored. When | ||
defined, :hg:`clone` will automatically use shared repository | ||||
storage instead of creating a store inside each clone. | ||||
|
r25851 | ``share.poolnaming`` | ||
|
r25761 | How directory names in ``share.pool`` are constructed. | ||
"identity" means the name is derived from the first changeset in the | ||||
repository. In this mode, different remotes share storage if their | ||||
root/initial changeset is identical. In this mode, the local shared | ||||
repository is an aggregate of all encountered remote repositories. | ||||
"remote" means the name is derived from the source repository's | ||||
path or URL. In this mode, storage is only shared if the path or URL | ||||
requested in the :hg:`clone` command matches exactly to a repository | ||||
that was cloned before. | ||||
The default naming mode is "identity." | ||||
''' | ||||
|
r8873 | |||
|
r8801 | from mercurial.i18n import _ | ||
|
r26587 | from mercurial import cmdutil, commands, hg, util, extensions, bookmarks, error | ||
|
r23548 | from mercurial.hg import repository, parseurl | ||
import errno | ||||
|
r15079 | |||
|
r21253 | cmdtable = {} | ||
command = cmdutil.command(cmdtable) | ||||
|
r25186 | # Note for extension authors: ONLY specify testedwith = 'internal' for | ||
# extensions which SHIP WITH MERCURIAL. Non-mainline extensions should | ||||
# be specifying the version(s) of Mercurial they are tested with, or | ||||
# leave the attribute unspecified. | ||||
|
r16743 | testedwith = 'internal' | ||
|
r21253 | @command('share', | ||
|
r24364 | [('U', 'noupdate', None, _('do not create a working directory')), | ||
|
r23614 | ('B', 'bookmarks', None, _('also share bookmarks'))], | ||
_('[-U] [-B] SOURCE [DEST]'), | ||||
|
r21772 | norepo=True) | ||
|
r23614 | def share(ui, source, dest=None, noupdate=False, bookmarks=False): | ||
|
r10798 | """create a new shared repository | ||
|
r8801 | |||
|
r9273 | Initialize a new repository and working directory that shares its | ||
|
r23614 | history (and optionally bookmarks) with another repository. | ||
|
r8801 | |||
|
r12389 | .. note:: | ||
|
r19997 | |||
|
r12389 | using rollback or extensions that destroy/modify history (mq, | ||
rebase, etc.) can cause considerable confusion with shared | ||||
clones. In particular, if two shared clones are both updated to | ||||
the same changeset, and one of them destroys that changeset | ||||
with rollback, the other clone will suddenly stop working: all | ||||
operations will fail with "abort: working directory has unknown | ||||
parent". The only known workaround is to use debugsetparents on | ||||
|
r19399 | the broken clone to reset it to a changeset that still exists. | ||
|
r8801 | """ | ||
|
r27353 | return hg.share(ui, source, dest=dest, update=not noupdate, | ||
bookmarks=bookmarks) | ||||
|
r8801 | |||
|
r21253 | @command('unshare', [], '') | ||
|
r15079 | def unshare(ui, repo): | ||
"""convert a shared repository to a normal one | ||||
Copy the store data to the repo and remove the sharedpath data. | ||||
""" | ||||
|
r23666 | if not repo.shared(): | ||
|
r26587 | raise error.Abort(_("this is not a shared repo")) | ||
|
r15079 | |||
destlock = lock = None | ||||
lock = repo.lock() | ||||
try: | ||||
# we use locks here because if we race with commit, we | ||||
# can end up with extra data in the cloned revlogs that's | ||||
# not pointed to by changesets, thus causing verify to | ||||
# fail | ||||
destlock = hg.copystore(ui, repo, repo.path) | ||||
sharefile = repo.join('sharedpath') | ||||
util.rename(sharefile, sharefile + '.old') | ||||
repo.requirements.discard('sharedpath') | ||||
repo._writerequirements() | ||||
finally: | ||||
destlock and destlock.release() | ||||
lock and lock.release() | ||||
|
r25666 | # update store, spath, svfs and sjoin of repo | ||
|
r20056 | repo.unfiltered().__init__(repo.baseui, repo.root) | ||
|
r23548 | |||
|
r25761 | # Wrap clone command to pass auto share options. | ||
def clone(orig, ui, source, *args, **opts): | ||||
pool = ui.config('share', 'pool', None) | ||||
if pool: | ||||
pool = util.expandpath(pool) | ||||
opts['shareopts'] = dict( | ||||
pool=pool, | ||||
mode=ui.config('share', 'poolnaming', 'identity'), | ||||
) | ||||
return orig(ui, source, *args, **opts) | ||||
|
r23548 | def extsetup(ui): | ||
|
r27186 | extensions.wrapfunction(bookmarks, '_getbkfile', getbkfile) | ||
|
r23548 | extensions.wrapfunction(bookmarks.bmstore, 'recordchange', recordchange) | ||
|
r26933 | extensions.wrapfunction(bookmarks.bmstore, '_writerepo', writerepo) | ||
|
r25761 | extensions.wrapcommand(commands.table, 'clone', clone) | ||
|
r23548 | |||
def _hassharedbookmarks(repo): | ||||
"""Returns whether this repo has shared bookmarks""" | ||||
try: | ||||
|
r23883 | shared = repo.vfs.read('shared').splitlines() | ||
|
r25660 | except IOError as inst: | ||
|
r23548 | if inst.errno != errno.ENOENT: | ||
raise | ||||
return False | ||||
|
r29424 | return hg.sharedbookmarks in shared | ||
|
r23548 | |||
def _getsrcrepo(repo): | ||||
""" | ||||
Returns the source repository object for a given shared repository. | ||||
If repo is not a shared repository, return None. | ||||
""" | ||||
|
r23626 | if repo.sharedpath == repo.path: | ||
return None | ||||
# the sharedpath always ends in the .hg; we want the path to the repo | ||||
source = repo.vfs.split(repo.sharedpath)[0] | ||||
srcurl, branches = parseurl(source) | ||||
return repository(repo.ui, srcurl) | ||||
|
r23548 | |||
|
r27186 | def getbkfile(orig, repo): | ||
|
r23548 | if _hassharedbookmarks(repo): | ||
srcrepo = _getsrcrepo(repo) | ||||
if srcrepo is not None: | ||||
repo = srcrepo | ||||
|
r27186 | return orig(repo) | ||
|
r23548 | |||
def recordchange(orig, self, tr): | ||||
# Continue with write to local bookmarks file as usual | ||||
orig(self, tr) | ||||
if _hassharedbookmarks(self._repo): | ||||
srcrepo = _getsrcrepo(self._repo) | ||||
if srcrepo is not None: | ||||
category = 'share-bookmarks' | ||||
tr.addpostclose(category, lambda tr: self._writerepo(srcrepo)) | ||||
|
r26933 | def writerepo(orig, self, repo): | ||
|
r23548 | # First write local bookmarks file in case we ever unshare | ||
|
r26933 | orig(self, repo) | ||
|
r23548 | if _hassharedbookmarks(self._repo): | ||
srcrepo = _getsrcrepo(self._repo) | ||||
if srcrepo is not None: | ||||
|
r26933 | orig(self, srcrepo) | ||