mercurial/streamclone.py

50471:521fec115dad

    total_bytes = 0
    # Get consistent snapshot of repo, lock during scan.
    with repo.lock():
        repo.ui.debug(b'scanning\n')
        for entry in _walkstreamfiles(repo):
            if entry.file_size:
                entries.append((entry.unencoded_path, entry.file_size))
                total_bytes += entry.file_size
        _test_sync_point_walk_1(repo)
    _test_sync_point_walk_2(repo)

    repo.ui.debug(
        b'%d files, %d bytes to transfer\n' % (len(entries), total_bytes)

    matcher = None
    if includes or excludes:
        matcher = narrowspec.match(repo.root, includes, excludes)

    for entry in _walkstreamfiles(repo, matcher):
        if entry.file_size:
            ft = _fileappend
            if entry.is_volatile:
                ft = _filefull
            entries.append(
                (_srcstore, entry.unencoded_path, ft, entry.file_size)
            )
            totalfilesize += entry.file_size
    for name in _walkstreamfullstorefiles(repo):
        if repo.svfs.exists(name):
            totalfilesize += repo.svfs.lstat(name).st_size
            entries.append((_srcstore, name, _filefull, None))
    if includeobsmarkers and repo.svfs.exists(b'obsstore'):

50472:9fdc28e21b68

    total_bytes = 0
    # Get consistent snapshot of repo, lock during scan.
    with repo.lock():
        repo.ui.debug(b'scanning\n')
        for entry in _walkstreamfiles(repo):
            for f in entry.files():
                if f.file_size:
                    entries.append((f.unencoded_path, f.file_size))
                    total_bytes += f.file_size
        _test_sync_point_walk_1(repo)
    _test_sync_point_walk_2(repo)

    repo.ui.debug(
        b'%d files, %d bytes to transfer\n' % (len(entries), total_bytes)

    matcher = None
    if includes or excludes:
        matcher = narrowspec.match(repo.root, includes, excludes)

    for entry in _walkstreamfiles(repo, matcher):
        for f in entry.files():
            if f.file_size:
                ft = _fileappend
                if f.is_volatile:
                    ft = _filefull
                entries.append((_srcstore, f.unencoded_path, ft, f.file_size))
                totalfilesize += f.file_size
    for name in _walkstreamfullstorefiles(repo):
        if repo.svfs.exists(name):
            totalfilesize += repo.svfs.lstat(name).st_size
            entries.append((_srcstore, name, _filefull, None))
    if includeobsmarkers and repo.svfs.exists(b'obsstore'):