[PATCH 6 of 6 clone bundles] clonebundles: advertise clone bundles feature to clients
Augie Fackler
raf at durin42.com
Thu Oct 15 08:47:30 CDT 2015
On Wed, Oct 14, 2015 at 11:07:58AM -0700, Gregory Szorc wrote:
> # HG changeset patch
> # User Gregory Szorc <gregory.szorc at gmail.com>
> # Date 1444845953 25200
> # Wed Oct 14 11:05:53 2015 -0700
> # Node ID 2aaae4e1134db787e6fdc41829b17451750a2d4d
> # Parent 69474173bfb98339226a29c0ba132adb7619626a
> clonebundles: advertise clone bundles feature to clients
Queued these, thanks.
>
> Server operators that have enabled clone bundles probably want clients
> to use it. This patch introduces a feature that will insert a bundle2
> "output" part that advertises the existence of the clone bundles
> feature to clients that aren't using it.
>
> The server uses the "cbattempted" argument to "getbundle" to determine
> whether a client supports clone bundles and to avoid sending the message
> to clients that failed the clone bundle for whatever reason.
>
> diff --git a/hgext/clonebundles.py b/hgext/clonebundles.py
> --- a/hgext/clonebundles.py
> +++ b/hgext/clonebundles.py
> @@ -63,9 +63,12 @@ REQUIRESNI
>
> Value should be "true".
> """
>
> +from mercurial.i18n import _
> +from mercurial.node import nullid
> from mercurial import (
> + exchange,
> extensions,
> wireproto,
> )
>
> @@ -93,6 +96,45 @@ def bundles(repo, proto):
> the closest data center given the client's IP address.
> """
> return repo.opener.tryread('clonebundles.manifest')
>
> + at exchange.getbundle2partsgenerator('clonebundlesadvertise', 0)
> +def advertiseclonebundlespart(bundler, repo, source, bundlecaps=None,
> + b2caps=None, heads=None, common=None,
> + cbattempted=None, **kwargs):
> + """Inserts an output part to advertise clone bundles availability."""
> + # Allow server operators to disable this behavior.
> + # # experimental config: ui.clonebundleadvertise
> + if not repo.ui.configbool('ui', 'clonebundleadvertise', True):
> + return
> +
> + # Only advertise if a manifest is present.
> + if not repo.opener.exists('clonebundles.manifest'):
> + return
> +
> + # And when changegroup data is requested.
> + if not kwargs.get('cg', True):
> + return
> +
> + # And when the client supports clone bundles.
> + if cbattempted is None:
> + return
> +
> + # And when the client didn't attempt a clone bundle as part of this pull.
> + if cbattempted:
> + return
> +
> + # And when a full clone is requested.
> + # Note: client should not send "cbattempted" for regular pulls. This check
> + # is defense in depth.
> + if common and common != [nullid]:
> + return
> +
> + msg = _('this server supports the experimental "clone bundles" feature '
> + 'that should enable faster and more reliable cloning\n'
> + 'help test it by setting the "experimental.clonebundles" config '
> + 'flag to "true"')
> +
> + bundler.newpart('output', data=msg)
> +
> def extsetup(ui):
> extensions.wrapfunction(wireproto, '_capabilities', capabilities)
> diff --git a/tests/test-clonebundles.t b/tests/test-clonebundles.t
> --- a/tests/test-clonebundles.t
> +++ b/tests/test-clonebundles.t
> @@ -63,8 +63,19 @@ Empty manifest file results in retrieval
> adding manifests
> adding file changes
> added 2 changesets with 2 changes to 2 files
>
> +Server advertises presence of feature to client requesting full clone
> +
> + $ hg --config experimental.clonebundles=false clone -U http://localhost:$HGPORT advertise-on-clone
> + requesting all changes
> + remote: this server supports the experimental "clone bundles" feature that should enable faster and more reliable cloning
> + remote: help test it by setting the "experimental.clonebundles" config flag to "true"
> + adding changesets
> + adding manifests
> + adding file changes
> + added 2 changesets with 2 changes to 2 files
> +
> Manifest file with invalid URL aborts
>
> $ echo 'http://does.not.exist/bundle.hg' > server/.hg/clonebundles.manifest
> $ hg clone http://localhost:$HGPORT 404-url
> _______________________________________________
> Mercurial-devel mailing list
> Mercurial-devel at selenic.com
> https://selenic.com/mailman/listinfo/mercurial-devel
More information about the Mercurial-devel
mailing list