This is an archive of the discontinued Mercurial Phabricator instance.

Status	Author	Revision
Closed	marmoute	D10731 updatecaches: deprecate the `full` argument
Closed	marmoute	D10730 updatecaches: use the `caches` argument instead of a special `full` value
Closed	marmoute	D10729 updatecaches: use the caches argument in `hg debugupdatecaches`
Closed	marmoute	D10728 updatecaches: adds a `caches` parameters to `repo.updatecaches`
Closed	marmoute	D10727 updatecaches: introduce a set of constants to control which are updated

Diff 28069

	statichttprepo,			statichttprepo,
	ui as uimod,			ui as uimod,
	unionrepo,			unionrepo,
	url,			url,
	util,			util,
	verify as verifymod,			verify as verifymod,
	vfs as vfsmod,			vfs as vfsmod,
	)			)
				from .interfaces import repository as repositorymod
	from .utils import (			from .utils import (
	hashutil,			hashutil,
	stringutil,			stringutil,
	urlutil,			urlutil,
	)			)


	release = lock.release			release = lock.release
	bookmarks.activate(destrepo, update)			bookmarks.activate(destrepo, update)
	if destlock is not None:			if destlock is not None:
	release(destlock)			release(destlock)
	# here is a tiny windows were someone could end up writing the			# here is a tiny windows were someone could end up writing the
	# repository before the cache are sure to be warm. This is "fine"			# repository before the cache are sure to be warm. This is "fine"
	# as the only "bad" outcome would be some slowness. That potential			# as the only "bad" outcome would be some slowness. That potential
	# slowness already affect reader.			# slowness already affect reader.
	with destrepo.lock():			with destrepo.lock():
	destrepo.updatecaches(full=b"post-clone")			destrepo.updatecaches(caches=repositorymod.CACHES_POST_CLONE)
	finally:			finally:
	release(srclock, destlock)			release(srclock, destlock)
	if cleandir is not None:			if cleandir is not None:
	shutil.rmtree(cleandir, True)			shutil.rmtree(cleandir, True)
	if srcpeer is not None:			if srcpeer is not None:
	srcpeer.close()			srcpeer.close()
	if destpeer and destpeer.local() is None:			if destpeer and destpeer.local() is None:
	destpeer.close()			destpeer.close()

	CACHE_CHANGELOG_CACHE,			CACHE_CHANGELOG_CACHE,
	CACHE_FILE_NODE_TAGS,			CACHE_FILE_NODE_TAGS,
	CACHE_FULL_MANIFEST,			CACHE_FULL_MANIFEST,
	CACHE_MANIFESTLOG_CACHE,			CACHE_MANIFESTLOG_CACHE,
	CACHE_TAGS_DEFAULT,			CACHE_TAGS_DEFAULT,
	CACHE_TAGS_SERVED,			CACHE_TAGS_SERVED,
	}			}

				# the cache to warm by default on simple call
				# (this is a mutable set to let extension update it)
				CACHES_POST_CLONE = CACHES_ALL.copy()
				CACHES_POST_CLONE.discard(CACHE_FILE_NODE_TAGS)


	class ipeerconnection(interfaceutil.Interface):			class ipeerconnection(interfaceutil.Interface):
	"""Represents a "connection" to a repository.			"""Represents a "connection" to a repository.

	This is the base interface for representing a connection to a repository.			This is the base interface for representing a connection to a repository.
	It holds basic properties and methods applicable to all peer types.			It holds basic properties and methods applicable to all peer types.

	This is not a complete interface definition and should not be used			This is not a complete interface definition and should not be used

	return			return

	unfi = self.unfiltered()			unfi = self.unfiltered()

	if caches is None:			if caches is None:
	if full:			if full:
	caches = repository.CACHES_ALL			caches = repository.CACHES_ALL
	if full == b"post-clone":			if full == b"post-clone":
	caches = caches.copy()			caches = repository.CACHES_POST_CLONE
	caches.discard(repository.CACHE_FILE_NODE_TAGS)
	else:			else:
	caches = repository.CACHES_DEFAULT			caches = repository.CACHES_DEFAULT

	if repository.CACHE_BRANCHMAP_SERVED in caches:			if repository.CACHE_BRANCHMAP_SERVED in caches:
	if tr is None or tr.changes[b'origrepolen'] < len(self):			if tr is None or tr.changes[b'origrepolen'] < len(self):
	# accessing the 'served' branchmap should refresh all the others,			# accessing the 'served' branchmap should refresh all the others,
	self.ui.debug(b'updating the branch cache\n')			self.ui.debug(b'updating the branch cache\n')
	self.filtered(b'served').branchmap()			self.filtered(b'served').branchmap()