This is an archive of the discontinued Mercurial Phabricator instance.

Status	Author	Revision
Closed	marmoute	D10482 store: exclude `undo.` nodemap's file from `walk`
Closed	marmoute	D10481 streamclone: treat volatile file as "fullfile"
Closed	marmoute	D10480 nodemap: add a test about nodemap "vacuum" during stream clone
Closed	marmoute	D10479 nodemap: add a test about racy commit during stream clone
Closed	marmoute	D10478 streamclone: remove sleep based "synchronisation" in tests
Closed	marmoute	D10477 testing: add a `write_file` function
Closed	marmoute	D10476 testing: add a utility function to wait for file create
Closed	marmoute	D10475 streamclone: check the errors log in tests

Diff 27116

				from __future__ import (
				absolute_import,
				division,
				)

				import os
				import time


				# work around check-code complains
				#
				# This is a simple log level module doing simple test related work, we can't
				# import more things, and we do not need it.
				environ = getattr(os, 'environ')


				def _timeout_factor():
				"""return the current modification to timeout"""
				default = int(environ.get('HGTEST_TIMEOUT_DEFAULT', 1))
				current = int(environ.get('HGTEST_TIMEOUT', default))
				return current / float(default)


				def wait_file(path, timeout=10):
				timeout *= _timeout_factor()
				start = time.time()
				while not os.path.exists(path):
				if time.time() - start > timeout:
				raise RuntimeError(b"timed out waiting for file: %s" % path)
				time.sleep(0.01)