*jFo S r SSKrSSKrSSKrSSKrSSKr\" \S5 ( a \ S-
r SSKJr SSKJ r SSKJ
r
SS KJ r SS
KJ r SS K
Jr SS KJr S
rS\S.S jjrS\S.S jjr\" \S5 ( a S \S.S jjrS \S.S jjr " S S\ R, 5 r " S S\\ R, 5 r " S S5 r " S S5 rg) ) StreamReader StreamWriterStreamReaderProtocolopen_connection start_server NAF_UNIX)open_unix_connectionstart_unix_server )
coroutines)events)
exceptions)format_helpers) protocols)logger)sleepi )limitc ^ # [ R " 5 n[ X$S9n[ XTS9m UR " U 4S jX40 UD6I S h vN u pg[ UT XT5 nXX4$ N7f)Nr loopr c > T $ N protocols 6/opt/alt/python313/lib64/python3.13/asyncio/streams.py!open_connection..1 s )r
get_running_loopr r create_connectionr )
hostportr kwdsr reader transport_writerr s
@r r r si & " " $D
1F#F6H //$.(,. .LI
)Xv
. AA A A c ^ ^^# [ R " 5 mU UU4S jnTR " XQU40 UD6I S h vN $ N7f)Nc 2 > [ TTS9n [ U TTS9nU$ Nr r r r r& r client_connected_cbr r s r factory start_server..factoryN s& E5'0C-13r )r
r!
create_server)r0 r# r$ r r% r1 r s ` ` @r r r 6 s; , " " $D ##G4@4@ @@ @s 5A?Ac ^# [ R " 5 n[ XS9n[ XCS9mUR " U4S jU 40 UD6I S h vN u pV[ UTXC5 nXG4$ N7f)Nr r c > T $ r r r s r r &open_unix_connection..b s Hr )r
r! r r create_unix_connectionr ) pathr r% r r& r' r( r) r s @r r r Z si &&( E5': ! 8 8 d ,&* , , i6@~ ,r* c ^ ^^# [ R " 5 mU UU4S jnTR " XA40 UD6I S h vN $ N7f)Nc 2 > [ TTS9n [ U TTS9nU$ r- r. r/ s r r1 "start_unix_server..factoryk s& !D9F+F4G157HOr )r
r! create_unix_server)r0 r8 r r% r1 r s ` ` @r r
r
f s9 &&( ,,WCdCCCCs 4A >A c < \ rS rSrS
S jrS rS rS rS rS r S r
g) FlowControlMixint Nc Uc [ R " 5 U l OXl SU l [ R
" 5 U l SU l g NF)r
get_event_loop_loop_paused collectionsdeque_drain_waiters_connection_lost)selfr s r __init__FlowControlMixin.__init__~ s< < ..0DJ J ) / / 1 % r c SU l U R R 5 ( a [ R " SU 5 g g )NTz%r pauses writing)rD rC get_debugr debugrI s r
pause_writing FlowControlMixin.pause_writing s0 :: ! ! LL,d 3 "r c SU l U R R 5 ( a [ R " SU 5 U R
H+ nUR
5 ( a M UR S 5 M- g )NFz%r resumes writing)rD rC rM r rN rG done
set_resultrI waiters r resume_writing FlowControlMixin.resume_writing sT :: ! ! LL-t 4))F;;==!!$' *r c SU l U R ( d g U R HA nUR 5 ( a M Uc UR S 5 M0 UR U5 MC g NT)rH rD rG rS rT
set_exceptionrI excrV s r connection_lost FlowControlMixin.connection_lost sP $ || ))F;;==;%%d+((- *r c b # U R ( a [ S5 eU R ( d g U R R 5 nU R
R
U5 UI S h vN U R
R U5 g N ! U R
R U5 f = f7f)NzConnection lost)rH ConnectionResetErrorrD rC
create_futurerG appendremoverU s r
_drain_helper FlowControlMixin._drain_helper s &'89 9|| ))+ ""6* /LL & &v .
& &v .s0 A$B/'B ,B
-B 1 B/
B B,,B/c [ er )NotImplementedErrorrI streams r _get_close_waiter"FlowControlMixin._get_close_waiter s !!r )rH rG rC rD r ) __name__
__module__ __qualname____firstlineno__rJ rP rW r^ re rk __static_attributes__r r r r> r> t s &4 ( .
/"r r> c p ^ \ rS rSrSrS
U 4S jjr\S 5 rS rS r U 4S jr
S r S r S
r
S rS rU =r$ )r Nc " > [ TU ] US9 Ub- [ R " U5 U l UR
U l OS U l Ub Xl SU l S U l S U l X l
SU l U R R 5 U l g )Nr F)superrJ weakrefref_stream_reader_wr_source_traceback_strong_reader_reject_connection_task
_transport_client_connected_cb _over_sslrC rb _closed)rI
stream_readerr0 r __class__s r rJ StreamReaderProtocol.__init__ s
d# $%,[[ %?D "%2%D%DD "%)D " * #0 "'
$7! zz//1 r c > U R c g U R 5 $ r )rx rO s r _stream_reader#StreamReaderProtocol._stream_reader s ! ! )%%''r c X U R nXl UR S5 S LU l g )N
sslcontext)rC r} get_extra_infor )rI r' r s r _replace_transport'StreamReaderProtocol._replace_transport s' zz#"11,?tKr c ~ ^ ^ T R ( aP SS0nT R ( a T R US' T R R U5 TR 5 g TT l T R nUb UR T5 TR S5 S LT l T R b [ TT UT R 5 nT R X45 n[ R " U5 ( aB U U4S jnT R R U5 T l T R R! U5 S T l g g )NmessagezpAn open stream was garbage collected prior to establishing network connection; call "stream.close()" explicitly.source_tracebackr c > U R 5 ( a TR 5 g U R 5 nUb0 TR R SUTS.5 TR 5 g g )Nz*Unhandled exception in client_connected_cb)r exceptionr' ) cancelledcloser rC call_exception_handler)taskr] rI r' s r callback6StreamReaderProtocol.connection_made..callback s_ ~~''!) ..*C
99'S),)2;
")
'r )r{ ry rC r abortr} r
set_transportr r r~ r r iscoroutine create_taskr| add_done_callbackrz )rI r' contextr& r) resr s `` r connection_made$StreamReaderProtocol.connection_made s " " @G
%%.2.D.D*+ JJ - -g 6 OO #$$ +"11,?tK $ $ 0!)T64::FF++F;C%%c** * "ZZ 3 3C 8
,,X6"&D ) 1r c v > U R nUb% Uc UR 5 OUR U5 U R R 5 ( d: Uc U R R S 5 OU R R U5 [ TU ] U5 S U l S U l S U l
S U l g r ) r feed_eofr[ r rS rT ru r^ rx _stream_writerr| r} )rI r] r& r s r r^ $StreamReaderProtocol.connection_lost s $$ {!$$S)|| ""{ ''- **3/
$!% "
r c F U R nUb UR U5 g g r )r feed_data)rI datar& s r
data_received"StreamReaderProtocol.data_received s& $$ T " r c f U R nUb UR 5 U R ( a gg)NFT)r r r )rI r& s r eof_received!StreamReaderProtocol.eof_received s, $$ OO >> r c U R $ r )r ri s r rk &StreamReaderProtocol._get_close_waiter& s ||r c U R nUR 5 ( a' UR 5 ( d UR 5 g g g ! [ a g f = fr )r rS r r AttributeError)rI closeds r __del__ StreamReaderProtocol.__del__) sR #\\F {{}}V%5%5%7%7 " &8} s A
AA)
r~ r r r{ ry rx r rz r| r} NN)rm rn ro rp ry rJ propertyr r r r^ r r rk r rq
__classcell__)r s @r r r sN 2& ( (
L
%'N $#
# #r r c \ rS rSrS rS r\S 5 rS rS r S r
S r S r S
r
S rSS
jrS rS S S S.S jr\4S jrSrg )r i5 c Xl X l X0l X@l U R R 5 U l U R
R
S 5 g r )r} _protocol_readerrC rb
_complete_futrT )rI r' r r& r s r rJ StreamWriter.__init__? sA #!
!ZZ 5 5 7 %%d+r c U R R SU R < 3/nU R b UR SU R < 35 SR SR
U5 5 $ )N
transport=zreader=<{}> )r rm r} r rc formatjoinrI infos r __repr__StreamWriter.__repr__I s[ '':doo5H)IJ << # KK'$,,!12 3}}SXXd^,,r c U R $ r r} rO s r r' StreamWriter.transportO s r c : U R R U5 g r )r} writerI r s r r StreamWriter.writeS s d#r c : U R R U5 g r )r}
writelinesr s r r StreamWriter.writelinesV s ""4(r c 6 U R R 5 $ r )r} write_eofrO s r r StreamWriter.write_eofY s ((**r c 6 U R R 5 $ r )r}
can_write_eofrO s r r StreamWriter.can_write_eof\ s ,,..r c 6 U R R 5 $ r )r} r rO s r r StreamWriter.close_ s $$&&r c 6 U R R 5 $ r )r}
is_closingrO s r r StreamWriter.is_closingb s ))++r c V # U R R U 5 I S h vN g N7fr )r rk rO s r wait_closedStreamWriter.wait_closede s nn..t444s )')Nc 8 U R R X5 $ r )r} r )rI namedefaults r r StreamWriter.get_extra_infoh s --d<B?BB)server_hostnamessl_handshake_timeoutssl_shutdown_timeoutc
# U R R S LnU R nU R 5 I S h vN U R R U R
XaXRUUS9I S h vN nXpl UR
U5 g NK N 7f)N) server_sider r r )r r~ r rC start_tlsr} r )rI r r r r r r
new_transports r r StreamWriter.start_tls s
nn99E >>jjl "jj 2 2 OOX#"7!5 3 7 7
(##M2 7s! 8B
B.B
)B* B
B
c U R R 5 ( dc U R R 5 ( a UR " S[
5 g U R
5 UR " SU < 3[
5 g g )Nzloop is closedz unclosed )r} r rC is_closedwarnResourceWarningr )rI warningss r r StreamWriter.__del__ sZ ))++zz##%%
.@
$ 2OD ,r )r rC r r r} r )rm rn ro rp rJ r r r' r r r r r r r r r r r r rq r r r r r 5 sh ,- $)+/',5=-4 )-.2-13 ( Er r c \ rS rSrSr\S4S jrS rS rS r S r
S r S r S
r
S rS rS
rS rSS jrSS jrS rS rS rSrg)r i Nc | US:: a [ S5 eXl Uc [ R " 5 U l OX l [ 5 U l SU l S U l S U l S U l
SU l U R R 5 ( a0 [ R " [ R " S5 5 U l g g )Nr zLimit cannot be <= 0Fr )
ValueError_limitr
rB rC bytearray_buffer_eof_waiter
_exceptionr} rD rM r
extract_stacksys _getframery )rI r r s r rJ StreamReader.__init__ s A: 34 4 < ..0DJ J { :: ! !%3%A%A
a &"D " "r c S/nU R ( a' UR [ U R 5 S35 U R ( a UR S5 U R [
:w a UR SU R 35 U R ( a UR SU R < 35 U R ( a UR SU R < 35 U R ( a UR SU R < 35 U R ( a UR S5 S R S
R U5 5 $ ) Nr z byteseofzlimit=zwaiter=z
exception=r pausedr r ) r rc lenr r _DEFAULT_LIMITr r r} rD r r r s r r StreamReader.__repr__ s << KK3t||,-V4 5 99 KK ;;. ( KK&
. / << KK'$,,!12 3 ?? KK*T__$78 9 ?? KK*T__$78 9 << KK !}}SXXd^,,r c U R $ r )r rO s r r StreamReader.exception s r c Xl U R nUb/ S U l UR 5 ( d UR U5 g g g r )r r r r[ r\ s r r[ StreamReader.set_exception sD DL##%%$$S) & r c U R nUb/ S U l UR 5 ( d UR S 5 g g g r )r r rT rU s r _wakeup_waiterStreamReader._wakeup_waiter s? DL##%%!!$' & r c Xl g r r )rI r' s r r StreamReader.set_transport s #r c U R ( aF [ U R 5 U R :: a" SU l U R R 5 g g g rA )rD r r r r} resume_readingrO s r _maybe_resume_transport$StreamReader._maybe_resume_transport s; < U
nU nMD Ub O[ SUS- U-
5 nX@R : a [ R " SU5 eU R ( aF [ U R 5 n U R R 5 [ R " U S 5 eU R! S5 I S h vN GM X`R : a [ R " S U5 eU R S U n U R S U2 U R# 5 [ U 5 $ Nf7f)
N)keyz-Separator should contain at least one elementr z,Separator should be at least one-byte stringr z2Separator is not found, and chunk exceed the limitr$ z2Separator is found, but chunk is longer than limit)
isinstancetuplesortedr r r r findmaxr r r' r bytesr* r% r r ) rI separator
min_seplen
max_seplenoffsetbuflen match_start match_endr, isependchunks r r$ StreamReader.readuntil> s 4 i ' ' yc2I" I LM M1 &
2 '
? KL L ?? &// !* &F *, " $C <<,,S9Drz #SXo$,(+I*.K % ( Q
Z 78KK'$66L yy dll+ ""$ 44UDAA %%k2 2 2O R $ ..DkS
S Zi( LL) $ $$&U|
3s CG>G>&B/G>G<A'G>c # U R b U R eUS:X a gUS: aR / n U R U R 5 I S h vN nU( d OUR U5 M> SR U5 $ U R
( d* U R ( d U R S5 I S h vN [ [ U R
5 S U 5 nU R
S U2 U R 5 U$ N NH7f)Nr r read) r rG r rc r r r r r:
memoryviewr )rI nblocksblockr s r rG StreamReader.read s , ?? &// ! 6 q5
F "ii 44
e$
88F# #||DII%%f- - - Z -bq12 LL! $$& 5
.s& AC<
C8 A&C<1C:2AC<:C<c # US: a [ S5 eU R b U R eUS:X a g[ U R 5 U: a U R ( aE [ U R 5 nU R R
5 [ R " X!5 eU R S5 I S h vN [ U R 5 U: a M [ U R 5 U:X a0 [ U R 5 nU R R
5 O0[ [ U R 5 S U 5 nU R S U2 U R 5 U$ N7f)Nr z*readexactly size can not be less than zeror readexactly) r r r r r r: r* r r% r rH r )rI rI
incompleter s r rN StreamReader.readexactly s
q5 IJ J ?? &// ! 6$,, !#yy "4<< 0
""$ 44ZCC%%m4 4 4
$,, !# t|| ! &D LL DLL1"156D RaR $$&
5s B5E$7E"8 E$B E$c U $ r r rO s r __aiter__StreamReader.__aiter__ s r c Z # U R 5 I S h vN nUS:X a [ eU$ N7f)Nr )r0 StopAsyncIteration)rI vals r __anext__StreamReader.__anext__ s* MMO# #:$ $
$s +)+) r r r r rC rD ry r} r )r# )r4 )rm rn ro rp ry r rJ r r r[ r r r r r r r r0 r$ rG rN rR rW rq r r r r r sf +$ ",-$ *($-
.$, 8 >p d1f'Rr r r r )__all__rE socketr r rv hasattr r r
r r r logr tasksr r r r r r
Protocolr> r r r r r r r` s '
69 <