Show More
@@ -584,9 +584,9 b' def getsubsetraw(repo, outgoing, bundler' | |||||
584 | _changegroupinfo(repo, csets, source) |
|
584 | _changegroupinfo(repo, csets, source) | |
585 | return bundler.generate(commonrevs, csets, fastpathlinkrev, source) |
|
585 | return bundler.generate(commonrevs, csets, fastpathlinkrev, source) | |
586 |
|
586 | |||
587 |
def getsubset(repo, outgoing, bundler, source, fastpath=False |
|
587 | def getsubset(repo, outgoing, bundler, source, fastpath=False): | |
588 | gengroup = getsubsetraw(repo, outgoing, bundler, source, fastpath) |
|
588 | gengroup = getsubsetraw(repo, outgoing, bundler, source, fastpath) | |
589 | return packermap[version][1](util.chunkbuffer(gengroup), None) |
|
589 | return packermap[bundler.version][1](util.chunkbuffer(gengroup), None) | |
590 |
|
590 | |||
591 | def changegroupsubset(repo, roots, heads, source, version='01'): |
|
591 | def changegroupsubset(repo, roots, heads, source, version='01'): | |
592 | """Compute a changegroup consisting of all the nodes that are |
|
592 | """Compute a changegroup consisting of all the nodes that are | |
@@ -613,7 +613,7 b' def changegroupsubset(repo, roots, heads' | |||||
613 | discbases = [n for n in discbases if n not in included] |
|
613 | discbases = [n for n in discbases if n not in included] | |
614 | outgoing = discovery.outgoing(cl, discbases, heads) |
|
614 | outgoing = discovery.outgoing(cl, discbases, heads) | |
615 | bundler = packermap[version][0](repo) |
|
615 | bundler = packermap[version][0](repo) | |
616 |
return getsubset(repo, outgoing, bundler, source |
|
616 | return getsubset(repo, outgoing, bundler, source) | |
617 |
|
617 | |||
618 | def getlocalchangegroupraw(repo, source, outgoing, bundlecaps=None, |
|
618 | def getlocalchangegroupraw(repo, source, outgoing, bundlecaps=None, | |
619 | version='01'): |
|
619 | version='01'): |
@@ -63,7 +63,7 b' test bundle types' | |||||
63 | 1 changesets found |
|
63 | 1 changesets found | |
64 | HG20\x00\x00 (esc) |
|
64 | HG20\x00\x00 (esc) | |
65 | Stream params: {} |
|
65 | Stream params: {} | |
66 |
changegroup -- "{'version': '0 |
|
66 | changegroup -- "{'version': '02'}" | |
67 | c35a0f9217e65d1fdb90c936ffa7dbe679f83ddf |
|
67 | c35a0f9217e65d1fdb90c936ffa7dbe679f83ddf | |
68 |
|
68 | |||
69 | % test bundle type v2 |
|
69 | % test bundle type v2 | |
@@ -71,7 +71,7 b' test bundle types' | |||||
71 | 1 changesets found |
|
71 | 1 changesets found | |
72 | HG20\x00\x00 (esc) |
|
72 | HG20\x00\x00 (esc) | |
73 | Stream params: {'Compression': 'BZ'} |
|
73 | Stream params: {'Compression': 'BZ'} | |
74 |
changegroup -- "{'version': '0 |
|
74 | changegroup -- "{'version': '02'}" | |
75 | c35a0f9217e65d1fdb90c936ffa7dbe679f83ddf |
|
75 | c35a0f9217e65d1fdb90c936ffa7dbe679f83ddf | |
76 |
|
76 | |||
77 | % test bundle type v1 |
|
77 | % test bundle type v1 |
General Comments 0
You need to be logged in to leave comments.
Login now