(self, cfg, unreader, peer_addr, req_number=1)
| 430 | |
| 431 | class Request(Message): |
| 432 | def __init__(self, cfg, unreader, peer_addr, req_number=1): |
| 433 | self.method = None |
| 434 | self.uri = None |
| 435 | self.path = None |
| 436 | self.query = None |
| 437 | self.fragment = None |
| 438 | |
| 439 | # get max request line size (0 means unlimited per documentation) |
| 440 | self.limit_request_line = cfg.limit_request_line |
| 441 | if self.limit_request_line < 0: |
| 442 | self.limit_request_line = MAX_REQUEST_LINE |
| 443 | # For fast parser: use large value when unlimited (0), since C parser |
| 444 | # doesn't support 0 as unlimited. 1MB should be more than enough. |
| 445 | if self.limit_request_line == 0: |
| 446 | self._fast_limit_request_line = 1024 * 1024 # 1MB |
| 447 | elif self.limit_request_line >= MAX_REQUEST_LINE: |
| 448 | self._fast_limit_request_line = MAX_REQUEST_LINE |
| 449 | self.limit_request_line = MAX_REQUEST_LINE |
| 450 | else: |
| 451 | self._fast_limit_request_line = self.limit_request_line |
| 452 | |
| 453 | self.req_number = req_number |
| 454 | self.proxy_protocol_info = None |
| 455 | |
| 456 | # Check if fast parser should be used |
| 457 | self._use_fast = _check_fast_parser(cfg) |
| 458 | |
| 459 | super().__init__(cfg, unreader, peer_addr) |
| 460 | |
| 461 | def get_data(self, unreader, buf, stop=False): |
| 462 | data = unreader.read() |
nothing calls this directly
no test coverage detected