equal
deleted
inserted
replaced
197 # nothing to do |
197 # nothing to do |
198 pass |
198 pass |
199 else: |
199 else: |
200 raise util.Abort(_("%s: unknown bundle compression type") |
200 raise util.Abort(_("%s: unknown bundle compression type") |
201 % bundlename) |
201 % bundlename) |
202 self.changelog = bundlechangelog(self.opener, self.bundlefile) |
202 self.changelog = bundlechangelog(self.sopener, self.bundlefile) |
203 self.manifest = bundlemanifest(self.opener, self.bundlefile, |
203 self.manifest = bundlemanifest(self.sopener, self.bundlefile, |
204 self.changelog.rev) |
204 self.changelog.rev) |
205 # dict with the mapping 'filename' -> position in the bundle |
205 # dict with the mapping 'filename' -> position in the bundle |
206 self.bundlefilespos = {} |
206 self.bundlefilespos = {} |
207 while 1: |
207 while 1: |
208 f = changegroup.getchunk(self.bundlefile) |
208 f = changegroup.getchunk(self.bundlefile) |
221 def file(self, f): |
221 def file(self, f): |
222 if f[0] == '/': |
222 if f[0] == '/': |
223 f = f[1:] |
223 f = f[1:] |
224 if f in self.bundlefilespos: |
224 if f in self.bundlefilespos: |
225 self.bundlefile.seek(self.bundlefilespos[f]) |
225 self.bundlefile.seek(self.bundlefilespos[f]) |
226 return bundlefilelog(self.opener, f, self.bundlefile, |
226 return bundlefilelog(self.sopener, f, self.bundlefile, |
227 self.changelog.rev) |
227 self.changelog.rev) |
228 else: |
228 else: |
229 return filelog.filelog(self.opener, f) |
229 return filelog.filelog(self.sopener, f) |
230 |
230 |
231 def close(self): |
231 def close(self): |
232 """Close assigned bundle file immediately.""" |
232 """Close assigned bundle file immediately.""" |
233 self.bundlefile.close() |
233 self.bundlefile.close() |
234 |
234 |