3, d Z dZddlZddlZddlZddlZddlZddlZddlZddl m
Z
ddl m Z ddl m Z ddl m
Z
dd l mZ dd
l mZ dd l mZ dd l mZ dd
lmZ d Z G d dej ej Z G d deej Z G d deej Z G d de Z G d deej Z G d deeej Z G d d eeej Z! G d d e
j" Z#dS ) zEvent loop using a proactor and related classes.
A proactor is a "notify-on-completion" multiplexer. Currently a
proactor is only implemented on Windows with IOCP.
)BaseProactorEventLoop N ) base_events) constants)futures)
exceptions) protocols)sslproto)
transports)trsock)loggerc t j | | j d< | | j d< nE# t j $ r3 | j rt j d|d Y nw xY wd| j vr? |
| j d< d S # t j $ r d | j d< Y d S w xY wd S )Nsocketsocknamezgetsockname() failed on %rTexc_infopeername) r TransportSocket_extra getsocknamer error_loop get_debugr
warning getpeername) transportsocks D/opt/alt/python-internal/lib64/python3.11/asyncio/proactor_events.py_set_socket_extrar s !'!7!=!=IX C'+'7'7'9'9 $$ < C C C ? $ $ & & C N,dT
C
C
C
CC
))) 0+/+;+;+=+=I Z ( ( (| 0 0 0+/I Z ( ( ( ( 0 *)s! ; ?A=<A=
B( (CCc z e Zd ZdZ d fd Zd Zd Zd Zd Zd Z d Z
e j fd
Z
dd Zd
Zd Zd Z xZS )_ProactorBasePipeTransportz*Base class for pipe and socket transports.Nc
t || | | || _ | | || _ d | _ d | _ d | _ d| _ d| _
d| _ d| _ d| _
| j | j | j | j j | |(| j t& j |d d S d S )Nr F)super__init__
_set_extra_sock set_protocol_server_buffer _read_fut
_write_fut_pending_write
_conn_lost_closing_called_connection_lost _eof_written_attachr call_soon _protocolconnection_mader _set_result_unless_cancelledselfloopr protocolwaiterextraserver __class__s r r$ z#_ProactorBasePipeTransport.__init__2 s
%%%
(###
',$ ! < # L " " "
T^ ;TBBB J !E!'
/
/
/
/
/ c t | j j g}| j | d n | j r| d | j /| d| j | j | d| j | j | d| j | j r*| dt | j | j
r| d d d | S )
Nclosedclosingzfd=zread=zwrite=zwrite_bufsize=z EOF writtenz<{}> )
r= __name__r& appendr. filenor* r+ r) lenr0 formatjoin)r7 infos r __repr__z#_ProactorBasePipeTransport.__repr__I s+ '( : KK ! ! ! !
] # KK " " " : ! KK3dj / / 1 133 4 4 4 > % KK222 3 3 3 ? & KK4 44 5 5 5 < > KK<T\):):<< = = = ' KK
& & &}}SXXd^^,,,r> c || j d< d S )Npipe)r r7 r s r r% z%_ProactorBasePipeTransport._set_extra[ s " Fr> c || _ d S Nr3 )r7 r9 s r r' z'_ProactorBasePipeTransport.set_protocol^ s
!r> c | j S rO rP r7 s r get_protocolz'_ProactorBasePipeTransport.get_protocola s
~ r> c | j S rO )r. rR s r
is_closingz%_ProactorBasePipeTransport.is_closingd s
} r> c | j rd S d| _ | xj dz
c_ | j s'| j | j | j d | j "| j d | _ d S d S )NTr ) r. r- r) r+ r r2 _call_connection_lostr* cancelrR s r closez _ProactorBasePipeTransport.closeg s = F
1 | C 7 J !;T B B B > % N ! ! # # # !DNNN & %r> c v | j 1 |d| t | | j d S d S )Nzunclosed transport )source)r& ResourceWarningrY )r7 _warns r __del__z"_ProactorBasePipeTransport.__del__r sL : ! E000/$ O O O O J " !r> Fatal error on pipe transportc < t |t r2| j rt j d| |d n$| j ||| | j d | | d S # | | w xY w)Nz%r: %sTr )message exceptionr r9 )
isinstanceOSErrorr r r
debugcall_exception_handlerr3 _force_close)r7 excra s r _fatal_errorz'_ProactorBasePipeTransport._fatal_errorw s ##w''
:'')) IL44HHHH
11 &!$!% $ 3 3
c " " " " "D c " " " "s A+B Bc | j P| j s7|| j d n| j | | j r | j rd S d| _ | xj dz
c_ | j r | j d | _ | j r | j d | _ d| _
d | _ | j
| j | d S )NTr r )
_empty_waiterdone
set_result
set_exceptionr. r/ r- r+ rX r* r, r) r r2 rW )r7 rh s r rg z'_ProactorBasePipeTransport._force_close s )$2D2I2I2K2K ){"--d3333"00555 = T 9 F
1 ? # O " " $ $ $ "DO > " N ! ! # # # !DN
T 7=====r> c | j rd S | j | t | j d rA| j dk r$| j t j | j d | _ | j
}|| d | _
d| _ d S # t | j d rA| j dk r$| j t j | j d | _ | j
}|| d | _
d| _ w xY w)NshutdownT) r/ r3 connection_losthasattrr& rE rp r SHUT_RDWRrY r( _detach)r7 rh r< s r rW z0_ProactorBasePipeTransport._call_connection_lost s\ ' F 0 N * *3 / / / tz:..
64:3D3D3F3F"3L3L
##F$4555 J DJ\F! # +/D ( ( ( tz:..
64:3D3D3F3F"3L3L
##F$4555 J DJ\F! # +/D ( / / / /s C B#E+c P | j }| j |t | j z
}|S rO )r, r) rF )r7 sizes r get_write_buffer_sizez0_ProactorBasePipeTransport.get_write_buffer_size s+ " < # C %% %D r> NNN)r_ )rC
__module__ __qualname____doc__r$ rJ r% r' rS rU rY warningswarnr^ ri rg rW rx
__classcell__r= s @r r! r! . s 4448$(/ / / / / /.- - -$# # #" " " " " " %M
#
#
#
# > > >(0 0 0( r> r! c N e Zd ZdZ d fd Zd Zd Zd Zd Zd Z d d
Z
xZ S )
_ProactorReadPipeTransportzTransport for read pipes.N c d| _ d| _ t |||||| t | | _ | j | j d| _ d S )Nrq TF) _pending_data_length_pausedr# r$ bytearray_datar r2
_loop_reading) r7 r8 r r9 r: r; r< buffer_sizer= s r r$ z#_ProactorReadPipeTransport.__init__ sg $&!
tXvufEEE {++
T /000 r> c " | j o| j S rO )r r. rR s r
is_readingz%_ProactorReadPipeTransport.is_reading s < 5
$55r> c | j s| j rd S d| _ | j rt j d| d S d S )NTz%r pauses reading)r. r r r r
re rR s r
pause_readingz(_ProactorReadPipeTransport.pause_reading s\ = DL F : ! ! 4 L,d 3 3 3 3 3 4 4r> c f | j s| j sd S d| _ | j | j | j d | j }d| _ |dk r.| j | j | j d | | | j rt j d| d S d S )NFrq z%r resumes reading) r. r r* r r2 r r _data_receivedr r r
re )r7 lengths r resume_readingz)_ProactorReadPipeTransport.resume_reading s = F > ! J !3T : : :*$&! B;;
J !4dj&6I6 R R R : ! ! 5 L-t 4 4 4 4 4 5 5r> c F | j rt j d| | j }n?# t t f$ r t $ r!}| |d Y d }~d S d }~ww xY w|s|
d S d S )Nz%r received EOFz1Fatal error: protocol.eof_received() call failed.) r r r
re r3 eof_received
SystemExitKeyboardInterrupt
BaseExceptionri rY )r7 keep_openrh s r
_eof_receivedz(_ProactorReadPipeTransport._eof_received s : ! ! 2 L*D 1 1 1 3355II -. H
J
J
J FFFFF
JJLLLLL s A
B%BBc | j r| j dk sJ || _ d S |dk r| d S t | j t
j r\ t j | j | d S # t t f$ r t $ r!}| |d Y d }~d S d }~ww xY w| j | d S )Nrq r z3Fatal error: protocol.buffer_updated() call failed.)
r r r rc r3 r BufferedProtocol _feed_data_to_buffered_protor r r ri
data_received)r7 datar rh s r r z)_ProactorReadPipeTransport._data_received s < ,2222(.D % F Q;; F dni&@ A A /
6t~tLLLLL 12
!!##12 2 2
N ( ( . . . . .s A6 6B2B--B2c Z d}d } || j |u s| j | j sJ d | _ | rK| }|dk r! |dk r| || d S d S | j d | }n| | j r! |dk r| || d S d S | j s/| j j
| j | j | _ | j s | j | j
n# t $ rW}| j s| |d n/| j rt# j dd Y d }~nod }~wt& $ r }| | Y d }~nHd }~wt* $ r }| |d Y d }~n d }~wt, j $ r | j s Y nw xY w|dk r| || d S d S # |dk r| || w w xY w)Nrq r z"Fatal read error on pipe transportz*Read error on pipe transport while closingTr )r* r. rl resultr r rX r r _proactor recv_intor& add_done_callbackr ConnectionAbortedErrorri r r
re ConnectionResetErrorrg rd r CancelledError)r7 futr r rh s r r z(_ProactorReadPipeTransport._loop_reading s - 2~,, 1G15 2H1G @!%88::
! ZZ\\F {{ D {{##D&11111 {A :gvg.DD JJLLL}
2 {{##D&11111 {) <
X!%!5!?!?
DJ!W!W <
E001CDDD & , , ,=
,!!#'KLLLL%%''
, I&*, , , ,# # # # c " " " " " " " " I I I c#G H H H H H H H H( =
{{##D&11111 {v{{##D&1111 sm AD 7+D 6D 9'H
G(*A
E<7H <
G( F# H #
G(0G H G(%H 'G((H H*)NNNr rO ) rC rz r{ r| r$ r r r r r r r r s @r r r s ##486; 6 6 64 4 4&5 5 5$ / / /202 02 02 02 02 02 02 02r> r c R e Zd ZdZdZ fdZd Zd dZd Zd Z d Z
d
Z d Z xZ
S )
_ProactorBaseWritePipeTransportzTransport for write pipes.Tc H t j |i | d | _ d S rO )r# r$ rk r7 argskwr= s r r$ z(_ProactorBaseWritePipeTransport.__init__M s- $%"%%% !r> c 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 .| j J | t | d S | j s*t | | _ | d S | j | | d S )Nz/data argument must be a bytes-like object, not zwrite_eof() already calledz(unable to write; sendfile is in progressz socket.send() raised exception.r )r )rc bytesr
memoryview TypeErrortyperC r0 RuntimeErrorrk r- r !LOG_THRESHOLD_FOR_CONNLOST_WRITESr
r r+ r)
_loop_writing_maybe_pause_protocolextend)r7 r s r writez%_ProactorBaseWritePipeTransport.writeQ sc $ : >?? .-Dzz*- -. .
. = ;<< < ) IJJ J F ? )"MMM @AAA OOq OO F ? "<''' E$KK 0 0 0 0 0 )$T??DL & & ( ( ( ( (
L % % % & & ( ( ( ( (r> Nc || j | j rd S || j u sJ d | _ d| _ |r| || j }d | _ |sg| j r | j | j d | j r$| j
t j |
n| j j | j | | _ | j sU| j dk sJ t# | | _ | j | j | n | j | j | j #| j | j d d S d S d S # t. $ r }| | Y d }~d S d }~wt2 $ r!}| |d Y d }~d S d }~ww xY w)Nr z#Fatal write error on pipe transport)r+ r. r, r r) r r2 rW r0 r& rp r SHUT_WR_maybe_resume_protocolr sendrl rF r r r rk rm r rg rd ri )r7 fr rh s r r z-_ProactorBaseWritePipeTransport._loop_writingw s6 & J} !8T]!8 '''' "DO"#D
|| #
J= KJ(()CTJJJ$ 8J''777 ++----"&*"6";";DJ"M"M++-- J .!3333*-d))D'O55d6HIII..0000O55d6HIII!-$/2I"--d33333 .-2I2I# # # # c " " " " " " " " " J J J c#H I I I I I I I I I Js) F! FF! !
G4+G
G4G//G4c dS NT rR s r
can_write_eofz-_ProactorBaseWritePipeTransport.can_write_eof tr> c . | d S rO )rY rR s r write_eofz)_ProactorBaseWritePipeTransport.write_eof s
r> c 0 | d d S rO rg rR s r abortz%_ProactorBaseWritePipeTransport.abort $ r> c | j t d | j | _ | j | j d | j S )NzEmpty waiter is already set)rk r r
create_futurer+ rm rR s r _make_empty_waiterz2_ProactorBaseWritePipeTransport._make_empty_waiter sX ) <== = !Z 5 5 7 7 ? " ) )$ / / /!!r> c d | _ d S rO )rk rR s r _reset_empty_waiterz3_ProactorBaseWritePipeTransport._reset_empty_waiter s !r> NN)rC rz r{ r| _start_tls_compatibler$ r r r r r r r r r s @r r r G s $$ " " " " "$) $) $)L'J 'J 'J 'JR " " "" " " " " " "r> r c $ e Zd Z fdZd Z xZS )_ProactorWritePipeTransportc t j |i | | j j | j d | _ | j | j d S )N ) r# r$ r r recvr& r* r _pipe_closedr s r r$ z$_ProactorWritePipeTransport.__init__ s\ $%"%%% -224:rBB (():;;;;;r> c H | rd S | dk sJ | j r | j J d S || j u sJ || j f d | _ | j #| t
d S | d S )Nr> ) cancelledr r. r* r+ rg BrokenPipeErrorrY )r7 r s r r z(_ProactorWritePipeTransport._pipe_closed s ==?? Fzz||s"""" = >))) Fdn$$$sDN&;$$$ ? & o / / 0 0 0 0 0 JJLLLLLr> )rC rz r{ r$ r r r s @r r r sG < < < < <
r> r c R e Zd ZdZ d
fd Zd Zd Zd Zd dZd dZ d d Z
xZ S ) _ProactorDatagramTransporti Nc || _ d | _ d| _ t ||||| t j | _ | j | j
d S )Nr )r: r; ) _addressrk _buffer_sizer# r$ collectionsdequer) r r2 r )r7 r8 r r9 addressr: r; r= s r r$ z#_ProactorDatagramTransport.__init__ sp
! tXfEJJJ #(**
T /00000r> c & t | | d S rO r rM s r r% z%_ProactorDatagramTransport._set_extra $%%%%%r> c | j S rO )r rR s r rx z0_ProactorDatagramTransport.get_write_buffer_size s r> c 0 | d d S rO r rR s r r z _ProactorDatagramTransport.abort r r> c Z t |t t t f s t dt | |sd S | j "|d | j fvrt d| j | j rB| j r;| j t j
k rt j d | xj dz
c_ d S | j
t | |f | xj t! | z
c_ | j | | d S )Nz,data argument must be bytes-like object (%r)z!Invalid address: must be None or z!socket.sendto() raised exception.r )rc r r r r r r
ValueErrorr- r r r
r r) rD r rF r+ r r )r7 r addrs r sendtoz!_ProactorDatagramTransport.sendto s? $ : >?? ( J JJ( (
( F = $dDM5J)J)J CDMCCE E
E ? t} )"MMM BCCC OOq OO F
U4[[$ /000 SYY& ? "
""$$$$$r> c 0 | j rd S || j u sJ d | _ |r| | j r| j r0| j r)| j r | j | j d d S | j \ }}| xj
t | z c_
| j +| j j
| j | | _ n,| j j | j || | _ | j | j | d S # t& $ r%}| j | Y d }~d S d }~wt, $ r!}| |d Y d }~d S d }~ww xY w)N)r z'Fatal write error on datagram transport)r- r+ r r) r r. r r2 rW popleftr rF r r r& r r r r rd r3 error_received Exceptionri )r7 r r r rh s r r z(_ProactorDatagramTransport._loop_writing s *
$/)))) "DO
<
DO
= KJ(()CTJJJ --//JD$ T * }("&*"6";";DJ<@#B #B #'*"6"="=dj>BCG #> #I #I
O - -d.@ A A A ' ' ) ) ) ) )
/ / / N ) )# . . . . . . . . . N N N c#L M M M M M M M M M Ns0 D= A$D= 1BD= =
FE''
F4FFc d } | j r" |r | j || d S d S | j |u s| j | j sJ d | _ |U| }| j r$d } |r | j || d S d S | j
|| j }}n|\ }}| j r" |r | j || d S d S | j 0| j j | j
| j | _ n/| j j | j
| j | _ | j | j
| j nI# t $ r$}| j | Y d }~n d }~wt" j $ r | j s Y nw xY w|r | j || d S d S # |r | j || w w xY wrO )r- r3 datagram_receivedr* r. r r r r r r& max_sizerecvfromr r rd r r r )r7 r r r resrh s r r z(_ProactorDatagramTransport._loop_reading# s ' =
H
=00t<<<<<
=
=E >S((T^-C-1] .D-C < "DNjjll= D0
=00t<<<<<
=
=- =,!$dm$DD!$JD$
=00t<<<<<
=
= }(!%!5!:!:4:;?="J "J "&!5!>!>tz?C}"N "N ~)001CDDD / / / N ) )# . . . . . . . .( =
=00t<<<<<
=
=t
=00t<<<<
=sM E ?E E
A&E 3'G
F $F>G F G F G G$ry rO ) rC rz r{ r r$ r% rx r r r r r r s @r r r s H59$( 1 1 1 1 1 1& & &! ! ! % % % %: * * * *D)= )= )= )= )= )= )= )=r> r c e Zd ZdZd Zd ZdS ) _ProactorDuplexPipeTransportzTransport for duplex pipes.c dS )NFr rR s r r z*_ProactorDuplexPipeTransport.can_write_eofT s ur> c t rO )NotImplementedErrorrR s r r z&_ProactorDuplexPipeTransport.write_eofW s !!r> N)rC rz r{ r| r r r r> r r r O s: &% " " " " "r> r c R e Zd ZdZej j Z d fd Zd Z d Z
d Z xZ S )_ProactorSocketTransportz Transport for connected sockets.Nc | t |||||| t j | d S rO )r# r$ r _set_nodelayr6 s r r$ z!_ProactorSocketTransport.__init__b s<
tXvufEEE &&&&&r> c & t | | d S rO r rM s r r% z#_ProactorSocketTransport._set_extrag r r> c dS r r rR s r r z&_ProactorSocketTransport.can_write_eofj r r> c | j s| j rd S d| _ | j &| j t
j d S d S r )r. r0 r+ r& rp r r rR s r r z"_ProactorSocketTransport.write_eofm sQ = D - F ? " J / / / / / # "r> ry )
rC rz r{ r| r
_SendfileMode
TRY_NATIVE_sendfile_compatibler$ r% r r r r s @r r r [ s +*$2=48$(' ' ' ' ' '
& & & 0 0 0 0 0 0 0r> r c e Zd Z fdZ d dZ d!ddddddddZ d dZ d"dZ d"d Z d"d
Z fd Z
d Z d
Z d Z
d#dZd Zd Zd Zd Zd Zd Zd Zd Zd!dZd Z d$d Zd Zd Zd Z xZ S )%r c t t j d|j j || _ || _ d | _ i | _ |
| | t j
t j u r-t j | j d S d S )NzUsing proactor: %s)r# r$ r
re r= rC r _selector_self_reading_future_accept_futuresset_loop_make_self_pipe threadingcurrent_thread main_threadsignal
set_wakeup_fd_csockrE )r7 proactorr= s r r$ z BaseProactorEventLoop.__init__w s
)8+=+FGGG!!$(! ! $ # % %)>)@)@ @ @ !3!3!5!5 6 6 6 6 6 A @r> Nc * t | ||||| S rO )r )r7 r r9 r: r; r< s r _make_socket_transportz,BaseProactorEventLoop._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)r r r; r< )r
SSLProtocolr _app_transport) r7 rawsockr9
sslcontextr: r r r; r< r r ssl_protocols r _make_ssl_transportz)BaseProactorEventLoop._make_ssl_transport s\ +h
F_&;%9 ; ; ;
!w ',V = = = =**r> c * t | ||||| S rO )r )r7 r r9 r r: r; s r _make_datagram_transportz.BaseProactorEventLoop._make_datagram_transport s! )$h*0%9 9 9r> c ( t | |||| S rO )r r7 r r9 r: r; s r _make_duplex_pipe_transportz1BaseProactorEventLoop._make_duplex_pipe_transport s" +D,0(FEK K Kr> c ( t | |||| S rO )r r! s r _make_read_pipe_transportz/BaseProactorEventLoop._make_read_pipe_transport s )$hNNNr> c ( t | |||| S rO )r r! s r _make_write_pipe_transportz0BaseProactorEventLoop._make_write_pipe_transport s$ +4+/65J J Jr> c | rt d | rd S t j t j u rt
j d | | | j
d | _
d | _ t d S )Nz!Cannot close a running event looprq )
is_runningr is_closedr r
r r r
_stop_accept_futures_close_self_piper rY r r# )r7 r= s r rY zBaseProactorEventLoop.close s ?? D BCC C >> F # % %)>)@)@ @ @ $ $ $
!!###
r> c H K | j || d {V S rO )r r )r7 r ns r sock_recvz BaseProactorEventLoop.sock_recv s0 ^((q111111111r> c H K | j || d {V S rO )r r )r7 r bufs r sock_recv_intoz$BaseProactorEventLoop.sock_recv_into s0 ^--dC888888888r> c H K | j || d {V S rO )r r )r7 r bufsizes r
sock_recvfromz#BaseProactorEventLoop.sock_recvfrom s0 ^,,T7;;;;;;;;;r> r c l K |st | }| j ||| d {V S rO )rF r
recvfrom_into)r7 r r0 nbytess r sock_recvfrom_intoz(BaseProactorEventLoop.sock_recvfrom_into sE XXF^11$VDDDDDDDDDr> c H K | j || d {V S rO )r r )r7 r r s r sock_sendallz"BaseProactorEventLoop.sock_sendall s0 ^((t444444444r> c L K | j ||d| d {V S )Nr )r r )r7 r r r s r sock_sendtoz!BaseProactorEventLoop.sock_sendto s4 ^**4q'BBBBBBBBBr> c H K | j || d {V S rO )r connect)r7 r r s r sock_connectz"BaseProactorEventLoop.sock_connect s0 ^++D':::::::::r> c F K | j | d {V S rO )r acceptrM s r sock_acceptz!BaseProactorEventLoop.sock_accept s. ^**4000000000r> c K | }n2# t t j f$ r}t j d d }~ww xY w t
j | j }n"# t $ r t j d w xY w|r|n|}|sdS t |d }|rt ||z | n|} t || }d}
t | |z
| }|dk r |
|
dk r| | S S | j
|||| d {V ||z
}|
|z
}
e# |
dk r| | w w xY w)Nznot a regular filer l )rE AttributeErrorioUnsupportedOperationr SendfileNotAvailableErrorosfstatst_sizerd minseekr sendfile) r7 r fileoffsetcountrE errfsize blocksizeend_pos
total_sents r _sock_sendfile_nativez+BaseProactorEventLoop._sock_sendfile_native s M[[]]FF 78 M M M 67KLL L M MHV$$,EE M M M 67KLL L M "-EE 1 ;// 05@#fune,,,5VU##
"
( & 0) < < >>%
A~~ &!!!! n--dD&)LLLLLLLLL)#i'
( A~~ &!!!! s2 AAA A& & B D2 .D2 2 Ec K | }| | d {V | |j |||d d {V | |r| S S # | |r| w w xY w)NF)fallback)r r r
sock_sendfiler& r r )r7 transprN rO rP r s r _sendfile_nativez&BaseProactorEventLoop._sendfile_native s
**,, ''))))))))) ( ++FL$5: , < < < < < < < <
<
& & ( ( (
(%%''''
(
& & ( ( (
(%%''''
(s $B -Cc | j | j d | _ | j d | _ | j d | _ | xj dz c_ d S )Nr )r rX _ssockrY r
_internal_fdsrR s r r+ z&BaseProactorEventLoop._close_self_pipe sx $ 0 % , , . . .(,D % a r> c t j \ | _ | _ | j d | j d | xj dz
c_ d S )NFr )r
socketpairr] r setblockingr^ rR s r r z%BaseProactorEventLoop._make_self_pipe s_ #)#4#6#6 T[ &&& &&& a r> c r || | j |urd S | j | j d }|| _ | | j d S # t j $ r Y d S t t f$ r t $ r$}| d|| d Y d }~d S d }~ww xY w)Ni z.Error on reading from the event loop self pipe)ra rb r8 )
r r r r r] r _loop_self_readingr r r r r rf )r7 r rh s r rc z(BaseProactorEventLoop._loop_self_reading s 9}
(11 ##DK66A )*D %
7 8 8 8 8 8 ( FF -. ' 'K ) )
s" A& A& &B68B6B11B6c | 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 socketTr )r r rd _debugr
re )r7 csocks r _write_to_selfz$BaseProactorEventLoop._write_to_self1 s = F , JJu , , ,{
, 0&*, , , , , , ,
,
,
, ,s $ 'AAd c Z d fd d S )Nc
F | || \ }}j rt j d|| } || dd|i
n ||d|i rd S j } | j
< | d S # t $ r}
dk r@
d|t j d n*j r t j d d
Y d }~d S Y d }~d S Y d }~d S d }~wt" j $ r Y d S w xY w) Nz#%r got a new connection from %r: %rTr )r r; r< r r r rq zAccept failed on a socket)ra rb r zAccept failed on socket %rr )r rf r
re r r r) r rA r rE r rd rf r r rY r r )
r connr r9 rh r8 protocol_factoryr7 r< r r r r s
r r8 z2BaseProactorEventLoop._start_serving..loopH sD #
*=!"JD${ 9 %J%+T49 9 9 / / 1 1H!- 00 (JD#-t"4V2G1E 1 G G G G 33 (#-t"4V 4 E E E >>## FN))$// 78$T[[]]3##D)))))
6
6
6;;==B&&//#>%("("8">">1 1
JJLLLL[ 6L!=!%6 6 6 6 6 6 6 6 6 66 6 6 6 6 6 !LLLLL ,
s% BC$ C$ $
F .A6E66&F F rO )r2 ) r7 rm r r r< backlogr r r8 s ````` ``@r _start_servingz$BaseProactorEventLoop._start_servingC sf
$ * $ * $ * $ * $ * $ * $ * $ * $ * $ * $ * $ * $ *L
t r> c d S rO r )r7
event_lists r _process_eventsz%BaseProactorEventLoop._process_eventsp s r> c | j D ]}| | j d S rO )r valuesrX clear)r7 futures r r* z*BaseProactorEventLoop._stop_accept_futurest sJ *1133 F MMOOOO ""$$$$$r> c | j | d }|r| | j | | d S rO )r poprE rX r
_stop_servingrY )r7 r rv s r ry z#BaseProactorEventLoop._stop_servingy s^ %))$++-->> MMOOO $$T***
r> ry rO r )r )NNri NN) rC rz r{ r$ r r r r" r$ r& rY r. r1 r4 r8 r: r< r? rB rV r[ r+ r rc rh ro rr r* ry r r s @r r r u sS 7 7 7 7 7 =A267 7 7 7 9=
+ $t"&!%
+
+
+
+
+ CG9 9 9 9
BF*.K K K K
@D(,O O O O AE)-J J J J (2 2 29 9 9< < <E E E E 5 5 5C C C; ; ;1 1 1" " ":
(
(
( 9 9 9 98, , ,& >A-1,0+ + + + Z
% % %
r> r )$r| __all__rE rH r r} r r r r r r r r r
r r logr
r _FlowControlMixin
BaseTransportr!
ReadTransportr WriteTransportr r DatagramTransportr Transportr r
BaseEventLoopr r r> r r s #
0 0 0$D D D D D!=!+!9D D DNO2 O2 O2 O2 O2!;!+!9O2 O2 O2dk" k" k" k" k"&@&0&?k" k" k"\ "A ,A= A= A= A= A=!;!+!=A= A= A=H " " " " "#=#B#-#7 " " "0 0 0 0 0 9 > ) 30 0 04I I I I IK 5 I I I I Ir>