Mercurial > public > mercurial-scm > hg-stable
comparison mercurial/streamclone.py @ 3791:8643b9f90b51
introduce localrepo.spath for the store path, sopener fixes
author | Benoit Boissinot <benoit.boissinot@ens-lyon.org> |
---|---|
date | Tue, 05 Dec 2006 11:28:23 +0100 |
parents | 98f2507c5551 |
children | c0b449154a90 |
comparison
equal
deleted
inserted
replaced
3790:f183c18568df | 3791:8643b9f90b51 |
---|---|
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() |