Show More
@@ -1526,14 +1526,14 b' class localrepository(repo.repository):' | |||||
1526 | # Create a changenode group generator that will call our functions |
|
1526 | # Create a changenode group generator that will call our functions | |
1527 | # back to lookup the owning changenode and collect information. |
|
1527 | # back to lookup the owning changenode and collect information. | |
1528 | group = cl.group(csets, lambda x: x, collect) |
|
1528 | group = cl.group(csets, lambda x: x, collect) | |
1529 | for cnt, chnk in enumerate(group): |
|
1529 | for count, chunk in enumerate(group): | |
1530 | yield chnk |
|
1530 | yield chunk | |
1531 | # revlog.group yields three entries per node, so |
|
1531 | # revlog.group yields three entries per node, so | |
1532 | # dividing by 3 gives an approximation of how many |
|
1532 | # dividing by 3 gives an approximation of how many | |
1533 | # nodes have been processed. |
|
1533 | # nodes have been processed. | |
1534 | self.ui.progress(_('bundling'), cnt / 3, |
|
1534 | self.ui.progress(_('bundling'), count / 3, | |
1535 | unit=_('changesets')) |
|
1535 | unit=_('changesets')) | |
1536 | changecount = cnt / 3 |
|
1536 | changecount = count / 3 | |
1537 | self.ui.progress(_('bundling'), None) |
|
1537 | self.ui.progress(_('bundling'), None) | |
1538 |
|
1538 | |||
1539 | prune(mf, mfs) |
|
1539 | prune(mf, mfs) | |
@@ -1543,13 +1543,13 b' class localrepository(repo.repository):' | |||||
1543 | lambda mnode: mfs[mnode], |
|
1543 | lambda mnode: mfs[mnode], | |
1544 | filenode_collector(changedfiles)) |
|
1544 | filenode_collector(changedfiles)) | |
1545 | efiles = {} |
|
1545 | efiles = {} | |
1546 | for cnt, chnk in enumerate(group): |
|
1546 | for count, chunk in enumerate(group): | |
1547 | if cnt % 3 == 1: |
|
1547 | if count % 3 == 1: | |
1548 | mnode = chnk[:20] |
|
1548 | mnode = chunk[:20] | |
1549 | efiles.update(mf.readdelta(mnode)) |
|
1549 | efiles.update(mf.readdelta(mnode)) | |
1550 | yield chnk |
|
1550 | yield chunk | |
1551 | # see above comment for why we divide by 3 |
|
1551 | # see above comment for why we divide by 3 | |
1552 | self.ui.progress(_('bundling'), cnt / 3, |
|
1552 | self.ui.progress(_('bundling'), count / 3, | |
1553 | unit=_('manifests'), total=changecount) |
|
1553 | unit=_('manifests'), total=changecount) | |
1554 | self.ui.progress(_('bundling'), None) |
|
1554 | self.ui.progress(_('bundling'), None) | |
1555 | efiles = len(efiles) |
|
1555 | efiles = len(efiles) | |
@@ -1576,14 +1576,14 b' class localrepository(repo.repository):' | |||||
1576 | group = filerevlog.group( |
|
1576 | group = filerevlog.group( | |
1577 | sorted(missingfnodes, key=filerevlog.rev), |
|
1577 | sorted(missingfnodes, key=filerevlog.rev), | |
1578 | lambda fnode: missingfnodes[fnode]) |
|
1578 | lambda fnode: missingfnodes[fnode]) | |
1579 | for chnk in group: |
|
1579 | for chunk in group: | |
1580 | # even though we print the same progress on |
|
1580 | # even though we print the same progress on | |
1581 | # most loop iterations, put the progress call |
|
1581 | # most loop iterations, put the progress call | |
1582 | # here so that time estimates (if any) can be updated |
|
1582 | # here so that time estimates (if any) can be updated | |
1583 | self.ui.progress( |
|
1583 | self.ui.progress( | |
1584 | _('bundling'), idx, item=fname, |
|
1584 | _('bundling'), idx, item=fname, | |
1585 | unit=_('files'), total=efiles) |
|
1585 | unit=_('files'), total=efiles) | |
1586 | yield chnk |
|
1586 | yield chunk | |
1587 | # Signal that no more groups are left. |
|
1587 | # Signal that no more groups are left. | |
1588 | yield changegroup.closechunk() |
|
1588 | yield changegroup.closechunk() | |
1589 | self.ui.progress(_('bundling'), None) |
|
1589 | self.ui.progress(_('bundling'), None) |
General Comments 0
You need to be logged in to leave comments.
Login now