j,dZddlZGddZdS)zt Async version of gunicorn/http/unreader.py for ASGI workers. Provides async reading with pushback buffer support. NcFeZdZdZd dZdZdZdZd dZd Z d Z d Z dS) 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|_dS)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 I/var/www/html/venv/lib/python3.11/site-packages/gunicorn/asgi/unreader.py__init__zAsyncUnreader.__init__s* :<<"c||jd|jdd|_dS)z7Reset buffer for reuse instead of creating new BytesIO.rN)r seektruncater r s r _reset_bufferzAsyncUnreader._reset_buffer$s7  a !rc|j|j|j}||S)z'Get all buffered data and reset buffer.)r rr readr)r datas r_get_buffered_dataz AsyncUnreader._get_buffered_data*s>  do&&&x}}  rc`|jdtj}||jz S)zGet size of buffered data.r)r rrSEEK_ENDr )r ends r _buffer_sizezAsyncUnreader._buffer_size1s&hmmAr{++T_$$rNcjK|$t|tstd||dkrdS|dkrd}|}||dkr|S||d{V}|S||kr|d{V}|s|S|jdtj |j ||t|z }||k|j|j |j |}|xj |z c_ |j dkrI|j }||r|j ||S)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.rrr) isinstanceint TypeErrorrr _read_chunkr rrrwritelenr rr)r sizebuf_sizechunkr remainings rrzAsyncUnreader.read6s  JtS$9$9 DEE E  qyysaxx$$&& r5sV   y'y'y'y'y'y'y'y'y'y'r