equal
deleted
inserted
replaced
162 def _decompress(self, stream): |
162 def _decompress(self, stream): |
163 return stream |
163 return stream |
164 |
164 |
165 def _recv(self): |
165 def _recv(self): |
166 l = self.pipei.readline() |
166 l = self.pipei.readline() |
|
167 if l == '\n': |
|
168 err = [] |
|
169 while True: |
|
170 line = self.pipee.readline() |
|
171 if line == '-\n': |
|
172 break |
|
173 err.extend([line]) |
|
174 if len(err) > 0: |
|
175 # strip the trailing newline added to the last line server-side |
|
176 err[-1] = err[-1][:-1] |
|
177 self._abort(error.OutOfBandError(*err)) |
167 self.readerr() |
178 self.readerr() |
168 try: |
179 try: |
169 l = int(l) |
180 l = int(l) |
170 except ValueError: |
181 except ValueError: |
171 self._abort(error.ResponseError(_("unexpected response:"), l)) |
182 self._abort(error.ResponseError(_("unexpected response:"), l)) |