ېi$dZddlZGddZy)zt Async version of gunicorn/http/unreader.py for ASGI workers. Provides async reading with pushback buffer support. NcDeZdZdZd dZdZdZdZd dZdZ d Z d Z y) AsyncUnreadera8Async socket reader with pushback buffer support. This class wraps an asyncio StreamReader and provides the ability to "unread" data back into a buffer for re-parsing. Performance optimization: Reuses BytesIO buffer with truncate/seek instead of creating new objects to reduce GC pressure. c`||_tj|_||_d|_y)zInitialize the async unreader. Args: reader: asyncio.StreamReader instance max_chunk: Maximum bytes to read at once rN)readerioBytesIObuf max_chunk _buf_start)selfrr s Q/var/www/html/Extract/venv/lib/python3.12/site-packages/gunicorn/asgi/unreader.py__init__zAsyncUnreader.__init__s& ::<"c~|jjd|jjdd|_y)z7Reset buffer for reuse instead of creating new BytesIO.rN)r seektruncater r s r _reset_bufferzAsyncUnreader._reset_buffer$s+  a !rc|jj|j|jj}|j |S)z'Get all buffered data and reset buffer.)r rr readr)r datas r _get_buffered_dataz AsyncUnreader._get_buffered_data*s6  doo&xx}}  rct|jjdtj}||jz S)zGet size of buffered data.r)r rrSEEK_ENDr )r ends r _buffer_sizezAsyncUnreader._buffer_size1s)hhmmAr{{+T__$$rNc^K|t|ts td| |dk(ry|dkrd}|j}||dkDr|j S||j d{}|S||kr|j d{}|s|j S|j jdtj|j j||t|z }||kr|j j|j|j j|}|xj|z c_ |jdkDrG|j j}|j|r|j j||S7<7 w)a Read data from the stream, using buffered data first. Args: size: Number of bytes to read. If None, returns all buffered data or reads a single chunk. Returns: bytes: Data read from buffer or stream Nz&size parameter must be an int or long.rr ) isinstanceint TypeErrorrr _read_chunkr rrrwritelenr rr)r sizebuf_sizechunkr remainings r rzAsyncUnreader.read6sq  JtS$9DE E  qyax$$& r5s   y'y'r