(self, transport)
| 142 | ceil(now+timeout), self.cancel_slow_request) |
| 143 | |
| 144 | def connection_made(self, transport): |
| 145 | super().connection_made(transport) |
| 146 | |
| 147 | self._request_handler = ensure_future(self.start(), loop=self._loop) |
| 148 | |
| 149 | # start slow request timer |
| 150 | if self._timeout: |
| 151 | now = self._loop.time() |
| 152 | self._timeout_handle = self._loop.call_at( |
| 153 | ceil(now+self._timeout), self.cancel_slow_request) |
| 154 | |
| 155 | if self._keep_alive_on: |
| 156 | tcp_keepalive(self, transport) |
| 157 | |
| 158 | def connection_lost(self, exc): |
| 159 | super().connection_lost(exc) |
nothing calls this directly
no test coverage detected