comparison mercurial/transaction.py @ 39684:1a68c9b1920d

transaction: make map a private attribute

This is used to track which files are modified. It is an
implementation detail of current transactions and doesn't need
to be exposed to the public interface. So mark it as private.

Differential Revision: https://phab.mercurial-scm.org/D4632

39683:337d6e0fd9c9

        vfsmap = vfsmap.copy()
        vfsmap[''] = opener  # set default value
        self._vfsmap = vfsmap
        self._after = after
        self.entries = []
        self.map = {}
        self._journal = journalname
        self._undoname = undoname
        self._queue = []
        # A callback to validate transaction content before closing it.
        # should raise exception is anything is wrong.

            self._addentry(f, o, data)

    @active
    def add(self, file, offset, data=None):
        """record the state of an append-only file before update"""
        if file in self.map or file in self._backupmap:
            return
        if self._queue:
            self._queue[-1].append((file, offset, data))
            return

        self._addentry(file, offset, data)

    def _addentry(self, file, offset, data):
        """add a append-only entry to memory and on-disk state"""
        if file in self.map or file in self._backupmap:
            return
        self.entries.append((file, offset, data))
        self.map[file] = len(self.entries) - 1
        # add enough data to the journal to do the truncate
        self._file.write("%s\0%d\n" % (file, offset))
        self._file.flush()

    @active

        """
        if self._queue:
            msg = 'cannot use transaction.addbackup inside "group"'
            raise error.ProgrammingError(msg)

        if file in self.map or file in self._backupmap:
            return
        vfs = self._vfsmap[location]
        dirname, filename = vfs.split(file)
        backupfilename = "%s.backup.%s" % (self._journal, filename)
        backupfile = vfs.reljoin(dirname, backupfilename)

                    f.close()
        return any

    @active
    def find(self, file):
        if file in self.map:
            return self.entries[self.map[file]]
        if file in self._backupmap:
            return self._backupentries[self._backupmap[file]]
        return None

    @active

        '''
        replace can only replace already committed entries
        that are not pending in the queue
        '''

        if file not in self.map:
            raise KeyError(file)
        index = self.map[file]
        self.entries[index] = (file, offset, data)
        self._file.write("%s\0%d\n" % (file, offset))
        self._file.flush()

    @active

39684:1a68c9b1920d

        vfsmap = vfsmap.copy()
        vfsmap[''] = opener  # set default value
        self._vfsmap = vfsmap
        self._after = after
        self.entries = []
        self._map = {}
        self._journal = journalname
        self._undoname = undoname
        self._queue = []
        # A callback to validate transaction content before closing it.
        # should raise exception is anything is wrong.

            self._addentry(f, o, data)

    @active
    def add(self, file, offset, data=None):
        """record the state of an append-only file before update"""
        if file in self._map or file in self._backupmap:
            return
        if self._queue:
            self._queue[-1].append((file, offset, data))
            return

        self._addentry(file, offset, data)

    def _addentry(self, file, offset, data):
        """add a append-only entry to memory and on-disk state"""
        if file in self._map or file in self._backupmap:
            return
        self.entries.append((file, offset, data))
        self._map[file] = len(self.entries) - 1
        # add enough data to the journal to do the truncate
        self._file.write("%s\0%d\n" % (file, offset))
        self._file.flush()

    @active

        """
        if self._queue:
            msg = 'cannot use transaction.addbackup inside "group"'
            raise error.ProgrammingError(msg)

        if file in self._map or file in self._backupmap:
            return
        vfs = self._vfsmap[location]
        dirname, filename = vfs.split(file)
        backupfilename = "%s.backup.%s" % (self._journal, filename)
        backupfile = vfs.reljoin(dirname, backupfilename)

                    f.close()
        return any

    @active
    def find(self, file):
        if file in self._map:
            return self.entries[self._map[file]]
        if file in self._backupmap:
            return self._backupentries[self._backupmap[file]]
        return None

    @active

        '''
        replace can only replace already committed entries
        that are not pending in the queue
        '''

        if file not in self._map:
            raise KeyError(file)
        index = self._map[file]
        self.entries[index] = (file, offset, data)
        self._file.write("%s\0%d\n" % (file, offset))
        self._file.flush()

    @active