comparison mercurial/localrepo.py @ 13786:4ed718f909e5

changegroup: roll changegroup.collector into lookup functions

13785:470ec600b525

        # logically divide up the task, generate the group.
        def gengroup():
            # The set of changed files starts empty.
            changedfiles = set()

            collect = changegroup.collector(cl, mfs, changedfiles)
            count = [0]
            def clookup(revlog, x):
                collect(x)
                count[0] += 1
                self.ui.progress(_('bundling'), count[0], unit=_('changesets'))
                return x

            # Create a changenode group generator that will call our functions

            '''yield a sequence of changegroup chunks (strings)'''
            # construct a list of all changed files
            changedfiles = set()
            mmfs = {}

            collect = changegroup.collector(cl, mmfs, changedfiles)
            count = [0]
            def clookup(revlog, x):
                count[0] += 1
                self.ui.progress(_('bundling'), count[0], unit=_('changesets'))
                collect(x)
                return x

            for chunk in cl.group(nodes, clookup):
                yield chunk
            efiles = len(changedfiles)

13786:4ed718f909e5

        # logically divide up the task, generate the group.
        def gengroup():
            # The set of changed files starts empty.
            changedfiles = set()

            count = [0]
            def clookup(revlog, x):
                c = cl.read(x)
                changedfiles.update(c[3])
                mfs.setdefault(c[0], x)
                count[0] += 1
                self.ui.progress(_('bundling'), count[0], unit=_('changesets'))
                return x

            # Create a changenode group generator that will call our functions

            '''yield a sequence of changegroup chunks (strings)'''
            # construct a list of all changed files
            changedfiles = set()
            mmfs = {}

            count = [0]
            def clookup(revlog, x):
                c = cl.read(x)
                changedfiles.update(c[3])
                mmfs.setdefault(c[0], x)
                count[0] += 1
                self.ui.progress(_('bundling'), count[0], unit=_('changesets'))
                return x

            for chunk in cl.group(nodes, clookup):
                yield chunk
            efiles = len(changedfiles)