(self)
| 879 | # Flow control for reads from SSL socket |
| 880 | |
| 881 | def _control_ssl_reading(self): |
| 882 | size = self._get_read_buffer_size() |
| 883 | if size >= self._incoming_high_water and not self._ssl_reading_paused: |
| 884 | self._ssl_reading_paused = True |
| 885 | self._transport.pause_reading() |
| 886 | elif size <= self._incoming_low_water and self._ssl_reading_paused: |
| 887 | self._ssl_reading_paused = False |
| 888 | self._transport.resume_reading() |
| 889 | |
| 890 | def _set_read_buffer_limits(self, high=None, low=None): |
| 891 | high, low = add_flowcontrol_defaults( |
no test coverage detected