Show More
@@ -523,6 +523,10 b' def pushkey(repo, proto, namespace, key,' | |||||
523 | def _allowstream(ui): |
|
523 | def _allowstream(ui): | |
524 | return ui.configbool('server', 'uncompressed', True, untrusted=True) |
|
524 | return ui.configbool('server', 'uncompressed', True, untrusted=True) | |
525 |
|
525 | |||
|
526 | def _walkstreamfiles(repo): | |||
|
527 | # this is it's own function so extensions can override it | |||
|
528 | return repo.store.walk() | |||
|
529 | ||||
526 | def stream(repo, proto): |
|
530 | def stream(repo, proto): | |
527 | '''If the server supports streaming clone, it advertises the "stream" |
|
531 | '''If the server supports streaming clone, it advertises the "stream" | |
528 | capability with a value representing the version and flags of the repo |
|
532 | capability with a value representing the version and flags of the repo | |
@@ -544,7 +548,7 b' def stream(repo, proto):' | |||||
544 | lock = repo.lock() |
|
548 | lock = repo.lock() | |
545 | try: |
|
549 | try: | |
546 | repo.ui.debug('scanning\n') |
|
550 | repo.ui.debug('scanning\n') | |
547 |
for name, ename, size in repo |
|
551 | for name, ename, size in _walkstreamfiles(repo): | |
548 | if size: |
|
552 | if size: | |
549 | entries.append((name, size)) |
|
553 | entries.append((name, size)) | |
550 | total_bytes += size |
|
554 | total_bytes += size |
General Comments 0
You need to be logged in to leave comments.
Login now