comparison mercurial/cmdutil.py @ 26632:59b5e8844eb0

dirstate: move code paths for backup from dirstateguard to dirstate

This can centralize the logic to write in-memory changes out correctly
according to transaction activity into dirstate.

Passing 'repo' object to newly added functions is needed to examine
current transaction activity in subsequent patches, because 'dirstate'
itself doesn't have direct reference to it.

26631:e077ce385609

    This just removes the backup file at ``close()`` before ``release()``.
    '''

    def __init__(self, repo, name):
        repo.dirstate.write()
        self._repo = repo
        self._filename = 'dirstate.backup.%s.%d' % (name, id(self))
        repo.vfs.write(self._filename, repo.vfs.tryread('dirstate'))
        self._active = True
        self._closed = False

    def __del__(self):
        if self._active: # still active

            # ``release(tr, ....)``.
            self._abort()

    def close(self):
        if not self._active: # already inactivated
            msg = (_("can't close already inactivated backup: %s")
                   % self._filename)
            raise error.Abort(msg)

        self._repo.vfs.unlink(self._filename)
        self._active = False
        self._closed = True

    def _abort(self):
        # this "invalidate()" prevents "wlock.release()" from writing
        # changes of dirstate out after restoring to original status
        self._repo.dirstate.invalidate()

        self._repo.vfs.rename(self._filename, 'dirstate')
        self._active = False

    def release(self):
        if not self._closed:
            if not self._active: # already inactivated
                msg = (_("can't release already inactivated backup: %s")
                       % self._filename)
                raise error.Abort(msg)
            self._abort()

_bundlecompspecs = {'none': None,
                    'bzip2': 'BZ',

26632:59b5e8844eb0

    This just removes the backup file at ``close()`` before ``release()``.
    '''

    def __init__(self, repo, name):
        self._repo = repo
        self._suffix = '.backup.%s.%d' % (name, id(self))
        repo.dirstate._savebackup(repo, self._suffix)
        self._active = True
        self._closed = False

    def __del__(self):
        if self._active: # still active

            # ``release(tr, ....)``.
            self._abort()

    def close(self):
        if not self._active: # already inactivated
            msg = (_("can't close already inactivated backup: dirstate%s")
                   % self._suffix)
            raise error.Abort(msg)

        self._repo.dirstate._clearbackup(self._repo, self._suffix)
        self._active = False
        self._closed = True

    def _abort(self):
        self._repo.dirstate._restorebackup(self._repo, self._suffix)
        self._active = False

    def release(self):
        if not self._closed:
            if not self._active: # already inactivated
                msg = (_("can't release already inactivated backup:"
                         " dirstate%s")
                       % self._suffix)
                raise error.Abort(msg)
            self._abort()

_bundlecompspecs = {'none': None,
                    'bzip2': 'BZ',