+ys U d dl Z d dlZd dlZd dlmZmZmZmZmZm Z m
Z
m Z m Z ddl
mZ ddlmZmZmZmZ 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) AwaitableCallableDequeFinalGenericListOptionalTupleTypeVar ) BaseProtocol)BaseTimerContext TimerNoop
set_exception
set_result)internal_logger)
EMPTY_PAYLOAD EofStream StreamReader DataQueueFlowControlDataQueue_Tc e Zd ZdZdS )r zeof stream indication.N)__name__
__module__ __qualname____doc__ c/builddir/build/BUILD/cloudlinux-venv-1.0.10/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, r3 r r r r" r" # ss #(2y}+<"= #$ # # # # r r" c : e Zd ZddZd dZdeeef fdZdS )
ChunkTupleAsyncStreamIteratorstreamr r$ Nc || _ d S r& )_stream)r' r6 s r r( z&ChunkTupleAsyncStreamIterator.__init__5 s
r c | S r& r r+ s r r, z'ChunkTupleAsyncStreamIterator.__aiter__8 r- r c b K | j d {V }|dk rt |S )Nr F)r8 readchunkr0 r1 s r r3 z'ChunkTupleAsyncStreamIterator.__anext__; sA <))++
+
+
+
+
+
+
$ $ r )r6 r r$ N)r$ r5 ) r r r r( r, r
bytesboolr3 r r r r5 r5 4 s` ud{!3 r r5 c f e Zd Zdee fdZdedee fdZdee fdZde fdZ
dS )AsyncStreamReaderMixinr$ c * t | j S r& )r" readliner+ s r r, z AsyncStreamReaderMixin.__aiter__C s "4=111r nc , t fd S )z>Returns an asynchronous iterator that yields chunks of size n.c . S r& )read)rC r' s r z5AsyncStreamReaderMixin.iter_chunked..H s 499Q<< r )r" r' rC s ``r iter_chunkedz#AsyncStreamReaderMixin.iter_chunkedF s "#7#7#7#7#7888r c * t | j S )z3Yield all available data as soon as it is received.)r" readanyr+ s r iter_anyz AsyncStreamReaderMixin.iter_anyJ 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.
)r5 r+ s r iter_chunksz"AsyncStreamReaderMixin.iter_chunksN s -T222r N) r r r r" r= r, intrI rL r5 rN r r r r@ r@ B s 2.u5 2 2 2 29c 9&9%&@ 9 9 9 91-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)timerloopprotocollimitrQ rR r$ c J || _ || _ |dz | _ |t j }|| _ d| _ d| _ d | _ t j
| _ d| _ d| _
d | _ d | _ d | _ |t# n|| _ 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
_exceptionr _timer_eof_callbacks)r' rS rT rQ rR s r r( zStreamReader.__init__g s " 19 <)++D
7; %0%6%8%8 7; ;?37%*]ikkk 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=%r<%s> )
__class__r r] appendrd rX rY re rg 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& )rX rY r+ s r get_read_buffer_limitsz#StreamReader.get_read_buffer_limits s !122r c | j S r& rg r+ s r exceptionzStreamReader.exception
r excc || _ | j | j }|d | _ t || | j }|d | _ t || d S d S r& )rg ri clearre r rf r' ry 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)rd Exceptionr rw ri ro 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 ) rd re r rf ri r r rw r{ )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.rd 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.rd rb 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& )rd rf 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)rV )
stacklevelNr )
warningswarnDeprecationWarningrc rb 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) rd r] r rb ro total_bytesre r rY rW _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 ro re 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 5 | d {V d d d n # 1 swxY w Y d | _ d S # d | _ w xY w)NzH%s() called while another coroutine is already waiting for incoming data)re r r\ r rh )r' r r} s r _waitzStreamReader._wait s
< # 46?@
!%
8 8 : ::
DLLL4DL s/ A- A
A- A A- A !A- - A6c : K | d {V S r& ) readuntilr+ s r rB zStreamReader.readline2 s( ^^%%%%%%%%%r
separatorc K t | }|dk rt d | j | j d}d}d}|r| j r|r| j }| j d || dz }| |r ||z
|z dz
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
ValueErrorrg rb rc find_read_nowait_chunkrY rd r ) r' r seplenchunk
chunk_size
not_enoughoffseticharr s r r zStreamReader.readuntil5 s\ Y Q;; KLL L ? &/ !
.,
6:
6 , Q,,Y??!C..38@EFNV+a//b
c$ii'
'!&J 000$_555 ,
6:
6 y
.jj---------) ., r r rC 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 rF ) rg rd rb getattrr r warningrK ro rp r _read_nowait)r' rC blocksblocks r rF zStreamReader.readY 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 )NrK r )rg rb rd r r r+ s r rK 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< ) rg r_ popr^ r r r rb r rd 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 )rg rF rp rZ IncompleteReadErrorr ro )r' rC r r partials r readexactlyzStreamReader.readexactly s ? &/ ! !ee ))A,,&&&&&&E
M ((6** 1'3w< r r r r= r r r r r rB r rF rK r< r r r r r r r r r W sd K -148
; ; ; ; ;
() ; w01
;
; ; ; ;4 '# ' ' ' ' 3c3h 3 3 3 3 8M2 ' '4 ' ' ' ' 1xD 1 1d 1 1 1 1$ $ $ $* . . . . . $ $ $ $ $ (+ +e +3 +t + + + +$) ) ) ) % % % %< S T $& & & & &" " "5 " " " "H($ ($C ($ ($ ($ ($ ($T
%u
%
%
%
% *ud{!3 * * * *D
3
5
$
$S
$%
$
$
$
$ C E 6
3c
3e
3
3
3
3
3
3r r c e Zd ZddZdefdZdee fdZdeddfdZ de
g df ddfd Z dd
Z de
fd Zde
fd Zdd
ZddededdfdZdefdZddedefdZdefdZdeee
f fdZdedefdZddedefdZdS ) EmptyStreamReaderr$ Nc d| _ d S )NF_read_eof_chunkr+ s r r( zEmptyStreamReader.__init__ s $ r c d| j j z S )Nrl )rn r r+ s r rr zEmptyStreamReader.__repr__ s ///r c d S r& r r+ s r rw zEmptyStreamReader.exception tr ry c d S r& r )r' ry s r r z EmptyStreamReader.set_exception r r~ c f | d S # t $ r t j d Y d S w xY wr )r r rw r s r r zEmptyStreamReader.on_eof sQ C HJJJJJ C C C %&A B B B B B B Cs
00c d S r& r r+ s r r zEmptyStreamReader.feed_eof
r r c dS NTr r+ s r r zEmptyStreamReader.is_eof r r c dS r r r+ s r r zEmptyStreamReader.at_eof r r c
K d S r& r r+ s r r zEmptyStreamReader.wait_eof s r r r rC c d S r& r )r' r rC s r r zEmptyStreamReader.feed_data r r c
K dS r/ r r+ s r rB zEmptyStreamReader.readline sr r c
K dS r/ r rH s r rF zEmptyStreamReader.read r r c
K dS r/ r r+ s r rK zEmptyStreamReader.readany$ r r c * K | j s d| _ dS dS )NTr; r r r+ s r r< zEmptyStreamReader.readchunk' s# # #'D <{r c 0 K t j d| r/ )rZ r rH s r r z EmptyStreamReader.readexactly. s )#q111r c dS r/ r rH s r r z EmptyStreamReader.read_nowait1 s sr r r r )r r r r( r rr r r rw r r r r r> r r r r= rO r rB rF rK r
r< r r r r r r r s % % % %0# 0 0 0 08M2
4
CxD 1 Cd C C C C
e
D
C
u ud{!3 23 25 2 2 2 2 S % r r r c e Zd ZdZdej ddfdZdefdZde fdZ
de fdZ de e
fd Zd
e
ddfd Zdd
ededdfdZddZdefdZdee fdZdS )r z>DataQueue is a general-purpose blocking queue with one reader.rR r$ Nc | || _ d| _ d | _ d | _ d| _ t j | _ d S )NFr )r\ rd re rg r] r` ra rb )r' rR s r r( zDataQueue.__init__; s9
7; 37
.9.?.A.A r c * t | j S r& )r rb r+ s r __len__zDataQueue.__len__C s 4< r c | j S r& r r+ s r r zDataQueue.is_eofF s
yr c | j o| j S r& r r+ s r r zDataQueue.at_eofI s y- --r c | j S r& rv r+ s r rw zDataQueue.exceptionL rx r ry c f d| _ || _ | j }|d | _ t || d S d S r )rd rg re r r| s r r zDataQueue.set_exceptionO sB DL &# & & & & & r r r r c | xj |z
c_ | j ||f | j }|d | _ t |d d S d S r& )r] rb ro re r r s r r zDataQueue.feed_dataX s^
d
T4L))) DL vt $ $ $ $ $ r c X d| _ | j }|d | _ t |d d S d S r )rd re r )r' r} s r r zDataQueue.feed_eofa 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& ) rb rd re r\ r rZ CancelledError TimeoutErrorr r] rg r )r' r r s r rF zDataQueue.readi s | DI | # ## :3355DL
l""""""""*G,@A
#
< --//JD$ JJ$ JJK*o% s
A $A+c * t | j S r& )r" rF r+ s r r, zDataQueue.__aiter__} s "49---r r r )r r r r rZ r r( rO r r> r r r r rw r r r r rF r" r, r r r r r 8 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.
rS rT rR r$ Nc n t | || _ |dz | _ d S )N)rR rV )superr( rW _limit)r' rS rT rR rn 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 rW r r )r' r r rn 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 rF r] r rW r r )r' rn s r rF zFlowControlDataQueue.read s 0 '''''' 'zDK''DN,J'--//// ('tzDK''DN,J'--//// ('s %A# #9B r )
r r r r r
rO rZ r r( r r rF
__classcell__)rn s @r r r s
$ -0 ;B;T
+ +b + +D + + + + + + 0B 0 0 0 0 0 0 0 0 0 0r r )#rZ r` r typingr r r r r r r r
r
base_protocolr
helpersr r r r logr __all__r r r r" r5 r@ r r r __annotations__r r r r r r s
( ' ' ' ' ' K K K K K K K K K K K K
WT]]! ! ! ! ! ! ! ! '"+ " 3 3 3 3 3 3 3 3*`3 `3 `3 `3 `3) `3 `3 `3F
8 8 8 8 8 8 8 8v &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