equal
deleted
inserted
replaced
2083 if not heads: |
2083 if not heads: |
2084 heads = cl.heads() |
2084 heads = cl.heads() |
2085 return self.getlocalbundle(source, |
2085 return self.getlocalbundle(source, |
2086 discovery.outgoing(cl, common, heads)) |
2086 discovery.outgoing(cl, common, heads)) |
2087 |
2087 |
|
2088 @unfilteredmeth |
2088 def _changegroupsubset(self, commonrevs, csets, heads, source): |
2089 def _changegroupsubset(self, commonrevs, csets, heads, source): |
2089 |
2090 |
2090 cl = self.changelog |
2091 cl = self.changelog |
2091 mf = self.manifest |
2092 mf = self.manifest |
2092 mfs = {} # needed manifests |
2093 mfs = {} # needed manifests |
2194 |
2195 |
2195 def changegroup(self, basenodes, source): |
2196 def changegroup(self, basenodes, source): |
2196 # to avoid a race we use changegroupsubset() (issue1320) |
2197 # to avoid a race we use changegroupsubset() (issue1320) |
2197 return self.changegroupsubset(basenodes, self.heads(), source) |
2198 return self.changegroupsubset(basenodes, self.heads(), source) |
2198 |
2199 |
|
2200 @unfilteredmeth |
2199 def _changegroup(self, nodes, source): |
2201 def _changegroup(self, nodes, source): |
2200 """Compute the changegroup of all nodes that we have that a recipient |
2202 """Compute the changegroup of all nodes that we have that a recipient |
2201 doesn't. Return a chunkbuffer object whose read() method will return |
2203 doesn't. Return a chunkbuffer object whose read() method will return |
2202 successive changegroup chunks. |
2204 successive changegroup chunks. |
2203 |
2205 |