| 1692 | |
| 1693 | @staticmethod |
| 1694 | def _iter_chunked(read, bufsize): |
| 1695 | err = HTTPError(400, 'Error while parsing chunked transfer body.') |
| 1696 | rn, sem, bs = tob('\r\n'), tob(';'), tob('') |
| 1697 | while True: |
| 1698 | header = read(1) |
| 1699 | while header[-2:] != rn: |
| 1700 | c = read(1) |
| 1701 | header += c |
| 1702 | if not c: raise err |
| 1703 | if len(header) > bufsize: raise err |
| 1704 | size, _, _ = header.partition(sem) |
| 1705 | try: |
| 1706 | maxread = int(tonat(size.strip()), 16) |
| 1707 | except ValueError: |
| 1708 | raise err |
| 1709 | if maxread == 0: break |
| 1710 | buff = bs |
| 1711 | while maxread > 0: |
| 1712 | if not buff: |
| 1713 | buff = read(min(maxread, bufsize)) |
| 1714 | part, buff = buff[:maxread], buff[maxread:] |
| 1715 | if not part: raise err |
| 1716 | yield part |
| 1717 | maxread -= len(part) |
| 1718 | if read(2) != rn: |
| 1719 | raise err |
| 1720 | |
| 1721 | @DictProperty('environ', 'bottle.request.body', read_only=True) |
| 1722 | def _body(self): |