This is an archive of the discontinued Mercurial Phabricator instance.


	def decompressorreader(self, fh):			def decompressorreader(self, fh):
	zstd = self._module			zstd = self._module
	dctx = zstd.ZstdDecompressor()			dctx = zstd.ZstdDecompressor()
	return chunkbuffer(dctx.read_from(fh))			return chunkbuffer(dctx.read_from(fh))

	class zstdrevlogcompressor(object):			class zstdrevlogcompressor(object):
	def __init__(self, zstd, level=3):			def __init__(self, zstd, level=3):
	# Writing the content size adds a few bytes to the output. However,			# TODO consider omitting frame magic to save 4 bytes.
	# it allows decompression to be more optimal since we can			# This writes content sizes into the frame header. That is
	# pre-allocate a buffer to hold the result.			# extra storage. But it allows a correct size memory allocation
	self._cctx = zstd.ZstdCompressor(level=level,			# to hold the result.
	write_content_size=True)			self._cctx = zstd.ZstdCompressor(level=level)
	self._dctx = zstd.ZstdDecompressor()			self._dctx = zstd.ZstdDecompressor()
	self._compinsize = zstd.COMPRESSION_RECOMMENDED_INPUT_SIZE			self._compinsize = zstd.COMPRESSION_RECOMMENDED_INPUT_SIZE
	self._decompinsize = zstd.DECOMPRESSION_RECOMMENDED_INPUT_SIZE			self._decompinsize = zstd.DECOMPRESSION_RECOMMENDED_INPUT_SIZE

	def compress(self, data):			def compress(self, data):
	insize = len(data)			insize = len(data)
	# Caller handles empty input case.			# Caller handles empty input case.
	assert insize > 0			assert insize > 0

util: drop write_content_size=TrueClosedPublic