Show More
@@ -213,26 +213,21 b' def generatev1(repo):' | |||
|
213 | 213 | (len(entries), total_bytes)) |
|
214 | 214 | |
|
215 | 215 | svfs = repo.svfs |
|
216 | oldaudit = svfs.mustaudit | |
|
217 | 216 | debugflag = repo.ui.debugflag |
|
218 | svfs.mustaudit = False | |
|
219 | 217 | |
|
220 | 218 | def emitrevlogdata(): |
|
221 | try: | |
|
222 | for name, size in entries: | |
|
223 | if debugflag: | |
|
224 | repo.ui.debug('sending %s (%d bytes)\n' % (name, size)) | |
|
225 | # partially encode name over the wire for backwards compat | |
|
226 | yield '%s\0%d\n' % (store.encodedir(name), size) | |
|
227 | if size <= 65536: | |
|
228 | with svfs(name, 'rb', auditpath=False) as fp: | |
|
229 | yield fp.read(size) | |
|
230 | else: | |
|
231 | data = svfs(name, auditpath=False) | |
|
232 | for chunk in util.filechunkiter(data, limit=size): | |
|
233 | yield chunk | |
|
234 | finally: | |
|
235 | svfs.mustaudit = oldaudit | |
|
219 | for name, size in entries: | |
|
220 | if debugflag: | |
|
221 | repo.ui.debug('sending %s (%d bytes)\n' % (name, size)) | |
|
222 | # partially encode name over the wire for backwards compat | |
|
223 | yield '%s\0%d\n' % (store.encodedir(name), size) | |
|
224 | if size <= 65536: | |
|
225 | with svfs(name, 'rb', auditpath=False) as fp: | |
|
226 | yield fp.read(size) | |
|
227 | else: | |
|
228 | data = svfs(name, auditpath=False) | |
|
229 | for chunk in util.filechunkiter(data, limit=size): | |
|
230 | yield chunk | |
|
236 | 231 | |
|
237 | 232 | return len(entries), total_bytes, emitrevlogdata() |
|
238 | 233 |
General Comments 0
You need to be logged in to leave comments.
Login now