Mercurial > hg
comparison mercurial/bundle2.py @ 51700:7f0cb9ee0534
Backout accidental publication of a large range of revisions
I accidentally published 25e7f9dcad0f::bd1483fd7088, this is the inverse.
author | Raphaël Gomès <rgomes@octobus.net> |
---|---|
date | Tue, 23 Jul 2024 10:02:46 +0200 |
parents | 493034cc3265 |
children | ca7bde5dbafb |
comparison
equal
deleted
inserted
replaced
51699:bd1483fd7088 | 51700:7f0cb9ee0534 |
---|---|
1284 if headersize: | 1284 if headersize: |
1285 return self._readexact(headersize) | 1285 return self._readexact(headersize) |
1286 return None | 1286 return None |
1287 | 1287 |
1288 def __call__(self): | 1288 def __call__(self): |
1289 | |
1289 self.ui.debug( | 1290 self.ui.debug( |
1290 b'bundle2-input-stream-interrupt: opening out of band context\n' | 1291 b'bundle2-input-stream-interrupt: opening out of band context\n' |
1291 ) | 1292 ) |
1292 indebug(self.ui, b'bundle2 stream interruption, looking for a part.') | 1293 indebug(self.ui, b'bundle2 stream interruption, looking for a part.') |
1293 headerblock = self._readpartheader() | 1294 headerblock = self._readpartheader() |
2611 op.addhookargs(hookargs) | 2612 op.addhookargs(hookargs) |
2612 | 2613 |
2613 | 2614 |
2614 @parthandler(b'stream2', (b'requirements', b'filecount', b'bytecount')) | 2615 @parthandler(b'stream2', (b'requirements', b'filecount', b'bytecount')) |
2615 def handlestreamv2bundle(op, part): | 2616 def handlestreamv2bundle(op, part): |
2617 | |
2616 requirements = urlreq.unquote(part.params[b'requirements']) | 2618 requirements = urlreq.unquote(part.params[b'requirements']) |
2617 requirements = requirements.split(b',') if requirements else [] | 2619 requirements = requirements.split(b',') if requirements else [] |
2618 filecount = int(part.params[b'filecount']) | 2620 filecount = int(part.params[b'filecount']) |
2619 bytecount = int(part.params[b'bytecount']) | 2621 bytecount = int(part.params[b'bytecount']) |
2620 | 2622 |