equal
deleted
inserted
replaced
136 yield zd.decompress(chunk) |
136 yield zd.decompress(chunk) |
137 else: |
137 else: |
138 raise util.Abort("unknown bundle compression '%s'" % alg) |
138 raise util.Abort("unknown bundle compression '%s'" % alg) |
139 return generator(fh) |
139 return generator(fh) |
140 |
140 |
|
141 class unbundle10(object): |
|
142 def __init__(self, fh, alg): |
|
143 self._stream = util.chunkbuffer(decompressor(fh, alg)) |
|
144 def read(self, l): |
|
145 return self._stream.read(l) |
|
146 |
141 def readbundle(fh, fname): |
147 def readbundle(fh, fname): |
142 header = fh.read(6) |
148 header = fh.read(6) |
143 |
149 |
144 if not fname: |
150 if not fname: |
145 fname = "stream" |
151 fname = "stream" |
156 |
162 |
157 if magic != 'HG': |
163 if magic != 'HG': |
158 raise util.Abort(_('%s: not a Mercurial bundle') % fname) |
164 raise util.Abort(_('%s: not a Mercurial bundle') % fname) |
159 if version != '10': |
165 if version != '10': |
160 raise util.Abort(_('%s: unknown bundle version %s') % (fname, version)) |
166 raise util.Abort(_('%s: unknown bundle version %s') % (fname, version)) |
161 return util.chunkbuffer(decompressor(fh, alg)) |
167 return unbundle10(fh, alg) |