context.py
1371 lines
| 43.9 KiB
| text/x-python
|
PythonLexer
/ mercurial / context.py
|
r2563 | # context.py - changeset and file context objects for mercurial | ||
# | ||||
|
r4635 | # Copyright 2006, 2007 Matt Mackall <mpm@selenic.com> | ||
|
r2563 | # | ||
|
r8225 | # This software may be used and distributed according to the terms of the | ||
|
r10263 | # GNU General Public License version 2 or any later version. | ||
|
r2563 | |||
|
r16376 | from node import nullid, nullrev, short, hex, bin | ||
|
r3891 | from i18n import _ | ||
|
r15818 | import ancestor, mdiff, error, util, scmutil, subrepo, patch, encoding, phases | ||
|
r16602 | import copies | ||
|
r14669 | import match as matchmod | ||
|
r11303 | import os, errno, stat | ||
|
r17469 | import obsolete as obsmod | ||
|
r18252 | import repoview | ||
|
r3122 | |||
|
r8207 | propertycache = util.propertycache | ||
|
r7368 | |||
|
r2563 | class changectx(object): | ||
"""A changecontext object makes access to data related to a particular | ||||
changeset convenient.""" | ||||
|
r6741 | def __init__(self, repo, changeid=''): | ||
|
r2563 | """changeid is a revision number, node, or tag""" | ||
|
r6741 | if changeid == '': | ||
changeid = '.' | ||||
|
r2563 | self._repo = repo | ||
|
r16376 | |||
if isinstance(changeid, int): | ||||
|
r18084 | try: | ||
self._node = repo.changelog.node(changeid) | ||||
except IndexError: | ||||
raise error.RepoLookupError( | ||||
_("unknown revision '%s'") % changeid) | ||||
|
r7367 | self._rev = changeid | ||
|
r16376 | return | ||
|
r16760 | if isinstance(changeid, long): | ||
changeid = str(changeid) | ||||
|
r16376 | if changeid == '.': | ||
self._node = repo.dirstate.p1() | ||||
self._rev = repo.changelog.rev(self._node) | ||||
return | ||||
if changeid == 'null': | ||||
self._node = nullid | ||||
self._rev = nullrev | ||||
return | ||||
if changeid == 'tip': | ||||
|
r18464 | self._node = repo.changelog.tip() | ||
self._rev = repo.changelog.rev(self._node) | ||||
|
r16376 | return | ||
if len(changeid) == 20: | ||||
try: | ||||
self._node = changeid | ||||
self._rev = repo.changelog.rev(changeid) | ||||
return | ||||
except LookupError: | ||||
pass | ||||
try: | ||||
r = int(changeid) | ||||
if str(r) != changeid: | ||||
raise ValueError | ||||
l = len(repo.changelog) | ||||
if r < 0: | ||||
r += l | ||||
if r < 0 or r >= l: | ||||
raise ValueError | ||||
self._rev = r | ||||
self._node = repo.changelog.node(r) | ||||
return | ||||
|
r18423 | except (ValueError, OverflowError, IndexError): | ||
|
r16376 | pass | ||
if len(changeid) == 40: | ||||
try: | ||||
self._node = bin(changeid) | ||||
self._rev = repo.changelog.rev(self._node) | ||||
return | ||||
except (TypeError, LookupError): | ||||
pass | ||||
if changeid in repo._bookmarks: | ||||
self._node = repo._bookmarks[changeid] | ||||
self._rev = repo.changelog.rev(self._node) | ||||
return | ||||
if changeid in repo._tagscache.tags: | ||||
self._node = repo._tagscache.tags[changeid] | ||||
self._rev = repo.changelog.rev(self._node) | ||||
return | ||||
|
r16719 | try: | ||
self._node = repo.branchtip(changeid) | ||||
|
r16376 | self._rev = repo.changelog.rev(self._node) | ||
return | ||||
|
r16719 | except error.RepoLookupError: | ||
pass | ||||
|
r16376 | |||
self._node = repo.changelog._partialmatch(changeid) | ||||
if self._node is not None: | ||||
self._rev = repo.changelog.rev(self._node) | ||||
return | ||||
# lookup failed | ||||
# check if it might have come from damaged dirstate | ||||
|
r18005 | # | ||
# XXX we could avoid the unfiltered if we had a recognizable exception | ||||
# for filtered changeset access | ||||
if changeid in repo.unfiltered().dirstate.parents(): | ||||
|
r16376 | raise error.Abort(_("working directory has unknown parent '%s'!") | ||
% short(changeid)) | ||||
try: | ||||
if len(changeid) == 20: | ||||
changeid = hex(changeid) | ||||
except TypeError: | ||||
pass | ||||
raise error.RepoLookupError( | ||||
_("unknown revision '%s'") % changeid) | ||||
|
r2563 | |||
|
r3166 | def __str__(self): | ||
return short(self.node()) | ||||
|
r6763 | def __int__(self): | ||
return self.rev() | ||||
|
r3151 | def __repr__(self): | ||
|
r3216 | return "<changectx %s>" % str(self) | ||
|
r3151 | |||
|
r6469 | def __hash__(self): | ||
try: | ||||
return hash(self._rev) | ||||
except AttributeError: | ||||
return id(self) | ||||
|
r3165 | def __eq__(self, other): | ||
|
r3715 | try: | ||
return self._rev == other._rev | ||||
except AttributeError: | ||||
return False | ||||
|
r3165 | |||
|
r4748 | def __ne__(self, other): | ||
return not (self == other) | ||||
|
r3168 | def __nonzero__(self): | ||
|
r3578 | return self._rev != nullrev | ||
|
r3168 | |||
|
r8157 | @propertycache | ||
|
r7368 | def _changeset(self): | ||
|
r16377 | return self._repo.changelog.read(self.rev()) | ||
|
r7368 | |||
|
r8157 | @propertycache | ||
|
r7368 | def _manifest(self): | ||
return self._repo.manifest.read(self._changeset[0]) | ||||
|
r8157 | @propertycache | ||
|
r7368 | def _manifestdelta(self): | ||
return self._repo.manifest.readdelta(self._changeset[0]) | ||||
|
r8157 | @propertycache | ||
|
r7368 | def _parents(self): | ||
p = self._repo.changelog.parentrevs(self._rev) | ||||
if p[1] == nullrev: | ||||
p = p[:-1] | ||||
return [changectx(self._repo, x) for x in p] | ||||
|
r3215 | |||
|
r8812 | @propertycache | ||
def substate(self): | ||||
|
r11775 | return subrepo.state(self, self._repo.ui) | ||
|
r8812 | |||
|
r4909 | def __contains__(self, key): | ||
return key in self._manifest | ||||
def __getitem__(self, key): | ||||
return self.filectx(key) | ||||
def __iter__(self): | ||||
|
r8209 | for f in sorted(self._manifest): | ||
|
r5485 | yield f | ||
|
r4909 | |||
|
r10282 | def changeset(self): | ||
return self._changeset | ||||
def manifest(self): | ||||
return self._manifest | ||||
def manifestnode(self): | ||||
return self._changeset[0] | ||||
|
r2563 | |||
|
r10282 | def rev(self): | ||
return self._rev | ||||
def node(self): | ||||
return self._node | ||||
def hex(self): | ||||
return hex(self._node) | ||||
def user(self): | ||||
return self._changeset[1] | ||||
def date(self): | ||||
return self._changeset[2] | ||||
def files(self): | ||||
return self._changeset[3] | ||||
def description(self): | ||||
return self._changeset[4] | ||||
def branch(self): | ||||
|
r13047 | return encoding.tolocal(self._changeset[5].get("branch")) | ||
|
r16720 | def closesbranch(self): | ||
return 'close' in self._changeset[5] | ||||
|
r10282 | def extra(self): | ||
return self._changeset[5] | ||||
def tags(self): | ||||
return self._repo.nodetags(self._node) | ||||
|
r13384 | def bookmarks(self): | ||
return self._repo.nodebookmarks(self._node) | ||||
|
r15421 | def phase(self): | ||
|
r16657 | return self._repo._phasecache.phase(self._repo, self._rev) | ||
|
r15822 | def phasestr(self): | ||
return phases.phasenames[self.phase()] | ||||
|
r15703 | def mutable(self): | ||
|
r16359 | return self.phase() > phases.public | ||
|
r14644 | def hidden(self): | ||
|
r18382 | return self._rev in repoview.filterrevs(self._repo, 'visible') | ||
|
r2563 | |||
def parents(self): | ||||
"""return contexts for each parent changeset""" | ||||
|
r6742 | return self._parents | ||
|
r2563 | |||
|
r8406 | def p1(self): | ||
return self._parents[0] | ||||
def p2(self): | ||||
if len(self._parents) == 2: | ||||
return self._parents[1] | ||||
return changectx(self._repo, -1) | ||||
|
r2563 | def children(self): | ||
"""return contexts for each child changeset""" | ||||
|
r2627 | c = self._repo.changelog.children(self._node) | ||
|
r3673 | return [changectx(self._repo, x) for x in c] | ||
|
r2563 | |||
|
r6876 | def ancestors(self): | ||
|
r16866 | for a in self._repo.changelog.ancestors([self._rev]): | ||
|
r6876 | yield changectx(self._repo, a) | ||
def descendants(self): | ||||
|
r16867 | for d in self._repo.changelog.descendants([self._rev]): | ||
|
r6876 | yield changectx(self._repo, d) | ||
|
r17076 | def obsolete(self): | ||
"""True if the changeset is obsolete""" | ||||
|
r17825 | return self.rev() in obsmod.getrevs(self._repo, 'obsolete') | ||
|
r17076 | |||
|
r17173 | def extinct(self): | ||
"""True if the changeset is extinct""" | ||||
|
r17825 | return self.rev() in obsmod.getrevs(self._repo, 'extinct') | ||
|
r17173 | |||
|
r17171 | def unstable(self): | ||
"""True if the changeset is not obsolete but it's ancestor are""" | ||||
|
r17825 | return self.rev() in obsmod.getrevs(self._repo, 'unstable') | ||
|
r17171 | |||
|
r17832 | def bumped(self): | ||
"""True if the changeset try to be a successor of a public changeset | ||||
Only non-public and non-obsolete changesets may be bumped. | ||||
""" | ||||
return self.rev() in obsmod.getrevs(self._repo, 'bumped') | ||||
|
r18072 | def divergent(self): | ||
"""Is a successors of a changeset with multiple possible successors set | ||||
Only non-public and non-obsolete changesets may be divergent. | ||||
""" | ||||
return self.rev() in obsmod.getrevs(self._repo, 'divergent') | ||||
|
r18160 | def troubled(self): | ||
"""True if the changeset is either unstable, bumped or divergent""" | ||||
return self.unstable() or self.bumped() or self.divergent() | ||||
|
r18161 | def troubles(self): | ||
"""return the list of troubles affecting this changesets. | ||||
Troubles are returned as strings. possible values are: | ||||
- unstable, | ||||
- bumped, | ||||
- divergent. | ||||
""" | ||||
troubles = [] | ||||
if self.unstable(): | ||||
troubles.append('unstable') | ||||
if self.bumped(): | ||||
troubles.append('bumped') | ||||
if self.divergent(): | ||||
troubles.append('divergent') | ||||
return troubles | ||||
|
r5389 | def _fileinfo(self, path): | ||
|
r3336 | if '_manifest' in self.__dict__: | ||
|
r3242 | try: | ||
|
r5389 | return self._manifest[path], self._manifest.flags(path) | ||
|
r3242 | except KeyError: | ||
|
r18855 | raise error.ManifestLookupError(self._node, path, | ||
_('not found in manifest')) | ||||
|
r3337 | if '_manifestdelta' in self.__dict__ or path in self.files(): | ||
if path in self._manifestdelta: | ||||
|
r16683 | return (self._manifestdelta[path], | ||
self._manifestdelta.flags(path)) | ||||
|
r3215 | node, flag = self._repo.manifest.find(self._changeset[0], path) | ||
|
r3242 | if not node: | ||
|
r18855 | raise error.ManifestLookupError(self._node, path, | ||
_('not found in manifest')) | ||||
|
r3242 | |||
|
r5389 | return node, flag | ||
def filenode(self, path): | ||||
return self._fileinfo(path)[0] | ||||
|
r6743 | def flags(self, path): | ||
|
r5389 | try: | ||
return self._fileinfo(path)[1] | ||||
|
r7633 | except error.LookupError: | ||
|
r5389 | return '' | ||
|
r2563 | |||
|
r3966 | def filectx(self, path, fileid=None, filelog=None): | ||
|
r2563 | """get a file context from this changeset""" | ||
|
r2628 | if fileid is None: | ||
fileid = self.filenode(path) | ||||
|
r3966 | return filectx(self._repo, path, fileid=fileid, | ||
changectx=self, filelog=filelog) | ||||
|
r2563 | |||
|
r3125 | def ancestor(self, c2): | ||
""" | ||||
return the ancestor context of self and c2 | ||||
""" | ||||
|
r9843 | # deal with workingctxs | ||
n2 = c2._node | ||||
|
r13031 | if n2 is None: | ||
|
r9843 | n2 = c2._parents[0]._node | ||
n = self._repo.changelog.ancestor(self._node, n2) | ||||
|
r3125 | return changectx(self._repo, n) | ||
|
r17626 | def descendant(self, other): | ||
"""True if other is descendant of this changeset""" | ||||
return self._repo.changelog.descendant(self._rev, other._rev) | ||||
|
r6764 | def walk(self, match): | ||
|
r8380 | fset = set(match.files()) | ||
|
r6764 | # for dirstate.walk, files=['.'] means "walk the whole tree". | ||
# follow that here, too | ||||
|
r8380 | fset.discard('.') | ||
|
r6764 | for fn in self: | ||
|
r16145 | if fn in fset: | ||
# specified pattern is the exact name | ||||
fset.remove(fn) | ||||
|
r6764 | if match(fn): | ||
yield fn | ||||
|
r8380 | for fn in sorted(fset): | ||
|
r16145 | if fn in self._dirs: | ||
# specified pattern is a directory | ||||
continue | ||||
|
r12067 | if match.bad(fn, _('no such file in rev %s') % self) and match(fn): | ||
|
r6764 | yield fn | ||
|
r8813 | def sub(self, path): | ||
return subrepo.subrepo(self, path) | ||||
|
r14669 | def match(self, pats=[], include=None, exclude=None, default='glob'): | ||
r = self._repo | ||||
return matchmod.match(r.root, r.getcwd(), pats, | ||||
|
r14674 | include, exclude, default, | ||
auditor=r.auditor, ctx=self) | ||||
|
r14669 | |||
|
r11106 | def diff(self, ctx2=None, match=None, **opts): | ||
|
r11097 | """Returns a diff generator for the given contexts and matcher""" | ||
if ctx2 is None: | ||||
ctx2 = self.p1() | ||||
if ctx2 is not None and not isinstance(ctx2, changectx): | ||||
ctx2 = self._repo[ctx2] | ||||
|
r11105 | diffopts = patch.diffopts(self._repo.ui, opts) | ||
return patch.diff(self._repo, ctx2.node(), self.node(), | ||||
match=match, opts=diffopts) | ||||
|
r11097 | |||
|
r16143 | @propertycache | ||
def _dirs(self): | ||||
|
r18899 | return scmutil.dirs(self._manifest) | ||
|
r16143 | |||
def dirs(self): | ||||
return self._dirs | ||||
|
r18036 | def dirty(self): | ||
return False | ||||
|
r2563 | class filectx(object): | ||
"""A filecontext object makes access to data related to a particular | ||||
filerevision convenient.""" | ||||
|
r3214 | def __init__(self, repo, path, changeid=None, fileid=None, | ||
filelog=None, changectx=None): | ||||
|
r2563 | """changeid can be a changeset revision, node, or tag. | ||
fileid can be a file revision or node.""" | ||||
self._repo = repo | ||||
self._path = path | ||||
|
r3964 | assert (changeid is not None | ||
or fileid is not None | ||||
|
r9024 | or changectx is not None), \ | ||
("bad args: changeid=%r, fileid=%r, changectx=%r" | ||||
% (changeid, fileid, changectx)) | ||||
|
r2643 | |||
|
r3124 | if filelog: | ||
self._filelog = filelog | ||||
|
r5810 | if changeid is not None: | ||
self._changeid = changeid | ||||
if changectx is not None: | ||||
self._changectx = changectx | ||||
if fileid is not None: | ||||
|
r3213 | self._fileid = fileid | ||
|
r2563 | |||
|
r8157 | @propertycache | ||
|
r7368 | def _changectx(self): | ||
|
r18211 | try: | ||
return changectx(self._repo, self._changeid) | ||||
except error.RepoLookupError: | ||||
# Linkrev may point to any revision in the repository. When the | ||||
# repository is filtered this may lead to `filectx` trying to build | ||||
# `changectx` for filtered revision. In such case we fallback to | ||||
# creating `changectx` on the unfiltered version of the reposition. | ||||
|
r18644 | # This fallback should not be an issue because `changectx` from | ||
# `filectx` are not used in complex operations that care about | ||||
|
r18211 | # filtering. | ||
# | ||||
# This fallback is a cheap and dirty fix that prevent several | ||||
|
r18644 | # crashes. It does not ensure the behavior is correct. However the | ||
|
r18211 | # behavior was not correct before filtering either and "incorrect | ||
# behavior" is seen as better as "crash" | ||||
# | ||||
# Linkrevs have several serious troubles with filtering that are | ||||
# complicated to solve. Proper handling of the issue here should be | ||||
# considered when solving linkrev issue are on the table. | ||||
return changectx(self._repo.unfiltered(), self._changeid) | ||||
|
r7368 | |||
|
r8157 | @propertycache | ||
|
r7368 | def _filelog(self): | ||
return self._repo.file(self._path) | ||||
|
r8157 | @propertycache | ||
|
r7368 | def _changeid(self): | ||
if '_changectx' in self.__dict__: | ||||
return self._changectx.rev() | ||||
|
r3144 | else: | ||
|
r7368 | return self._filelog.linkrev(self._filerev) | ||
|
r8157 | @propertycache | ||
|
r7368 | def _filenode(self): | ||
if '_fileid' in self.__dict__: | ||||
return self._filelog.lookup(self._fileid) | ||||
else: | ||||
return self._changectx.filenode(self._path) | ||||
|
r8157 | @propertycache | ||
|
r7368 | def _filerev(self): | ||
return self._filelog.rev(self._filenode) | ||||
|
r8157 | @propertycache | ||
|
r7368 | def _repopath(self): | ||
return self._path | ||||
|
r2563 | |||
|
r3168 | def __nonzero__(self): | ||
|
r3712 | try: | ||
|
r7874 | self._filenode | ||
|
r3712 | return True | ||
|
r7633 | except error.LookupError: | ||
|
r3712 | # file is missing | ||
return False | ||||
|
r3168 | |||
|
r3166 | def __str__(self): | ||
return "%s@%s" % (self.path(), short(self.node())) | ||||
|
r3151 | def __repr__(self): | ||
|
r3216 | return "<filectx %s>" % str(self) | ||
|
r3151 | |||
|
r6469 | def __hash__(self): | ||
try: | ||||
|
r10942 | return hash((self._path, self._filenode)) | ||
|
r6469 | except AttributeError: | ||
return id(self) | ||||
|
r3165 | def __eq__(self, other): | ||
|
r3715 | try: | ||
return (self._path == other._path | ||||
|
r10942 | and self._filenode == other._filenode) | ||
|
r3715 | except AttributeError: | ||
return False | ||||
|
r3165 | |||
|
r4748 | def __ne__(self, other): | ||
return not (self == other) | ||||
|
r3207 | def filectx(self, fileid): | ||
'''opens an arbitrary revision of the file without | ||||
opening a new filelog''' | ||||
return filectx(self._repo, self._path, fileid=fileid, | ||||
filelog=self._filelog) | ||||
|
r10282 | def filerev(self): | ||
return self._filerev | ||||
def filenode(self): | ||||
return self._filenode | ||||
def flags(self): | ||||
return self._changectx.flags(self._path) | ||||
def filelog(self): | ||||
return self._filelog | ||||
|
r2563 | |||
|
r3150 | def rev(self): | ||
|
r3336 | if '_changectx' in self.__dict__: | ||
|
r3150 | return self._changectx.rev() | ||
|
r5810 | if '_changeid' in self.__dict__: | ||
|
r6210 | return self._changectx.rev() | ||
|
r7361 | return self._filelog.linkrev(self._filerev) | ||
|
r3150 | |||
|
r10282 | def linkrev(self): | ||
return self._filelog.linkrev(self._filerev) | ||||
def node(self): | ||||
return self._changectx.node() | ||||
def hex(self): | ||||
return hex(self.node()) | ||||
def user(self): | ||||
return self._changectx.user() | ||||
def date(self): | ||||
return self._changectx.date() | ||||
def files(self): | ||||
return self._changectx.files() | ||||
def description(self): | ||||
return self._changectx.description() | ||||
def branch(self): | ||||
return self._changectx.branch() | ||||
def extra(self): | ||||
return self._changectx.extra() | ||||
|
r17792 | def phase(self): | ||
return self._changectx.phase() | ||||
def phasestr(self): | ||||
return self._changectx.phasestr() | ||||
|
r10282 | def manifest(self): | ||
return self._changectx.manifest() | ||||
def changectx(self): | ||||
return self._changectx | ||||
|
r2563 | |||
|
r10282 | def data(self): | ||
return self._filelog.read(self._filenode) | ||||
def path(self): | ||||
return self._path | ||||
def size(self): | ||||
return self._filelog.size(self._filerev) | ||||
|
r2563 | |||
|
r15738 | def isbinary(self): | ||
try: | ||||
return util.binary(self.data()) | ||||
except IOError: | ||||
return False | ||||
|
r11702 | def cmp(self, fctx): | ||
"""compare with other file context | ||||
|
r11539 | |||
|
r11702 | returns True if different than fctx. | ||
|
r11539 | """ | ||
|
r15848 | if (fctx._filerev is None | ||
and (self._repo._encodefilterpats | ||||
# if file data starts with '\1\n', empty metadata block is | ||||
|
r15872 | # prepended, which adds 4 bytes to filelog.size(). | ||
|
r15848 | or self.size() - 4 == fctx.size()) | ||
|
r12731 | or self.size() == fctx.size()): | ||
return self._filelog.cmp(self._filenode, fctx.data()) | ||||
|
r12709 | |||
|
r12731 | return True | ||
|
r3310 | |||
|
r5811 | def renamed(self): | ||
"""check if file was actually renamed in this changeset revision | ||||
If rename logged in file revision, we report copy for changeset only | ||||
if file revisions linkrev points back to the changeset in question | ||||
or both changeset parents contain different file revisions. | ||||
""" | ||||
renamed = self._filelog.renamed(self._filenode) | ||||
if not renamed: | ||||
return renamed | ||||
if self.rev() == self.linkrev(): | ||||
return renamed | ||||
name = self.path() | ||||
fnode = self._filenode | ||||
for p in self._changectx.parents(): | ||||
try: | ||||
if fnode == p.filenode(name): | ||||
return None | ||||
|
r7633 | except error.LookupError: | ||
|
r5811 | pass | ||
return renamed | ||||
|
r2563 | def parents(self): | ||
|
r3124 | p = self._path | ||
fl = self._filelog | ||||
|
r3673 | pl = [(p, n, fl) for n in self._filelog.parents(self._filenode)] | ||
|
r3123 | |||
|
r5813 | r = self._filelog.renamed(self._filenode) | ||
|
r3122 | if r: | ||
|
r3124 | pl[0] = (r[0], r[1], None) | ||
|
r3673 | return [filectx(self._repo, p, fileid=n, filelog=l) | ||
|
r10282 | for p, n, l in pl if n != nullid] | ||
|
r2563 | |||
|
r13877 | def p1(self): | ||
return self.parents()[0] | ||||
def p2(self): | ||||
p = self.parents() | ||||
if len(p) == 2: | ||||
return p[1] | ||||
return filectx(self._repo, self._path, fileid=-1, filelog=self._filelog) | ||||
|
r2563 | def children(self): | ||
# hard for renames | ||||
c = self._filelog.children(self._filenode) | ||||
|
r3673 | return [filectx(self._repo, self._path, fileid=x, | ||
filelog=self._filelog) for x in c] | ||||
|
r2566 | |||
|
r15528 | def annotate(self, follow=False, linenumber=None, diffopts=None): | ||
|
r3172 | '''returns a list of tuples of (ctx, line) for each line | ||
in the file, where ctx is the filectx of the node where | ||||
|
r4856 | that line was last changed. | ||
This returns tuples of ((ctx, linenumber), line) for each line, | ||||
if "linenumber" parameter is NOT "None". | ||||
In such tuples, linenumber means one at the first appearance | ||||
in the managed file. | ||||
To reduce annotation cost, | ||||
this returns fixed value(False is used) as linenumber, | ||||
if "linenumber" parameter is "False".''' | ||||
|
r3172 | |||
|
r4856 | def decorate_compat(text, rev): | ||
|
r3172 | return ([rev] * len(text.splitlines()), text) | ||
|
r4856 | def without_linenumber(text, rev): | ||
return ([(rev, False)] * len(text.splitlines()), text) | ||||
def with_linenumber(text, rev): | ||||
size = len(text.splitlines()) | ||||
return ([(rev, i) for i in xrange(1, size + 1)], text) | ||||
decorate = (((linenumber is None) and decorate_compat) or | ||||
(linenumber and with_linenumber) or | ||||
without_linenumber) | ||||
|
r3172 | def pair(parent, child): | ||
|
r15528 | blocks = mdiff.allblocks(parent[1], child[1], opts=diffopts, | ||
refine=True) | ||||
for (a1, a2, b1, b2), t in blocks: | ||||
# Changed blocks ('!') or blocks made only of blank lines ('~') | ||||
# belong to the child. | ||||
if t == '=': | ||||
child[0][b1:b2] = parent[0][a1:a2] | ||||
|
r3172 | return child | ||
|
r9097 | getlog = util.lrucachefunc(lambda x: self._repo.file(x)) | ||
|
r3172 | def getctx(path, fileid): | ||
log = path == self._path and self._filelog or getlog(path) | ||||
return filectx(self._repo, path, fileid=fileid, filelog=log) | ||||
|
r9097 | getctx = util.lrucachefunc(getctx) | ||
|
r3172 | |||
def parents(f): | ||||
# we want to reuse filectx objects as much as possible | ||||
p = f._path | ||||
|
r3217 | if f._filerev is None: # working dir | ||
|
r3673 | pl = [(n.path(), n.filerev()) for n in f.parents()] | ||
|
r3217 | else: | ||
|
r3673 | pl = [(p, n) for n in f._filelog.parentrevs(f._filerev)] | ||
|
r3172 | |||
if follow: | ||||
r = f.renamed() | ||||
if r: | ||||
pl[0] = (r[0], getlog(r[0]).rev(r[1])) | ||||
|
r3146 | |||
|
r3578 | return [getctx(p, n) for p, n in pl if n != nullrev] | ||
|
r3217 | |||
|
r3404 | # use linkrev to find the first changeset where self appeared | ||
|
r5811 | if self.rev() != self.linkrev(): | ||
|
r3404 | base = self.filectx(self.filerev()) | ||
else: | ||||
base = self | ||||
|
r13552 | # This algorithm would prefer to be recursive, but Python is a | ||
# bit recursion-hostile. Instead we do an iterative | ||||
# depth-first search. | ||||
visit = [base] | ||||
hist = {} | ||||
pcache = {} | ||||
|
r3404 | needed = {base: 1} | ||
|
r3172 | while visit: | ||
|
r13552 | f = visit[-1] | ||
if f not in pcache: | ||||
pcache[f] = parents(f) | ||||
|
r3172 | |||
|
r13552 | ready = True | ||
pl = pcache[f] | ||||
for p in pl: | ||||
if p not in hist: | ||||
ready = False | ||||
visit.append(p) | ||||
needed[p] = needed.get(p, 0) + 1 | ||||
if ready: | ||||
visit.pop() | ||||
curr = decorate(f.data(), f) | ||||
for p in pl: | ||||
curr = pair(hist[p], curr) | ||||
if needed[p] == 1: | ||||
del hist[p] | ||||
else: | ||||
needed[p] -= 1 | ||||
|
r6762 | |||
|
r13552 | hist[f] = curr | ||
pcache[f] = [] | ||||
|
r3172 | |||
|
r13552 | return zip(hist[base][0], hist[base][1].splitlines(True)) | ||
|
r3124 | |||
|
r16599 | def ancestor(self, fc2, actx): | ||
|
r3126 | """ | ||
find the common ancestor file context, if any, of self, and fc2 | ||||
|
r11453 | |||
|
r16599 | actx must be the changectx of the common ancestor | ||
|
r11453 | of self's and fc2's respective changesets. | ||
|
r3126 | """ | ||
|
r9751 | # the easy case: no (relevant) renames | ||
if fc2.path() == self.path() and self.path() in actx: | ||||
|
r9750 | return actx[self.path()] | ||
|
r16601 | |||
# the next easiest cases: unambiguous predecessor (name trumps | ||||
# history) | ||||
if self.path() in actx and fc2.path() not in actx: | ||||
return actx[self.path()] | ||||
if fc2.path() in actx and self.path() not in actx: | ||||
return actx[fc2.path()] | ||||
|
r3217 | |||
# prime the ancestor cache for the working directory | ||||
|
r16601 | acache = {} | ||
|
r3217 | for c in (self, fc2): | ||
|
r8527 | if c._filerev is None: | ||
|
r3673 | pl = [(n.path(), n.filenode()) for n in c.parents()] | ||
|
r3217 | acache[(c._path, None)] = pl | ||
|
r6286 | flcache = {self._repopath:self._filelog, fc2._repopath:fc2._filelog} | ||
|
r3135 | def parents(vertex): | ||
if vertex in acache: | ||||
return acache[vertex] | ||||
f, n = vertex | ||||
if f not in flcache: | ||||
|
r3126 | flcache[f] = self._repo.file(f) | ||
|
r3135 | fl = flcache[f] | ||
|
r3673 | pl = [(f, p) for p in fl.parents(n) if p != nullid] | ||
|
r3135 | re = fl.renamed(n) | ||
if re: | ||||
pl.append(re) | ||||
|
r3673 | acache[vertex] = pl | ||
|
r3135 | return pl | ||
|
r3126 | |||
|
r3135 | a, b = (self._path, self._filenode), (fc2._path, fc2._filenode) | ||
v = ancestor.ancestor(a, b, parents) | ||||
if v: | ||||
|
r3673 | f, n = v | ||
|
r3135 | return filectx(self._repo, f, fileid=n, filelog=flcache[f]) | ||
|
r3126 | |||
|
r3135 | return None | ||
|
r3217 | |||
|
r16185 | def ancestors(self, followfirst=False): | ||
|
r13481 | visit = {} | ||
c = self | ||||
|
r16185 | cut = followfirst and 1 or None | ||
|
r13481 | while True: | ||
|
r16185 | for parent in c.parents()[:cut]: | ||
|
r13481 | visit[(parent.rev(), parent.node())] = parent | ||
if not visit: | ||||
break | ||||
c = visit.pop(max(visit)) | ||||
yield c | ||||
|
r10262 | |||
|
r16602 | def copies(self, c2): | ||
|
r16610 | if not util.safehasattr(self, "_copycache"): | ||
|
r16602 | self._copycache = {} | ||
sc2 = str(c2) | ||||
if sc2 not in self._copycache: | ||||
self._copycache[sc2] = copies.pathcopies(c2) | ||||
return self._copycache[sc2] | ||||
|
r3217 | class workingctx(changectx): | ||
"""A workingctx object makes access to data related to | ||||
|
r6705 | the current working directory convenient. | ||
|
r6709 | date - any valid date string or (unixtime, offset), or None. | ||
user - username string, or None. | ||||
|
r6708 | extra - a dictionary of extra values, or None. | ||
|
r6707 | changes - a list of file lists as returned by localrepo.status() | ||
or None to use the repository status. | ||||
|
r6705 | """ | ||
|
r10969 | def __init__(self, repo, text="", user=None, date=None, extra=None, | ||
changes=None): | ||||
|
r3217 | self._repo = repo | ||
self._rev = None | ||||
self._node = None | ||||
|
r6709 | self._text = text | ||
|
r6718 | if date: | ||
|
r6709 | self._date = util.parsedate(date) | ||
|
r6817 | if user: | ||
self._user = user | ||||
|
r6707 | if changes: | ||
|
r11101 | self._status = list(changes[:4]) | ||
self._unknown = changes[4] | ||||
|
r11099 | self._ignored = changes[5] | ||
self._clean = changes[6] | ||||
else: | ||||
|
r11101 | self._unknown = None | ||
|
r11099 | self._ignored = None | ||
self._clean = None | ||||
|
r3217 | |||
|
r6708 | self._extra = {} | ||
if extra: | ||||
self._extra = extra.copy() | ||||
if 'branch' not in self._extra: | ||||
try: | ||||
|
r13047 | branch = encoding.fromlocal(self._repo.dirstate.branch()) | ||
|
r6708 | except UnicodeDecodeError: | ||
raise util.Abort(_('branch name not in UTF-8!')) | ||||
self._extra['branch'] = branch | ||||
if self._extra['branch'] == '': | ||||
self._extra['branch'] = 'default' | ||||
|
r3217 | def __str__(self): | ||
|
r3313 | return str(self._parents[0]) + "+" | ||
|
r3217 | |||
|
r12947 | def __repr__(self): | ||
return "<workingctx %s>" % str(self) | ||||
|
r3217 | def __nonzero__(self): | ||
return True | ||||
|
r6771 | def __contains__(self, key): | ||
|
r8061 | return self._repo.dirstate[key] not in "?r" | ||
|
r6771 | |||
|
r15337 | def _buildflagfunc(self): | ||
# Create a fallback function for getting file flags when the | ||||
# filesystem doesn't support them | ||||
copiesget = self._repo.dirstate.copies().get | ||||
if len(self._parents) < 2: | ||||
# when we have one parent, it's easy: copy from parent | ||||
man = self._parents[0].manifest() | ||||
def func(f): | ||||
f = copiesget(f, f) | ||||
return man.flags(f) | ||||
else: | ||||
# merges are tricky: we try to reconstruct the unstored | ||||
# result from the merge (issue1802) | ||||
p1, p2 = self._parents | ||||
pa = p1.ancestor(p2) | ||||
m1, m2, ma = p1.manifest(), p2.manifest(), pa.manifest() | ||||
def func(f): | ||||
f = copiesget(f, f) # may be wrong for merges with copies | ||||
fl1, fl2, fla = m1.flags(f), m2.flags(f), ma.flags(f) | ||||
if fl1 == fl2: | ||||
return fl1 | ||||
if fl1 == fla: | ||||
return fl2 | ||||
if fl2 == fla: | ||||
return fl1 | ||||
return '' # punt for conflicts | ||||
return func | ||||
@propertycache | ||||
def _flagfunc(self): | ||||
return self._repo.dirstate.flagfunc(self._buildflagfunc) | ||||
|
r8157 | @propertycache | ||
|
r7368 | def _manifest(self): | ||
|
r3217 | """generate a manifest corresponding to the working directory""" | ||
|
r3218 | man = self._parents[0].manifest().copy() | ||
|
r10921 | if len(self._parents) > 1: | ||
man2 = self.p2().manifest() | ||||
def getman(f): | ||||
if f in man: | ||||
return man | ||||
return man2 | ||||
else: | ||||
getman = lambda f: man | ||||
|
r15337 | |||
copied = self._repo.dirstate.copies() | ||||
ff = self._flagfunc | ||||
|
r11101 | modified, added, removed, deleted = self._status | ||
|
r16094 | for i, l in (("a", added), ("m", modified)): | ||
|
r3217 | for f in l: | ||
|
r10921 | orig = copied.get(f, f) | ||
man[f] = getman(orig).get(orig, nullid) + i | ||||
|
r3823 | try: | ||
|
r6743 | man.set(f, ff(f)) | ||
|
r3823 | except OSError: | ||
pass | ||||
|
r3217 | |||
for f in deleted + removed: | ||||
|
r3325 | if f in man: | ||
del man[f] | ||||
|
r3217 | |||
|
r7368 | return man | ||
|
r14129 | def __iter__(self): | ||
d = self._repo.dirstate | ||||
for f in d: | ||||
if d[f] != 'r': | ||||
yield f | ||||
|
r8157 | @propertycache | ||
|
r7368 | def _status(self): | ||
|
r11101 | return self._repo.status()[:4] | ||
|
r7368 | |||
|
r8157 | @propertycache | ||
|
r7368 | def _user(self): | ||
return self._repo.ui.username() | ||||
|
r8157 | @propertycache | ||
|
r7368 | def _date(self): | ||
return util.makedate() | ||||
|
r8157 | @propertycache | ||
|
r7368 | def _parents(self): | ||
p = self._repo.dirstate.parents() | ||||
if p[1] == nullid: | ||||
p = p[:-1] | ||||
|
r17330 | return [changectx(self._repo, x) for x in p] | ||
|
r3217 | |||
|
r11098 | def status(self, ignored=False, clean=False, unknown=False): | ||
"""Explicit status query | ||||
Unless this method is used to query the working copy status, the | ||||
_status property will implicitly read the status using its default | ||||
arguments.""" | ||||
|
r11099 | stat = self._repo.status(ignored=ignored, clean=clean, unknown=unknown) | ||
|
r11101 | self._unknown = self._ignored = self._clean = None | ||
if unknown: | ||||
self._unknown = stat[4] | ||||
if ignored: | ||||
self._ignored = stat[5] | ||||
if clean: | ||||
self._clean = stat[6] | ||||
self._status = stat[:4] | ||||
return stat | ||||
|
r11098 | |||
|
r10282 | def manifest(self): | ||
return self._manifest | ||||
def user(self): | ||||
return self._user or self._repo.ui.username() | ||||
def date(self): | ||||
return self._date | ||||
def description(self): | ||||
return self._text | ||||
|
r3217 | def files(self): | ||
|
r8209 | return sorted(self._status[0] + self._status[1] + self._status[2]) | ||
|
r3217 | |||
|
r10282 | def modified(self): | ||
return self._status[0] | ||||
def added(self): | ||||
return self._status[1] | ||||
def removed(self): | ||||
return self._status[2] | ||||
def deleted(self): | ||||
return self._status[3] | ||||
def unknown(self): | ||||
|
r11101 | assert self._unknown is not None # must call status first | ||
return self._unknown | ||||
|
r11098 | def ignored(self): | ||
|
r11100 | assert self._ignored is not None # must call status first | ||
|
r11099 | return self._ignored | ||
|
r10282 | def clean(self): | ||
|
r11100 | assert self._clean is not None # must call status first | ||
|
r11099 | return self._clean | ||
|
r10282 | def branch(self): | ||
|
r13047 | return encoding.tolocal(self._extra['branch']) | ||
|
r16720 | def closesbranch(self): | ||
return 'close' in self._extra | ||||
|
r10282 | def extra(self): | ||
return self._extra | ||||
|
r3217 | |||
|
r4663 | def tags(self): | ||
t = [] | ||||
|
r13412 | for p in self.parents(): | ||
t.extend(p.tags()) | ||||
|
r4663 | return t | ||
|
r13476 | def bookmarks(self): | ||
b = [] | ||||
for p in self.parents(): | ||||
b.extend(p.bookmarks()) | ||||
return b | ||||
|
r15707 | def phase(self): | ||
|
r15818 | phase = phases.draft # default phase to draft | ||
|
r15707 | for p in self.parents(): | ||
phase = max(phase, p.phase()) | ||||
return phase | ||||
def hidden(self): | ||||
return False | ||||
|
r3217 | def children(self): | ||
return [] | ||||
|
r6743 | def flags(self, path): | ||
|
r5389 | if '_manifest' in self.__dict__: | ||
try: | ||||
return self._manifest.flags(path) | ||||
except KeyError: | ||||
return '' | ||||
|
r5760 | |||
|
r15337 | try: | ||
return self._flagfunc(path) | ||||
except OSError: | ||||
|
r5389 | return '' | ||
|
r3966 | def filectx(self, path, filelog=None): | ||
|
r3217 | """get a file context from the working directory""" | ||
|
r3966 | return workingfilectx(self._repo, path, workingctx=self, | ||
filelog=filelog) | ||||
|
r3217 | |||
def ancestor(self, c2): | ||||
"""return the ancestor context of self and c2""" | ||||
return self._parents[0].ancestor(c2) # punt on two parents for now | ||||
|
r6764 | def walk(self, match): | ||
|
r18364 | return sorted(self._repo.dirstate.walk(match, sorted(self.substate), | ||
|
r10176 | True, False)) | ||
|
r6764 | |||
|
r16491 | def dirty(self, missing=False, merge=True, branch=True): | ||
|
r8717 | "check whether a working directory is modified" | ||
|
r11110 | # check subrepos first | ||
|
r18364 | for s in sorted(self.substate): | ||
|
r11110 | if self.sub(s).dirty(): | ||
return True | ||||
# check current working dir | ||||
|
r16491 | return ((merge and self.p2()) or | ||
(branch and self.branch() != self.p1().branch()) or | ||||
|
r8717 | self.modified() or self.added() or self.removed() or | ||
(missing and self.deleted())) | ||||
|
r12270 | def add(self, list, prefix=""): | ||
join = lambda f: os.path.join(prefix, f) | ||||
|
r11303 | wlock = self._repo.wlock() | ||
ui, ds = self._repo.ui, self._repo.dirstate | ||||
try: | ||||
rejected = [] | ||||
for f in list: | ||||
|
r13962 | scmutil.checkportable(ui, join(f)) | ||
|
r11303 | p = self._repo.wjoin(f) | ||
try: | ||||
st = os.lstat(p) | ||||
|
r14004 | except OSError: | ||
|
r12270 | ui.warn(_("%s does not exist!\n") % join(f)) | ||
|
r11303 | rejected.append(f) | ||
continue | ||||
if st.st_size > 10000000: | ||||
ui.warn(_("%s: up to %d MB of RAM may be required " | ||||
"to manage this file\n" | ||||
"(use 'hg revert %s' to cancel the " | ||||
"pending addition)\n") | ||||
|
r12270 | % (f, 3 * st.st_size // 1000000, join(f))) | ||
|
r11303 | if not (stat.S_ISREG(st.st_mode) or stat.S_ISLNK(st.st_mode)): | ||
ui.warn(_("%s not added: only files and symlinks " | ||||
|
r12270 | "supported currently\n") % join(f)) | ||
|
r11303 | rejected.append(p) | ||
elif ds[f] in 'amn': | ||||
|
r12270 | ui.warn(_("%s already tracked!\n") % join(f)) | ||
|
r11303 | elif ds[f] == 'r': | ||
ds.normallookup(f) | ||||
else: | ||||
ds.add(f) | ||||
return rejected | ||||
finally: | ||||
wlock.release() | ||||
|
r15912 | def forget(self, files, prefix=""): | ||
join = lambda f: os.path.join(prefix, f) | ||||
|
r11303 | wlock = self._repo.wlock() | ||
try: | ||||
|
r15912 | rejected = [] | ||
|
r14435 | for f in files: | ||
|
r16111 | if f not in self._repo.dirstate: | ||
|
r15912 | self._repo.ui.warn(_("%s not tracked!\n") % join(f)) | ||
rejected.append(f) | ||||
|
r16111 | elif self._repo.dirstate[f] != 'a': | ||
self._repo.dirstate.remove(f) | ||||
|
r11303 | else: | ||
|
r14434 | self._repo.dirstate.drop(f) | ||
|
r15912 | return rejected | ||
|
r11303 | finally: | ||
wlock.release() | ||||
|
r16410 | def ancestors(self): | ||
|
r12999 | for a in self._repo.changelog.ancestors( | ||
|
r16866 | [p.rev() for p in self._parents]): | ||
|
r12999 | yield changectx(self._repo, a) | ||
|
r11303 | def undelete(self, list): | ||
pctxs = self.parents() | ||||
wlock = self._repo.wlock() | ||||
try: | ||||
for f in list: | ||||
if self._repo.dirstate[f] != 'r': | ||||
self._repo.ui.warn(_("%s not removed!\n") % f) | ||||
else: | ||||
|
r12360 | fctx = f in pctxs[0] and pctxs[0][f] or pctxs[1][f] | ||
|
r11303 | t = fctx.data() | ||
self._repo.wwrite(f, t, fctx.flags()) | ||||
self._repo.dirstate.normal(f) | ||||
finally: | ||||
wlock.release() | ||||
def copy(self, source, dest): | ||||
p = self._repo.wjoin(dest) | ||||
|
r12344 | if not os.path.lexists(p): | ||
|
r11303 | self._repo.ui.warn(_("%s does not exist!\n") % dest) | ||
elif not (os.path.isfile(p) or os.path.islink(p)): | ||||
self._repo.ui.warn(_("copy failed: %s is not a file or a " | ||||
"symbolic link\n") % dest) | ||||
else: | ||||
wlock = self._repo.wlock() | ||||
try: | ||||
if self._repo.dirstate[dest] in '?r': | ||||
self._repo.dirstate.add(dest) | ||||
self._repo.dirstate.copy(source, dest) | ||||
finally: | ||||
wlock.release() | ||||
|
r18661 | def markcommitted(self, node): | ||
|
r18958 | """Perform post-commit cleanup necessary after committing this ctx | ||
|
r18661 | |||
Specifically, this updates backing stores this working context | ||||
wraps to reflect the fact that the changes reflected by this | ||||
workingctx have been committed. For example, it marks | ||||
modified and added files as normal in the dirstate. | ||||
""" | ||||
for f in self.modified() + self.added(): | ||||
self._repo.dirstate.normal(f) | ||||
for f in self.removed(): | ||||
self._repo.dirstate.drop(f) | ||||
self._repo.dirstate.setparents(node) | ||||
|
r16143 | def dirs(self): | ||
|
r18899 | return self._repo.dirstate.dirs() | ||
|
r16143 | |||
|
r3217 | class workingfilectx(filectx): | ||
"""A workingfilectx object makes access to data related to a particular | ||||
file in the working directory convenient.""" | ||||
def __init__(self, repo, path, filelog=None, workingctx=None): | ||||
"""changeid can be a changeset revision, node, or tag. | ||||
fileid can be a file revision or node.""" | ||||
self._repo = repo | ||||
self._path = path | ||||
self._changeid = None | ||||
self._filerev = self._filenode = None | ||||
if filelog: | ||||
self._filelog = filelog | ||||
if workingctx: | ||||
self._changectx = workingctx | ||||
|
r8157 | @propertycache | ||
|
r7368 | def _changectx(self): | ||
return workingctx(self._repo) | ||||
|
r3217 | def __nonzero__(self): | ||
return True | ||||
def __str__(self): | ||||
|
r3313 | return "%s@%s" % (self.path(), self._changectx) | ||
|
r3217 | |||
|
r12947 | def __repr__(self): | ||
return "<workingfilectx %s>" % str(self) | ||||
|
r10282 | def data(self): | ||
return self._repo.wread(self._path) | ||||
|
r3217 | def renamed(self): | ||
|
r8528 | rp = self._repo.dirstate.copied(self._path) | ||
if not rp: | ||||
|
r3217 | return None | ||
|
r3965 | return rp, self._changectx._parents[0]._manifest.get(rp, nullid) | ||
|
r3217 | |||
def parents(self): | ||||
'''return parent filectxs, following copies if necessary''' | ||||
|
r8528 | def filenode(ctx, path): | ||
return ctx._manifest.get(path, nullid) | ||||
path = self._path | ||||
|
r3217 | fl = self._filelog | ||
|
r8528 | pcl = self._changectx._parents | ||
renamed = self.renamed() | ||||
if renamed: | ||||
pl = [renamed + (None,)] | ||||
else: | ||||
pl = [(path, filenode(pcl[0], path), fl)] | ||||
for pc in pcl[1:]: | ||||
pl.append((path, filenode(pc, path), fl)) | ||||
|
r3217 | |||
|
r3673 | return [filectx(self._repo, p, fileid=n, filelog=l) | ||
|
r10282 | for p, n, l in pl if n != nullid] | ||
|
r3217 | |||
def children(self): | ||||
return [] | ||||
|
r10282 | def size(self): | ||
|
r11605 | return os.lstat(self._repo.wjoin(self._path)).st_size | ||
|
r3962 | def date(self): | ||
t, tz = self._changectx.date() | ||||
try: | ||||
|
r4117 | return (int(os.lstat(self._repo.wjoin(self._path)).st_mtime), tz) | ||
|
r3962 | except OSError, err: | ||
|
r10282 | if err.errno != errno.ENOENT: | ||
raise | ||||
|
r3962 | return (t, tz) | ||
|
r3310 | |||
|
r11702 | def cmp(self, fctx): | ||
"""compare with other file context | ||||
|
r11539 | |||
|
r11702 | returns True if different than fctx. | ||
|
r11539 | """ | ||
|
r17425 | # fctx should be a filectx (not a workingfilectx) | ||
|
r11703 | # invert comparison to reuse the same code path | ||
return fctx.cmp(self) | ||||
|
r6715 | |||
class memctx(object): | ||||
|
r7077 | """Use memctx to perform in-memory commits via localrepo.commitctx(). | ||
|
r6715 | |||
|
r7077 | Revision information is supplied at initialization time while | ||
related files data and is made available through a callback | ||||
mechanism. 'repo' is the current localrepo, 'parents' is a | ||||
sequence of two parent revisions identifiers (pass None for every | ||||
missing parent), 'text' is the commit message and 'files' lists | ||||
names of files touched by the revision (normalized and relative to | ||||
repository root). | ||||
|
r6715 | |||
|
r7077 | filectxfn(repo, memctx, path) is a callable receiving the | ||
repository, the current memctx object and the normalized path of | ||||
requested file, relative to repository root. It is fired by the | ||||
commit function for every file in 'files', but calls order is | ||||
undefined. If the file is available in the revision being | ||||
committed (updated or added), filectxfn returns a memfilectx | ||||
object. If the file was removed, filectxfn raises an | ||||
IOError. Moved files are represented by marking the source file | ||||
removed and the new file added with copy information (see | ||||
memfilectx). | ||||
user receives the committer name and defaults to current | ||||
repository username, date is the commit date in any format | ||||
supported by util.parsedate() and defaults to current date, extra | ||||
is a dictionary of metadata or is left empty. | ||||
|
r6715 | """ | ||
|
r6721 | def __init__(self, repo, parents, text, files, filectxfn, user=None, | ||
|
r6715 | date=None, extra=None): | ||
self._repo = repo | ||||
self._rev = None | ||||
self._node = None | ||||
self._text = text | ||||
self._date = date and util.parsedate(date) or util.makedate() | ||||
|
r6809 | self._user = user | ||
|
r6715 | parents = [(p or nullid) for p in parents] | ||
p1, p2 = parents | ||||
|
r6747 | self._parents = [changectx(self._repo, p) for p in (p1, p2)] | ||
|
r8209 | files = sorted(set(files)) | ||
|
r6715 | self._status = [files, [], [], [], []] | ||
self._filectxfn = filectxfn | ||||
self._extra = extra and extra.copy() or {} | ||||
|
r14528 | if self._extra.get('branch', '') == '': | ||
|
r6715 | self._extra['branch'] = 'default' | ||
def __str__(self): | ||||
return str(self._parents[0]) + "+" | ||||
|
r6763 | def __int__(self): | ||
return self._rev | ||||
|
r6715 | def __nonzero__(self): | ||
return True | ||||
|
r8401 | def __getitem__(self, key): | ||
return self.filectx(key) | ||||
|
r10282 | def p1(self): | ||
return self._parents[0] | ||||
def p2(self): | ||||
return self._parents[1] | ||||
|
r8406 | |||
|
r10282 | def user(self): | ||
return self._user or self._repo.ui.username() | ||||
def date(self): | ||||
return self._date | ||||
def description(self): | ||||
return self._text | ||||
def files(self): | ||||
return self.modified() | ||||
def modified(self): | ||||
return self._status[0] | ||||
def added(self): | ||||
return self._status[1] | ||||
def removed(self): | ||||
return self._status[2] | ||||
def deleted(self): | ||||
return self._status[3] | ||||
def unknown(self): | ||||
return self._status[4] | ||||
|
r11098 | def ignored(self): | ||
return self._status[5] | ||||
|
r10282 | def clean(self): | ||
|
r11098 | return self._status[6] | ||
|
r10282 | def branch(self): | ||
|
r13047 | return encoding.tolocal(self._extra['branch']) | ||
|
r10282 | def extra(self): | ||
return self._extra | ||||
def flags(self, f): | ||||
return self[f].flags() | ||||
|
r6715 | |||
def parents(self): | ||||
"""return contexts for each parent changeset""" | ||||
return self._parents | ||||
def filectx(self, path, filelog=None): | ||||
"""get a file context from the working directory""" | ||||
return self._filectxfn(self._repo, self, path) | ||||
|
r11151 | def commit(self): | ||
"""commit context to the repo""" | ||||
return self._repo.commitctx(self) | ||||
|
r6715 | class memfilectx(object): | ||
|
r7077 | """memfilectx represents an in-memory file to commit. | ||
See memctx for more details. | ||||
|
r6715 | """ | ||
|
r11151 | def __init__(self, path, data, islink=False, isexec=False, copied=None): | ||
|
r7077 | """ | ||
path is the normalized file path relative to repository root. | ||||
data is the file content as a string. | ||||
islink is True if the file is a symbolic link. | ||||
isexec is True if the file is executable. | ||||
copied is the source file path if current file was copied in the | ||||
revision being committed, or None.""" | ||||
|
r6715 | self._path = path | ||
self._data = data | ||||
self._flags = (islink and 'l' or '') + (isexec and 'x' or '') | ||||
self._copied = None | ||||
if copied: | ||||
self._copied = (copied, nullid) | ||||
|
r10282 | def __nonzero__(self): | ||
return True | ||||
def __str__(self): | ||||
return "%s@%s" % (self.path(), self._changectx) | ||||
def path(self): | ||||
return self._path | ||||
def data(self): | ||||
return self._data | ||||
def flags(self): | ||||
return self._flags | ||||
def isexec(self): | ||||
return 'x' in self._flags | ||||
def islink(self): | ||||
return 'l' in self._flags | ||||
def renamed(self): | ||||
return self._copied | ||||