equal
deleted
inserted
replaced
301 |
301 |
302 @interfaceutil.implementer(repository.ipeercommands) |
302 @interfaceutil.implementer(repository.ipeercommands) |
303 class localpeer(repository.peer): |
303 class localpeer(repository.peer): |
304 '''peer for a local repo; reflects only the most recent API''' |
304 '''peer for a local repo; reflects only the most recent API''' |
305 |
305 |
306 def __init__(self, repo, caps=None): |
306 def __init__(self, repo, caps=None, path=None): |
307 super(localpeer, self).__init__(repo.ui) |
307 super(localpeer, self).__init__(repo.ui, path=path) |
308 |
308 |
309 if caps is None: |
309 if caps is None: |
310 caps = moderncaps.copy() |
310 caps = moderncaps.copy() |
311 self._repo = repo.filtered(b'served') |
311 self._repo = repo.filtered(b'served') |
312 |
312 |
449 @interfaceutil.implementer(repository.ipeerlegacycommands) |
449 @interfaceutil.implementer(repository.ipeerlegacycommands) |
450 class locallegacypeer(localpeer): |
450 class locallegacypeer(localpeer): |
451 """peer extension which implements legacy methods too; used for tests with |
451 """peer extension which implements legacy methods too; used for tests with |
452 restricted capabilities""" |
452 restricted capabilities""" |
453 |
453 |
454 def __init__(self, repo): |
454 def __init__(self, repo, path=None): |
455 super(locallegacypeer, self).__init__(repo, caps=legacycaps) |
455 super(locallegacypeer, self).__init__(repo, caps=legacycaps, path=path) |
456 |
456 |
457 # Begin of baselegacywirecommands interface. |
457 # Begin of baselegacywirecommands interface. |
458 |
458 |
459 def between(self, pairs): |
459 def between(self, pairs): |
460 return self._repo.between(pairs) |
460 return self._repo.between(pairs) |
1631 return sub.checknested(subpath[len(prefix) + 1 :]) |
1631 return sub.checknested(subpath[len(prefix) + 1 :]) |
1632 else: |
1632 else: |
1633 parts.pop() |
1633 parts.pop() |
1634 return False |
1634 return False |
1635 |
1635 |
1636 def peer(self): |
1636 def peer(self, path=None): |
1637 return localpeer(self) # not cached to avoid reference cycle |
1637 return localpeer(self, path=path) # not cached to avoid reference cycle |
1638 |
1638 |
1639 def unfiltered(self): |
1639 def unfiltered(self): |
1640 """Return unfiltered version of the repository |
1640 """Return unfiltered version of the repository |
1641 |
1641 |
1642 Intended to be overwritten by filtered repo.""" |
1642 Intended to be overwritten by filtered repo.""" |