diff mercurial/streamclone.py @ 52390:11484a19cd77

stream: rename all test hook point one number up This leave room for a new hook point earlier to detect some race condition with caches.
author Pierre-Yves David <pierre-yves.david@octobus.net>
date Wed, 04 Dec 2024 17:13:39 +0100
parents a260d326458f
children 3f0cf7bb3086
line wrap: on
line diff
--- a/mercurial/streamclone.py	Mon Dec 02 17:00:12 2024 +0100
+++ b/mercurial/streamclone.py	Wed Dec 04 17:13:39 2024 +0100
@@ -277,8 +277,8 @@
                 if file_size:
                     entries.append((f.unencoded_path, file_size))
                     total_bytes += file_size
-        _test_sync_point_walk_1(repo)
-    _test_sync_point_walk_2(repo)
+        _test_sync_point_walk_3(repo)
+    _test_sync_point_walk_4(repo)
 
     repo.ui.debug(
         b'%d files, %d bytes to transfer\n' % (len(entries), total_bytes)
@@ -813,11 +813,11 @@
                 progress.increment()
 
 
-def _test_sync_point_walk_1(repo):
+def _test_sync_point_walk_3(repo):
     """a function for synchronisation during tests"""
 
 
-def _test_sync_point_walk_2(repo):
+def _test_sync_point_walk_4(repo):
     """a function for synchronisation during tests"""
 
 
@@ -883,8 +883,8 @@
         chunks = _emit2(repo, entries)
         first = next(chunks)
         file_count, total_file_size = first
-        _test_sync_point_walk_1(repo)
-    _test_sync_point_walk_2(repo)
+        _test_sync_point_walk_3(repo)
+    _test_sync_point_walk_4(repo)
 
     return file_count, total_file_size, chunks
 
@@ -929,8 +929,8 @@
         chunks = _emit3(repo, list(entries))
         first = next(chunks)
         assert first is None
-        _test_sync_point_walk_1(repo)
-    _test_sync_point_walk_2(repo)
+        _test_sync_point_walk_3(repo)
+    _test_sync_point_walk_4(repo)
 
     return chunks