comparison mercurial/streamclone.py @ 50279:97e91001a4e0 stable

undo-files: use the cleanup function in streamclone

Lets use the same code, so that we can fix things only once.

50278:cd680b45a920

# This software may be used and distributed according to the terms of the
# GNU General Public License version 2 or any later version.


import contextlib
import errno
import os
import struct

from .i18n import _
from .pycompat import open

    cacheutil,
    error,
    narrowspec,
    phases,
    pycompat,
    requirements as requirementsmod,
    scmutil,
    store,
    util,
)
from .revlogutils import (
    nodemap,
)
from .utils import (
    stringutil,
)


def new_stream_clone_requirements(default_requirements, streamed_requirements):
    """determine the final set of requirement for a new stream clone

        with dest_repo.transaction(b"localclone") as tr:
            dest_repo.store.write(tr)

        # clean up transaction file as they do not make sense
        undo_files = [(dest_repo.svfs, b'undo.backupfiles')]
        undo_files.extend(dest_repo.undofiles())
        for undovfs, undofile in undo_files:
            try:
                undovfs.unlink(undofile)
            except OSError as e:
                if e.errno != errno.ENOENT:
                    msg = _(b'error removing %s: %s\n')
                    path = undovfs.join(undofile)
                    e_msg = stringutil.forcebytestr(e)
                    msg %= (path, e_msg)
                    dest_repo.ui.warn(msg)

50279:97e91001a4e0

# This software may be used and distributed according to the terms of the
# GNU General Public License version 2 or any later version.


import contextlib
import os
import struct

from .i18n import _
from .pycompat import open

    cacheutil,
    error,
    narrowspec,
    phases,
    pycompat,
    repair,
    requirements as requirementsmod,
    scmutil,
    store,
    util,
)
from .revlogutils import (
    nodemap,
)


def new_stream_clone_requirements(default_requirements, streamed_requirements):
    """determine the final set of requirement for a new stream clone

        with dest_repo.transaction(b"localclone") as tr:
            dest_repo.store.write(tr)

        # clean up transaction file as they do not make sense
        repair.cleanup_undo_files(dest_repo)