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