This is an archive of the discontinued Mercurial Phabricator instance.

Status	Author	Revision
Closed	indygreg	D5136 exchange: support declaring pull depth
Closed	indygreg	D5135 exchangev2: support for calling rawstorefiledata to retrieve raw files
Closed	indygreg	D5134 wireprotov2: implement command for retrieving raw store files
Closed	indygreg	D5133 wireprotov2: add response type that serializes to indefinite length bytestring
Closed	indygreg	D5132 exchangev2: recognize narrow patterns when pulling
Closed	indygreg	D4928 sqlitestore: file storage backend using SQLite
Closed	indygreg	D5118 storageutil: extract most of peek_censored from revlog
Closed	indygreg	D5117 storageutil: convert fileid to bytes to avoid cast to %s
Closed	indygreg	D5116 testing: switch to inserting deltas
Closed	indygreg	D5115 testing: remove expectation of error on bad node insert
Closed	indygreg	D5114 tests: use byte literals in test-storage.py

Diff 12202

	# TODO consider extracting the content normalization to a			# TODO consider extracting the content normalization to a
	# standalone function, as it may be useful for e.g. cachers.			# standalone function, as it may be useful for e.g. cachers.

	# A pre-encoded object is sent directly to the emitter.			# A pre-encoded object is sent directly to the emitter.
	if isinstance(o, wireprototypes.encodedresponse):			if isinstance(o, wireprototypes.encodedresponse):
	for frame in emitter.send(o.data):			for frame in emitter.send(o.data):
	yield frame			yield frame

				elif isinstance(
				o, wireprototypes.indefinitebytestringresponse):
				for chunk in cborutil.streamencodebytestringfromiter(
				o.chunks):

				for frame in emitter.send(chunk):
				yield frame

	# A regular object is CBOR encoded.			# A regular object is CBOR encoded.
	else:			else:
	for chunk in cborutil.streamencode(o):			for chunk in cborutil.streamencode(o):
	for frame in emitter.send(chunk):			for frame in emitter.send(chunk):
	yield frame			yield frame

	except Exception as e:			except Exception as e:
	for frame in createerrorframe(stream, requestid,			for frame in createerrorframe(stream, requestid,

	"""			"""
	url = attr.ib()			url = attr.ib()
	mediatype = attr.ib()			mediatype = attr.ib()
	size = attr.ib(default=None)			size = attr.ib(default=None)
	fullhashes = attr.ib(default=None)			fullhashes = attr.ib(default=None)
	fullhashseed = attr.ib(default=None)			fullhashseed = attr.ib(default=None)
	serverdercerts = attr.ib(default=None)			serverdercerts = attr.ib(default=None)
	servercadercerts = attr.ib(default=None)			servercadercerts = attr.ib(default=None)

				@attr.s
				class indefinitebytestringresponse(object):
				"""Represents an object to be encoded to an indefinite length bytestring.

				Instances are initialized from an iterable of chunks, with each chunk being
				a bytes instance.
				"""
				chunks = attr.ib()