FM / __pycache_

/opt/alt/python38/lib64/python3.8/site-packages/aiohttp/__pycache__/

/opt/alt/python38/lib64/python3.8/site-packages/aiohttp/__pycache__

Name	Size	Mode	Actions
abc.cpython-38.opt-1.pyc	8309	0644	edit dl rm
abc.cpython-38.pyc	8309	0644	edit dl rm
base_protocol.cpython-38.opt-1.pyc	2554	0644	edit dl rm
base_protocol.cpython-38.pyc	2637	0644	edit dl rm
client.cpython-38.opt-1.pyc	28520	0644	edit dl rm
client.cpython-38.pyc	28669	0644	edit dl rm
client_exceptions.cpython-38.opt-1.pyc	10267	0644	edit dl rm
client_exceptions.cpython-38.pyc	10267	0644	edit dl rm
client_proto.cpython-38.opt-1.pyc	6130	0644	edit dl rm
client_proto.cpython-38.pyc	6130	0644	edit dl rm
client_reqrep.cpython-38.opt-1.pyc	27406	0644	edit dl rm
client_reqrep.cpython-38.pyc	27670	0644	edit dl rm
client_ws.cpython-38.opt-1.pyc	8857	0644	edit dl rm
client_ws.cpython-38.pyc	8857	0644	edit dl rm
connector.cpython-38.opt-1.pyc	30866	0644	edit dl rm
connector.cpython-38.pyc	30997	0644	edit dl rm
cookiejar.cpython-38.opt-1.pyc	9292	0644	edit dl rm
cookiejar.cpython-38.pyc	9326	0644	edit dl rm
formdata.cpython-38.opt-1.pyc	4484	0644	edit dl rm
formdata.cpython-38.pyc	4516	0644	edit dl rm
frozenlist.cpython-38.opt-1.pyc	2620	0644	edit dl rm
frozenlist.cpython-38.pyc	2620	0644	edit dl rm
hdrs.cpython-38.opt-1.pyc	3615	0644	edit dl rm
hdrs.cpython-38.pyc	3615	0644	edit dl rm
helpers.cpython-38.opt-1.pyc	22972	0644	edit dl rm
helpers.cpython-38.pyc	22972	0644	edit dl rm
http.cpython-38.opt-1.pyc	1239	0644	edit dl rm
http.cpython-38.pyc	1239	0644	edit dl rm
http_exceptions.cpython-38.opt-1.pyc	4267	0644	edit dl rm
http_exceptions.cpython-38.pyc	4267	0644	edit dl rm
http_parser.cpython-38.opt-1.pyc	15959	0644	edit dl rm
http_parser.cpython-38.pyc	16039	0644	edit dl rm
http_websocket.cpython-38.opt-1.pyc	14684	0644	edit dl rm
http_websocket.cpython-38.pyc	14803	0644	edit dl rm
http_writer.cpython-38.opt-1.pyc	4992	0644	edit dl rm
http_writer.cpython-38.pyc	4992	0644	edit dl rm
locks.cpython-38.opt-1.pyc	1685	0644	edit dl rm
locks.cpython-38.pyc	1685	0644	edit dl rm
log.cpython-38.opt-1.pyc	438	0644	edit dl rm
log.cpython-38.pyc	438	0644	edit dl rm
multipart.cpython-38.opt-1.pyc	25710	0644	edit dl rm
multipart.cpython-38.pyc	26160	0644	edit dl rm
payload.cpython-38.opt-1.pyc	13108	0644	edit dl rm
payload.cpython-38.pyc	13108	0644	edit dl rm
payload_streamer.cpython-38.opt-1.pyc	3223	0644	edit dl rm
payload_streamer.cpython-38.pyc	3223	0644	edit dl rm
pytest_plugin.cpython-38.opt-1.pyc	9387	0644	edit dl rm
pytest_plugin.cpython-38.pyc	9439	0644	edit dl rm
resolver.cpython-38.opt-1.pyc	3788	0644	edit dl rm
resolver.cpython-38.pyc	3788	0644	edit dl rm
signals.cpython-38.opt-1.pyc	1293	0644	edit dl rm
signals.cpython-38.pyc	1293	0644	edit dl rm
streams.cpython-38.opt-1.pyc	17992	0644	edit dl rm
streams.cpython-38.pyc	18270	0644	edit dl rm
tcp_helpers.cpython-38.opt-1.pyc	1103	0644	edit dl rm
tcp_helpers.cpython-38.pyc	1103	0644	edit dl rm
test_utils.cpython-38.opt-1.pyc	20928	0644	edit dl rm
test_utils.cpython-38.pyc	21076	0644	edit dl rm
tracing.cpython-38.opt-1.pyc	14312	0644	edit dl rm
tracing.cpython-38.pyc	14312	0644	edit dl rm
typedefs.cpython-38.opt-1.pyc	1308	0644	edit dl rm
typedefs.cpython-38.pyc	1308	0644	edit dl rm
web.cpython-38.opt-1.pyc	9705	0644	edit dl rm
web.cpython-38.pyc	9705	0644	edit dl rm
web_app.cpython-38.opt-1.pyc	15203	0644	edit dl rm
web_app.cpython-38.pyc	15249	0644	edit dl rm
web_exceptions.cpython-38.opt-1.pyc	12014	0644	edit dl rm
web_exceptions.cpython-38.pyc	12014	0644	edit dl rm
web_fileresponse.cpython-38.opt-1.pyc	4578	0644	edit dl rm
web_fileresponse.cpython-38.pyc	4622	0644	edit dl rm
web_log.cpython-38.opt-1.pyc	7126	0644	edit dl rm
web_log.cpython-38.pyc	7126	0644	edit dl rm
web_middlewares.cpython-38.opt-1.pyc	3811	0644	edit dl rm
web_middlewares.cpython-38.pyc	3895	0644	edit dl rm
web_protocol.cpython-38.opt-1.pyc	15647	0644	edit dl rm
web_protocol.cpython-38.pyc	15831	0644	edit dl rm
web_request.cpython-38.opt-1.pyc	22602	0644	edit dl rm
web_request.cpython-38.pyc	22712	0644	edit dl rm
web_response.cpython-38.opt-1.pyc	19411	0644	edit dl rm
web_response.cpython-38.pyc	20351	0644	edit dl rm
web_routedef.cpython-38.opt-1.pyc	7800	0644	edit dl rm
web_routedef.cpython-38.pyc	7800	0644	edit dl rm
web_runner.cpython-38.opt-1.pyc	11620	0644	edit dl rm
web_runner.cpython-38.pyc	11726	0644	edit dl rm
web_server.cpython-38.opt-1.pyc	2758	0644	edit dl rm
web_server.cpython-38.pyc	2758	0644	edit dl rm
web_urldispatcher.cpython-38.opt-1.pyc	41344	0644	edit dl rm
web_urldispatcher.cpython-38.pyc	42190	0644	edit dl rm
web_ws.cpython-38.opt-1.pyc	13077	0644	edit dl rm
web_ws.cpython-38.pyc	13215	0644	edit dl rm
worker.cpython-38.opt-1.pyc	6863	0644	edit dl rm
worker.cpython-38.pyc	6928	0644	edit dl rm
__init__.cpython-38.opt-1.pyc	3696	0644	edit dl rm
__init__.cpython-38.pyc	3696	0644	edit dl rm

Edit: /opt/alt/python38/lib64/python3.8/site-packages/aiohttp/__pycache__/streams.cpython-38.pyc (18270B)

U '�7`2P�@s8ddlZddlZddlZddlmZmZmZmZmZm Z m Z ddlmZddl mZmZmZddlmZzddlmZWn ek r�ddlmZYnXdZe d �ZGd d�de�ZGdd �d ee�ZGdd�d�ZGdd�d�ZGdd�de�ZGdd�de�Ze�ZGdd�dee�Z Gdd�de e�Z!dS)�N)� Awaitable�Callable�Generic�List�Optional�Tuple�TypeVar�)�BaseProtocol)�BaseTimerContext� set_exception� set_result)�internal_logger)�Deque)� EMPTY_PAYLOAD� EofStream�StreamReader� DataQueue�FlowControlDataQueue�_Tc@seZdZdZdS)rzeof stream indication.N)�__name__� __module__�__qualname__�__doc__�rr�B/opt/alt/python38/lib64/python3.8/site-packages/aiohttp/streams.pyrsrc@sDeZdZegeefdd�dd�Zdd�dd�Zed�d d �ZdS)�AsyncStreamIteratorN)� read_func�returncCs ||_dS�N)r)�selfrrrr�__init__szAsyncStreamIterator.__init__zAsyncStreamIterator[_T]�rcCs|Srr�r rrr� __aiter__"szAsyncStreamIterator.__aiter__c�s<z|��IdH}Wntk r*t�YnX|dkr8t�|S�N�)rr�StopAsyncIteration�r �rvrrr� __anext__%s zAsyncStreamIterator.__anext__) rrrrrrr!r$r*rrrrrsrc@s@eZdZddd�dd�Zdd�dd�Zeeefd�d d �ZdS)�ChunkTupleAsyncStreamIteratorrN)�streamrcCs ||_dSr)�_stream)r r,rrrr!0sz&ChunkTupleAsyncStreamIterator.__init__r"cCs|Srrr#rrrr$3sz'ChunkTupleAsyncStreamIterator.__aiter__c�s |j��IdH}|dkrt�|S)N�r&F)r-� readchunkr'r(rrrr*6sz'ChunkTupleAsyncStreamIterator.__anext__) rrrr!r$r�bytes�boolr*rrrrr+/sr+c@sReZdZeed�dd�Zeeed�dd�Zeed�dd�Ze d�d d �Z dS)�AsyncStreamReaderMixinr"cCs t|j�Sr)r�readliner#rrrr$>sz AsyncStreamReaderMixin.__aiter__��nrcst��fdd��S)zzReturns an asynchronous iterator that yields chunks of size n. Python-3.5 available for Python 3.5+ only cs ��Sr)�readr�r5r rr�Fr&z5AsyncStreamReaderMixin.iter_chunked..)r�r r5rr7r�iter_chunkedAsz#AsyncStreamReaderMixin.iter_chunkedcCs t|j�S)z�Returns an asynchronous iterator that yields all the available data as soon as it is received Python-3.5 available for Python 3.5+ only )r�readanyr#rrr�iter_anyHszAsyncStreamReaderMixin.iter_anycCst|�S)a Returns an asynchronous iterator that yields chunks of data as they are received by the server. The yielded objects are tuples of (bytes, bool) as returned by the StreamReader.readchunk method. Python-3.5 available for Python 3.5+ only )r+r#rrr�iter_chunksPsz"AsyncStreamReaderMixin.iter_chunksN)rrrrr0r$�intr:r<r+r=rrrrr2=sr2c@s�eZdZdZdZddd�eeeeee j dd�dd�Zed�d d �Z eeefd�dd�Zeed�d d�Zedd�dd�Zegdfdd�dd�Zdd�dd�Zed�dd�Zed�dd�Zdd�dd�Zedd�dd�Zdeed-�d6d7�Z%eed-�d8d9�Z&eed-�d:d;�Z'dS)?ra*An enhancement of asyncio.StreamReader. Supports asynchronous iteration by line, chunk or as available:: async for line in reader: ... async for chunk in reader.iter_chunked(1024): ... async for slice in reader.iter_any(): ... rN)�timer�loop)�protocol�limitr?r@rcCsv||_||_|d|_|dkr&t��}||_d|_d|_d|_t � �|_d|_d|_ d|_d|_d|_||_g|_dS)N�rF)� _protocol� _low_water�_high_water�asyncioZget_event_loop�_loop�_size�_cursor�_http_chunk_splits�collections�deque�_buffer�_buffer_offset�_eof�_waiter�_eof_waiter� _exception�_timer�_eof_callbacks)r rArBr?r@rrrr!js" zStreamReader.__init__r"cCs�|jjg}|jr |�d|j�|jr0|�d�|jdkrP|�d|j|jf�|jrf|�d|j�|jr||�d|j�dd� |�S) Nz%d bytes�eofizlow=%d high=%dzw=%rze=%rz<%s>� ) � __class__rrI�appendrPrErFrQrS�join)r �inforrr�__repr__�s zStreamReader.__repr__cCs|j|jfSr)rErFr#rrr�get_read_buffer_limits�sz#StreamReader.get_read_buffer_limitscCs|jSr�rSr#rrr� exception�szStreamReader.exception��excrcCsP||_|j��|j}|dk r.d|_t||�|j}|dk rLd|_t||�dSr)rSrU�clearrQrrR�r ra�waiterrrrr�s zStreamReader.set_exception��callbackrcCsB|jr2z |�Wq>tk r.t�d�Yq>Xn|j�|�dS�N�Exception in eof callback)rP� Exceptionrr_rUrY�r rfrrr�on_eof�s zStreamReader.on_eofc Cs�d|_|j}|dk r$d|_t|d�|j}|dk rBd|_t|d�|jD].}z |�WqHtk rtt�d�YqHXqH|j��dS)NTrh) rPrQr rRrUrirr_rb)r rd�cbrrr�feed_eof�s zStreamReader.feed_eofcCs|jS)z&Return True if 'feed_eof' was called.�rPr#rrr�is_eof�szStreamReader.is_eofcCs|jo|jS)z=Return True if the buffer is empty and 'feed_eof' was called.�rPrNr#rrr�at_eof�szStreamReader.at_eofc�sB|jr dS|jdkst�|j��|_z|jIdHW5d|_XdSr)rPrR�AssertionErrorrH� create_futurer#rrr�wait_eof�szStreamReader.wait_eof)�datarcCsxtjdtdd�|sdS|jr>|jd|jd�|jd<d|_|jt|�7_|jt|�8_|j�|�d|_ dS)zDrollback reading some data from stream, inserting it to buffer head.zJunread_data() is deprecated and will be removed in future releases (#3260)rC)� stacklevelNr) �warnings�warn�DeprecationWarningrOrNrI�lenrJ� appendleft�_eof_counter)r rurrr�unread_data�s�zStreamReader.unread_data�ru�sizercCs�|jrtd��|sdS|jt|�7_|j�|�|jt|�7_|j}|dk rdd|_t|d�|j|j kr�|j js�|j ��dS)Nzfeed_data after feed_eof) rPrrrIrzrNrY�total_bytesrQr rFrD�_reading_paused� pause_reading�r rurrdrrr� feed_data�s zStreamReader.feed_datacCs"|jdkr|jrtd��g|_dS)Nz?Called begin_http_chunk_receiving whensome data was already fed)rKr��RuntimeErrorr#rrr�begin_http_chunk_receiving�s �z'StreamReader.begin_http_chunk_receivingcCsd|jdkrtd��|jr"|jdnd}|j|kr4dS|j�|j�|j}|dk r`d|_t|d�dS)NzFCalled end_chunk_receiving without calling begin_chunk_receiving first��r)rKr�r�rYrQr )r �posrdrrr�end_http_chunk_receivings � z%StreamReader.end_http_chunk_receiving)� func_namerc �sf|jdk rtd|��|j��}|_z2|jrL|j�|IdHW5QRXn |IdHW5d|_XdS)NzH%s() called while another coroutine is already waiting for incoming data)rQr�rHrsrT)r r�rdrrr�_wait#s ��zStreamReader._waitc�s�|jdk r|j�g}d}d}|r�|jr�|r�|j}|jd�d|�d}|�|rV||nd�}|�|�|t|�7}|rzd}||jkr td��q |j r�q�|r|� d�IdHqd �|�S) NrT� r r�FzLine is too longr3r&)rSrNrO�find�_read_nowait_chunkrYrzrF� ValueErrorrPr�rZ)r �lineZ line_sizeZ not_enough�offsetZicharrurrrr38s* zStreamReader.readliner�r4c�s�|jdk r|j�|jrF|jsFt|dd�d|_|jdkrFtjddd�|sNdS|dkr�g}|��IdH}|snqz|�|�qZd� |�S|js�|js�|� d �IdHq�|�|�S) Nr|rr �zEMultiple access to StreamReader in eof state, might be infinite loop.T)Z stack_infor&r6)rSrPrN�getattrr|r�warningr;rYrZr��_read_nowait)r r5�blocks�blockrrrr6Vs* � zStreamReader.readc�s8|jdk r|j�|js.|js.|�d�IdHq|�d�S)Nr;r�)rSrNrPr�r�r#rrrr;�s zStreamReader.readanyc�s�|jdk r|j�|jrZ|j�d�}||jkr0dS||jkrN|�||j�dfSt�d�q|jrn|�d�dfS|j rxdS|� d �IdHqdS) z�Returns a tuple of (data, end_of_http_chunk). When chunked transfer encoding is used, end_of_http_chunk is a boolean indicating if the end of the data corresponds to the end of a HTTP chunk , otherwise it is always False. Nr�r&TTzESkipping HTTP chunk end due to data consumption beyond chunk boundaryr�Fr.r/)rSrK�poprJr�rr�rNr�rPr�)r r�rrrr/�s �zStreamReader.readchunkc�sp|jdk r|j�g}|dkrf|�|�IdH}|sNd�|�}t�|t|�|��|�|�|t|�8}qd�|�S)Nrr&)rSr6rZrG�IncompleteReadErrorrzrY)r r5r�r��partialrrr�readexactly�s zStreamReader.readexactlycCs2|jdk r|j�|jr(|j��s(td��|�|�S)Nz9Called while some coroutine is waiting for incoming data.)rSrQZdoner�r�r9rrr�read_nowait�s �zStreamReader.read_nowaitcCs�|jd}|j}|dkrHt|�||krH||||�}|j|7_n,|rj|j��||d�}d|_n |j��}|jt|�8_|jt|�7_|j}|r�|d|jkr�|�d�q�|j|jkr�|j j r�|j ��|S)Nrr�)rNrOrz�popleftrIrJrKr�rErDr��resume_reading)r r5Zfirst_bufferr�ruZchunk_splitsrrrr��s$ zStreamReader._read_nowait_chunkcCsPg}|jr>|�|�}|�|�|dkr|t|�8}|dkrq>q|rLd�|�SdS)z8 Read not more than n bytes, or whole buffer if n == -1 r�rr&)rNr�rYrzrZ)r r5Zchunks�chunkrrrr��s zStreamReader._read_nowait)r)r�)r�)(rrrrr�r r>rrrG�AbstractEventLoopr!�strr\rr]� BaseExceptionr_rrrkrmr1rorqrtr0r}r�r�r�r�r3r6r;r/r�r�r�r�rrrrrZsB �� * rc@s�eZdZeed�dd�Zedd�dd�Zegdfdd�d d �Zdd�dd�Z e d�d d�Ze d�dd�Zdd�dd�Z d%eedd�dd�Zed�dd�Zd&eed�dd�Zed�dd�Zeee fd�dd �Zeed�d!d"�Zed�d#d$�ZdS)'�EmptyStreamReaderr"cCsdSrrr#rrrr_�szEmptyStreamReader.exceptionNr`cCsdSrr)r rarrrr�szEmptyStreamReader.set_exceptionrecCs.z |�Wntk r(t�d�YnXdSrg)rirr_rjrrrrk�s zEmptyStreamReader.on_eofcCsdSrrr#rrrrmszEmptyStreamReader.feed_eofcCsdS�NTrr#rrrroszEmptyStreamReader.is_eofcCsdSr�rr#rrrrqszEmptyStreamReader.at_eofc�sdSrrr#rrrrt szEmptyStreamReader.wait_eofr)rur5rcCsdSrr)r rur5rrrr� szEmptyStreamReader.feed_datac�sdSr%rr#rrrr3szEmptyStreamReader.readliner�r4c�sdSr%rr9rrrr6szEmptyStreamReader.readc�sdSr%rr#rrrr;szEmptyStreamReader.readanyc�sdS)Nr�rr#rrrr/szEmptyStreamReader.readchunkc�st�d|��dSr%)rGr�r9rrrr�szEmptyStreamReader.readexactlycCsdSr%rr#rrrr�szEmptyStreamReader.read_nowait)r)r�)rrrrr�r_rrrkrmr1rorqrtr0r>r�r3r6r;rr/r�r�rrrrr��sr�c@s�eZdZdZejdd�dd�Zed�dd�Ze d�d d �Z e d�dd�Zee d�d d�Ze dd�dd�Zdeedd�dd�Zdd�dd�Zed�dd�Zeed�dd�ZdS)rz>DataQueue is a general-purpose blocking queue with one reader.N)r@rcCs,||_d|_d|_d|_d|_t��|_dS)NFr)rHrPrQrSrIrLrMrN)r r@rrrr!)szDataQueue.__init__r"cCs t|j�Sr)rzrNr#rrr�__len__1szDataQueue.__len__cCs|jSrrnr#rrrro4szDataQueue.is_eofcCs|jo|jSrrpr#rrrrq7szDataQueue.at_eofcCs|jSrr^r#rrrr_:szDataQueue.exceptionr`cCs.d|_||_|j}|dk r*d|_t||�dSr�)rPrSrQrrcrrrr=szDataQueue.set_exceptionrr~cCs@|j|7_|j�||f�|j}|dk rr�r1rorqrr�r_rrr�rmr6rr$rrrrr&s rcsXeZdZdZeeejdd��fdd�Zd e edd��fdd � Z e d ��fdd�Z�ZS)rzgFlowControlDataQueue resumes and pauses an underlying stream. It is a destination for parsed data.N)rArBr@rcs"t�j|d�||_|d|_dS)N)r@rC)�superr!rD�_limit)r rArBr@�rXrrr!tszFlowControlDataQueue.__init__rr~cs0t��||�|j|jkr,|jjs,|j��dSr)r�r�rIr�rDr�r�r�r�rrr�|szFlowControlDataQueue.feed_datar"c�s:zt��IdHW�S|j|jkr4|jjr4|j��XdSr)rIr�rDr�r�r�r6r#r�rrr6�szFlowControlDataQueue.read)r) rrrrr r>rGr�r!rr�r6� __classcell__rrr�rros�r)"rGrLrw�typingrrrrrrrZ base_protocolr Zhelpersrrr �logrr�ImportErrorZtyping_extensions�__all__rrirrr+r2rr�rrrrrrr�s0$/I