223 # add the changegroup bundle |
223 # add the changegroup bundle |
224 cg = changegroup.getlocalbundle(pushop.repo, 'push', pushop.outgoing) |
224 cg = changegroup.getlocalbundle(pushop.repo, 'push', pushop.outgoing) |
225 cgpart = bundle2.bundlepart('B2X:CHANGEGROUP', data=cg.getchunks()) |
225 cgpart = bundle2.bundlepart('B2X:CHANGEGROUP', data=cg.getchunks()) |
226 bundler.addpart(cgpart) |
226 bundler.addpart(cgpart) |
227 stream = util.chunkbuffer(bundler.getchunks()) |
227 stream = util.chunkbuffer(bundler.getchunks()) |
228 reply = pushop.remote.unbundle(stream, ['force'], 'push') |
228 try: |
|
229 reply = pushop.remote.unbundle(stream, ['force'], 'push') |
|
230 except bundle2.UnknownPartError, exc: |
|
231 raise util.Abort('missing support for %s' % exc) |
229 try: |
232 try: |
230 op = bundle2.processbundle(pushop.repo, reply) |
233 op = bundle2.processbundle(pushop.repo, reply) |
231 except bundle2.UnknownPartError, exc: |
234 except bundle2.UnknownPartError, exc: |
232 raise util.Abort('missing support for %s' % exc) |
235 raise util.Abort('missing support for %s' % exc) |
233 cgreplies = op.records.getreplies(cgpart.id) |
236 cgreplies = op.records.getreplies(cgpart.id) |