equal
deleted
inserted
replaced
1191 """Reads bundle2 part payload data into chunks. |
1191 """Reads bundle2 part payload data into chunks. |
1192 |
1192 |
1193 Part payload data consists of framed chunks. This function takes |
1193 Part payload data consists of framed chunks. This function takes |
1194 a file handle and emits those chunks. |
1194 a file handle and emits those chunks. |
1195 """ |
1195 """ |
|
1196 dolog = ui.configbool('devel', 'bundle2.debug') |
|
1197 debug = ui.debug |
|
1198 |
1196 headersize = struct.calcsize(_fpayloadsize) |
1199 headersize = struct.calcsize(_fpayloadsize) |
1197 readexactly = changegroup.readexactly |
1200 readexactly = changegroup.readexactly |
1198 |
1201 |
1199 chunksize = _unpack(_fpayloadsize, readexactly(fh, headersize))[0] |
1202 chunksize = _unpack(_fpayloadsize, readexactly(fh, headersize))[0] |
1200 indebug(ui, 'payload chunk size: %i' % chunksize) |
1203 indebug(ui, 'payload chunk size: %i' % chunksize) |
1209 else: |
1212 else: |
1210 raise error.BundleValueError( |
1213 raise error.BundleValueError( |
1211 'negative payload chunk size: %s' % chunksize) |
1214 'negative payload chunk size: %s' % chunksize) |
1212 |
1215 |
1213 chunksize = _unpack(_fpayloadsize, readexactly(fh, headersize))[0] |
1216 chunksize = _unpack(_fpayloadsize, readexactly(fh, headersize))[0] |
1214 indebug(ui, 'payload chunk size: %i' % chunksize) |
1217 |
|
1218 # indebug() inlined for performance. |
|
1219 if dolog: |
|
1220 debug('bundle2-input: payload chunk size: %i\n' % chunksize) |
1215 |
1221 |
1216 class unbundlepart(unpackermixin): |
1222 class unbundlepart(unpackermixin): |
1217 """a bundle part read from a bundle""" |
1223 """a bundle part read from a bundle""" |
1218 |
1224 |
1219 def __init__(self, ui, header, fp): |
1225 def __init__(self, ui, header, fp): |