mpEH U d dl Z d dlZd dlZd dlmZmZmZmZmZm Z m
Z
m Z ddl m
Z
ddlmZmZmZ ddlmZ ddlmZ dZ e d Z G d
d e Z G d d
ee Z G d d Z G d d Z G d de Z G d de Z e Z ee e d< G d dee Z! G d de!e Z"dS ) N) AwaitableCallableDequeGenericListOptionalTupleTypeVar ) BaseProtocol)BaseTimerContext
set_exception
set_result)internal_logger)Final)
EMPTY_PAYLOAD EofStream StreamReader DataQueueFlowControlDataQueue_Tc e Zd ZdZdS )r zeof stream indication.N)__name__
__module__ __qualname____doc__ q/builddir/build/BUILD/imunify360-venv-2.6.2/opt/imunify360/venv/lib64/python3.11/site-packages/aiohttp/streams.pyr r s r r c N e Zd Zdeg ee f ddfdZddZdefdZdS ) AsyncStreamIterator read_funcreturnNc || _ d S N)r" )selfr" s r __init__z AsyncStreamIterator.__init__ s
"r AsyncStreamIterator[_T]c | S r% r r& s r __aiter__z AsyncStreamIterator.__aiter__ r c K | d {V }n# t $ r t w xY w|dk rt |S Nr )r" r StopAsyncIterationr& rvs r __anext__z AsyncStreamIterator.__anext__! sc %~~''''''''BB % % %$ $ %
99$ $ s 1)r# r( ) r r r r r r r' r+ r2 r r r r! r! ss #(2y}+<"= #$ # # # # r r! c : e Zd ZddZd dZdeeef fdZdS )
ChunkTupleAsyncStreamIteratorstreamr r# Nc || _ d S r% )_stream)r& r5 s r r' z&ChunkTupleAsyncStreamIterator.__init__, s
r c | S r% r r* s r r+ z'ChunkTupleAsyncStreamIterator.__aiter__/ r, r c b K | j d {V }|dk rt |S )Nr F)r7 readchunkr/ r0 s r r2 z'ChunkTupleAsyncStreamIterator.__anext__2 sA <))++
+
+
+
+
+
+
$ $ r )r5 r r# N)r# r4 ) r r r r' r+ r bytesboolr2 r r r r4 r4 + s` ud{!3 r r4 c f e Zd Zdee fdZdedee fdZdee fdZde fdZ
dS )AsyncStreamReaderMixinr# c * t | j S r% )r! readliner* s r r+ z AsyncStreamReaderMixin.__aiter__: s "4=111r nc , t fd S )zzReturns an asynchronous iterator that yields chunks of size n.
Python-3.5 available for Python 3.5+ only
c . S r% )read)rB r& s r z5AsyncStreamReaderMixin.iter_chunked..C s DIIaLL r )r! r& rB s ``r iter_chunkedz#AsyncStreamReaderMixin.iter_chunked= s'
#
r c * t | j S )zoYield all available data as soon as it is received.
Python-3.5 available for Python 3.5+ only
)r! readanyr* s r iter_anyz AsyncStreamReaderMixin.iter_anyF s
#4<000r c t | S )zYield 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
)r4 r* s r iter_chunksz"AsyncStreamReaderMixin.iter_chunksM s -T222r N) r r r r! r< r+ intrH rK r4 rM r r r r? r? 9 s 2.u5 2 2 2 2
c
&9%&@
1-e4 1 1 1 13 : 3 3 3 3 3 3r r? c e Zd ZdZdZddddededee dee j
d df
d
Z d e fd Z
d eeef fd Zd ee fd
Zded dfdZdeg df d dfdZd+dZd efdZd efdZd+dZded dfdZd,deded dfdZ d+dZ d+dZ d e d dfd Z d efd Z d-d ed efd!Z!d.d#ed efd$Z"d efd%Z#d eeef fd&Z$d#ed efd'Z%d.d#ed efd(Z&d#ed efd)Z'd#ed efd*Z(dS )/r a* 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():
...
r N)timerloopprotocollimitrP rQ r# c * || _ || _ |dz | _ |t j }|| _ d| _ d| _ d | _ t j
| _ d| _ d| _
d | _ d | _ d | _ || _ g | _ d S )N r F) _protocol
_low_water _high_waterasyncioget_event_loop_loop_size_cursor_http_chunk_splits collectionsdeque_buffer_buffer_offset_eof_waiter _eof_waiter
_exception_timer_eof_callbacks)r& rR rS rP rQ s r r' zStreamReader.__init__h s " 19 <)++D
7; %0%6%8%8 7; ;?37 8:r c | j j g}| j r | d| j z | j r| d | j dk r$| d| j | j fz | j r | d| j z | j r | d| j z dd | z S ) Nz%d byteseofi zlow=%d high=%dzw=%rze=%rz<%s> )
__class__r r\ appendrc rW rX rd rf join)r& infos r __repr__zStreamReader.__repr__ s '( : 1 KK
TZ/ 0 0 0 9 KK ?e # # KK(DOT=M+NN O O O < / KK - . . . ? 2 KK 0 1 1 1&&r c | j | j fS r% )rW rX r* s r get_read_buffer_limitsz#StreamReader.get_read_buffer_limits s !122r c | j S r% rf r* s r exceptionzStreamReader.exception
r excc || _ | j | j }|d | _ t || | j }|d | _ t || d S d S r% )rf rh clearrd r re r& rw waiters r r zStreamReader.set_exception sv !!### DL &# & & &! #D &# & & & & & r callbackc | j r2 | d S # t $ r t j d Y d S w xY w| j | d S NException in eof callback)rc Exceptionr ru rh rm r& r| s r on_eofzStreamReader.on_eof sz 9 1
G
G
G
G )*EFFFFFF
G
& &x 0 0 0 0 0s
77c 8 d| _ | j }|d | _ t |d | j }|d | _ t |d | j D ]1} | # t
$ r t
j d Y .w xY w| j d S )NTr ) rc rd r re rh r r ru ry )r& r{ cbs r feed_eofzStreamReader.feed_eof s DL vt $ $ $! #D vt $ $ $% G GB
G
G
G
G )*EFFFFF
G
!!#####s
A A>=A>c | j S )z&Return True if 'feed_eof' was called.rc r* s r is_eofzStreamReader.is_eof s
yr c | j o| j S )z=Return True if the buffer is empty and 'feed_eof' was called.rc ra r* s r at_eofzStreamReader.at_eof s y- --r c K | j rd S | j J | j | _ | j d {V d | _ d S # d | _ w xY wr% )rc re r[
create_futurer* s r wait_eofzStreamReader.wait_eof s| 9 F ''' :3355 $" " " " " " " " #D tD # # # #s
A
Adatac \ t j dt d |sdS | j r)| j d | j d | j d< d| _ | xj t
| z
c_ | xj t
| z c_ | 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)rU )
stacklevelNr )
warningswarnDeprecationWarningrb ra r\ lenr]
appendleft _eof_counter)r& r s r unread_datazStreamReader.unread_data s
=
F $ "l1od.A.C.C DDLO"#D
c$ii
D ! %%% r sizec | j r
J d |sd S | xj t | z
c_ | j | | xj t | z
c_ | j }|d | _ t |d | j | j k r'| j j
s | j d S d S d S )Nzfeed_data after feed_eof) rc r\ r ra rm total_bytesrd r rX rV _reading_paused
pause_readingr& r r r{ s r feed_datazStreamReader.feed_data s 988 888} F
c$ii
D!!! CII% DL vt $ $ $ :( ( ( 1O ( N ( ( * * * * * ) ( ( (r c R | j | j rt d g | _ d S d S )Nz?Called begin_http_chunk_receiving whensome data was already fed)r^ r RuntimeErrorr* s r begin_http_chunk_receivingz'StreamReader.begin_http_chunk_receiving sC " *
"X ')D # # # + *r c | j t d | j r
| j d nd}| j |k rd S | j | j | j }|d | _ t |d d S d S )NzFCalled end_chunk_receiving without calling begin_chunk_receiving firstr )r^ r r rm rd r )r& posr{ s r end_http_chunk_receivingz%StreamReader.end_http_chunk_receiving s " * .
.2-DKd%b))! s " "
F &&t'7888 DL vt $ $ $ $ $ r func_namec K | j t d|z | j x}| _ | j r(| j 5 | d {V d d d n # 1 swxY w Y n| d {V d | _ d S # d | _ w xY w)NzH%s() called while another coroutine is already waiting for incoming data)rd r r[ r rg )r& r r{ s r _waitzStreamReader._wait! s
< # 46?@
!%
8 8 : :: {
[ ! ! LLLLLLL! ! ! ! ! ! ! ! ! ! ! ! ! ! ! DLLL4DL s/ A= A A= A$$A= 'A$( A= = Bc : K | d {V S r% ) readuntilr* s r rA zStreamReader.readline6 s( ^^%%%%%%%%%r
separatorc K t | }|dk rt d | j | j d}d}d}|r| j r|r| j }| j d || dz }| |r||z
nd }||z
}|t | z
}|rd}|| j k rt d | j r|| j rn |r| d d {V ||S )
Nr z,Separator should be at least one-byte stringr Tr r Fz
Chunk too bigr )
r
ValueErrorrf ra rb find_read_nowait_chunkrX rc r ) r& r seplenchunk
chunk_size
not_enoughoffseticharr s r r zStreamReader.readuntil9 sJ Y Q;; KLL L ? &/ !
.,
6:
6 , Q,,Y??!C../Nuv~~BOO
c$ii'
'!&J 000$_555 ,
6:
6 y
.jj---------% .( r r rB c K | j | j | j rA| j s:t | dd dz | _ | j dk rt j dd |sdS |dk rKg } | d {V }|sn| | 3d | S | j s0| j s)|
d d {V | j s| j )| | S )
NTr r r zEMultiple access to StreamReader in eof state, might be infinite loop.)
stack_infor rE ) rf rc ra getattrr r warningrJ rm rn r _read_nowait)r& rB blocksblocks r rE zStreamReader.read[ sT ? &/ ! y
$+D.!$D$Dq$H!$q((#+2#' 3 q55
F
% "llnn,,,,,,
e$$$
%
88F## #
, %ty %**V$$ $ $ $ $ $ $ $ , %ty % ###r c K | j | j | j s0| j s)| d d {V | j s| j )| d S )NrJ r )rf ra rc r r r* s r rJ zStreamReader.readany sz ? &/ !
, (ty (**Y'' ' ' ' ' ' ' ' , (ty ( $$$r c K | j | j | j rl| j d }|| j k rdS || j k r | || j z
dfS t j d | j l| j r| d dfS | j rdS |
d d{V )
a 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.
TNr r TzESkipping HTTP chunk end due to data consumption beyond chunk boundaryr Fr: r; ) rf r^ popr] r r r ra r rc r )r& r s r r; zStreamReader.readchunk s **o%)
-11!44$,&&&; %% - -cDL.@ A A4HH '8
)
|
< //33U;; y
$ $|**[)) ) ) ) ) ) ) )1 *r c d K | j | j g }|dk r| | d {V }|s:d | }t j |t | |z | | |t | z }|dk d | S )Nr r )rf rE rn rY IncompleteReadErrorr rm )r& rB r r partials r readexactlyzStreamReader.readexactly s ? &/ ! !ee ))A,,&&&&&&E
M ((6** 1'3w<DataQueue is a general-purpose blocking queue with one reader.rQ r# Nc | || _ d| _ d | _ d | _ d| _ t j | _ d S )NFr )r[ rc rd rf r\ r_ r` ra )r& rQ s r r' zDataQueue.__init__5 s9
7; 37
.9.?.A.A r c * t | j S r% )r ra r* s r __len__zDataQueue.__len__= s 4< r c | j S r% r r* s r r zDataQueue.is_eof@ s
yr c | j o| j S r% r r* s r r zDataQueue.at_eofC s y- --r c | j S r% rt r* s r ru zDataQueue.exceptionF rv r rw c f d| _ || _ | j }|d | _ t || d S d S r )rc rf rd r rz s r r zDataQueue.set_exceptionI sB DL &# & & & & & r r r r c | xj |z
c_ | j ||f | j }|d | _ t |d d S d S r% )r\ ra rm rd r r s r r zDataQueue.feed_dataR s^
d
T4L))) DL vt $ $ $ $ $ r c X d| _ | j }|d | _ t |d d S d S r )rc rd r )r& r{ s r r zDataQueue.feed_eof[ s; DL vt $ $ $ $ $ r c p K | j sd| j s]| j rJ | j | _ | j d {V n'# t
j t
j f$ r d | _ w xY w| j r.| j \ }}| xj |z c_ |S | j
| j
t r% ) ra rc rd r[ r rY CancelledError TimeoutErrorr r\ rf r )r& r r s r rE zDataQueue.readc s | DI | # ## :3355DL
l""""""""*G,@A
#
< --//JD$ JJ$ JJK*o% s
A $A+c * t | j S r% )r! rE r* s r r+ zDataQueue.__aiter__w s "49---r r r )r r r r rY r r' rN r r= r r r r ru r r r r rE r! r+ r r r r r 2 sV HHBW 6 B4 B B B B! ! ! ! ! . . . . . 8M2 ' '4 ' ' ' '% %b % %D % % % %% % % % B (..r2 . . . . . .r r c h e Zd ZdZdededej ddf fd Zd
d e d
eddf fd
Z
de f fd Z xZ S )r zlFlowControlDataQueue resumes and pauses an underlying stream.
It is a destination for parsed data.
rR rS rQ r# Nc n t | || _ |dz | _ d S )N)rQ rU )superr' rV _limit)r& rR rS rQ rl s r r' z FlowControlDataQueue.__init__ s6 d###!ai r r r r c t || | j | j k r'| j j s | j d S d S d S r% )r r r\ r rV r r )r& r r rl s r r z FlowControlDataQueue.feed_data s^
$%%% : # #DN,J # N ( ( * * * * * $ # # #r c > K t d {V | j | j k r&| j j r| j S S S # | j | j k r&| j j r| j w w w xY wr% )r rE r\ r rV r r )r& rl s r rE zFlowControlDataQueue.read s 0 '''''' 'zDK''DN,J'--//// ('tzDK''DN,J'--//// ('s %A# #9B r )
r r r r r rN rY r r' r r rE
__classcell__)rl s @r r r { s
$ -0 ;B;T
+ +b + +D + + + + + + 0B 0 0 0 0 0 0 0 0 0 0r r )#rY r_ r typingr r r r r r r r
base_protocolr helpersr
r r logr typedefsr __all__r r r r! r4 r? r r r __annotations__r r r r r r sa V V V V V V V V V V V V V V V V V V V V ' ' ' ' ' ' @ @ @ @ @ @ @ @ @ @
WT]]! ! ! ! ! ! ! ! '"+ " 3 3 3 3 3 3 3 3>`3 `3 `3 `3 `3) `3 `3 `3F
1 1 1 1 1 1 1 1h &7%6%8%8
u\" 8 8 8F. F. F. F. F. F. F. F.R0 0 0 0 09R= 0 0 0 0 0r