| 255 | ) |
| 256 | |
| 257 | def __init__( |
| 258 | self, |
| 259 | client: Optional[SimpleAsyncHTTPClient], |
| 260 | request: HTTPRequest, |
| 261 | release_callback: Callable[[], None], |
| 262 | final_callback: Callable[[HTTPResponse], None], |
| 263 | max_buffer_size: int, |
| 264 | tcp_client: TCPClient, |
| 265 | max_header_size: int, |
| 266 | max_body_size: int, |
| 267 | ) -> None: |
| 268 | self.io_loop = IOLoop.current() |
| 269 | self.start_time = self.io_loop.time() |
| 270 | self.start_wall_time = time.time() |
| 271 | self.client = client |
| 272 | self.request = request |
| 273 | self.release_callback = release_callback |
| 274 | self.final_callback = final_callback |
| 275 | self.max_buffer_size = max_buffer_size |
| 276 | self.tcp_client = tcp_client |
| 277 | self.max_header_size = max_header_size |
| 278 | self.max_body_size = max_body_size |
| 279 | self.code = None # type: Optional[int] |
| 280 | self.headers = None # type: Optional[httputil.HTTPHeaders] |
| 281 | self.chunks = [] # type: List[bytes] |
| 282 | self._decompressor = None |
| 283 | # Timeout handle returned by IOLoop.add_timeout |
| 284 | self._timeout = None # type: object |
| 285 | self._sockaddr = None |
| 286 | IOLoop.current().add_future( |
| 287 | gen.convert_yielded(self.run()), lambda f: f.result() |
| 288 | ) |
| 289 | |
| 290 | async def run(self) -> None: |
| 291 | try: |