Mercurial > hg
comparison mercurial/sshpeer.py @ 20905:167047ba3cfa
wireproto: drop the _decompress method in favor a new call type
We already have multiple call function for multiple return type. The
`_decompress` function is only used for http and seems like a layer violation.
We drop it in favor of a new call type dedicated to "stream that may be useful to
compress".
author | Pierre-Yves David <pierre-yves.david@fb.com> |
---|---|
date | Fri, 28 Mar 2014 14:24:13 -0700 |
parents | 8b0e3a8982ea |
children | 83ce71ef7804 |
comparison
equal
deleted
inserted
replaced
20904:3dbe6bcd7f62 | 20905:167047ba3cfa |
---|---|
155 self.pipeo.write(v) | 155 self.pipeo.write(v) |
156 self.pipeo.flush() | 156 self.pipeo.flush() |
157 | 157 |
158 return self.pipei | 158 return self.pipei |
159 | 159 |
160 def _callcompressable(self, cmd, **args): | |
161 return self._callstream(cmd, **args) | |
162 | |
160 def _call(self, cmd, **args): | 163 def _call(self, cmd, **args): |
161 self._callstream(cmd, **args) | 164 self._callstream(cmd, **args) |
162 return self._recv() | 165 return self._recv() |
163 | 166 |
164 def _callpush(self, cmd, fp, **args): | 167 def _callpush(self, cmd, fp, **args): |
174 r = self._recv() | 177 r = self._recv() |
175 if r: | 178 if r: |
176 return '', r | 179 return '', r |
177 return self._recv(), '' | 180 return self._recv(), '' |
178 | 181 |
179 def _decompress(self, stream): | |
180 return stream | |
181 | 182 |
182 def _recv(self): | 183 def _recv(self): |
183 l = self.pipei.readline() | 184 l = self.pipei.readline() |
184 if l == '\n': | 185 if l == '\n': |
185 err = [] | 186 err = [] |