mercurial/localrepo.py

50280:5e568d70f54d

                )
            return ret

        return checksvfs

    def close(self):
        self._writecaches()

    def _writecaches(self):
        if self._revbranchcache:

        renames = [(vfs, x, undoname(x)) for vfs, x in self._journalfiles()]
        if report:
            rp = report
        else:
            rp = self.ui.warn
        vfsmap = {b'plain': self.vfs, b'store': self.svfs}  # root of .hg/
        # we must avoid cyclic reference between repo and transaction.
        reporef = weakref.ref(self)
        # Code to track tag movement
        #
        # Since tags are all handled as file content, it is actually quite hard

    def recover(self):
        with self.lock():
            if self.svfs.exists(b"journal"):
                self.ui.status(_(b"rolling back interrupted transaction\n"))
                vfsmap = {
                    b'': self.svfs,
                    b'plain': self.vfs,
                }
                transaction.rollback(
                    self.svfs,
                    vfsmap,
                    b"journal",
                    self.ui.warn,

        ui.status(msg)
        if dryrun:
            return 0

        self.destroying()
        vfsmap = {b'plain': self.vfs, b'': self.svfs}
        skip_journal_pattern = None
        if not parentgone:
            skip_journal_pattern = RE_SKIP_DIRSTATE_ROLLBACK
        transaction.rollback(
            self.svfs,

50281:f34887316f1f

                )
            return ret

        return checksvfs

    @property
    def vfs_map(self):
        return {
            b'': self.svfs,
            b'plain': self.vfs,
            b'store': self.svfs,
        }

    def close(self):
        self._writecaches()

    def _writecaches(self):
        if self._revbranchcache:

        renames = [(vfs, x, undoname(x)) for vfs, x in self._journalfiles()]
        if report:
            rp = report
        else:
            rp = self.ui.warn
        vfsmap = self.vfs_map
        # we must avoid cyclic reference between repo and transaction.
        reporef = weakref.ref(self)
        # Code to track tag movement
        #
        # Since tags are all handled as file content, it is actually quite hard

    def recover(self):
        with self.lock():
            if self.svfs.exists(b"journal"):
                self.ui.status(_(b"rolling back interrupted transaction\n"))
                vfsmap = self.vfs_map
                transaction.rollback(
                    self.svfs,
                    vfsmap,
                    b"journal",
                    self.ui.warn,

        ui.status(msg)
        if dryrun:
            return 0

        self.destroying()
        vfsmap = self.vfs_map
        skip_journal_pattern = None
        if not parentgone:
            skip_journal_pattern = RE_SKIP_DIRSTATE_ROLLBACK
        transaction.rollback(
            self.svfs,