mercurial/revlog.py

46560:f7b61ad3c64a

            for data in deltas:
                node, p1, p2, linknode, deltabase, delta, flags = data
                link = linkmapper(linknode)
                flags = flags or REVIDX_DEFAULT_FLAGS

                if self.index.has_node(node):
                    # this can happen if two branches make the same change
                    self._nodeduplicatecallback(transaction, node)
                    if duplicaterevisioncb:
                        duplicaterevisioncb(self, node)
                    empty = False
                    continue

                for p in (p1, p2):
                    if not self.index.has_node(p):

                # revision(). revision() will fast path if there is a cache
                # hit. So, we tell _addrevision() to always cache in this case.
                # We're only using addgroup() in the context of changegroup
                # generation so the revision data can always be handled as raw
                # by the flagprocessor.
                self._addrevision(
                    node,
                    None,
                    transaction,
                    link,
                    p1,

                    alwayscache=alwayscache,
                    deltacomputer=deltacomputer,
                )

                if addrevisioncb:
                    addrevisioncb(self, node)
                empty = False

                if not dfh and not self._inline:
                    # addrevision switched from inline to conventional
                    # reopen the index

46561:7a93b7b3dc2d

            for data in deltas:
                node, p1, p2, linknode, deltabase, delta, flags = data
                link = linkmapper(linknode)
                flags = flags or REVIDX_DEFAULT_FLAGS

                rev = self.index.get_rev(node)
                if rev is not None:
                    # this can happen if two branches make the same change
                    self._nodeduplicatecallback(transaction, rev)
                    if duplicaterevisioncb:
                        duplicaterevisioncb(self, rev)
                    empty = False
                    continue

                for p in (p1, p2):
                    if not self.index.has_node(p):

                # revision(). revision() will fast path if there is a cache
                # hit. So, we tell _addrevision() to always cache in this case.
                # We're only using addgroup() in the context of changegroup
                # generation so the revision data can always be handled as raw
                # by the flagprocessor.
                rev = self._addrevision(
                    node,
                    None,
                    transaction,
                    link,
                    p1,

                    alwayscache=alwayscache,
                    deltacomputer=deltacomputer,
                )

                if addrevisioncb:
                    addrevisioncb(self, rev)
                empty = False

                if not dfh and not self._inline:
                    # addrevision switched from inline to conventional
                    # reopen the index