Mercurial > public > mercurial-scm > hg-stable
comparison mercurial/upgrade_utils/engine.py @ 46216:34efa84a43a1
engine: pass upgrade operation inside _clonerevlogs()
Better to pass the operation instead of passing three of it's members (one of
the them is a function call) separately.
This will also be useful in future when we will like to control which things are
upgraded.
Differential Revision: https://phab.mercurial-scm.org/D9667
author | Pulkit Goyal <7895pulkit@gmail.com> |
---|---|
date | Wed, 30 Dec 2020 16:29:33 +0530 |
parents | 82f3ee1a505f |
children | 02df91e895bd |
comparison
equal
deleted
inserted
replaced
46215:82f3ee1a505f | 46216:34efa84a43a1 |
---|---|
157 def _clonerevlogs( | 157 def _clonerevlogs( |
158 ui, | 158 ui, |
159 srcrepo, | 159 srcrepo, |
160 dstrepo, | 160 dstrepo, |
161 tr, | 161 tr, |
162 deltareuse, | 162 upgrade_op, |
163 forcedeltabothparents, | |
164 revlogs=UPGRADE_ALL_REVLOGS, | |
165 ): | 163 ): |
166 """Copy revlogs between 2 repos.""" | 164 """Copy revlogs between 2 repos.""" |
167 revcount = 0 | 165 revcount = 0 |
168 srcsize = 0 | 166 srcsize = 0 |
169 srcrawsize = 0 | 167 srcrawsize = 0 |
276 ui, | 274 ui, |
277 dstrepo, | 275 dstrepo, |
278 tr, | 276 tr, |
279 oldrl, | 277 oldrl, |
280 unencoded, | 278 unencoded, |
281 deltareuse, | 279 upgrade_op.delta_reuse_mode, |
282 forcedeltabothparents, | 280 upgrade_op.has_upgrade_action(b're-delta-multibase'), |
283 revlogs, | 281 upgrade_op.revlogs_to_process, |
284 sidedatacompanion, | 282 sidedatacompanion, |
285 oncopiedrevision, | 283 oncopiedrevision, |
286 ) | 284 ) |
287 info = newrl.storageinfo(storedsize=True) | 285 info = newrl.storageinfo(storedsize=True) |
288 fdstsize += info[b'storedsize'] or 0 | 286 fdstsize += info[b'storedsize'] or 0 |
317 ui, | 315 ui, |
318 dstrepo, | 316 dstrepo, |
319 tr, | 317 tr, |
320 oldrl, | 318 oldrl, |
321 unencoded, | 319 unencoded, |
322 deltareuse, | 320 upgrade_op.delta_reuse_mode, |
323 forcedeltabothparents, | 321 upgrade_op.has_upgrade_action(b're-delta-multibase'), |
324 revlogs, | 322 upgrade_op.revlogs_to_process, |
325 sidedatacompanion, | 323 sidedatacompanion, |
326 oncopiedrevision, | 324 oncopiedrevision, |
327 ) | 325 ) |
328 info = newrl.storageinfo(storedsize=True) | 326 info = newrl.storageinfo(storedsize=True) |
329 mdstsize += info[b'storedsize'] or 0 | 327 mdstsize += info[b'storedsize'] or 0 |
357 ui, | 355 ui, |
358 dstrepo, | 356 dstrepo, |
359 tr, | 357 tr, |
360 oldrl, | 358 oldrl, |
361 unencoded, | 359 unencoded, |
362 deltareuse, | 360 upgrade_op.delta_reuse_mode, |
363 forcedeltabothparents, | 361 upgrade_op.has_upgrade_action(b're-delta-multibase'), |
364 revlogs, | 362 upgrade_op.revlogs_to_process, |
365 sidedatacompanion, | 363 sidedatacompanion, |
366 oncopiedrevision, | 364 oncopiedrevision, |
367 ) | 365 ) |
368 info = newrl.storageinfo(storedsize=True) | 366 info = newrl.storageinfo(storedsize=True) |
369 cdstsize += info[b'storedsize'] or 0 | 367 cdstsize += info[b'storedsize'] or 0 |
450 _clonerevlogs( | 448 _clonerevlogs( |
451 ui, | 449 ui, |
452 srcrepo, | 450 srcrepo, |
453 dstrepo, | 451 dstrepo, |
454 tr, | 452 tr, |
455 upgrade_op.delta_reuse_mode, | 453 upgrade_op, |
456 upgrade_op.has_upgrade_action(b're-delta-multibase'), | |
457 revlogs=upgrade_op.revlogs_to_process, | |
458 ) | 454 ) |
459 | 455 |
460 # Now copy other files in the store directory. | 456 # Now copy other files in the store directory. |
461 # The sorted() makes execution deterministic. | 457 # The sorted() makes execution deterministic. |
462 for p, kind, st in sorted(srcrepo.store.vfs.readdir(b'', stat=True)): | 458 for p, kind, st in sorted(srcrepo.store.vfs.readdir(b'', stat=True)): |