Show More
@@ -1498,8 +1498,8 b' class localrepository(object):' | |||
|
1498 | 1498 | |
|
1499 | 1499 | tr = self.transaction() |
|
1500 | 1500 | |
|
1501 |
# write changelog |
|
|
1502 |
# |
|
|
1501 | # write changelog data to temp files so concurrent readers will not see | |
|
1502 | # inconsistent view | |
|
1503 | 1503 | cl = None |
|
1504 | 1504 | try: |
|
1505 | 1505 | cl = appendfile.appendchangelog(self.opener, self.changelog.version) |
@@ -1515,51 +1515,38 b' class localrepository(object):' | |||
|
1515 | 1515 | cnr = cl.count() - 1 |
|
1516 | 1516 | changesets = cnr - cor |
|
1517 | 1517 | |
|
1518 | mf = None | |
|
1519 | try: | |
|
1520 | mf = appendfile.appendmanifest(self.opener, | |
|
1521 | self.manifest.version) | |
|
1522 | ||
|
1523 |
|
|
|
1524 | self.ui.status(_("adding manifests\n")) | |
|
1525 | chunkiter = changegroup.chunkiter(source) | |
|
1526 | # no need to check for empty manifest group here: | |
|
1527 | # if the result of the merge of 1 and 2 is the same in 3 and 4, | |
|
1528 | # no new manifest will be created and the manifest group will | |
|
1529 | # be empty during the pull | |
|
1530 | mf.addgroup(chunkiter, revmap, tr) | |
|
1518 | # pull off the manifest group | |
|
1519 | self.ui.status(_("adding manifests\n")) | |
|
1520 | chunkiter = changegroup.chunkiter(source) | |
|
1521 | # no need to check for empty manifest group here: | |
|
1522 | # if the result of the merge of 1 and 2 is the same in 3 and 4, | |
|
1523 | # no new manifest will be created and the manifest group will | |
|
1524 | # be empty during the pull | |
|
1525 | self.manifest.addgroup(chunkiter, revmap, tr) | |
|
1531 | 1526 | |
|
1532 |
|
|
|
1533 |
|
|
|
1534 |
|
|
|
1535 |
|
|
|
1536 |
|
|
|
1537 |
|
|
|
1538 |
|
|
|
1539 |
|
|
|
1540 |
|
|
|
1541 |
|
|
|
1542 |
|
|
|
1543 |
|
|
|
1544 |
|
|
|
1545 |
|
|
|
1527 | # process the files | |
|
1528 | self.ui.status(_("adding file changes\n")) | |
|
1529 | while 1: | |
|
1530 | f = changegroup.getchunk(source) | |
|
1531 | if not f: | |
|
1532 | break | |
|
1533 | self.ui.debug(_("adding %s revisions\n") % f) | |
|
1534 | fl = self.file(f) | |
|
1535 | o = fl.count() | |
|
1536 | chunkiter = changegroup.chunkiter(source) | |
|
1537 | if fl.addgroup(chunkiter, revmap, tr) is None: | |
|
1538 | raise util.Abort(_("received file revlog group is empty")) | |
|
1539 | revisions += fl.count() - o | |
|
1540 | files += 1 | |
|
1546 | 1541 | |
|
1547 | # write order here is important so concurrent readers will see | |
|
1548 | # consistent view of repo | |
|
1549 | mf.writedata() | |
|
1550 | finally: | |
|
1551 | if mf: | |
|
1552 | mf.cleanup() | |
|
1553 | 1542 | cl.writedata() |
|
1554 | 1543 | finally: |
|
1555 | 1544 | if cl: |
|
1556 | 1545 | cl.cleanup() |
|
1557 | 1546 | |
|
1558 |
# make changelog |
|
|
1547 | # make changelog see real files again | |
|
1559 | 1548 | self.changelog = changelog.changelog(self.opener, self.changelog.version) |
|
1560 | self.manifest = manifest.manifest(self.opener, self.manifest.version) | |
|
1561 | 1549 | self.changelog.checkinlinesize(tr) |
|
1562 | self.manifest.checkinlinesize(tr) | |
|
1563 | 1550 | |
|
1564 | 1551 | newheads = len(self.changelog.heads()) |
|
1565 | 1552 | heads = "" |
General Comments 0
You need to be logged in to leave comments.
Login now