Show More
@@ -683,40 +683,6 b' Stream clone while repo is changing:' | |||||
683 | $ mkdir changing |
|
683 | $ mkdir changing | |
684 | $ cd changing |
|
684 | $ cd changing | |
685 |
|
685 | |||
686 | extension for delaying the server process so we reliably can modify the repo |
|
|||
687 | while cloning |
|
|||
688 |
|
||||
689 | $ cat > stream_steps.py <<EOF |
|
|||
690 | > import os |
|
|||
691 | > import sys |
|
|||
692 | > from mercurial import ( |
|
|||
693 | > encoding, |
|
|||
694 | > extensions, |
|
|||
695 | > streamclone, |
|
|||
696 | > testing, |
|
|||
697 | > ) |
|
|||
698 | > WALKED_FILE_1 = encoding.environ[b'HG_TEST_STREAM_WALKED_FILE_1'] |
|
|||
699 | > WALKED_FILE_2 = encoding.environ[b'HG_TEST_STREAM_WALKED_FILE_2'] |
|
|||
700 | > |
|
|||
701 | > def _test_sync_point_walk_1(orig, repo): |
|
|||
702 | > testing.write_file(WALKED_FILE_1) |
|
|||
703 | > |
|
|||
704 | > def _test_sync_point_walk_2(orig, repo): |
|
|||
705 | > assert repo._currentlock(repo._lockref) is None |
|
|||
706 | > testing.wait_file(WALKED_FILE_2) |
|
|||
707 | > |
|
|||
708 | > extensions.wrapfunction( |
|
|||
709 | > streamclone, |
|
|||
710 | > '_test_sync_point_walk_1', |
|
|||
711 | > _test_sync_point_walk_1 |
|
|||
712 | > ) |
|
|||
713 | > extensions.wrapfunction( |
|
|||
714 | > streamclone, |
|
|||
715 | > '_test_sync_point_walk_2', |
|
|||
716 | > _test_sync_point_walk_2 |
|
|||
717 | > ) |
|
|||
718 | > EOF |
|
|||
719 |
|
||||
720 | prepare repo with small and big file to cover both code paths in emitrevlogdata |
|
686 | prepare repo with small and big file to cover both code paths in emitrevlogdata | |
721 |
|
687 | |||
722 | $ hg init repo |
|
688 | $ hg init repo |
General Comments 0
You need to be logged in to leave comments.
Login now