comparison mercurial/merge.py @ 28009:4a25e91fa55d

merge: add state extras merge state data

In future commits we will want to store more data related to each file in the
merge state. This patch adds an optional record for storing a dictionary of
extras for each file.

28008:86c4cbdaffee

    C: a change/delete or delete/change conflict
    D: a file that the external merge driver will merge internally
       (experimental)
    m: the external merge driver defined for this merge plus its run state
       (experimental)
    X: unsupported mandatory record type (used in tests)
    x: unsupported advisory record type (used in tests)

    Merge driver run states (experimental):
    u: driver-resolved files unmarked -- needs to be run next time we're about

        self._repo = repo
        self._dirty = False

    def reset(self, node=None, other=None):
        self._state = {}
        self._local = None
        self._other = None
        for var in ('localctx', 'otherctx'):
            if var in vars(self):
                delattr(self, var)

        This function process "record" entry produced by the de-serialization
        of on disk file.
        """
        self._state = {}
        self._local = None
        self._other = None
        for var in ('localctx', 'otherctx'):
            if var in vars(self):
                delattr(self, var)

                self._readmergedriver = bits[0]
                self._mdstate = mdstate
            elif rtype in 'FDC':
                bits = record.split('\0')
                self._state[bits[0]] = bits[1:]
            elif not rtype.islower():
                unsupported.add(rtype)
        self._results = {}
        self._dirty = False

            # older versions of Mercurial
            elif v[1] == nullhex or v[6] == nullhex:
                records.append(('C', '\0'.join([d] + v)))
            else:
                records.append(('F', '\0'.join([d] + v)))
        return records

    def _writerecords(self, records):
        """Write current state on disk (both v1 and v2)"""
        self._writerecordsv1(records)

        """Obtain the paths of driver-resolved files."""

        for f, entry in self._state.items():
            if entry[0] == 'd':
                yield f

    def _resolve(self, preresolve, dfile, wctx, labels=None):
        """rerun merge process for file path `dfile`"""
        if self[dfile] in 'rd':
            return True, 0

                                                       lfile, fcd, fco, fca,
                                                       labels=labels)
        if r is None:
            # no real conflict
            del self._state[dfile]
            self._dirty = True
        elif not r:
            self.mark(dfile, 'r')

        if complete:

28009:4a25e91fa55d

    C: a change/delete or delete/change conflict
    D: a file that the external merge driver will merge internally
       (experimental)
    m: the external merge driver defined for this merge plus its run state
       (experimental)
    f: a (filename, dictonary) tuple of optional values for a given file
    X: unsupported mandatory record type (used in tests)
    x: unsupported advisory record type (used in tests)

    Merge driver run states (experimental):
    u: driver-resolved files unmarked -- needs to be run next time we're about

        self._repo = repo
        self._dirty = False

    def reset(self, node=None, other=None):
        self._state = {}
        self._stateextras = {}
        self._local = None
        self._other = None
        for var in ('localctx', 'otherctx'):
            if var in vars(self):
                delattr(self, var)

        This function process "record" entry produced by the de-serialization
        of on disk file.
        """
        self._state = {}
        self._stateextras = {}
        self._local = None
        self._other = None
        for var in ('localctx', 'otherctx'):
            if var in vars(self):
                delattr(self, var)

                self._readmergedriver = bits[0]
                self._mdstate = mdstate
            elif rtype in 'FDC':
                bits = record.split('\0')
                self._state[bits[0]] = bits[1:]
            elif rtype == 'f':
                filename, rawextras = record.split('\0', 1)
                extraparts = rawextras.split('\0')
                extras = {}
                i = 0
                while i < len(extraparts):
                    extras[extraparts[i]] = extraparts[i + 1]
                    i += 2

                self._stateextras[filename] = extras
            elif not rtype.islower():
                unsupported.add(rtype)
        self._results = {}
        self._dirty = False

            # older versions of Mercurial
            elif v[1] == nullhex or v[6] == nullhex:
                records.append(('C', '\0'.join([d] + v)))
            else:
                records.append(('F', '\0'.join([d] + v)))
        for filename, extras in sorted(self._stateextras.iteritems()):
            rawextras = '\0'.join('%s\0%s' % (k, v) for k, v in
                                  extras.iteritems())
            records.append(('f', '%s\0%s' % (filename, rawextras)))
        return records

    def _writerecords(self, records):
        """Write current state on disk (both v1 and v2)"""
        self._writerecordsv1(records)

        """Obtain the paths of driver-resolved files."""

        for f, entry in self._state.items():
            if entry[0] == 'd':
                yield f

    def extras(self, filename):
        return self._stateextras.setdefault(filename, {})

    def _resolve(self, preresolve, dfile, wctx, labels=None):
        """rerun merge process for file path `dfile`"""
        if self[dfile] in 'rd':
            return True, 0

                                                       lfile, fcd, fco, fca,
                                                       labels=labels)
        if r is None:
            # no real conflict
            del self._state[dfile]
            self._stateextras.pop(dfile, None)
            self._dirty = True
        elif not r:
            self.mark(dfile, 'r')

        if complete: