֦i̼ d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl
Z
ddl m
Z
ddl mZ ddl mZ ddl mZ ddl mZ dd l mZ dd
l mZ dd l mZ dd lmZ eej d
Zer ej2 d Zd Z G d de
j: Z G d dej> ej@ Z! G d de! Z" G d de!ejF Z$y# e $ r dZ
Y w xY w# e$ r dZY pw xY w))BaseSelectorEventLoop N ) base_events) constants)events)futures) protocols)sslproto)
transports)trsock)loggersendmsg
SC_IOV_MAXFc t | j | }t |j |z S # t $ r Y yw xY wNF)get_keyboolr KeyError)selectorfdeventkeys 0/usr/lib64/python3.12/asyncio/selector_events.py_test_selector_eventr * sA ( r" CJJ&'' s + 77c e Zd Z d2 fd Zd2ddddZ d2ddddej ej ddZ d3dZ fd Z
d
Z d Z d Z
d
Zd Zdddej ej fdZdddej ej fdZddej ej fdZd Zd Zd Zd Zd Zd Zd Zd Zd Zd Z d2d Z d Z d Z d Z d! Z!d" Z"d4d#Z#d$ Z$d% Z%d& Z&d' Z'd( Z(d) Z)d* Z*d2d+Z+d, Z,d- Z-d. Z.d/ Z/d0 Z0d1 Z1 xZ2S )5r Nc t | |t j }t j
d|j j || _ | j t j | _ y )NzUsing selector: %s)
super__init__ selectorsDefaultSelectorr
debug __class____name__ _selector_make_self_pipeweakrefWeakValueDictionary _transports)selfr r" s r r z BaseSelectorEventLoop.__init__; sa
002H )8+=+=+F+FG! "668 extraserverc D | j | t | ||||| S N)_ensure_fd_no_transport_SelectorSocketTransport)r) sockprotocolwaiterr, r- s r _make_socket_transportz,BaseSelectorEventLoop._make_socket_transportE s* $$T*'dHf(-v7 7r* F) server_sideserver_hostnamer, r- ssl_handshake_timeoutssl_shutdown_timeoutc
| j | t j | |||||| |
} t | || || | j S )N)r8 r9 r+ )r0 r
SSLProtocolr1 _app_transport) r) rawsockr3
sslcontextr4 r6 r7 r, r- r8 r9 ssl_protocols r _make_ssl_transportz)BaseSelectorEventLoop._make_ssl_transportK sW
$$W- ++ (J "7!5
!w ',V =***r* c D | j | t | ||||| S r/ )r0 _SelectorDatagramTransport)r) r2 r3 addressr4 r, s r _make_datagram_transportz.BaseSelectorEventLoop._make_datagram_transport] s, $$T*)$h*165B Br* c | j r t d | j ry | j t | | j "| j j d | _ y y )Nz!Cannot close a running event loop)
is_running RuntimeError is_closed_close_self_piper closer$ r) r" s r rJ zBaseSelectorEventLoop.closec sa ?? BC C >>
>> % NN " !DN &r* c | j | j j | j j d | _ | j j d | _ | xj
dz c_ y )Nr )_remove_reader_ssockfilenorJ _csock
_internal_fdsr) s r rI z&BaseSelectorEventLoop._close_self_pipen s\ DKK . . 01 a r* c D t j \ | _ | _ | j j d | j j d | xj
dz
c_ | j
| j j | j y )NFr ) socket
socketpairrN rP setblockingrQ _add_readerrO _read_from_selfrR s r r% z%BaseSelectorEventLoop._make_self_pipev sq #)#4#4#6 T[ & & a ++-t/C/CDr* c y r/ r) datas r _process_self_dataz(BaseSelectorEventLoop._process_self_data~ s r* c | j j d }|sy | j | 1# t $ r Y =t $ r Y y w xY w)Ni )rN recvr] InterruptedErrorBlockingIOErrorr[ s r rX z%BaseSelectorEventLoop._read_from_self sV
{{''-''- $
"
s 3 3 A A A c | j }|y |j d y # t $ r( | j rt j
dd Y y Y y w xY w)N z3Fail to write a null byte into the self-pipe socketTexc_info)rP sendOSError_debugr
r! )r) csocks r _write_to_selfz$BaseSelectorEventLoop._write_to_self sU = , JJu ,{{ 0&*, ,s # ,AAd c f | j |j | j ||||||| y r/ )rW rO _accept_connection)r) protocol_factoryr2 r> r- backlogr8 r9 s r _start_servingz$BaseSelectorEventLoop._start_serving s4
(?(?)4VW.0D Fr* c
t | D ]w } |j \ } }
| j rt j d||
| | j d d|
i} | j
|| | |||| } | j | y y # t t t f$ r Y y t $ r}
|
j t j t j t j t j fv ry| j# d|
t% j& | d | j) |j+ | j- t. j0 | j2 ||||||| n Y d }
~
dd }
~
ww xY w)Nz#%r got a new connection from %r: %rFpeernamez&socket.accept() out of system resource)message exceptionrT )rangeacceptrh r
r! rV _accept_connection2 create_taskra r` ConnectionAbortedErrorrg errnoEMFILEENFILEENOBUFSENOMEMcall_exception_handlerr TransportSocketrM rO
call_laterr ACCEPT_RETRY_DELAYrp )r) rn r2 r> r- ro r8 r9 _connaddrr, rv excs r rm z(BaseSelectorEventLoop._accept_connection sX w A"
) ![[]
d;;LL!F!'t5 '2 $T* 11$dE:v)+?A (G $%57MN
99 u||!& !> >
//#K%("("8"8">1
''
6OOI$@$@$($7$7$4dJ$+-B$8 :
:
s ABE5 E5&CE00E5c K d }d } | }| j }
|r| j ||||
d|||| } n| j |||
|| } |
d { y 7 # t $ r | j d }
w xY w# t
t f$ r t $ r?} | j r)d| d} ||| d< | | | d< | j | Y d } ~ y Y d } ~ y d } ~ ww xY ww)NT)r4 r6 r, r- r8 r9 )r4 r, r- z3Error on transport creation for incoming connection)rs rt r3 transport)
create_futurer@ r5
BaseExceptionrJ
SystemExitKeyboardInterruptrh r )
r) rn r r, r> r- r8 r9 r3 r r4 r contexts
r rw z)BaseSelectorEventLoop._accept_connection2 s
& 5')H'')F 4 4(Jv $E&*?)= 5 ? ! 7 7(6! 8 #
!
-. 5{{ N!$
'*2GJ' (+4GK(++G44 5sS CA
B A A A C A A==B C0C
CCCc * |}t |t s t |j } | j | }|j st d|d| y # t t t
f$ r t d| d w xY w# t $ r Y y w xY w)NzInvalid file object: zFile descriptor z is used by transport )
isinstanceintrO AttributeError TypeError
ValueErrorr(
is_closingrG r )r) r rO r s r r0 z-BaseSelectorEventLoop._ensure_fd_no_transport s &#&
K V]]_- & ((0I '')"&rf,B m%& & * #Iz:
K #8!?@dJ
K
s A B $B BBc | j t j ||| d } | j j | }|j |j
c}\ }}| j j
||t j z ||f ||j |S # t $ r1 | j j |t j |d f Y |S w xY wr/ )
_check_closedr Handler$ r r\ modifyr
EVENT_READcancelr register r) r callbackargshandler maskreaderwriters r rW z!BaseSelectorEventLoop._add_reader s xtT:
..((,C
&)ZZ "D"66 NN ! !"dY-A-A&A#)6"2
4!
4 NN # #B (<(<%+TN
4
4 B% %6C C c | | j ry | j j | }|j |j c}\ }}|t
j z }|s | j j | n | j j ||d |f ||j yy# t $ r Y yw xY wNFT) rH r$ r r r\ r r
unregisterr r r r) r r r r r s r rM z$BaseSelectorEventLoop._remove_reader& s >> ..((,C &)ZZ "D"66 Y))) )D))"-%%b$v?!
s B/ / B;:B;c | j t j ||| d } | j j | }|j |j
c}\ }}| j j
||t j z ||f ||j |S # t $ r1 | j j |t j d |f Y |S w xY wr/ ) r r r r$ r r\ r r EVENT_WRITEr r r r s r _add_writerz!BaseSelectorEventLoop._add_writer; s xtT:
..((,C
&)ZZ "D"66 NN ! !"dY-B-B&B#)6"2
4!
4 NN # #B (=(=%)6N
4
4r c ~ | j ry | j j | }|j |j c}\ }}|t
j z }|s | j j | n | j j |||d f ||j yy# t $ r Y yw xY wr ) rH r$ r r r\ r r r r r r r s r _remove_writerz$BaseSelectorEventLoop._remove_writerK s ' >> ..((,C &)ZZ "D"66 Y*** *D))"-%%b$?!
s B0 0 B<;B<c P | j | | j ||g| y r/ )r0 rW r) r r r s r
add_readerz BaseSelectorEventLoop.add_readerb s* $ $$R(X--r* c H | j | | j | S r/ )r0 rM r) r s r
remove_readerz#BaseSelectorEventLoop.remove_readerg $ ' $$R(""2&&r* c P | j | | j ||g| y r/ )r0 r r s r
add_writerz BaseSelectorEventLoop.add_writerl s* % $$R(X--r* c H | j | | j | S r/ )r0 r r s r
remove_writerz#BaseSelectorEventLoop.remove_writerq r r* c K t j | | j r |j dk7 r t d |j | S # t t f$ r Y nw xY w| j }|j }| j | | j || j ||| }|j t j | j || | d { 7 S wNr the socket must be non-blockingr )r _check_ssl_socketrh
gettimeoutr r_ ra r` r rO r0 rW
_sock_recvadd_done_callback functoolspartial_sock_read_done)r) r2 nfutr r s r sock_recvz BaseSelectorEventLoop.sock_recvv s %%d+ ;;4??,1 >? ? 99Q< !12 "
[[] $$R(!!"doosD!D d 2 2Bv F Hyy7 AC6A C6A'$C6&A''B C60C31C6c L ||j s| j | y y r/ ) cancelledr r) r r r s r r z%BaseSelectorEventLoop._sock_read_done % >!1!1!3 r " "4r* c |j ry |j | }|j | y # t t f$ r Y y t
t f$ r t $ r}|j | Y d }~y d }~ww xY wr/ ) doner_
set_resultra r` r r r
set_exception)r) r r2 r r\ r s r r z BaseSelectorEventLoop._sock_recv su 88: !99Q? ? >>#& & !12 "
[[] $$R(!!"d&:&:CsK d 2 2Bv F Hyyr c |j ry |j | }|j | y # t t f$ r Y y t
t f$ r t $ r}|j | Y d }~y d }~ww xY wr/ ) r r r ra r` r r r r )r) r r2 r nbytesr s r r z%BaseSelectorEventLoop._sock_recv_into sv 88: #^^C(F
NN6 " !12 -. # c " " #r c K t j | | j r |j dk7 r t d |j | S # t t f$ r Y nw xY w| j }|j }| j | | j || j ||| }|j t j | j || | d { 7 S wr )r r rh r r recvfromra r` r rO r0 rW _sock_recvfromr r r r )r) r2 bufsizer r r s r
sock_recvfromz#BaseSelectorEventLoop.sock_recvfrom s %%d+ ;;4??,1 >? ? ==) ) !12 "
[[] $$R(!!"d&9&93gN d 2 2Bv F Hyyr c |j ry |j | }|j | y # t t f$ r Y y t
t f$ r t $ r}|j | Y d }~y d }~ww xY wr/ ) r r r ra r` r r r r )r) r r2 r resultr s r r z$BaseSelectorEventLoop._sock_recvfrom sv 88: #]]7+F
NN6 " !12 -. # c " " #r c K t j | | j r |j dk7 r t d |s t | } |j
|| S # t t f$ r Y nw xY w| j }|j }| j | | j || j |||| }|j t j | j" || | d { 7 S wr )r r rh r r len
recvfrom_intora r` r rO r0 rW _sock_recvfrom_intor r r r )r) r2 r r r r r s r sock_recvfrom_intoz(BaseSelectorEventLoop.sock_recvfrom_into s
%%d+ ;;4??,1 >? ?XF %%c62 2 !12 "
[[] $$R(!!"d&>&>T3"(* d 2 2Bv F Hyys7 ADA# "D#A52D4A55B
D?D Dc |j ry |j || }|j | y # t t f$ r Y y t
t f$ r t $ r}|j | Y d }~y d }~ww xY wr/ ) r r r ra r` r r r r )r) r r2 r r r r s r r z)BaseSelectorEventLoop._sock_recvfrom_into sz 88: #''W5F
NN6 " !12 -. # c " " #s 7 A:A: A55A:c * K t j | | j r |j dk7 r t d |j | }|t | k( ry | j }|j }| j | | j || j ||t | |g }|j t! j" | j$ || | d { S # t t f$ r d}Y w xY w7 wr )r r rh r r rf ra r` r r rO r0 r
_sock_sendall
memoryviewr r r _sock_write_done)r) r2 r\ r r r r s r sock_sendallz"BaseSelectorEventLoop.sock_sendall s %%d+ ;;4??,1 >? ? $A
D > "
[[] $$R(!!"d&8&8#t",T"2QC9 d 3 3R G Iy !12 A s7 ADC: B D5D6D:D D
DDc : |j ry |d } |j ||d }||z
}|t | k( r|j d y ||d< y # t t f$ r Y y t t
f$ r t $ r}|j | Y d }~y d }~ww xY wNr )
r rf ra r` r r r r r r )r) r r2 viewposstartr r s r r z#BaseSelectorEventLoop._sock_sendall7 s 88: A $uv,'A
CI NN4 CF !12 -. c " s A B(B?BBc K t j | | j r |j dk7 r t d |j || S # t t f$ r Y nw xY w| j }|j }| j | | j || j |||| }|j t j | j || | d { 7 S wr )r r rh r r sendtora r` r rO r0 r _sock_sendtor r r r )r) r2 r\ rC r r r s r sock_sendtoz!BaseSelectorEventLoop.sock_sendtoM s %%d+ ;;4??,1 >? ? ;;tW- - !12 "
[[] $$R(!!"d&7&7dD")+ d 3 3R G Iyys7 AC8A C8A(%C8'A((B
C82C53C8c |j ry |j |d| }|j | y # t t f$ r Y y t
t f$ r t $ r}|j | Y d }~y d }~ww xY wr ) r r r ra r` r r r r )r) r r2 r\ rC r r s r r z"BaseSelectorEventLoop._sock_sendtoh sx 88: D!W-A
NN1 !12 -. # c " " #s 8 A; A; A66A;c " K t j | | j r |j dk7 r t d |j
t j k( s-t j rd|j
t j k( rG| j ||j
|j |j | d { }|d \ }}}}}| j }| j ||| | d { d }S 7 ?7 # d }w xY ww)Nr r )familytypeprotoloop)r r rh r r r rT AF_INET _HAS_IPv6AF_INET6_ensure_resolvedr r r
_sock_connect)r) r2 rC resolvedr r s r sock_connectz"BaseSelectorEventLoop.sock_connectw s %%d+ ;;4??,1 >? ? ;;&.. (%%$++ *H ! 2 2 $))4:: 3 H #+1+ Aq!Q " 3g. 9 C Cs< CDD2D8D =D>D DD D Dc |j } |j | |j d d }y # t t f$ rf | j | | j
|| j ||| }|j t j | j || Y d }y t t f$ r t $ r }|j | Y d }~d }y d }~ww xY w# d }w xY w)Nr )rO connectr ra r` r0 r _sock_connect_cbr r r r r r r r )r) r r2 rC r r r s r r z#BaseSelectorEventLoop._sock_connect s
[[] LL !
NN4 C# !12 M
( ( ,%%D))3g?F ! !!!$"7"7FK
M C -. # c " " C #
Cs9 7 C" A0C 'C" +C CC" C C" "C&c L ||j s| j | y y r/ )r r r s r r z&BaseSelectorEventLoop._sock_write_done r r* c v |j ry |j t j t j }|dk7 rt |d| |j
d d }y # t t f$ r Y d }y t t f$ r t $ r }|j | Y d }~d }y d }~ww xY w# d }w xY w)Nr zConnect call failed )
r
getsockoptrT
SOL_SOCKETSO_ERRORrg r ra r` r r r r )r) r r2 rC errr s r r z&BaseSelectorEventLoop._sock_connect_cb s 88: //&"3"3V__ECax c%9'#CDD
NN4 C !12 C -. # c " " C #
Cs< AA* B4 *B19B4 =B1B,%B4 ,B11B4 4B8c K t j | | j r |j dk7 r t d | j }| j
|| | d { S 7 w)Nr r )r r rh r r r _sock_accept)r) r2 r s r sock_acceptz!BaseSelectorEventLoop.sock_accept sd %%d+ ;;4??,1 >? ? " #t$yys A(A1*A/+A1c |j } |j \ }}|j d |j ||f y # t t
f$ rc | j
| | j || j || }|j t j | j || Y y t t f$ r t $ r}|j! | Y d }~y d }~ww xY w)NFr )rO rv rV r ra r` r0 rW r r r r r r r r r )r) r r2 r r rC r r s r r z"BaseSelectorEventLoop._sock_accept s
[[]
, KKMMD' U #
NND'? + !12 L ( ( ,%%b$*;*;S$GF ! !!!$"6"66J
L -. # c " " #s $A
A/C-;C-C((C-c K | j |j = |j }|j |j d { | j |j |||d d { |j |r|j || j |j < S 7 h7 A# |j |r|j || j |j < w xY ww)NF)fallback) r( _sock_fd
is_reading
pause_reading_make_empty_waiter
sock_sendfile_sock_reset_empty_waiterresume_reading)r) transpfileoffsetcountr s r _sendfile_nativez&BaseSelectorEventLoop._sendfile_native s V__ - **, ''))) 7 ++FLL$5: , < <
& & ( %%'06D V__ - *<
& & ( %%'06D V__ -s< A C:
B6C:#B: 6B87B: :=C:8B: :=C77C:c d |D ] \ }}|j |j c}\ }}|t j z r1|/|j r| j | n| j
| |t j z sz|}|j r| j | | j
| y r/ ) fileobjr\ r r
_cancelledrM
_add_callbackr r )r)
event_listr r r r r s r _process_eventsz%BaseSelectorEventLoop._process_events s #IC(+ SXX %G%ffi***v/A$$''0&&v.i+++0B$$''0&&v. $r* c b | j |j |j y r/ )rM rO rJ )r) r2 s r
_stop_servingz#BaseSelectorEventLoop._stop_serving s DKKM*
r* r/ NNN)r )3r#
__module__ __qualname__r r5 r SSL_HANDSHAKE_TIMEOUTSSL_SHUTDOWN_TIMEOUTr@ rD rJ rI r% r] rX rj rp rm rw r0 rW rM r r r r r r r r r r r r r r r r r r r r r r r r
r r r r"
__classcell__r" s @r r r 5 so
97%)$7 9=+ $t"+"A"A!*!?!? +& CGB " E
,& #'tS-6-L-L,5,J,JF D#"+"A"A!*!?!? ,)` D"+"A"A!*!?!? -5^&$ * ..
'
.
'
,#! *#".#"2#" >,6
2.#*
," 7 / r* r c e Zd ZdZdZd fd Zd Zd Zd Zd Z d Z
d Z d
Z d Z
d Zej fd
ZddZd Zd Zd Zd Z xZS )_SelectorTransporti Nc t | || t j | | j d< |j | j d< d| j vr |j | j d< || _
|j | _ d| _
| j | || _ t! j" | _ d| _ d| _ d| _ | j | j j- | |j. | j < y # t $ r d | j d< Y w xY w# t j $ r d | j d< Y w xY w)NrT socknamerr Fr )r r r r _extra getsocknamerg getpeernamerT errorr rO r _protocol_connected set_protocol_server collectionsdeque_buffer
_conn_lost_closing_paused_attachr( )r) r r2 r3 r, r- r" s r r z_SelectorTransport.__init__ s8
% & 6 6t < H +&*&6&6&8DKK
# T[[ (
/*.*:*:*< J'
#( (# "((*
<< # LL "*. '+ +&*DKK
# +
<<
/*. J'
/s# D' ! E 'EE"E*)E*c | j j g}| j |j d n | j r|j d |j d| j
| j | j j st | j j | j
t j }|r|j d n|j d t | j j | j
t j }|rd}nd}| j }|j d| d | d
d j d j | S )
Nclosedclosingzfd=z read=pollingz read=idlepollingidlezwrite=z<{}> )r" r# r appendr9 r _looprH r r$ r r r get_write_buffer_sizeformatjoin)r) infor? stater s r __repr__z_SelectorTransport.__repr__' s$ ''( :: KK !
]] KK " c$-- )* :: !$***>*>*@*4::+?+?+/==):N:NPG N+ K(*4::+?+?+/==+4+@+@BG ! 002G KK'%
7)1= >}}SXXd^,,r* c & | j d y r/ ) _force_closerR s r abortz_SelectorTransport.abortC s $ r* c || _ d| _ y NT) _protocolr2 )r) r3 s r r3 z _SelectorTransport.set_protocolF s !#' r* c | j S r/ )rP rR s r get_protocolz _SelectorTransport.get_protocolJ s ~~ r* c | j S r/ )r9 rR s r r z _SelectorTransport.is_closingM s }} r* c B | j xr
| j S r/ )r r: rR s r r z _SelectorTransport.is_readingP s ??$$9T\\)99r* c | j sy d| _ | j j | j | j j rt
j d| y y )NTz%r pauses reading)r r: rD rM r get_debugr
r! rR s r r z _SelectorTransport.pause_readingS sP
!!$--0 :: ! LL,d 3 "r* c | j s | j sy d| _ | j | j | j | j
j
rt j d| y y )NFz%r resumes reading) r9 r: rW r _read_readyrD rV r
r! rR s r r z!_SelectorTransport.resume_reading[ sW == (8(89 :: ! LL-t 4 "r* c P | j ry d| _ | j j | j | j sa| xj
dz
c_ | j j
| j | j j | j d y y NTr ) r9 rD rM r r7 r8 r call_soon_call_connection_lostrR s r rJ z_SelectorTransport.closec ss ==
!!$--0|| OOq O JJ % %dmm 4 JJ !;!;T B r* c v | j - |d| t | | j j y y )Nzunclosed transport )source)r ResourceWarningrJ )r) _warns r __del__z_SelectorTransport.__del__m s5 :: ! 'x0/$ O JJ "r* c t |t r4| j j rDt j
d| |d n*| j j
||| | j d | j | y )Nz%r: %sTrd )rs rt r r3 ) r rg rD rV r
r! r rP rL )r) r rs s r _fatal_errorz _SelectorTransport._fatal_errorr se c7 #zz##% XtWtD JJ - -" ! NN /
# r* c | j ry | j r?| j j | j j | j
| j s,d| _ | j j | j
| xj dz
c_ | j j | j | y rZ )
r8 r7 clearrD r r r9 rM r[ r\ )r) r s r rL z _SelectorTransport._force_close s ?? << LL JJ % %dmm 4}} DM JJ % %dmm 4 1
T 7 7=r* c | j r| j j | | j j d | _ d | _ d | _ | j }||j d | _ y y # | j j d | _ d | _ d | _ | j }||j d | _ w w xY wr/ )r2 rP connection_lostr rJ rD r4 _detach)r) r r- s r r\ z(_SelectorTransport._call_connection_lost s $''..s3 JJ DJ !DN DJ\\F! # "
JJ DJ !DN DJ\\F! # "s 'A? ?ACc H t t t | j S r/ )summapr r7 rR s r rE z(_SelectorTransport.get_write_buffer_size s 3sDLL)**r* c b | j sy | j j ||g| y r/ )r rD rW r s r rW z _SelectorTransport._add_reader s*
r83d3r* )NN)zFatal error on transport)r# r$ r% max_sizer r rJ rM r3 rR r r r r rJ warningswarnra rc rL r\ rE rW r( r) s @r r+ r+ sk H
E/8-8 ( :45C %MM
> $ +4r* r+ c e Zd ZdZej
j Z d fd Z fdZ d Z
d Z d Z d Z
d Zd
Zd Zd ed
dfdZd Zd Zd Zd Z fdZd Zd Z fdZ xZS )r1 TNc d | _ t | ||||| d| _ d | _ t
r| j | _ n| j | _ t j | j | j j | j j | | j j | j | j" | j$ |,| j j t& j( |d y y r )_read_ready_cbr r _eof
_empty_waiter _HAS_SENDMSG_write_sendmsg _write_ready _write_sendr _set_nodelayr rD r[ rP connection_maderW r rX r _set_result_unless_cancelled)r) r r2 r3 r4 r, r- r" s r r z!_SelectorSocketTransport.__init__ s #
tXuf= ! $ 3 3D $ 0 0D ,
T^^ ; ;TB
T - - !]]D,<,< > JJ !E!E!'
/ r* c t |t j r| j | _ n| j
| _ t | | y r/ )r r BufferedProtocol_read_ready__get_bufferrr _read_ready__data_receivedr r3 )r) r3 r" s r r3 z%_SelectorSocketTransport.set_protocol s< h : : ;"&">">D "&"A"AD
X&r* c $ | j y r/ )rr rR s r rX z$_SelectorSocketTransport._read_ready s r* c | j ry | j j d }t | s t d | j j | }|s| j y | j j | y # t
t f$ r t $ r }| j |d Y d }~y d }~ww xY w# t t f$ r Y y t
t f$ r t $ r }| j |d Y d }~y d }~ww xY w# t
t f$ r t $ r }| j |d Y d }~y d }~ww xY w)Nz%get_buffer() returned an empty bufferz/Fatal error: protocol.get_buffer() call failed.$Fatal read error on socket transportz3Fatal error: protocol.buffer_updated() call failed.)r8 rP
get_bufferr rG r r r rc r r ra r` _read_ready__on_eofbuffer_updated)r) r r r s r r~ z0_SelectorSocketTransport._read_ready__get_buffer sC ?? ..++B/Cs8"#JKK ZZ))#.F $ $ & L NN ) )& 1- -. F
H !12 -. c#I J -. L J
L
L LsM 1B
C 1D
C%B<<CDD,DD D?#D::D?c | j ry | j j | j }|s| j y | j j | y # t t
f$ r Y y t t f$ r t $ r }| j |d Y d }~y d }~ww xY w# t t f$ r t $ r }| j |d Y d }~y d }~ww xY w)Nr z2Fatal error: protocol.data_received() call failed.)
r8 r r_ rm ra r` r r r rc r rP
data_received)r) r\ r s r r z3_SelectorSocketTransport._read_ready__data_received s ?? ::??4==1D $ $ & K NN ( ( . !12 -. c#I J -. K I
K
K Ks5 %A$ B+ $B(5B( B##B(+C CC c x | j j rt j d| | j j }|r&| j j | j y | j y # t t f$ r t $ r }| j |d Y d }~y d }~ww xY w)Nz%r received EOFz1Fatal error: protocol.eof_received() call failed.)
rD rV r
r! rP eof_receivedr r r rc rM r rJ )r) keep_openr s r r z,_SelectorSocketTransport._read_ready__on_eof
s :: ! LL*D 1 335I
JJ % %dmm 4 JJL -. H
J s B B9 B44B9c < t |t t t f s!t dt | j | j r t d | j t d |sy | j rH| j t j k\ rt j d | xj dz
c_
y | j s] | j j# | }t | |d }|sy | j0 j3 | j4 | j6 | j j9 | | j; y # t$ t& f$ r Y mt( t* f$ r t, $ r }| j/ |d Y d }~y d }~ww xY w)N/data argument must be a bytes-like object, not z%Cannot call write() after write_eof()z(unable to write; sendfile is in progress socket.send() raised exception.r %Fatal write error on socket transport) r bytes bytearrayr r r r# rs rG rt r8 r !LOG_THRESHOLD_FOR_CONNLOST_WRITESr
warningr7 r rf ra r` r r r rc rD r r rw rC _maybe_pause_protocol)r) r\ r r s r writez _SelectorSocketTransport.write s_ $ : >? ##':#6#6"9 ; <
< 99 FG G ) IJ J ??)"M"MM @A OOq O ||
JJOOD) "$'+ JJ " "4==$2C2C D
D! ""$! $%56
12
!!#'NO
s E F(F?FFc J t j | j t S r/ ) itertoolsislicer7 r rR s r _get_sendmsg_bufferz,_SelectorSocketTransport._get_sendmsg_bufferF s j99r* c r | j ry | j j | j }| j | | j | j s| j j | j | j | j j d | j r| j d y | j r*| j j t j" y y y # t$ t& f$ r Y y t( t* f$ r t, $ r}| j j | j | j j/ | j1 |d | j | j j3 | Y d }~y Y d }~y d }~ww xY wNr )r8 r r r _adjust_leftover_buffer_maybe_resume_protocolr7 rD r r rt r r9 r\ rs shutdownrT SHUT_WRra r` r r r re rc r )r) r r s r rv z'_SelectorSocketTransport._write_sendmsgI sV ?? 8ZZ''(@(@(BCF ( ( 0
' ' )<<
))$--8%%1&&11$7==..t4YYJJ''7
!12 -. 6 JJ % %dmm 4 LL c#J K!!-""0055 . 6s :D F6F6/A8F11F6r returnc | j }|r?|j }t | }||k r||z }n|j ||d y |r>y y r/ )r7 popleftr
appendleft)r) r bufferbb_lens r r z0_SelectorSocketTransport._adjust_leftover_buffere sO AFE%!!!FG*- r* c | j ry | j j }| j j | }|t | k7 r | j j
||d | j | j s| j j | j | j | j j d | j r| j d y | j r*| j j! t" j$ y y y # t& t( f$ r Y y t* t, f$ r t. $ r}| j j | j | j j1 | j3 |d | j | j j5 | Y d }~y Y d }~y d }~ww xY wr )r8 r7 r r rf r r r rD r r rt r r9 r\ rs r rT r ra r` r r r re rc r )r) r r r s r rx z$_SelectorSocketTransport._write_sendp ss ?? 8\\))+F
'ACK ''qr
3
' ' )<<
))$--8%%1&&11$7==..t4YYJJ''7
!12 -. 6 JJ % %dmm 4 LL c#J K!!-""0055 . 6s A!D. .G ?G A8GG c | j s | j ry d| _ | j s*| j j t
j y y rO )r9 rs r7 r r rT r rR s r write_eofz"_SelectorSocketTransport.write_eof s; ==DII || JJ / r* c | j r t d | j t d |sy | j j |D cg c]
}t | c} | j
| j rA| j j | j | j | j y y c c}w )Nz*Cannot call writelines() after write_eof()z-unable to writelines; sendfile is in progress) rs rG rt r7 extendr rw rD r r r )r) list_of_datar\ s r
writelinesz#_SelectorSocketTransport.writelines s 99 KL L ) NO O , G,$Z -, GH << JJ " "4==$2C2C D & & ( Hs Cc yrO rZ rR s r
can_write_eofz&_SelectorSocketTransport.can_write_eof s r* c t | | d | _ | j %| j j t d y y # d | _ | j %| j j t d w w xY w)Nz Connection is closed by peer)r r\ rw rt r ConnectionError)r) r r" s r r\ z._SelectorSocketTransport._call_connection_lost s E G )# . $D !!-""00#$BCE . !%D !!-""00#$BCE .s A :Bc | j t d | j j | _ | j s| j j d | j S )NzEmpty waiter is already set)rt rG rD r r7 r rR s r r z+_SelectorSocketTransport._make_empty_waiter sV ) <= = !ZZ 5 5 7|| ) )$ /!!!r* c d | _ y r/ )rt rR s r r z,_SelectorSocketTransport._reset_empty_waiter s
!r* c 0 d | _ t | y r/ )rr r rJ rK s r rJ z _SelectorSocketTransport.close s "
r* r# ) r# r$ r% _start_tls_compatibler
_SendfileMode
TRY_NATIVE_sendfile_compatibler r3 rX r~ r r r r rv r r rx r r r r\ r r rJ r( r) s @r r1 r1 s $22==48$(/2' #LJK2*%%N:88 c d 8>0 ) E"" r* r1 c V e Zd Zej Z d fd Zd Zd ZddZ d Z
xZ S )rB c x t | |||| || _ d| _ | j j | j j | | j j | j | j | j |,| j j t j |d y y r )
r r _address _buffer_sizerD r[ rP rz rW r rX r r{ )r) r r2 r3 rC r4 r, r" s r r z#_SelectorDatagramTransport.__init__ s
tXu5
T^^ ; ;TB
T - - !]]D,<,< > JJ !E!E!'
/ r* c | j S r/ )r rR s r rE z0_SelectorDatagramTransport.get_write_buffer_size s r* c | j ry | j j | j \ }}| j j || y # t t f$ r Y y t $ r%}| j j | Y d }~y d }~wt t f$ r t $ r }| j |d Y d }~y d }~ww xY w)Nz&Fatal read error on datagram transport)r8 r r rm rP datagram_receivedra r` rg error_receivedr r r rc r) r\ r r s r rX z&_SelectorDatagramTransport._read_ready s ?? 9 ,,T]];JD$
NN , ,T4 8 !12 / NN ) )# . . -. M c#K L L Ms) (A C%C-B
C(B??Cc Z t |t t t f s!t dt | j |sy | j r4|d | j fvrt d| j | j }| j rT| j rH| j t j k\ rt j d | xj dz
c_ y | j sI | j d r | j j# | y | j j% || y | j jA t | |f | xjB tE | z
c_! | jG y # t& t( f$ r3 | j* j- | j. | j0 Y t2 $ r%}| j4 j7 | Y d }~y d }~wt8 t: f$ r t< $ r }| j? |d Y d }~y d }~ww xY w)Nr z!Invalid address: must be None or r r rr 'Fatal write error on datagram transport)$r r r r r r r# r r r8 r r r
r r7 r. r rf r ra r` rD r r
_sendto_readyrg rP r r r r rc rC r r r r s r r z!_SelectorDatagramTransport.sendto s $ : >? ##':#6#6"9 ; <
< ==D$--00 7
GI I==D ??t}})"M"MM @A OOq O ||
;;z*JJOOD) JJ%%dD1
U4[$ /0 SY& ""$ $%56
J
&&t}}d6H6HI
--c2 12
!!BD
s0 -*F
F
?H* H*G33H*H%%H*c X | j r| j j \ }}| xj t | z c_ | j d r | j
j
| n | j
j || | j r| j% | j sD| j& j) | j* | j, r| j/ d y y y # t t f$ r> | j j ||f | xj t | z
c_ Y t $ r%}| j j | Y d }~y d }~wt t f$ r t $ r }| j# |d Y d }~y d }~ww xY w)Nrr r )r7 r r r r. r rf r ra r` r rg rP r r r r rc r rD r r r9 r\ r s r r z(_SelectorDatagramTransport._sendto_ready sQ ll --/JD$ T *
;;z*JJOOD)JJ%%dD1 ll,
##%|| JJ % %dmm 4}}**40 $%56
''t 5!!SY.!
--c2 12
!!BD
s, AC> >A
F)
F)E22F)
F$$F)r# r/ ) r# r$ r% r5 r6 _buffer_factoryr rE rX r r r( r) s @r rB rB s. !''O59$( / !9 *%X1r* rB )%__all__r5 rz r r osr rT rn r& ssl ImportError r r r r r r
r r logr
hasattrru sysconfr rg r
BaseEventLoopr _FlowControlMixin Transportr+ r1 DatagramTransportrB rZ r* r r s #
v}}i0 RZZ -
(I K 5 5 I X_455#--_4DZ 1 Zzl1!3Z5Q5Q l1Y%
C$ s# C% 9C2 %C/.C/2C<;C<