!A?hX l d Z ddlZddlZddlZddlZddlZddlZddlZ ddlZn
# e $ r dZY nw xY wddl
m Z ddl
m Z ddl
m
Z
ddl
mZ ddl
mZ dd l
mZ dd
l
mZ dd l
mZ dd lmZ d
Z G d de j Z G d dej ej Z G d de Z G d de Z dS ))BaseSelectorEventLoop N ) base_events) constants)events)futures) protocols)sslproto)
transports)trsock)loggerc ~ | | }t |j |z S # t $ r Y dS w xY wNF)get_keyboolr KeyError)selectorfdeventkeys D/opt/alt/python-internal/lib64/python3.11/asyncio/selector_events.py_test_selector_eventr sU ( r"" CJ&''' uus .
<<c e Zd Z d3 fd Zd3ddddZ d3ddddej ej ddZ d4dZ 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 d3d Z d Z d Z d Z d! Z!d" Z"d5d$Z#d% Z$d& Z%d' Z&d( Z'd) Z(d* Z)d+ Z*d3d,Z+d- Z,d. Z-d/ Z.d0 Z/d1 Z0d2 Z1 xZ2S )6r Nc t |t j }t j d|j j || _ | t j | _ d S )NzUsing selector: %s)
super__init__ selectorsDefaultSelectorr
debug __class____name__ _selector_make_self_pipeweakrefWeakValueDictionary _transports)selfr r s r r z BaseSelectorEventLoop.__init__1 sv
022H )8+=+FGGG! "688 extraserverc * t | ||||| S N)_SelectorSocketTransport)r' sockprotocolwaiterr* r+ s r _make_socket_transportz,BaseSelectorEventLoop._make_socket_transport; s! 'dHf(-v7 7 7r( F) server_sideserver_hostnamer* r+ ssl_handshake_timeoutssl_shutdown_timeoutc
p t j | |||||| |
} t | || || | j S )N)r5 r6 r) )r
SSLProtocolr. _app_transport) r' rawsockr0
sslcontextr1 r3 r4 r* r+ r5 r6 ssl_protocols r _make_ssl_transportz)BaseSelectorEventLoop._make_ssl_transport@ s\ + (J "7!5
!w ',V = = = =**r( c * t | ||||| S r- )_SelectorDatagramTransport)r' r/ r0 addressr1 r* s r _make_datagram_transportz.BaseSelectorEventLoop._make_datagram_transportQ s$ )$h*165B B Br( c 4 | rt d | rd S | t | j "| j d | _ d S d S )Nz!Cannot close a running event loop)
is_running RuntimeError is_closed_close_self_piper closer" )r' r s r rG zBaseSelectorEventLoop.closeV s ?? D BCC C >> F
> % N " " " !DNNN & %r( c | | j | j d | _ | j d | _ | xj dz c_ d S )Nr )_remove_reader_ssockfilenorG _csock
_internal_fdsr' s r rF z&BaseSelectorEventLoop._close_self_pipea st DK . . 0 0111 a r( c 2 t j \ | _ | _ | j d | j d | xj dz
c_ | | j | j d S )NFr ) socket
socketpairrJ rL setblockingrM _add_readerrK _read_from_selfrN s r r# z%BaseSelectorEventLoop._make_self_pipei s #)#4#6#6 T[ &&& &&& a ++--t/CDDDDDr( c d S r- r' datas r _process_self_dataz(BaseSelectorEventLoop._process_self_dataq s r( c | j d }|sd S | | n # t $ r Y Bt $ r Y d S w xY wR)NTi )rJ recvrY InterruptedErrorBlockingIOErrorrW s r rT z%BaseSelectorEventLoop._read_from_selft s
{''-- E''----#
"
s 7 7
A AAc | j }|d S | d d S # t $ r$ | j rt j dd Y d S Y d S w xY w)N z3Fail to write a null byte into the self-pipe socketTexc_info)rL sendOSError_debugr
r )r' csocks r _write_to_selfz$BaseSelectorEventLoop._write_to_self s = F , JJu , , ,{
, 0&*, , , , , , ,
,
,
, ,s $ 'AAd c n | | | j ||||||| d S r- )rS rK _accept_connection)r' protocol_factoryr/ r; r+ backlogr5 r6 s r _start_servingz$BaseSelectorEventLoop._start_serving sK
(?)4VW.0D F F F F Fr( c
t | D ]h} | \ } }
| j rt j d||
| | d d|
i} | || | |||| } | | # t t t f$ r Y d S t $ r}
|
j t j
t j t j t j fv r| d|
t% j | d | | | t. j | j ||||||| n Y d }
~
bd }
~
ww xY wd S )Nz#%r got a new connection from %r: %rFpeernamez&socket.accept() out of system resource)message exceptionrP )rangeacceptrd r
r rR _accept_connection2 create_taskr] r\ ConnectionAbortedErrorrc errnoEMFILEENFILEENOBUFSENOMEMcall_exception_handlerr TransportSocketrI rK
call_laterr ACCEPT_RETRY_DELAYrl )r' rj r/ r; r+ rk r5 r6 _connaddrr* rr excs r ri z(BaseSelectorEventLoop._accept_connection s w # ) # )A"
) ![[]]
d; 5L!F!'t5 5 5 '''2 $T* 11$dE:v)+?A A ((((9 $%57MN
ttt
9 u|!& !> > >
//#K%("("8">">1 1
''
666OOI$@$($7$4dJ$+-B$8 : : : :
: : : : :
# ) # )s A
BE7. E77B5E22E7c K d }d } | }| }
|r | ||||
d|||| } n| |||
|| } |
d {V d S # t $ r | d }
w xY w# t
t f$ r t $ r@} | j r.d| d} ||| d< | | | d< | | Y d } ~ d S Y d } ~ d S d } ~ ww xY w)NT)r1 r3 r* r+ r5 r6 )r1 r* r+ z3Error on transport creation for incoming connection)ro rp r0 transport)
create_futurer= r2
BaseExceptionrG
SystemExitKeyboardInterruptrd r{ )
r' rj r r* r; r+ r5 r6 r0 r r1 r contexts
r rs z)BaseSelectorEventLoop._accept_connection2 s
& 5''))H''))F
# 4 4(Jv $E&*?)= 5 ? ? ! 7 7(6! 8 # #
!!!
-. 5 5 5{
5 N!$
'*2GJ' (+4GK(++G444444444
5
5
5
5
5
5 5s* AB "A, ,"BB C,,/C''C,c f |}t |t sQ t | }n.# t t t
f$ r t d| d w xY w | j | }| st d|d| d S # t $ r Y d S w xY w)NzInvalid file object: zFile descriptor z is used by transport )
isinstanceintrK AttributeError TypeError
ValueErrorr&
is_closingrD r )r' r rK r s r _ensure_fd_no_transportz-BaseSelectorEventLoop._ensure_fd_no_transport s &#&& K
K V]]__--"Iz:
K
K
K !?!?!?@@dJ
K & (0I ''))
&"%r % % % %& & &
&
& DD s !; +A&*
B" "
B0/B0c | t j ||| d } | j | }|j |j c}\ }}| j ||t j z ||f || n8# t $ r+ | j |t j |d f Y nw xY w|S r- )
_check_closedr Handler" r rX modifyr
EVENT_READcancelr register r' r callbackargshandler maskreaderwriters r rS z!BaseSelectorEventLoop._add_reader s xtT::
.((,,C
&)Z "D"66 N ! !"dY-A&A#)6"2
4
4
4!
4 4 4 N # #B (<%+TN
4
4
4
4
4 4
B 2CCc t | rdS | j | }|j |j c}\ }}|t
j z }|s| j | n | j ||d |f || dS dS # t $ r Y dS w xY wNFT) rE r" r r rX r r
unregisterr r r r' r r r r r s r rI z$BaseSelectorEventLoop._remove_reader s >> 5 .((,,C &)Z "D"66 Y)) )D
@))"----%%b$v???!
t u 55 s B) )
B76B7c | t j ||| d } | j | }|j |j c}\ }}| j ||t j z ||f || n8# t $ r+ | j |t j d |f Y nw xY w|S r- ) r r r r" r rX r r EVENT_WRITEr r r r s r _add_writerz!BaseSelectorEventLoop._add_writer. s xtT::
.((,,C
&)Z "D"66 N ! !"dY-B&B#)6"2
4
4
4!
4 4 4 N # #B (=%)6N
4
4
4
4
4 4
r c v | rdS | j | }|j |j c}\ }}|t
j z }|s| j | n | j |||d f || dS dS # t $ r Y dS w xY wr ) rE r" r r rX r r r r r r r s r _remove_writerz$BaseSelectorEventLoop._remove_writer> s ' >> 5 .((,,C &)Z "D"66 Y** *D
@))"----%%b$???!
t u 55 s B* *
B87B8c P | | | j ||g|R d S r- )r rS r' r r r s r
add_readerz BaseSelectorEventLoop.add_readerU s< $ $$R(((X-------r( c X | | | | S r- )r rI r' r s r
remove_readerz#BaseSelectorEventLoop.remove_readerZ - ' $$R(((""2&&&r( c P | | | j ||g|R d S r- )r r r s r
add_writerz BaseSelectorEventLoop.add_writer_ s< % $$R(((X-------r( c X | | | | S r- )r r r s r
remove_writerz#BaseSelectorEventLoop.remove_writerd r r( c
K t j | | j r'| dk rt d | | S # t t f$ r Y nw xY w| }| }|
| | || j ||| }|
t j | j || | d {V S Nr the socket must be non-blockingr )r _check_ssl_socketrd
gettimeoutr r[ r] r\ r rK r rS
_sock_recvadd_done_callback functoolspartial_sock_read_done)r' r/ nfutr r s r sock_recvz BaseSelectorEventLoop.sock_recvi s %d+++ ; @4??,,11 >?? ? 99Q<< !12 D ""
[[]] $$R(((!!"dosD!DD d 2Bv F F F H H Hyyyyyy A A0/A0c ` || s| | d S d S r- ) cancelledr r' r r r s r r z%BaseSelectorEventLoop._sock_read_done 8 >!1!1!3!3> r " " " " " >r( c * | rd S | | }| | d S # t t f$ r Y d S t
t f$ r t $ r }| | Y d }~d S d }~ww xY wr- ) doner[
set_resultr] r\ r r r
set_exception)r' r r/ r rX r s r r z BaseSelectorEventLoop._sock_recv s 88:: F !99Q<<D
NN4 !12 FF -. # # # c " " " " " " " " " # A BB2B
Bc
K t j | | j r'| dk rt d | | S # t t f$ r Y nw xY w| }| }|
| | || j ||| }|
t j | j || | d {V S r )r r rd r r recv_intor] r\ r rK r rS _sock_recv_intor r r r )r' r/ bufr r r s r sock_recv_intoz$BaseSelectorEventLoop.sock_recv_into s
%d+++ ; @4??,,11 >?? ? >>#&& & !12 D ""
[[]] $$R(((!!"d&:CsKK d 2Bv F F F H H Hyyyyyyr c * | rd S | | }| | d S # t t f$ r Y d S t
t f$ r t $ r }| | Y d }~d S d }~ww xY wr- ) r r r r] r\ r r r r )r' r r/ r nbytesr s r r z%BaseSelectorEventLoop._sock_recv_into s 88:: F #^^C((F
NN6 " " " " " !12 FF -. # # # c " " " " " " " " " #r c
K t j | | j r'| dk rt d | | S # t t f$ r Y nw xY w| }| }|
| | || j ||| }|
t j | j || | d {V S r )r r rd r r recvfromr] r\ r rK r rS _sock_recvfromr r r r )r' r/ bufsizer r r s r
sock_recvfromz#BaseSelectorEventLoop.sock_recvfrom s %d+++ ; @4??,,11 >?? ? ==)) ) !12 D ""
[[]] $$R(((!!"d&93gNN d 2Bv F F F H H Hyyyyyyr c * | rd S | | }| | d S # t t f$ r Y d S t
t f$ r t $ r }| | Y d }~d S d }~ww xY wr- ) r r r r] r\ r r r r )r' r r/ r resultr s r r z$BaseSelectorEventLoop._sock_recvfrom s 88:: F #]]7++F
NN6 " " " " " !12 FF -. # # # c " " " " " " " " " #r r c 0 K t j | | j r'| dk rt d |st | } | || S # t t f$ r Y nw xY w| }|
}| | | || j
|||| }| t j | j || | d {V S r )r r rd r r len
recvfrom_intor] r\ r rK r rS _sock_recvfrom_intor r r r )r' r/ r r r r r s r sock_recvfrom_intoz(BaseSelectorEventLoop.sock_recvfrom_into s<
%d+++ ; @4??,,11 >?? ? XXF %%c622 2 !12 D ""
[[]] $$R(((!!"d&>T3"(* * d 2Bv F F F H H Hyyyyyys A. .BBc , | rd S | || }| | d S # t t f$ r Y d S t
t f$ r t $ r }| | Y d }~d S d }~ww xY wr- ) r r r r] r\ r r r r )r' r r/ r r r r s r r z)BaseSelectorEventLoop._sock_recvfrom_into s 88:: F #''W55F
NN6 " " " " " !12 FF -. # # # c " " " " " " " " " #s A BB3BBc X K t j | | j r'| dk rt d | | }n# t t f$ r d}Y nw xY w|t | k rd S | }|
}| | | || j
||t | |g }| t! j | j || | d {V S r )r r rd r r rb r] r\ r r rK r r
_sock_sendall
memoryviewr r r _sock_write_done)r' r/ rX r r r r s r sock_sendallz"BaseSelectorEventLoop.sock_sendall sH %d+++ ; @4??,,11 >?? ? $AA !12 AAA
D >> F ""
[[]] $$R(((!!"d&8#t",T"2"2QC9 9 d 3R G G G I I Iyyyyyys A A32A3c | rd S |d } | ||d }nQ# t t f$ r Y d S t t
f$ r t $ r }| | Y d }~d S d }~ww xY w||z
}|t | k r| d d S ||d< d S Nr )
r rb r] r\ r r r r r r )r' r r/ viewposstartr r s r r z#BaseSelectorEventLoop._sock_sendall* s 88:: FA $uvv,''AA !12 FF -. c " " " FFFFF
CII NN4 CFFFs > B B ,BB c K t j | | j r'| dk rt d | || S # t t f$ r Y nw xY w| }| }|
| | || j |||| }|
t j | j || | d {V S r )r r rd r r sendtor] r\ r rK r r _sock_sendtor r r r )r' r/ rX r@ r r r s r sock_sendtoz!BaseSelectorEventLoop.sock_sendto@ s) %d+++ ; @4??,,11 >?? ? ;;tW-- - !12 D ""
[[]] $$R(((!!"d&7dD")+ + d 3R G G G I I Iyyyyyys A A10A1c . | rd S | |d| }| | d S # t t f$ r Y d S t
t f$ r t $ r }| | Y d }~d S d }~ww xY wr ) r r r r] r\ r r r r )r' r r/ rX r@ r r s r r z"BaseSelectorEventLoop._sock_sendto[ s 88:: F D!W--A
NN1 !12 FF -. # # # c " " " " " " " " " #s A BB4BBc K t j | | j r'| dk rt d |j t j k s!t j rR|j t j k r=|
||j |j |j | d {V }|d \ }}}}}|
}| ||| | d {V d }S # d }w xY w)Nr r )familytypeprotoloop)r r rd r r r rP AF_INET _HAS_IPv6AF_INET6_ensure_resolvedr r r
_sock_connect)r' r/ r@ resolvedr r s r sock_connectz"BaseSelectorEventLoop.sock_connectj s+ %d+++ ; @4??,,11 >?? ? ;&. ( (% )*.+ *H*H ! 2 2 $)4: 3 H #+1+ Aq!Q "" 3g... 999999 CC$CJJJJs %C0 0C4c | } | | | d n# t t f$ re | | | || j ||| }| t j
| j || Y n<t t f$ r t $ r }| | Y d }~nd }~ww xY wd }d S # d }w xY w)Nr )rK connectr r] r\ r r _sock_connect_cbr r r r r r r r )r' r r/ r@ r r r s r r z#BaseSelectorEventLoop._sock_connect sG
[[]] LL ! ! !
NN4 !12 M M M
( ( , , ,%%D)3g? ?F ! !!$"7FKKK
M
M
M
M
M -. # # # c " " " " " " " " #
CCC$CJJJJs; A C6 A3C/4C6 6C/C*%C6 *C//C6 6C:c ` || s| | d S d S r- )r r r s r r z&BaseSelectorEventLoop._sock_write_done r r( c | rd S | t j t j }|dk rt |d| | d nO# t t f$ r Y n<t t f$ r t $ r }| | Y d }~nd }~ww xY wd }d S # d }w xY w)Nr zConnect call failed )
r
getsockoptrP
SOL_SOCKETSO_ERRORrc r r] r\ r r r r )r' r r/ r@ errr s r r z&BaseSelectorEventLoop._sock_connect_cb s 88:: F //&"3V_EECaxx c#C'#C#CDDD
NN4 !12 D -. # # # c " " " " " " " " #
CCC$CJJJJs< AA2 C 2B>C B> B94C 9B>>C C c K t j | | j r'| dk rt d | }| || | d {V S )Nr r )r r rd r r r _sock_accept)r' r/ r s r sock_acceptz!BaseSelectorEventLoop.sock_accept s %d+++ ; @4??,,11 >?? ? "" #t$$$yyyyyyr( c | } | \ }}| d | ||f d S # t t
f$ re | | | || j || }| t j | j || Y d S t t f$ r t $ r }| | Y d }~d S d }~ww xY w)NFr )rK rr rR r r] r\ r rS r r r r r r r r r )r' r r/ r r r@ r r s r r z"BaseSelectorEventLoop._sock_accept sI
[[]]
, KKMMMD' U # # #
NND'? + + + + + !12 L L L ( ( , , ,%%b$*;S$GGF ! !!$"66JJJ
L
L
L
L
L
L -. # # # c " " " " " " " " " #s ,A A2D
D
*DD
c K | j |j = | }| | d {V | |j |||d d {V | |r| || j |j < S # | |r| || j |j < w xY w)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 s1 V_ - **,, ''))))))))) 7 ++FL$5: , < < < < < < < <
<
& & ( ( (
(%%'''06D V_ - -
& & ( ( (
(%%'''06D V_ - 6 6 6 6s $B2 2;C-c F |D ]\ }}|j |j c}\ }}|t j z r4|2|j r| | n| | |t j z r4|2|j r| | | | d S r- ) fileobjrX r r
_cancelledrI
_add_callbackr r )r'
event_listr r r r r s r _process_eventsz%BaseSelectorEventLoop._process_events s # / /IC(+ SX %G%ffi**
/v/A$ /''0000&&v...i++
/0B$ /''0000&&v... / /r( c | | | | d S r- )rI rK rG )r' r/ s r
_stop_servingz#BaseSelectorEventLoop._stop_serving s/ DKKMM***
r( r- NNN)r )3r!
__module__ __qualname__r r2 r SSL_HANDSHAKE_TIMEOUTSSL_SHUTDOWN_TIMEOUTr= rA rG rF r# rY rT rf rl ri rs r rS rI 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 + s
9 9 9 9 9 97%)$7 7 7 7 7 9=+ $t"+"A!*!? + + + + +$ CGB B B B
" " " " " E E E
, , ,& #'tS-6-L,5,JF F F F D#"+"A!*!? ,) ,) ,) ,)` D"+"A!*!? -5 -5 -5 -5^& & &$ * .. . .
' ' '
. . .
' ' '
,# # # #! ! ! *# # #" .# # #" 2# # #" > , 6
2 .# # # # *
, , ," 7 7 7 / / / r( r c e Zd ZdZeZdZd fd Zd Zd Z d Z
d Z d Z d Z
d
Zd Zd Zej fd
ZddZd Zd Zd Zd Z xZS )_SelectorTransporti Nc t || t j | | j d< | | j d< n# t $ r
d | j d< Y nw xY wd| j vr= | | j d< n # t j $ r
d | j d< Y nw xY w|| _
| | _ d| _
| | || _ | | _ d| _ d| _ d| _ | j | j | |j | j < d S )NrP socknamern Fr )r r r r| _extra getsocknamerc getpeernamerP errorr rK r _protocol_connected set_protocol_server_buffer_factory_buffer
_conn_lost_closing_paused_attachr& )r' r r/ r0 r* r+ r s r r z_SelectorTransport.__init__ so
%%% & 6t < < H +&*&6&6&8&8DK
# # + + +&*DK
# # # + T[ ( (
/*.*:*:*<*< J''<
/
/
/*. J'''
/
#( (### ++--
< # L " " "*. '''s$ A A54A5 B B;:B;c | j j g}| j | d n | j r| d | d| j | j | j st | j j | j t j }|r| d n| d t | j j | j t j }|rd}nd}|
}| d| d | d
d d | S )
Nclosedclosingzfd=z read=pollingz read=idlepollingidlezwrite=<z
, bufsize=>z<{}> )r r! r appendr5 r _looprE r r" r r r get_write_buffer_sizeformatjoin)r' infor; stater s r __repr__z_SelectorTransport.__repr__ s] '( : KK ! ! ! !
] # KK " " " )$-))*** : !$**>*>*@*@ !*4:+?+/=):NP PG
) N++++ K(((*4:+?+/=+4+@B BG
! 0022G KK=%==7=== > > >}}SXXd^^,,,r( c 0 | d d S r- ) _force_closerN s r abortz_SelectorTransport.abort8 s $ r( c " || _ d| _ d S NT) _protocolr/ )r' r0 s r r0 z _SelectorTransport.set_protocol; s !#' r( c | j S r- )rL rN s r get_protocolz _SelectorTransport.get_protocol? s
~ r( c | j S r- )r5 rN s r r z _SelectorTransport.is_closingB s
} r( c < | o| j S r- )r r6 rN s r r z _SelectorTransport.is_readingE s ??$$$9T\)99r( c | sd S d| _ | j | j | j rt
j d| d S d S )NTz%r pauses reading)r r6 r@ rI r get_debugr
r rN s r r
z _SelectorTransport.pause_readingH sq F
!!$-000 : ! ! 4 L,d 3 3 3 3 3 4 4r( c | j s| j sd S d| _ | | j | j | j rt j d| d S d S )NFz%r resumes reading) r5 r6 rS r _read_readyr@ rR r
r rN s r r z!_SelectorTransport.resume_readingP su = F (8999 : ! ! 5 L-t 4 4 4 4 4 5 5r( c | j rd S d| _ | j | j | j sQ| xj dz
c_ | j | j | j | j d d S d S NTr ) r5 r@ rI r r3 r4 r call_soon_call_connection_lostrN s r rG z_SelectorTransport.closeX s = F
!!$-000| C OOq OO J % %dm 4 4 4 J !;T B B B B B C Cr( c v | j 1 |d| t | | j d S d S )Nzunclosed transport )source)r ResourceWarningrG )r' _warns r __del__z_SelectorTransport.__del__b sL : ! E000/$ O O O O J " !r( Fatal error on transportc t |t r2| j rt j d| |d n$| j ||| | j d | | d S )Nz%r: %sTr` )ro rp r r0 ) r rc r@ rR r
r r{ rL rH )r' r ro s r _fatal_errorz _SelectorTransport._fatal_errorg s c7 # # z##%%
E XtWtDDDD J - -" ! N / /
# r( c P | j rd S | j r8| j | j | j | j s&d| _ | j | j | xj dz
c_ | j | j | d S rV )
r4 r3 clearr@ r r r5 rI rW rX )r' r s r rH z _SelectorTransport._force_closeu s ? F < 5 L J % %dm 4 4 4} 5 DM J % %dm 4 4 4 1
T 7=====r( c | j r| j | | j d | _ d | _ d | _ | j }| | d | _ d S d S # | j d | _ d | _ d | _ | j }|| d | _ w xY wr- )r/ rL connection_lostr rG r@ r1 _detach)r' r r+ s r rX z(_SelectorTransport._call_connection_lost s $'
4..s333 J DJ !DN DJ\F! # "!
J DJ !DN DJ\F! # ####s !A9 9AC
c * t | j S r- )r r3 rN s r rA z(_SelectorTransport.get_write_buffer_size s 4< r( c Z | sd S | j j ||g|R d S r- )r r@ rS r s r rS z _SelectorTransport._add_reader s> F
r83d333333r( )NN)r^ )r! r! r" max_size bytearrayr2 r r rF rI r0 rN r r r
r rG warningswarnr] r` rH rX rA rS r% r& s @r r( r( sE H O
E/ / / / / /8- - -8 ( ( ( : : :4 4 45 5 5C C C %M
>
>
> $ $ $ ! ! !4 4 4 4 4 4 4r( r( c e Zd ZdZej j Z d fd Z fdZ d Z
d Z d Z d Z
d Zd
Zd Zd Z fd
Zd Zd Z xZS )r. TNc d | _ t ||||| d| _ d | _ t j | j | j | j
j | | j | j | j
| j |(| j t j |d d S d S r )_read_ready_cbr r _eof
_empty_waiterr _set_nodelayr r@ rW rL connection_maderS r rT r _set_result_unless_cancelled)r' r r/ r0 r1 r* r+ r s r r z!_SelectorSocketTransport.__init__ s #
tXuf=== !
,,,
T^ ;TBBB
T - !]D,< > > > J !E!'
/
/
/
/
/ r( c t |t j r
| j | _ n | j | _ t
| d S r- )r r BufferedProtocol_read_ready__get_bufferrn _read_ready__data_receivedr r0 )r' r0 r s r r0 z%_SelectorSocketTransport.set_protocol sP h : ; ; B"&">D "&"AD
X&&&&&r( c . | d S r- )rn rN s r rT z$_SelectorSocketTransport._read_ready s r( c | j rd S | j d }t | st d n?# t
t f$ r t $ r!}| |d Y d }~d S d }~ww xY w | j
| }nR# t t f$ r Y d S t
t f$ r t $ r!}| |d Y d }~d S d }~ww xY w|s|
d S | j | d S # t
t f$ r t $ r!}| |d Y d }~d S 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.)r4 rL
get_bufferr rD r r r r` r r r] r\ _read_ready__on_eofbuffer_updated)r' r r r s r rv z0_SelectorSocketTransport._read_ready__get_buffer s ? F .++B//Cs88
L"#JKKK
L -. F
H
H
H FFFFF
Z))#..FF !12 FF -. c#I J J J FFFFF $ $ & & & F L N ) )& 1 1 1 1 1 -. L L L J
L
L
L
L
L
L
L
L
L LsM 8A B A;;B B C.3C.
C))C.
D& &E"E E"c | j rd S | j | j }nR# t t
f$ r Y d S t t f$ r t $ r!}| |d Y d }~d S d }~ww xY w|s|
d S | j | d S # t t f$ r t $ r!}| |d Y d }~d S d }~ww xY w)Nr{ z2Fatal error: protocol.data_received() call failed.)
r4 r r[ rh r] r\ r r r r` r} rL
data_received)r' rX r s r rw z3_SelectorSocketTransport._read_ready__data_received sp ? F :??4=11DD !12 FF -. c#I J J J FFFFF $ $ & & & F K N ( ( . . . . . -. K K K I
K
K
K
K
K
K
K
K
K Ks2 + A:A:A55A:B2 2C.
C))C.c | j rt j d| | j }n?# t t f$ r t $ r!}| |d Y d }~d S d }~ww xY w|r!| j
| j d S | d S )Nz%r received EOFz1Fatal error: protocol.eof_received() call failed.)
r@ rR r
r rL eof_receivedr r r r` rI r rG )r' keep_openr s r r} z,_SelectorSocketTransport._read_ready__on_eof s : ! ! 2 L*D 1 1 1 3355II -. H
J
J
J FFFFF
J % %dm 4 4 4 4 4 JJLLLLLs A
B%BBc t |t t t f s$t dt | j | j rt d | j t d |sd S | j
r;| j
t j k rt j d | xj
dz
c_
d S | j s | j | }||d }|sd S nQ# t$ t& f$ r Y n>t( t* f$ r t, $ r!}| |d Y d }~d S d }~ww xY w| j | j | j | j | | d S )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 bytesri r r r r! ro rD rp r4 r !LOG_THRESHOLD_FOR_CONNLOST_WRITESr
warningr3 r rb r] r\ r r r r` r@ r r _write_readyextend_maybe_pause_protocol)r' rX r r s r writez _SelectorSocketTransport.write s $ : >?? < ;#'::#6 ; ; < <
< 9 H FGG G ) IJJ J F ? )"MMM @AAA OOq OO F| E
JOOD)) ABBx F $%56
12
!!#'NOOO
J " "4=$2C D D D
D!!! ""$$$$$s C* *D8=D8D33D8c " | j rd S | j | j }|r
| j d |= | | j s| j | j | j | j d | j
r| d d S | j r(| j
t j d S d S d S # t t" f$ r Y d S t$ t& f$ r t( $ r}| j | j | j | |d | j | j | Y d }~d S Y d }~d S d }~ww xY w)Nr )r4 r rb r3 _maybe_resume_protocolr@ r r rp r r5 rX ro shutdownrP SHUT_WRr] r\ r r r rb r` r )r' r r s r r z%_SelectorSocketTransport._write_ready8 s ? F 8
--A
%L!$ ' ' ) ) )<
8
))$-888%1&11$777= 8..t44444Y 8J''77777
8
8 8 8) !12 DD -. 6 6 6 J % %dm 4 4 4 L c#J K K K!-"00555555555 .----- 6s C F4FA/F Fc | j s| j rd S d| _ | j s&| j t
j d S d S rK )r5 ro r3 r r rP r rN s r write_eofz"_SelectorSocketTransport.write_eofV sS = DI F | 0 J / / / / / 0 0r( c dS rK rV rN s r
can_write_eofz&_SelectorSocketTransport.can_write_eof] s tr( c t | | j )| j t d d S d S )Nz Connection is closed by peer)r rX rp r ConnectionError)r' r r s r rX z._SelectorSocketTransport._call_connection_lost` sb
%%c*** ) , , >??
A
A
A
A
A * )r( c | j t d | j | _ | j s| j d | j S )NzEmpty waiter is already set)rp rD r@ r r3 r rN s r r z+_SelectorSocketTransport._make_empty_waiterf sZ ) <== = !Z 5 5 7 7| 0 ) )$ / / /!!r( c d | _ d S r- )rp rN s r r z,_SelectorSocketTransport._reset_empty_waitern s !r( r )r! r! r" _start_tls_compatibler
_SendfileMode
TRY_NATIVE_sendfile_compatibler r0 rT rv rw r} r r r r rX r r r% r& s @r r. r. s* $2=48$(/ / / / / /,' ' ' ' ' #L #L #LJK K K2 *%% %% %%N 8 8 8<0 0 0 A A A A A " " "" " " " " " "r( r. c L e Zd Zej Z d fd Zd Zd ZddZ d Z
xZ S ) r? Nc ` t |||| || _ d| _ | j | j j | | j | j | j | j
|(| j t j |d d S d S r )
r r _address _buffer_sizer@ rW rL rr rS r rT r rs )r' r r/ r0 r@ r1 r* r s r r z#_SelectorDatagramTransport.__init__v s
tXu555
T^ ;TBBB
T - !]D,< > > > J !E!'
/
/
/
/
/ r( c | j S r- )r rN s r rA z0_SelectorDatagramTransport.get_write_buffer_size s r( c | j rd S | j | j \ }}| j || d S # t t f$ r Y d S t $ r%}| j | Y d }~d S d }~wt t f$ r t $ r!}|
|d Y d }~d S d }~ww xY w)Nz&Fatal read error on datagram transport)r4 r r rh rL datagram_receivedr] r\ rc error_receivedr r r r` r' rX r r s r rT z&_SelectorDatagramTransport._read_ready s ? F 9 ,,T];;JD$
N , ,T4 8 8 8 8 8 !12 DD / / / N ) )# . . . . . . . . . -. M M M c#K L L L L L L L L L Ms) "A
C C'B C%CCc t |t t t f s$t dt | j |sd S | j r)|d | j fvrt d| j | j }| j rB| j r;| j t j k rt j
d | xj dz
c_ d S | j s | j d r| j | n| j || d S # t& t( f$ r( | j | j | j Y nkt2 $ r%}| j | Y d }~d S d }~wt8 t: f$ r t< $ r!}| |d Y d }~d S d }~ww xY w| j t | |f | xj! tE | z
c_! | # d S )Nr z!Invalid address: must be None or r r rn 'Fatal write error on datagram transport)$r r ri r r r r! r r r4 r r r
r r3 r+ r rb r r] r\ r@ r r
_sendto_readyrc rL r r r r r` r? r r r r s r r z!_SelectorDatagramTransport.sendto si $ : >?? < ;#'::#6 ; ; < <
< F = !D$-000 G
GGI I I=D ? t} )"MMM @AAA OOq OO F|
;z* 2JOOD))))J%%dD111#%56
J
J
J
&&t}d6HIIIII
--c222 12
!!BD D D
U4[[$ /000 SYY& ""$$$$$s+ AD 6F1 F1E22 F1F,,F1c D | j r=| j \ }}| xj t | z c_ | j d r| j | n| j || n# t t f$ r< | j
||f | xj t | z
c_ Y nst $ r%}| j
| Y d }~d S d }~wt t f$ r t $ r!}| |d Y d }~d S d }~ww xY w| j =| | j s=| j | j | j r| d d S d S d S )Nrn r )r3 popleftr r r+ r rb r r] r\
appendleftrc rL r r r r r` r r@ r r r5 rX r s r r z(_SelectorDatagramTransport._sendto_ready s l --//JD$ T *
;z* 2JOOD))))J%%dD111#%56
''t 555!!SYY.!!
--c222 12
!!BD D D
# l ,
##%%%| 1 J % %dm 4 4 4}
1**400000 1 1
1
1s, AB A
D; D; C<< D;D66D;r r- ) r! r! r" collectionsdequer2 r rA rT r r r% r& s @r r? r? r s !'O59$( / / / / / / ! ! !9 9 9 *% *% *% *%X1 1 1 1 1 1 1r( r? ) __all__r rv r r rP rj r$ ssl ImportError r r r r r r
r r logr
r
BaseEventLoopr _FlowControlMixin Transportr( r. r? rV r( r <module>r s% #
JJJJ
CCC ( ( (F F F F F K 5 F F F Ra4 a4 a4 a4 a45#-a4 a4 a4HW" W" W" W" W" 1 W" W" W"tl1 l1 l1 l1 l1!3 l1 l1 l1 l1 l1s & 00