mercurial/changegroup.py

27734:5c0fd878779c

        - more heads than before: 1+added heads (2..n)
        - fewer heads than before: -1-removed heads (-2..-n)
        - number of heads stays the same: 1
        """
        repo = repo.unfiltered()
        wasempty = (len(repo.changelog) == 0)
        def csmap(x):
            repo.ui.debug("add changeset %s\n" % short(x))
            return len(cl)

        def revmap(x):

            # process the files
            repo.ui.status(_("adding file changes\n"))
            self.callback = None
            pr = prog(_('files'), efiles)
            newrevs, newfiles = _addchangegroupfiles(
                repo, self, revmap, trp, pr, needfiles, wasempty)
            revisions += newrevs
            files += newfiles

            dh = 0
            if oldheads:

def changegroup(repo, basenodes, source):
    # to avoid a race we use changegroupsubset() (issue1320)
    return changegroupsubset(repo, basenodes, repo.heads(), source)

def _addchangegroupfiles(repo, source, revmap, trp, pr, needfiles, wasempty):
    revisions = 0
    files = 0
    while True:
        chunkdata = source.filelogheader()
        if not chunkdata:

27735:bd37212c20ed

        - more heads than before: 1+added heads (2..n)
        - fewer heads than before: -1-removed heads (-2..-n)
        - number of heads stays the same: 1
        """
        repo = repo.unfiltered()
        def csmap(x):
            repo.ui.debug("add changeset %s\n" % short(x))
            return len(cl)

        def revmap(x):

            # process the files
            repo.ui.status(_("adding file changes\n"))
            self.callback = None
            pr = prog(_('files'), efiles)
            newrevs, newfiles = _addchangegroupfiles(
                repo, self, revmap, trp, pr, needfiles)
            revisions += newrevs
            files += newfiles

            dh = 0
            if oldheads:

def changegroup(repo, basenodes, source):
    # to avoid a race we use changegroupsubset() (issue1320)
    return changegroupsubset(repo, basenodes, repo.heads(), source)

def _addchangegroupfiles(repo, source, revmap, trp, pr, needfiles):
    revisions = 0
    files = 0
    while True:
        chunkdata = source.filelogheader()
        if not chunkdata: