| hg-reviewers |
I am about to add more reference to it, so I would rather have it an explicit
constant. This allow to unify various call too.
| Automatic diff as part of commit; lint not applicable. |
| Automatic diff as part of commit; unit tests not applicable. |
| Path | Packages | |||
|---|---|---|---|---|
| M | hgext/clonebundles.py (3 lines) | |||
| M | mercurial/bundlecaches.py (2 lines) | |||
| M | mercurial/localrepo.py (3 lines) | |||
| M | mercurial/wireprotov1server.py (2 lines) |
| occurs. So server operators should prepare for some people to follow these | occurs. So server operators should prepare for some people to follow these | ||||
| instructions when a failure occurs, thus driving more load to the original | instructions when a failure occurs, thus driving more load to the original | ||||
| Mercurial server when the bundle hosting service fails. | Mercurial server when the bundle hosting service fails. | ||||
| """ | """ | ||||
| from __future__ import absolute_import | from __future__ import absolute_import | ||||
| from mercurial import ( | from mercurial import ( | ||||
| bundlecaches, | |||||
| extensions, | extensions, | ||||
| wireprotov1server, | wireprotov1server, | ||||
| ) | ) | ||||
| testedwith = b'ships-with-hg-core' | testedwith = b'ships-with-hg-core' | ||||
| def capabilities(orig, repo, proto): | def capabilities(orig, repo, proto): | ||||
| caps = orig(repo, proto) | caps = orig(repo, proto) | ||||
| # Only advertise if a manifest exists. This does add some I/O to requests. | # Only advertise if a manifest exists. This does add some I/O to requests. | ||||
| # But this should be cheaper than a wasted network round trip due to | # But this should be cheaper than a wasted network round trip due to | ||||
| # missing file. | # missing file. | ||||
| if repo.vfs.exists(b'clonebundles.manifest'): | if repo.vfs.exists(bundlecaches.CB_MANIFEST_FILE): | ||||
| caps.append(b'clonebundles') | caps.append(b'clonebundles') | ||||
| return caps | return caps | ||||
| def extsetup(ui): | def extsetup(ui): | ||||
| extensions.wrapfunction(wireprotov1server, b'_capabilities', capabilities) | extensions.wrapfunction(wireprotov1server, b'_capabilities', capabilities) | ||||
| error, | error, | ||||
| sslutil, | sslutil, | ||||
| util, | util, | ||||
| ) | ) | ||||
| from .utils import stringutil | from .utils import stringutil | ||||
| urlreq = util.urlreq | urlreq = util.urlreq | ||||
| CB_MANIFEST_FILE = b'clonebundles.manifest' | |||||
| @attr.s | @attr.s | ||||
| class bundlespec(object): | class bundlespec(object): | ||||
| compression = attr.ib() | compression = attr.ib() | ||||
| wirecompression = attr.ib() | wirecompression = attr.ib() | ||||
| version = attr.ib() | version = attr.ib() | ||||
| wireversion = attr.ib() | wireversion = attr.ib() | ||||
| params = attr.ib() | params = attr.ib() | ||||
| from .pycompat import ( | from .pycompat import ( | ||||
| delattr, | delattr, | ||||
| getattr, | getattr, | ||||
| ) | ) | ||||
| from . import ( | from . import ( | ||||
| bookmarks, | bookmarks, | ||||
| branchmap, | branchmap, | ||||
| bundle2, | bundle2, | ||||
| bundlecaches, | |||||
| changegroup, | changegroup, | ||||
| color, | color, | ||||
| commit, | commit, | ||||
| context, | context, | ||||
| dirstate, | dirstate, | ||||
| dirstateguard, | dirstateguard, | ||||
| discovery, | discovery, | ||||
| encoding, | encoding, | ||||
| def branchmap(self): | def branchmap(self): | ||||
| return self._repo.branchmap() | return self._repo.branchmap() | ||||
| def capabilities(self): | def capabilities(self): | ||||
| return self._caps | return self._caps | ||||
| def clonebundles(self): | def clonebundles(self): | ||||
| return self._repo.tryread(b'clonebundles.manifest') | return self._repo.tryread(bundlecaches.CB_MANIFEST_FILE) | ||||
| def debugwireargs(self, one, two, three=None, four=None, five=None): | def debugwireargs(self, one, two, three=None, four=None, five=None): | ||||
| """Used to test argument passing over the wire""" | """Used to test argument passing over the wire""" | ||||
| return b"%s %s %s %s %s" % ( | return b"%s %s %s %s %s" % ( | ||||
| one, | one, | ||||
| two, | two, | ||||
| pycompat.bytestr(three), | pycompat.bytestr(three), | ||||
| pycompat.bytestr(four), | pycompat.bytestr(four), | ||||
| Clients will parse this response and determine what bundle to fetch. | Clients will parse this response and determine what bundle to fetch. | ||||
| Extensions may wrap this command to filter or dynamically emit data | Extensions may wrap this command to filter or dynamically emit data | ||||
| depending on the request. e.g. you could advertise URLs for the closest | depending on the request. e.g. you could advertise URLs for the closest | ||||
| data center given the client's IP address. | data center given the client's IP address. | ||||
| """ | """ | ||||
| return wireprototypes.bytesresponse( | return wireprototypes.bytesresponse( | ||||
| repo.vfs.tryread(b'clonebundles.manifest') | repo.vfs.tryread(bundlecaches.CB_MANIFEST_FILE) | ||||
| ) | ) | ||||
| wireprotocaps = [ | wireprotocaps = [ | ||||
| b'lookup', | b'lookup', | ||||
| b'branchmap', | b'branchmap', | ||||
| b'pushkey', | b'pushkey', | ||||
| b'known', | b'known', | ||||