This is an archive of the discontinued Mercurial Phabricator instance.

Differential D720

infinitepush: serve trees from stored bundle when rebundling
ClosedPublic

Authored by durham on Sep 14 2017, 7:50 PM.
Tags
None
Subscribers
None

Details

Reviewers
stash
Group Reviewers
Restricted Project
Commits
rFBHGXa5b6013b7e5c: infinitepush: serve trees from stored bundle when rebundling
Summary

When serving data from a stored bundle, if we need to rebundle the data first,
we need to make sure that the tree data stored within the bundle gets packaged
up as well.

If we're not rebundling, then things work fine as is since it just forwards the
parts along.

Diff Detail

Repository
rFBHGX Facebook Mercurial Extensions
Lint
Automatic diff as part of commit; lint not applicable.
Unit
Automatic diff as part of commit; unit tests not applicable.

Event Timeline

durham created this revision.Sep 14 2017, 7:50 PM
Herald added a reviewer: Restricted Project. · View Herald TranscriptSep 14 2017, 7:50 PM
stash accepted this revision.Sep 15 2017, 1:29 PM
This revision is now accepted and ready to land.Sep 15 2017, 1:29 PM
Closed by commit rFBHGXa5b6013b7e5c: infinitepush: serve trees from stored bundle when rebundling (authored by durham). · Explain WhySep 22 2017, 1:33 PM
This revision was automatically updated to reflect the committed changes.

Revision Contents
Changeset List

PathPackages
Minfinitepush/__init__.py (10 lines)

Diff 2036

infinitepush/__init__.py

version = '02' version = '02'
outgoing = discovery.outgoing(bundlerepo, commonheads=bundleroots, outgoing = discovery.outgoing(bundlerepo, commonheads=bundleroots,
missingheads=[unknownhead]) missingheads=[unknownhead])
cgstream = changegroup.makestream(bundlerepo, outgoing, version, 'pull') cgstream = changegroup.makestream(bundlerepo, outgoing, version, 'pull')
cgstream = util.chunkbuffer(cgstream).read() cgstream = util.chunkbuffer(cgstream).read()
cgpart = bundle2.bundlepart('changegroup', data=cgstream) cgpart = bundle2.bundlepart('changegroup', data=cgstream)
cgpart.addparam('version', version) cgpart.addparam('version', version)
parts.append(cgpart) parts.append(cgpart)
try:
treemod = extensions.find('treemanifest')
except KeyError:
pass
else:
treepart = treemod.createtreepackpart(bundlerepo, outgoing,
treemod.TREEGROUP_PARTTYPE2)
parts.append(treepart)
return parts return parts
def _getbundleroots(oldrepo, bundlerepo, bundlerevs): def _getbundleroots(oldrepo, bundlerepo, bundlerevs):
cl = bundlerepo.changelog cl = bundlerepo.changelog
bundleroots = [] bundleroots = []
for rev in bundlerevs: for rev in bundlerevs:
node = cl.node(rev) node = cl.node(rev)
parents = cl.parents(node) parents = cl.parents(node)