mercurial/obsolete.py

25668:1c2df7c91cf2

    # meta:    binary blob, encoded metadata dictionary
    # date:    (float, int) tuple, date of marker creation
    # parents: (tuple of nodeid) or None, parents of precursors
    #          None is used when no data has been recorded

    def __init__(self, sopener, defaultformat=_fm1version, readonly=False):
        # caches for various obsolescence related cache
        self.caches = {}
        self._all = []
        self.sopener = sopener
        data = sopener.tryread('obsstore')
        self._version = defaultformat
        self._readonly = readonly
        if data:
            self._version, markers = _readmarkers(data)
            self._addmarkers(markers)

        for m in markers:
            if m not in known:
                known.add(m)
                new.append(m)
        if new:
            f = self.sopener('obsstore', 'ab')
            try:
                offset = f.tell()
                transaction.add('obsstore', offset)
                # offset == 0: new file - add the version header
                for bytes in encodemarkers(new, offset == 0, self._version):

25669:8d94861842e5

    # meta:    binary blob, encoded metadata dictionary
    # date:    (float, int) tuple, date of marker creation
    # parents: (tuple of nodeid) or None, parents of precursors
    #          None is used when no data has been recorded

    def __init__(self, svfs, defaultformat=_fm1version, readonly=False):
        # caches for various obsolescence related cache
        self.caches = {}
        self._all = []
        self.svfs = svfs
        data = svfs.tryread('obsstore')
        self._version = defaultformat
        self._readonly = readonly
        if data:
            self._version, markers = _readmarkers(data)
            self._addmarkers(markers)

        for m in markers:
            if m not in known:
                known.add(m)
                new.append(m)
        if new:
            f = self.svfs('obsstore', 'ab')
            try:
                offset = f.tell()
                transaction.add('obsstore', offset)
                # offset == 0: new file - add the version header
                for bytes in encodemarkers(new, offset == 0, self._version):