(self)
| 277 | self._set_write_buffer_limits() |
| 278 | |
| 279 | def _maybe_pause_protocol(self): |
| 280 | size = self.get_write_buffer_size() |
| 281 | if size <= self._high_water: |
| 282 | return |
| 283 | if not self._protocol_paused: |
| 284 | self._protocol_paused = True |
| 285 | try: |
| 286 | self._protocol.pause_writing() |
| 287 | except (SystemExit, KeyboardInterrupt): |
| 288 | raise |
| 289 | except BaseException as exc: |
| 290 | self._loop.call_exception_handler({ |
| 291 | 'message': 'protocol.pause_writing() failed', |
| 292 | 'exception': exc, |
| 293 | 'transport': self, |
| 294 | 'protocol': self._protocol, |
| 295 | }) |
| 296 | |
| 297 | def _maybe_resume_protocol(self): |
| 298 | if (self._protocol_paused and |
no test coverage detected