Show More
@@ -91,7 +91,7 b' def reposetup(ui, repo):' | |||||
91 | # self.lfstatus is False. |
|
91 | # self.lfstatus is False. | |
92 | # XXX large file status is buggy when used on repo proxy. |
|
92 | # XXX large file status is buggy when used on repo proxy. | |
93 | # XXX this needs to be investigated. |
|
93 | # XXX this needs to be investigated. | |
94 | @localrepo.unfilteredmeth |
|
94 | @localrepo.unfilteredmethod | |
95 | def status(self, node1='.', node2=None, match=None, ignored=False, |
|
95 | def status(self, node1='.', node2=None, match=None, ignored=False, | |
96 | clean=False, unknown=False, listsubrepos=False): |
|
96 | clean=False, unknown=False, listsubrepos=False): | |
97 | listignored, listclean, listunknown = ignored, clean, unknown |
|
97 | listignored, listclean, listunknown = ignored, clean, unknown |
@@ -51,7 +51,7 b' def hasunfilteredcache(repo, name):' | |||||
51 | """check if an repo and a unfilteredproperty cached value for <name>""" |
|
51 | """check if an repo and a unfilteredproperty cached value for <name>""" | |
52 | return name in vars(repo.unfiltered()) |
|
52 | return name in vars(repo.unfiltered()) | |
53 |
|
53 | |||
54 | def unfilteredmeth(orig): |
|
54 | def unfilteredmethod(orig): | |
55 | """decorate method that always need to be run on unfiltered version""" |
|
55 | """decorate method that always need to be run on unfiltered version""" | |
56 | def wrapper(repo, *args, **kwargs): |
|
56 | def wrapper(repo, *args, **kwargs): | |
57 | return orig(repo.unfiltered(), *args, **kwargs) |
|
57 | return orig(repo.unfiltered(), *args, **kwargs) | |
@@ -422,7 +422,7 b' class localrepository(object):' | |||||
422 | def hook(self, name, throw=False, **args): |
|
422 | def hook(self, name, throw=False, **args): | |
423 | return hook.hook(self.ui, self, name, throw, **args) |
|
423 | return hook.hook(self.ui, self, name, throw, **args) | |
424 |
|
424 | |||
425 | @unfilteredmeth |
|
425 | @unfilteredmethod | |
426 | def _tag(self, names, node, message, local, user, date, extra={}): |
|
426 | def _tag(self, names, node, message, local, user, date, extra={}): | |
427 | if isinstance(names, str): |
|
427 | if isinstance(names, str): | |
428 | names = (names,) |
|
428 | names = (names,) | |
@@ -642,7 +642,7 b' class localrepository(object):' | |||||
642 |
|
642 | |||
643 | return partial |
|
643 | return partial | |
644 |
|
644 | |||
645 | @unfilteredmeth # Until we get a smarter cache management |
|
645 | @unfilteredmethod # Until we get a smarter cache management | |
646 | def updatebranchcache(self): |
|
646 | def updatebranchcache(self): | |
647 | tip = self.changelog.tip() |
|
647 | tip = self.changelog.tip() | |
648 | if self._branchcache is not None and self._branchcachetip == tip: |
|
648 | if self._branchcache is not None and self._branchcachetip == tip: | |
@@ -695,7 +695,7 b' class localrepository(object):' | |||||
695 | bt[bn] = self._branchtip(heads) |
|
695 | bt[bn] = self._branchtip(heads) | |
696 | return bt |
|
696 | return bt | |
697 |
|
697 | |||
698 | @unfilteredmeth # Until we get a smarter cache management |
|
698 | @unfilteredmethod # Until we get a smarter cache management | |
699 | def _readbranchcache(self): |
|
699 | def _readbranchcache(self): | |
700 | partial = {} |
|
700 | partial = {} | |
701 | try: |
|
701 | try: | |
@@ -728,7 +728,7 b' class localrepository(object):' | |||||
728 | partial, last, lrev = {}, nullid, nullrev |
|
728 | partial, last, lrev = {}, nullid, nullrev | |
729 | return partial, last, lrev |
|
729 | return partial, last, lrev | |
730 |
|
730 | |||
731 | @unfilteredmeth # Until we get a smarter cache management |
|
731 | @unfilteredmethod # Until we get a smarter cache management | |
732 | def _writebranchcache(self, branches, tip, tiprev): |
|
732 | def _writebranchcache(self, branches, tip, tiprev): | |
733 | try: |
|
733 | try: | |
734 | f = self.opener("cache/branchheads", "w", atomictemp=True) |
|
734 | f = self.opener("cache/branchheads", "w", atomictemp=True) | |
@@ -740,7 +740,7 b' class localrepository(object):' | |||||
740 | except (IOError, OSError): |
|
740 | except (IOError, OSError): | |
741 | pass |
|
741 | pass | |
742 |
|
742 | |||
743 | @unfilteredmeth # Until we get a smarter cache management |
|
743 | @unfilteredmethod # Until we get a smarter cache management | |
744 | def _updatebranchcache(self, partial, ctxgen): |
|
744 | def _updatebranchcache(self, partial, ctxgen): | |
745 | """Given a branchhead cache, partial, that may have extra nodes or be |
|
745 | """Given a branchhead cache, partial, that may have extra nodes or be | |
746 | missing heads, and a generator of nodes that are at least a superset of |
|
746 | missing heads, and a generator of nodes that are at least a superset of | |
@@ -1006,7 +1006,7 b' class localrepository(object):' | |||||
1006 | finally: |
|
1006 | finally: | |
1007 | release(lock, wlock) |
|
1007 | release(lock, wlock) | |
1008 |
|
1008 | |||
1009 | @unfilteredmeth # Until we get smarter cache management |
|
1009 | @unfilteredmethod # Until we get smarter cache management | |
1010 | def _rollback(self, dryrun, force): |
|
1010 | def _rollback(self, dryrun, force): | |
1011 | ui = self.ui |
|
1011 | ui = self.ui | |
1012 | try: |
|
1012 | try: | |
@@ -1265,7 +1265,7 b' class localrepository(object):' | |||||
1265 |
|
1265 | |||
1266 | return fparent1 |
|
1266 | return fparent1 | |
1267 |
|
1267 | |||
1268 | @unfilteredmeth |
|
1268 | @unfilteredmethod | |
1269 | def commit(self, text="", user=None, date=None, match=None, force=False, |
|
1269 | def commit(self, text="", user=None, date=None, match=None, force=False, | |
1270 | editor=False, extra={}): |
|
1270 | editor=False, extra={}): | |
1271 | """Add a new revision to current repository. |
|
1271 | """Add a new revision to current repository. | |
@@ -1436,7 +1436,7 b' class localrepository(object):' | |||||
1436 | self._afterlock(commithook) |
|
1436 | self._afterlock(commithook) | |
1437 | return ret |
|
1437 | return ret | |
1438 |
|
1438 | |||
1439 | @unfilteredmeth |
|
1439 | @unfilteredmethod | |
1440 | def commitctx(self, ctx, error=False): |
|
1440 | def commitctx(self, ctx, error=False): | |
1441 | """Add a new revision to current repository. |
|
1441 | """Add a new revision to current repository. | |
1442 | Revision information is passed via the context argument. |
|
1442 | Revision information is passed via the context argument. | |
@@ -1518,7 +1518,7 b' class localrepository(object):' | |||||
1518 | tr.release() |
|
1518 | tr.release() | |
1519 | lock.release() |
|
1519 | lock.release() | |
1520 |
|
1520 | |||
1521 | @unfilteredmeth |
|
1521 | @unfilteredmethod | |
1522 | def destroyed(self, newheadnodes=None): |
|
1522 | def destroyed(self, newheadnodes=None): | |
1523 | '''Inform the repository that nodes have been destroyed. |
|
1523 | '''Inform the repository that nodes have been destroyed. | |
1524 | Intended for use by strip and rollback, so there's a common |
|
1524 | Intended for use by strip and rollback, so there's a common | |
@@ -2113,7 +2113,7 b' class localrepository(object):' | |||||
2113 | return self.getlocalbundle(source, |
|
2113 | return self.getlocalbundle(source, | |
2114 | discovery.outgoing(cl, common, heads)) |
|
2114 | discovery.outgoing(cl, common, heads)) | |
2115 |
|
2115 | |||
2116 | @unfilteredmeth |
|
2116 | @unfilteredmethod | |
2117 | def _changegroupsubset(self, commonrevs, csets, heads, source): |
|
2117 | def _changegroupsubset(self, commonrevs, csets, heads, source): | |
2118 |
|
2118 | |||
2119 | cl = self.changelog |
|
2119 | cl = self.changelog | |
@@ -2225,7 +2225,7 b' class localrepository(object):' | |||||
2225 | # to avoid a race we use changegroupsubset() (issue1320) |
|
2225 | # to avoid a race we use changegroupsubset() (issue1320) | |
2226 | return self.changegroupsubset(basenodes, self.heads(), source) |
|
2226 | return self.changegroupsubset(basenodes, self.heads(), source) | |
2227 |
|
2227 | |||
2228 | @unfilteredmeth |
|
2228 | @unfilteredmethod | |
2229 | def _changegroup(self, nodes, source): |
|
2229 | def _changegroup(self, nodes, source): | |
2230 | """Compute the changegroup of all nodes that we have that a recipient |
|
2230 | """Compute the changegroup of all nodes that we have that a recipient | |
2231 | doesn't. Return a chunkbuffer object whose read() method will return |
|
2231 | doesn't. Return a chunkbuffer object whose read() method will return | |
@@ -2319,7 +2319,7 b' class localrepository(object):' | |||||
2319 |
|
2319 | |||
2320 | return changegroup.unbundle10(util.chunkbuffer(gengroup()), 'UN') |
|
2320 | return changegroup.unbundle10(util.chunkbuffer(gengroup()), 'UN') | |
2321 |
|
2321 | |||
2322 | @unfilteredmeth |
|
2322 | @unfilteredmethod | |
2323 | def addchangegroup(self, source, srctype, url, emptyok=False): |
|
2323 | def addchangegroup(self, source, srctype, url, emptyok=False): | |
2324 | """Add the changegroup returned by source.read() to this repo. |
|
2324 | """Add the changegroup returned by source.read() to this repo. | |
2325 | srctype is a string like 'push', 'pull', or 'unbundle'. url is |
|
2325 | srctype is a string like 'push', 'pull', or 'unbundle'. url is |
General Comments 0
You need to be logged in to leave comments.
Login now