fX n d Z dZddlZddlZddlZddlZddlZddlZddlZ ddl Z n
# e
$ r dZ Y nw xY wddl m Z ddl m
Z
ddl mZ ddl mZ dd l 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 )zEvent loop using a selector and related classes.
A selector is a "notify-when-ready" multiplexer. For a subclass which
also includes support for signal handling, see the unix_events sub-module.
)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 >/opt/alt/python311/lib64/python3.11/asyncio/selector_events.py_test_selector_eventr sU ( r"" CJ&''' uus .
<<c e Zd ZdZd4 fd Zd4ddddZ d4ddddej ej ddZ d5d Z
fd
Z d Z d Z
d
Zd Zd Zdddej ej fdZdddej ej fdZddej ej fdZd Zd Zd Zd Zd Zd Zd Zd Zd Z d Z d4d Z d Z d Z d! Z!d" Z"d# Z#d6d%Z$d& Z%d' Z&d( Z'd) Z(d* Z)d+ Z*d, Z+d4d-Z,d. Z-d/ Z.d0 Z/d1 Z0d2 Z1d3 Z2 xZ3S )7r zJSelector event loop.
See events.EventLoop for API specification.
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 w)NFT) 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 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 t | rdS | j | }|j |j c}\ }}|t
j z }|s| j | n | j |||df || dS dS # t $ r Y dS w xY w)Remove a writer callback.FNT) 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 r c N | | | j ||g|R dS )zAdd a reader callback.N)r rS r' r r r s r
add_readerz BaseSelectorEventLoop.add_readerU 9 $$R(((X-------r( c V | | | | S )zRemove a reader callback.)r rI r' r s r
remove_readerz#BaseSelectorEventLoop.remove_readerZ * $$R(((""2&&&r( c N | | | j ||g|R dS )zAdd a writer callback..N)r r r s r
add_writerz BaseSelectorEventLoop.add_writer_ r r( c V | | | | 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 )zReceive data from the socket.
The return value is a bytes object representing the data received.
The maximum amount of data to be received at once is specified by
nbytes.
r the socket must be non-blockingr N)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 A/.A/c ` || 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 )zReceive data from the socket.
The received data is written into *buf* (a writable buffer).
The return value is the number of bytes written.
r r r N)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 )a Receive a datagram from a datagram socket.
The return value is a tuple of (bytes, address) representing the
datagram received and the address it came from.
The maximum amount of data to be received at once is specified by
nbytes.
r r r N)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 . 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 )zReceive data from the socket.
The received data is written into *buf* (a writable buffer).
The return value is a tuple of (number of bytes written, address).
r r r N)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 s7 %d+++ ; @4??,,11 >?? ? XXF %%c622 2 !12 D ""
[[]] $$R(((!!"d&>T3"(* * d 2Bv F F F H H Hyyyyyys A- -B Bc , | 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 V K t j | | j r'| dk rt d | | }n# t t f$ r d}Y nw xY w|t | k rdS | }|
}| | | || j
||t | |g }| t! j | j || | d{V S ) Send data to the socket.
The socket must be connected to a remote socket. This method continues
to send data from data until either all data has been sent or an
error occurs. None is returned on success. On error, an exception is
raised, and there is no way to determine how much data, if any, was
successfully processed by the receiving end of the connection.
r r Nr )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 sC %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 A21A2c | 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 r N)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 A0/A0c . | 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)zTConnect to a remote socket at address.
This method is a coroutine.
r r )familytypeprotoloopN)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 $C/ /C3c | } | | | 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 )aW Accept a connection.
The socket must be bound to an address and listening for connections.
The return value is a pair (conn, address) where conn is a new socket
object usable to send and receive data on the connection, and address
is the address bound to the socket on the other end of the connection.
r r N)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 )4r!
__module__ __qualname____doc__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 appendr8 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) _protocolr2 )r' r0 s r r3 z _SelectorTransport.set_protocol; s !#' r( c | j S r- )rO rN s r get_protocolz _SelectorTransport.get_protocol? s
~ r( c | j S r- )r8 rN s r r z _SelectorTransport.is_closingB s
} r( c < | o| j S r- )r r9 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 r9 rC 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) r8 r9 rS r
_read_readyrC rU 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 ) r8 rC rI r
r6 r7 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 rC rU r
r r{ rO rK )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 rY )
r7 r6 clearrC r r
r8 rI rZ r[ )r' r s r rK 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- )r2 rO connection_lostr rG rC r4 _detach)r' r r+ s r r[ 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 r6 rN s r rD z(_SelectorTransport.get_write_buffer_size s 4< r( c Z | sd S | j j ||g|R d S r- )r rC rS r s r rS z _SelectorTransport._add_reader s> F
r83d333333r( )NN)ra )r! r# r$ max_size bytearrayr5 r r rI rL r3 rQ r r r r rG warningswarnr` rc rK r[ rD 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 rC rZ rO connection_maderS r
rW 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_bufferrq _read_ready__data_receivedr r3 )r' r0 r s r r3 z%_SelectorSocketTransport.set_protocol sP h : ; ; B"&">D "&"AD
X&&&&&r( c . | d S r- )rq rN s r rW 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.)r7 rO
get_bufferr rD r r r rc r r r] r\ _read_ready__on_eofbuffer_updated)r' r r r s r ry 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.)
r7 r r[ rk r] r\ r r r rc r rO
data_received)r' rX r s r rz 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.)
rC rU r
r rO eof_receivedr r r rc 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 bytesrl r r r r! rr rD rs r7 r !LOG_THRESHOLD_FOR_CONNLOST_WRITESr
warningr6 r rb r] r\ r r r rc rC 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 )r7 r rb r6 _maybe_resume_protocolrC r r
rs r r8 r[ rr shutdownrP SHUT_WRr] r\ r r r re rc 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 rN )r8 rr r6 r r rP r rN s r write_eofz"_SelectorSocketTransport.write_eofV sS = DI F | 0 J / / / / / 0 0r( c dS rN 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 r[ rs r ConnectionError)r' r r s r r[ 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)rs rD rC r r6 r rN s r r z+_SelectorSocketTransport._make_empty_waiterf sZ ) <== = !Z 5 5 7 7| 0 ) )$ / / /!!r( c d | _ d S r- )rs rN s r r z,_SelectorSocketTransport._reset_empty_waitern s !r( r" )r! r# r$ _start_tls_compatibler
_SendfileMode
TRY_NATIVE_sendfile_compatibler r3 rW ry rz r r r r r r[ 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_sizerC rZ rO ru rS r
rW r rv )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 rD 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)r7 r r rk rO datagram_receivedr] r\ rc error_receivedr r r rc r' rX r r s r rW 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 rl r r r r! r r r7 r r r
r r6 r. r rb r r] r\ rC r r
_sendto_readyrc rO r r r r rc rB 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 )r6 popleftr r r. r rb r r] r\
appendleftrc rO r r r r rc r rC r r
r8 r[ 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$ collectionsdequer5 r rD rW r r r( r) s @r r? r? r s !'O59$( / / / / / / ! ! !9 9 9 *% *% *% *%X1 1 1 1 1 1 1r( r? ) r% __all__r rv r r rP rm 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 ' 11