equal
deleted
inserted
replaced
375 # response contains the length of that response. |
375 # response contains the length of that response. |
376 _FRAMED_COMMANDS = { |
376 _FRAMED_COMMANDS = { |
377 'batch', |
377 'batch', |
378 } |
378 } |
379 |
379 |
380 # Begin of _basepeer interface. |
380 # Begin of ipeerconnection interface. |
381 |
381 |
382 @util.propertycache |
382 @util.propertycache |
383 def ui(self): |
383 def ui(self): |
384 return self._ui |
384 return self._ui |
385 |
385 |
396 return True |
396 return True |
397 |
397 |
398 def close(self): |
398 def close(self): |
399 pass |
399 pass |
400 |
400 |
401 # End of _basepeer interface. |
401 # End of ipeerconnection interface. |
402 |
402 |
403 # Begin of _basewirecommands interface. |
403 # Begin of ipeercommands interface. |
404 |
404 |
405 def capabilities(self): |
405 def capabilities(self): |
406 return self._caps |
406 return self._caps |
407 |
407 |
408 # End of _basewirecommands interface. |
408 # End of ipeercommands interface. |
409 |
409 |
410 def _readerr(self): |
410 def _readerr(self): |
411 _forwardoutput(self.ui, self._pipee) |
411 _forwardoutput(self.ui, self._pipee) |
412 |
412 |
413 def _abort(self, exception): |
413 def _abort(self, exception): |