|
|
# narrowwirepeer.py - passes narrow spec with unbundle command
|
|
|
#
|
|
|
# Copyright 2017 Google, Inc.
|
|
|
#
|
|
|
# This software may be used and distributed according to the terms of the
|
|
|
# GNU General Public License version 2 or any later version.
|
|
|
|
|
|
from __future__ import absolute_import
|
|
|
|
|
|
from mercurial import (
|
|
|
bundle2,
|
|
|
error,
|
|
|
extensions,
|
|
|
hg,
|
|
|
narrowspec,
|
|
|
node as nodemod,
|
|
|
pycompat,
|
|
|
wireprototypes,
|
|
|
wireprotov1peer,
|
|
|
wireprotov1server,
|
|
|
)
|
|
|
|
|
|
from . import narrowbundle2
|
|
|
|
|
|
def uisetup():
|
|
|
wireprotov1peer.wirepeer.narrow_widen = peernarrowwiden
|
|
|
|
|
|
def reposetup(repo):
|
|
|
def wirereposetup(ui, peer):
|
|
|
def wrapped(orig, cmd, *args, **kwargs):
|
|
|
if cmd == 'unbundle':
|
|
|
# TODO: don't blindly add include/exclude wireproto
|
|
|
# arguments to unbundle.
|
|
|
include, exclude = repo.narrowpats
|
|
|
kwargs[r"includepats"] = ','.join(include)
|
|
|
kwargs[r"excludepats"] = ','.join(exclude)
|
|
|
return orig(cmd, *args, **kwargs)
|
|
|
extensions.wrapfunction(peer, '_calltwowaystream', wrapped)
|
|
|
hg.wirepeersetupfuncs.append(wirereposetup)
|
|
|
|
|
|
@wireprotov1server.wireprotocommand('narrow_widen', 'oldincludes oldexcludes'
|
|
|
' newincludes newexcludes'
|
|
|
' commonheads cgversion'
|
|
|
' known ellipses',
|
|
|
permission='pull')
|
|
|
def narrow_widen(repo, proto, oldincludes, oldexcludes, newincludes,
|
|
|
newexcludes, commonheads, cgversion, known, ellipses):
|
|
|
"""wireprotocol command to send data when a narrow clone is widen. We will
|
|
|
be sending a changegroup here.
|
|
|
|
|
|
The current set of arguments which are required:
|
|
|
oldincludes: the old includes of the narrow copy
|
|
|
oldexcludes: the old excludes of the narrow copy
|
|
|
newincludes: the new includes of the narrow copy
|
|
|
newexcludes: the new excludes of the narrow copy
|
|
|
commonheads: list of heads which are common between the server and client
|
|
|
cgversion(maybe): the changegroup version to produce
|
|
|
known: list of nodes which are known on the client (used in ellipses cases)
|
|
|
ellipses: whether to send ellipses data or not
|
|
|
"""
|
|
|
|
|
|
preferuncompressed = False
|
|
|
try:
|
|
|
oldincludes = wireprototypes.decodelist(oldincludes)
|
|
|
newincludes = wireprototypes.decodelist(newincludes)
|
|
|
oldexcludes = wireprototypes.decodelist(oldexcludes)
|
|
|
newexcludes = wireprototypes.decodelist(newexcludes)
|
|
|
# validate the patterns
|
|
|
narrowspec.validatepatterns(set(oldincludes))
|
|
|
narrowspec.validatepatterns(set(newincludes))
|
|
|
narrowspec.validatepatterns(set(oldexcludes))
|
|
|
narrowspec.validatepatterns(set(newexcludes))
|
|
|
|
|
|
common = wireprototypes.decodelist(commonheads)
|
|
|
known = wireprototypes.decodelist(known)
|
|
|
known = {nodemod.bin(n) for n in known}
|
|
|
if ellipses == '0':
|
|
|
ellipses = False
|
|
|
else:
|
|
|
ellipses = bool(ellipses)
|
|
|
cgversion = cgversion
|
|
|
|
|
|
bundler = bundle2.bundle20(repo.ui)
|
|
|
if not ellipses:
|
|
|
newmatch = narrowspec.match(repo.root, include=newincludes,
|
|
|
exclude=newexcludes)
|
|
|
oldmatch = narrowspec.match(repo.root, include=oldincludes,
|
|
|
exclude=oldexcludes)
|
|
|
bundle2.widen_bundle(bundler, repo, oldmatch, newmatch, common,
|
|
|
known, cgversion, ellipses)
|
|
|
else:
|
|
|
narrowbundle2.generateellipsesbundle2(bundler, repo, oldincludes,
|
|
|
oldexcludes, newincludes, newexcludes, cgversion, common,
|
|
|
list(common), known, None)
|
|
|
except error.Abort as exc:
|
|
|
bundler = bundle2.bundle20(repo.ui)
|
|
|
manargs = [('message', pycompat.bytestr(exc))]
|
|
|
advargs = []
|
|
|
if exc.hint is not None:
|
|
|
advargs.append(('hint', exc.hint))
|
|
|
bundler.addpart(bundle2.bundlepart('error:abort', manargs, advargs))
|
|
|
preferuncompressed = True
|
|
|
|
|
|
chunks = bundler.getchunks()
|
|
|
return wireprototypes.streamres(gen=chunks,
|
|
|
prefer_uncompressed=preferuncompressed)
|
|
|
|
|
|
def peernarrowwiden(remote, **kwargs):
|
|
|
for ch in (r'oldincludes', r'newincludes', r'oldexcludes', r'newexcludes',
|
|
|
r'commonheads', r'known'):
|
|
|
kwargs[ch] = wireprototypes.encodelist(kwargs[ch])
|
|
|
|
|
|
kwargs[r'ellipses'] = '%i' % bool(kwargs[r'ellipses'])
|
|
|
f = remote._callcompressable('narrow_widen', **kwargs)
|
|
|
return bundle2.getunbundler(remote.ui, f)
|
|
|
|
