filelog.py
267 lines
| 7.6 KiB
| text/x-python
|
PythonLexer
/ mercurial / filelog.py
|
r1089 | # filelog.py - file history class for mercurial | ||
# | ||||
|
r4635 | # Copyright 2005-2007 Matt Mackall <mpm@selenic.com> | ||
|
r1089 | # | ||
|
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. | ||
|
r1089 | |||
|
r25948 | from __future__ import absolute_import | ||
|
r37459 | from .thirdparty.zope import ( | ||
interface as zi, | ||||
) | ||||
|
r25948 | from . import ( | ||
|
r37515 | error, | ||
|
r37459 | repository, | ||
|
r25948 | revlog, | ||
) | ||||
|
r1089 | |||
|
r37459 | @zi.implementer(repository.ifilestorage) | ||
|
r37515 | class filelog(object): | ||
|
r4258 | def __init__(self, opener, path): | ||
|
r37515 | self._revlog = revlog.revlog(opener, | ||
'/'.join(('data', path + '.i')), | ||||
censorable=True) | ||||
|
r35583 | # full name of the user visible file, relative to the repository root | ||
self.filename = path | ||||
|
r37515 | self.index = self._revlog.index | ||
self.version = self._revlog.version | ||||
self.storedeltachains = self._revlog.storedeltachains | ||||
self._generaldelta = self._revlog._generaldelta | ||||
def __len__(self): | ||||
return len(self._revlog) | ||||
def __iter__(self): | ||||
return self._revlog.__iter__() | ||||
def revs(self, start=0, stop=None): | ||||
return self._revlog.revs(start=start, stop=stop) | ||||
def parents(self, node): | ||||
return self._revlog.parents(node) | ||||
def parentrevs(self, rev): | ||||
return self._revlog.parentrevs(rev) | ||||
def rev(self, node): | ||||
return self._revlog.rev(node) | ||||
def node(self, rev): | ||||
return self._revlog.node(rev) | ||||
def lookup(self, node): | ||||
return self._revlog.lookup(node) | ||||
def linkrev(self, rev): | ||||
return self._revlog.linkrev(rev) | ||||
def flags(self, rev): | ||||
return self._revlog.flags(rev) | ||||
def commonancestorsheads(self, node1, node2): | ||||
return self._revlog.commonancestorsheads(node1, node2) | ||||
def descendants(self, revs): | ||||
return self._revlog.descendants(revs) | ||||
def headrevs(self): | ||||
return self._revlog.headrevs() | ||||
def heads(self, start=None, stop=None): | ||||
return self._revlog.heads(start, stop) | ||||
def children(self, node): | ||||
return self._revlog.children(node) | ||||
def deltaparent(self, rev): | ||||
return self._revlog.deltaparent(rev) | ||||
def candelta(self, baserev, rev): | ||||
return self._revlog.candelta(baserev, rev) | ||||
def iscensored(self, rev): | ||||
return self._revlog.iscensored(rev) | ||||
def rawsize(self, rev): | ||||
return self._revlog.rawsize(rev) | ||||
def checkhash(self, text, node, p1=None, p2=None, rev=None): | ||||
return self._revlog.checkhash(text, node, p1=p1, p2=p2, rev=rev) | ||||
def revision(self, node, _df=None, raw=False): | ||||
return self._revlog.revision(node, _df=_df, raw=raw) | ||||
def revdiff(self, rev1, rev2): | ||||
return self._revlog.revdiff(rev1, rev2) | ||||
def addrevision(self, revisiondata, transaction, linkrev, p1, p2, | ||||
node=None, flags=revlog.REVIDX_DEFAULT_FLAGS, | ||||
cachedelta=None): | ||||
return self._revlog.addrevision(revisiondata, transaction, linkrev, | ||||
p1, p2, node=node, flags=flags, | ||||
cachedelta=cachedelta) | ||||
def addgroup(self, deltas, linkmapper, transaction, addrevisioncb=None): | ||||
return self._revlog.addgroup(deltas, linkmapper, transaction, | ||||
addrevisioncb=addrevisioncb) | ||||
def getstrippoint(self, minlink): | ||||
return self._revlog.getstrippoint(minlink) | ||||
def strip(self, minlink, transaction): | ||||
return self._revlog.strip(minlink, transaction) | ||||
def files(self): | ||||
return self._revlog.files() | ||||
def checksize(self): | ||||
return self._revlog.checksize() | ||||
|
r1089 | |||
def read(self, node): | ||||
t = self.revision(node) | ||||
if not t.startswith('\1\n'): | ||||
return t | ||||
|
r2579 | s = t.index('\1\n', 2) | ||
|
r10282 | return t[s + 2:] | ||
|
r1089 | |||
def add(self, text, meta, transaction, link, p1=None, p2=None): | ||||
if meta or text.startswith('\1\n'): | ||||
|
r37460 | text = revlog.packmeta(meta, text) | ||
|
r1089 | return self.addrevision(text, transaction, link, p1, p2) | ||
|
r1116 | def renamed(self, node): | ||
|
r7634 | if self.parents(node)[0] != revlog.nullid: | ||
|
r1116 | return False | ||
|
r13240 | t = self.revision(node) | ||
|
r37460 | m = revlog.parsemeta(t)[0] | ||
|
r5915 | if m and "copy" in m: | ||
|
r7634 | return (m["copy"], revlog.bin(m["copyrev"])) | ||
|
r1116 | return False | ||
|
r2898 | def size(self, rev): | ||
"""return the size of a given revision""" | ||||
# for revisions with renames, we have to go the slow way | ||||
node = self.node(rev) | ||||
if self.renamed(node): | ||||
return len(self.read(node)) | ||||
|
r24118 | if self.iscensored(rev): | ||
|
r22597 | return 0 | ||
|
r2898 | |||
|
r11540 | # XXX if self.read(node).startswith("\1\n"), this returns (size+4) | ||
|
r37515 | return self._revlog.size(rev) | ||
|
r2898 | |||
|
r2887 | def cmp(self, node, text): | ||
|
r11539 | """compare text with a given file revision | ||
returns True if text is different than what is stored. | ||||
""" | ||||
|
r2887 | |||
|
r11541 | t = text | ||
if text.startswith('\1\n'): | ||||
t = '\1\n\1\n' + text | ||||
|
r37515 | samehashes = not self._revlog.cmp(node, t) | ||
|
r11541 | if samehashes: | ||
return False | ||||
|
r22597 | # censored files compare against the empty file | ||
|
r24118 | if self.iscensored(self.rev(node)): | ||
|
r22597 | return text != '' | ||
|
r11541 | # renaming a file produces a different hash, even if the data | ||
# remains unchanged. Check if it's the case (slow): | ||||
if self.renamed(node): | ||||
|
r2887 | t2 = self.read(node) | ||
|
r2895 | return t2 != text | ||
|
r2887 | |||
|
r11541 | return True | ||
|
r37515 | |||
@property | ||||
def filename(self): | ||||
return self._revlog.filename | ||||
@filename.setter | ||||
def filename(self, value): | ||||
self._revlog.filename = value | ||||
# TODO these aren't part of the interface and aren't internal methods. | ||||
# Callers should be fixed to not use them. | ||||
@property | ||||
def indexfile(self): | ||||
return self._revlog.indexfile | ||||
@indexfile.setter | ||||
def indexfile(self, value): | ||||
self._revlog.indexfile = value | ||||
@property | ||||
def datafile(self): | ||||
return self._revlog.datafile | ||||
@property | ||||
def opener(self): | ||||
return self._revlog.opener | ||||
@property | ||||
def _lazydeltabase(self): | ||||
return self._revlog._lazydeltabase | ||||
@_lazydeltabase.setter | ||||
def _lazydeltabase(self, value): | ||||
self._revlog._lazydeltabase = value | ||||
@property | ||||
def _aggressivemergedeltas(self): | ||||
return self._revlog._aggressivemergedeltas | ||||
@_aggressivemergedeltas.setter | ||||
def _aggressivemergedeltas(self, value): | ||||
self._revlog._aggressivemergedeltas = value | ||||
@property | ||||
def _inline(self): | ||||
return self._revlog._inline | ||||
@property | ||||
def _withsparseread(self): | ||||
return getattr(self._revlog, '_withsparseread', False) | ||||
@property | ||||
def _srmingapsize(self): | ||||
return self._revlog._srmingapsize | ||||
@property | ||||
def _srdensitythreshold(self): | ||||
return self._revlog._srdensitythreshold | ||||
def _deltachain(self, rev, stoprev=None): | ||||
return self._revlog._deltachain(rev, stoprev) | ||||
def chainbase(self, rev): | ||||
return self._revlog.chainbase(rev) | ||||
def chainlen(self, rev): | ||||
return self._revlog.chainlen(rev) | ||||
def clone(self, tr, destrevlog, **kwargs): | ||||
if not isinstance(destrevlog, filelog): | ||||
raise error.ProgrammingError('expected filelog to clone()') | ||||
return self._revlog.clone(tr, destrevlog._revlog, **kwargs) | ||||
def start(self, rev): | ||||
return self._revlog.start(rev) | ||||
def end(self, rev): | ||||
return self._revlog.end(rev) | ||||
def length(self, rev): | ||||
return self._revlog.length(rev) | ||||
def compress(self, data): | ||||
return self._revlog.compress(data) | ||||
def _addrevision(self, *args, **kwargs): | ||||
return self._revlog._addrevision(*args, **kwargs) | ||||