This is an archive of the discontinued Mercurial Phabricator instance.

Status	Author	Revision
Closed	marmoute	D9211 pycompat: add an entry for unnamedtmpfile
Closed	marmoute	D9210 pycompat: update comment about unnamedtempfile
Closed	marmoute	D9212 procutil: allow to specify arbitrary stdin bytes to runbgcommand
Closed	marmoute	D9209 clonebundle: move the manifest filename to a constant
Closed	marmoute	D9208 clonebundles: move a bundle of clone bundle related code to a new module
Closed	marmoute	D9213 test: check server error output in `test-pull-bundle.t`

Diff 23210

	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',