Show More
@@ -171,7 +171,6 b' def addchangegroupfiles(orig, repo, sour' | |||||
171 | if not shallowutil.isenabled(repo): |
|
171 | if not shallowutil.isenabled(repo): | |
172 | return orig(repo, source, revmap, trp, expectedfiles, *args) |
|
172 | return orig(repo, source, revmap, trp, expectedfiles, *args) | |
173 |
|
173 | |||
174 | files = 0 |
|
|||
175 | newfiles = 0 |
|
174 | newfiles = 0 | |
176 | visited = set() |
|
175 | visited = set() | |
177 | revisiondatas = {} |
|
176 | revisiondatas = {} | |
@@ -184,14 +183,14 b' def addchangegroupfiles(orig, repo, sour' | |||||
184 | # files in topological order. |
|
183 | # files in topological order. | |
185 |
|
184 | |||
186 | # read all the file chunks but don't add them |
|
185 | # read all the file chunks but don't add them | |
|
186 | progress = repo.ui.makeprogress(_('files'), total=expectedfiles) | |||
187 | while True: |
|
187 | while True: | |
188 | chunkdata = source.filelogheader() |
|
188 | chunkdata = source.filelogheader() | |
189 | if not chunkdata: |
|
189 | if not chunkdata: | |
190 | break |
|
190 | break | |
191 | files += 1 |
|
|||
192 | f = chunkdata["filename"] |
|
191 | f = chunkdata["filename"] | |
193 | repo.ui.debug("adding %s revisions\n" % f) |
|
192 | repo.ui.debug("adding %s revisions\n" % f) | |
194 | repo.ui.progress(_('files'), files, total=expectedfiles) |
|
193 | progress.increment() | |
195 |
|
194 | |||
196 | if not repo.shallowmatch(f): |
|
195 | if not repo.shallowmatch(f): | |
197 | fl = repo.file(f) |
|
196 | fl = repo.file(f) | |
@@ -289,6 +288,6 b' def addchangegroupfiles(orig, repo, sour' | |||||
289 | processed.add((f, node)) |
|
288 | processed.add((f, node)) | |
290 | skipcount = 0 |
|
289 | skipcount = 0 | |
291 |
|
290 | |||
292 | repo.ui.progress(_('files'), None) |
|
291 | progress.complete() | |
293 |
|
292 | |||
294 | return len(revisiondatas), newfiles |
|
293 | return len(revisiondatas), newfiles |
General Comments 0
You need to be logged in to leave comments.
Login now