76 |
76 |
77 fileobj.write('0\n') |
77 fileobj.write('0\n') |
78 repo.ui.debug('scanning\n') |
78 repo.ui.debug('scanning\n') |
79 entries = [] |
79 entries = [] |
80 total_bytes = 0 |
80 total_bytes = 0 |
81 for name, size in walkrepo(repo.path): |
81 for name, size in walkrepo(repo.spath): |
82 entries.append((name, size)) |
82 entries.append((name, size)) |
83 total_bytes += size |
83 total_bytes += size |
84 repolock.release() |
84 repolock.release() |
85 |
85 |
86 repo.ui.debug('%d files, %d bytes to transfer\n' % |
86 repo.ui.debug('%d files, %d bytes to transfer\n' % |
87 (len(entries), total_bytes)) |
87 (len(entries), total_bytes)) |
88 fileobj.write('%d %d\n' % (len(entries), total_bytes)) |
88 fileobj.write('%d %d\n' % (len(entries), total_bytes)) |
89 for name, size in entries: |
89 for name, size in entries: |
90 repo.ui.debug('sending %s (%d bytes)\n' % (name, size)) |
90 repo.ui.debug('sending %s (%d bytes)\n' % (name, size)) |
91 fileobj.write('%s\0%d\n' % (name, size)) |
91 fileobj.write('%s\0%d\n' % (name, size)) |
92 for chunk in util.filechunkiter(repo.opener(name), limit=size): |
92 for chunk in util.filechunkiter(repo.sopener(name), limit=size): |
93 fileobj.write(chunk) |
93 fileobj.write(chunk) |
94 flush = getattr(fileobj, 'flush', None) |
94 flush = getattr(fileobj, 'flush', None) |
95 if flush: flush() |
95 if flush: flush() |