Show More
@@ -1484,10 +1484,10 b' def generatestreamclone(repo):' | |||||
1484 | (len(entries), total_bytes)) |
|
1484 | (len(entries), total_bytes)) | |
1485 | yield '%d %d\n' % (len(entries), total_bytes) |
|
1485 | yield '%d %d\n' % (len(entries), total_bytes) | |
1486 |
|
1486 | |||
1487 |
s |
|
1487 | svfs = repo.svfs | |
1488 |
oldaudit = s |
|
1488 | oldaudit = svfs.mustaudit | |
1489 | debugflag = repo.ui.debugflag |
|
1489 | debugflag = repo.ui.debugflag | |
1490 |
s |
|
1490 | svfs.mustaudit = False | |
1491 |
|
1491 | |||
1492 | try: |
|
1492 | try: | |
1493 | for name, size in entries: |
|
1493 | for name, size in entries: | |
@@ -1496,17 +1496,17 b' def generatestreamclone(repo):' | |||||
1496 | # partially encode name over the wire for backwards compat |
|
1496 | # partially encode name over the wire for backwards compat | |
1497 | yield '%s\0%d\n' % (store.encodedir(name), size) |
|
1497 | yield '%s\0%d\n' % (store.encodedir(name), size) | |
1498 | if size <= 65536: |
|
1498 | if size <= 65536: | |
1499 |
fp = s |
|
1499 | fp = svfs(name) | |
1500 | try: |
|
1500 | try: | |
1501 | data = fp.read(size) |
|
1501 | data = fp.read(size) | |
1502 | finally: |
|
1502 | finally: | |
1503 | fp.close() |
|
1503 | fp.close() | |
1504 | yield data |
|
1504 | yield data | |
1505 | else: |
|
1505 | else: | |
1506 |
for chunk in util.filechunkiter(s |
|
1506 | for chunk in util.filechunkiter(svfs(name), limit=size): | |
1507 | yield chunk |
|
1507 | yield chunk | |
1508 | finally: |
|
1508 | finally: | |
1509 |
s |
|
1509 | svfs.mustaudit = oldaudit | |
1510 |
|
1510 | |||
1511 | def consumestreamclone(repo, fp): |
|
1511 | def consumestreamclone(repo, fp): | |
1512 | """Apply the contents from a streaming clone file. |
|
1512 | """Apply the contents from a streaming clone file. |
General Comments 0
You need to be logged in to leave comments.
Login now