P d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
Z
d dl Z ddl m
Z
ddl mZ ddl mZ ddl mZ ddl mZ ddl mZ dd l mZ dd
l mZ dd l mZ dd l mZ dd
lmZ dZe j dk r ed d Z d Z G d dej Z G d dej Z! G d dej" ej# Z$ G d dej% Z& G d d Z' G d d e' Z( G d d e' Z) G d! d"e) Z* G d# d$e) Z+ G d% d&e' Z, G d' d(e' Z- G d) d*ej. Z/e Z0e/Z1dS )+ N ) base_events)base_subprocess) constants)
coroutines)events)
exceptions)futures)selector_events)tasks)
transports)logger)SelectorEventLoopAbstractChildWatcherSafeChildWatcherFastChildWatcherPidfdChildWatcherMultiLoopChildWatcherThreadedChildWatcherDefaultEventLoopPolicywin32z+Signals are not really supported on Windowsc d S N )signumframes @/opt/alt/python-internal/lib64/python3.11/asyncio/unix_events.py_sighandler_noopr * s
D c P t j | S # t $ r | cY S w xY wr )oswaitstatus_to_exitcode
ValueError)statuss r r" r" / s> (000
s %%c e Zd Z d fd Z fdZd Zd Zd Zd Zd Z dd Z
dd
Z dd Z d Z
ddddddd
dZ dddddddddZd Zd Zd Zd Z xZS )_UnixSelectorEventLoopNc X t | i | _ d S r )super__init___signal_handlers)selfselector __class__s r r) z _UnixSelectorEventLoop.__init__? s)
""" " r c N t t j s.t | j D ]}| | d S | j r;t j d| dt | | j
d S d S )NzClosing the loop z@ on interpreter shutdown stage, skipping signal handlers removalsource) r( closesys
is_finalizinglistr* remove_signal_handlerwarningswarnResourceWarningclear)r+ sigr- s r r1 z _UnixSelectorEventLoop.closeC s
""
.D 122
0
0**3////
0
0 $
.
I$ I I I .%) + + + +
%++-----
.
.r c @ |D ]}|s| | d S r )_handle_signal)r+ datar s r _process_self_dataz)_UnixSelectorEventLoop._process_self_dataQ s= ( (F
' ' ' ' ( (r c T t j | st j | rt d | | | t
j | j n5# t t f$ r!}t t | d }~ww xY wt j ||| d }|| j |< t
j |t" t
j |d d S # t $ r}| j |= | j sI t
j d n3# t t f$ r }t' j d| Y d }~nd }~ww xY w|j t* j k rt d| d d }~ww xY w)Nz3coroutines cannot be used with add_signal_handler()F set_wakeup_fd(-1) failed: %ssig cannot be caught)r iscoroutineiscoroutinefunction TypeError
_check_signal
_check_closedsignal
set_wakeup_fd_csockfilenor# OSError RuntimeErrorstrr Handler* r siginterruptr infoerrnoEINVAL)r+ r: callbackargsexchandlenexcs r add_signal_handlerz)_UnixSelectorEventLoop.add_signal_handlerX s
"8 , , 9.x88 9 8 9 9
9 3 )
!3!3!5!5 6 6 6 6G$ ) ) ) s3xx(( ( ) xtT::%+ c"
M# / 0 0 0
U + + + + + %c*(
FF(,,,,"G, F F FK >EEEEEEEEF yEL(("#@##@#@#@AAA sZ #+B C B<<C&/D
F'!F"1EF"E6E1,F"1E66,F""F'c | j | }|d S |j r| | d S | | d S r )r* get
_cancelledr5 _add_callback_signalsafe)r+ r: rX s r r< z%_UnixSelectorEventLoop._handle_signal sd @&**3// > F 2 & &s + + + + + ) )& 1 1 1 1 1r c | | | j |= n# t $ r Y dS w xY w|t j k r
t j }n t j } t j || n;# t $ r.}|j t j k rt d| d d }~ww xY w| j sI t j d n3# t t f$ r }t j d| Y d }~nd }~ww xY wdS )NFrB rC r@ rA T)rG r* KeyErrorrI SIGINTdefault_int_handlerSIG_DFLrM rS rT rN rJ r# r rR )r+ r: handlerrW s r r5 z,_UnixSelectorEventLoop.remove_signal_handler sP
3 %c** 55 &- 0GG nG M#w ' ' ' ' yEL(("#@##@#@#@AAA $ A
A$R(((( (
A
A
A :C@@@@@@@@
A ts< !
// A2 2
B*<)B%%B*5C
C:C55C:c t |t st d| |t j vrt d| d S )Nzsig must be an int, not zinvalid signal number )
isinstanceintrF rI
valid_signalsr# )r+ r: s r rG z$_UnixSelectorEventLoop._check_signal sf
#s## @ >s > >?? ? f*,, , , ;c ; ;<< < - ,r c ( t | |||| S r )_UnixReadPipeTransportr+ pipeprotocolwaiterextras r _make_read_pipe_transportz0_UnixSelectorEventLoop._make_read_pipe_transport s %dD(FEJJJr c ( t | |||| S r )_UnixWritePipeTransportrk s r _make_write_pipe_transportz1_UnixSelectorEventLoop._make_write_pipe_transport s &tT8VUKKKr c
K t j 5 }
|
st d | } t | |||||||f| |d| } |
| | j | | d {V nN# t t f$ r t $ r0 | |
d {V w xY w d d d n # 1 swxY w Y | S )NzRasyncio.get_child_watcher() is not activated, subprocess support is not installed.)rn ro )r get_child_watcher is_activerN
create_future_UnixSubprocessTransportadd_child_handlerget_pid_child_watcher_callback
SystemExitKeyboardInterrupt
BaseExceptionr1 _wait)
r+ rm rV shellstdinstdoutstderrbufsizero kwargswatcherrn transps
r _make_subprocess_transportz1_UnixSelectorEventLoop._make_subprocess_transport s
%
'
' 7$$&&
K
# $J K K K''))F-dHdE.3VVW85;58 8 178 8F
% %fnn&6&6&*&BF
L
L
L
12
llnn$$$$$$$
# 2
s+ A=C8B C8 A C((C88C<?C<c H | | j |j | d S r )call_soon_threadsafe call_soon_process_exited)r+ pid
returncoder s r r{ z._UnixSelectorEventLoop._child_watcher_callback s% !!$.&2H*UUUUUr )sslsockserver_hostnamessl_handshake_timeoutssl_shutdown_timeoutc K |r|t d n3|t d |t d |t d ||t d t j | }t j t j t j d } | d | || d {V n|# | xY w|t d |j t j k s|j
t j k rt d | | d | ||||||
d {V \ }} || fS ) Nz/you have to pass server_hostname when using sslz+server_hostname is only meaningful with ssl1ssl_handshake_timeout is only meaningful with ssl0ssl_shutdown_timeout is only meaningful with ssl3path and sock can not be specified at the same timer Fz no path and sock were specified.A UNIX Domain Stream Socket was expected, got )r r ) r# r! fspathsocketAF_UNIX SOCK_STREAM setblocking sock_connectr1 familytype _create_connection_transport)
r+ protocol_factorypathr r r r r transportrm s
r create_unix_connectionz-_UnixSelectorEventLoop.create_unix_connection s H & EG G G ' * !NOOO$0 GI I I#/ FH H H IK K K 9T??D= 1CQGGD
'''''d3333333333
| !BCCC v~--I!333 MTMMO O O U # # #$($E$E "C "7!5 %F %7 %7 7 7 7 7 7 7 8 (""s 1C C%d T)r backlogr r r
start_servingc K t |t rt d ||st d ||st d |Z|t d t j | }t
j t j t j }|d dvry t j
t j | j rt j | n8# t $ r Y n,t $ r } t j d|| Y d } ~ nd } ~ ww xY w | | n# t $ rP}
| |
j t& j k r!d|d } t t& j | d d }
~
w | xY w|t d
|j t j k s|j t j k rt d | | d t1 j | |g||||| } |r.| t7 j d d {V | S )
Nz*ssl argument must be an SSLContext or Noner r r r )r z2Unable to check or remove stale UNIX socket %r: %rzAddress z is already in usez-path was not specified, and no sock specifiedr F) rf boolrF r# r! r r r r statS_ISSOCKst_moderemoveFileNotFoundErrorrM r errorbindr1 rS
EADDRINUSEr r r r Server_start_servingr sleep)
r+ r r r r r r r r errrW msgservers
r create_unix_serverz)_UnixSelectorEventLoop.create_unix_server s c4 J HII I ,S , CE E
E +C + BD D
D IK K K 9T??D= 1CDDD Awk))6}RWT]]%:;; ( $( D 6 6 6L "*+/6 6 6 6 6 6 6 66
$
9 000 @T???C!%"2C88dB
| CE E E v~--I!333 MTMMO O O
#D4&2B$'2G$8: : ! ! ! # # # +a..
s7 )?C) )
D 5 D >DD "D8 8
F'A F
F'c
K t j n"# t $ r t j d w xY w | }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 | } | | d |||||d | d {V S )Nz os.sendfile() is not availableznot a regular filer )
r! sendfileAttributeErrorr SendfileNotAvailableErrorrL ioUnsupportedOperationfstatst_sizerM rw _sock_sendfile_native_impl)
r+ r fileoffsetcountrL r fsize blocksizefuts
r _sock_sendfile_nativez,_UnixSelectorEventLoop._sock_sendfile_native` sN 2 KKK 2 2 2 602 2
2 2 M[[]]FF 78 M M M 67KLL L M MHV$$,EE M M M 67KLL L M "-EE 1 "" ''T4(.y! E E Eyyyyyys+ 0A A8 A33A8<B B5c
L | } || | | r| ||| d S |r9||z
}|dk r.| ||| | | d S t j | ||| }
|
dk r.| ||| | | d S ||
z
}||
z
}|| || | | | j || ||||||
d S # t t f$ r? || || | | | j || ||||||
Y d S t $ r} |N| j
t j k r9t | t ur#t! dt j } | | _ | } |dk rAt% j d }
| ||| | |
n2| ||| | | Y d } ~ d S Y d } ~ d S d } ~ wt* t, f$ r t. $ r7} | ||| | | Y d } ~ d S d } ~ ww xY w)Nr zsocket is not connectedzos.sendfile call failed)rL
remove_writer cancelled _sock_sendfile_update_filepos
set_resultr! r _sock_add_cancellation_callback
add_writerr BlockingIOErrorInterruptedErrorrM rS ENOTCONNr ConnectionError __cause__r r
set_exceptionr| r} r~ )r+ r
registered_fdr rL r r r
total_sentfdsentrW new_excr s r r z1_UnixSelectorEventLoop._sock_sendfile_native_implw sb
[[]] $
} - - - ==?? . .vvz J J J F
*IA~~2266:NNNz***1 F;r669==DJ qyy2266:NNNz*****$d"
(88dCCCD$CS "D& &y*F F F F F[ !12 B B B $44S$??? OOB ? f "E9j
B
B
B
B
B
B ' ' ' )I //II_44
*-u~? ?$'! Q
!:-/ /2266:NNN!!#&&&&2266:NNN!!#&&&&&&&&& '&&&&& -. # # # . .vvz J J J c " " " " " " " " " #s, D' 'A J#6 J#?CI J#,,J J#c V |dk r"t j ||t j d S d S Nr )r! lseekSEEK_SET)r+ rL r r s r r z4_UnixSelectorEventLoop._sock_sendfile_update_filepos s. >> HVVR[ 1 1 1 1 1 >r c @ fd}| | d S )Nc | r1 }|dk r | d S d S d S )Nr@ )r rL r )r r r+ r s r cbzB_UnixSelectorEventLoop._sock_add_cancellation_callback..cb sR }}
+[[]]88&&r*****
+
+8r )add_done_callback)r+ r r r s ` ` r r z6_UnixSelectorEventLoop._sock_add_cancellation_callback s> + + + + + +
b!!!!!r r NN)__name__
__module__ __qualname__r) r1 r> rZ r< r5 rG rp rs r r{ r r r r r r
__classcell__r- s @r r& r& 9 s
# # # # # # . . . . . ( ( (+ + +Z2 2 2 @
=
=
= @D(,K K K K AE)-L L L L 04 <V V V
*.0#4 "&!% 0# 0# 0# 0# 0#f *.Gs"&!% G G G G GR .DF DF DFL2 2 2" " " " " " "r r& c e Zd ZdZd fd Zd Zd Zd Zd Zd Z d Z
d
Z d Z d Z
d
Zej fdZddZd Zd Z xZS )rj i Nc t | || j d< || _ || _ | | _ || _ d| _ d| _ t j | j j }t j | sLt j | s8t j | s$d | _ d | _ d | _ t# d t j | j d | j | j j | | j | j | j | j |(| j t. j |d d S d S )Nrl Fz)Pipe transport is for pipes/sockets only.)r( r) _extra_loop_piperL _fileno _protocol_closing_pausedr! r r r S_ISFIFOr S_ISCHRr# set_blockingr connection_made _add_reader _read_readyr
_set_result_unless_cancelled)r+ looprl rm rn ro moder- s r r) z _UnixReadPipeTransport.__init__ sb
" F
{{}} !
x %%-
d## J
d## J T"" J DJ DL !DN HII I
e,,,
T^ ;TBBB
T - !\4+; = = = J !E!'
/
/
/
/
/ r c h | sd S | j || d S r )
is_readingr r )r+ r rU s r r z"_UnixReadPipeTransport._add_reader s7 F
r8,,,,,r c " | j o| j S r )r r r+ s r r z!_UnixReadPipeTransport.is_reading s < 5
$55r c ` | j j g}| j | d n | j r| d | d| j t
| j dd }| j U|St j || j t j }|r| d nH| d n2| j | d n| d d d
| S )
Nclosedclosingfd= _selectorpollingidleopen<{}> )r- r r appendr r getattrr r _test_selector_event selectors
EVENT_READformatjoin)r+ rR r, r s r __repr__z _UnixReadPipeTransport.__repr__ s '( : KK ! ! ! !
] # KK " " " ($,(()))4:{D99 : !h&:%:$, (<> >G
$ I&&&& F####
Z
# KK KK ! ! !}}SXXd^^,,,r c 4 t j | j | j }|r | j | d S | j rt j d| d| _
| j | j | j | j j
| j | j d d S # t t f$ r Y d S t" $ r!}| |d Y d }~d S d }~ww xY w)N%r was closed by peerTz"Fatal read error on pipe transport)r! readr max_sizer
data_receivedr get_debugr rR r _remove_readerr eof_received_call_connection_lostr r rM _fatal_error)r+ r= rW s r r z"_UnixReadPipeTransport._read_ready s5 G74< 77D
G,,T22222:'')) ?K 7>>> $
))$,777
$$T^%@AAA
$$T%?FFFFF !12 DD I I I c#G H H H H H H H H H Is C D- D6DDc | sd S d| _ | j | j | j rt
j d| d S d S )NTz%r pauses reading)r r r r r r r debugr s r
pause_readingz$_UnixReadPipeTransport.pause_reading sq F
!!$,/// : ! ! 4 L,d 3 3 3 3 3 4 4r c | j s| j sd S d| _ | j | j | j | j rt j d| d S d S )NFz%r resumes reading) r r r r r r r r r r s r resume_readingz%_UnixReadPipeTransport.resume_reading# sw = F
t|T-=>>> : ! ! 5 L-t 4 4 4 4 4 5 5r c || _ d S r r r+ rm s r set_protocolz#_UnixReadPipeTransport.set_protocol+
!r c | j S r r# r s r get_protocolz#_UnixReadPipeTransport.get_protocol.
~ r c | j S r r r s r
is_closingz!_UnixReadPipeTransport.is_closing1
} r c B | j s| d d S d S r )r _closer s r r1 z _UnixReadPipeTransport.close4 s. } KK r c v | j 1 |d| t | | j d S d S Nzunclosed transport r/ r r8 r1 r+ _warns r __del__z _UnixReadPipeTransport.__del__8 L : ! E000/$ O O O O J " !r Fatal error on pipe transportc 0 t |t rG|j t j k r2| j rt
j d| |d n$| j ||| | j d |
| d S Nz%r: %sTexc_info)message exceptionr rm ) rf rM rS EIOr r r r call_exception_handlerr r/ r+ rW r< s r r z#_UnixReadPipeTransport._fatal_error= s sG $ $ ei)?)?z##%%
E XtWtDDDD J - -" ! N / /
Cr c d| _ | j | j | j | j | d S NT)r r r r r r r+ rW s r r/ z _UnixReadPipeTransport._closeK sB
!!$,///
T 7=====r c | j | | j d | _ d | _ d | _ d S # | j d | _ d | _ d | _ w xY wr r connection_lostr r1 r rC s r r z,_UnixReadPipeTransport._call_connection_lostP N * *3 / / / J DJ !DN DJJJ
J DJ !DN DJ A 0A<r r7 )r r r r r) r r r r r r! r% r( r, r1 r6 r7 r5 r r/ r r r s @r rj rj s( H / / / / / /<- - -
6 6 6- - -*G G G$4 4 45 5 5" " " %M
> > >
r rj c e Zd Zd fd Zd Zd Zd Zd Zd Zd Z d Z
d
Z d Z d Z
d
Zej fdZd ZddZddZd Z xZS )rr Nc p t || || j d< || _ | | _ || _ t | _ d| _ d| _
t j | j j
}t j | }t j | }t j | } |s(|s&| s$d | _ d | _ d | _ t% d t j | j d | j | j j | | s!|rOt. j d s0| j | j j | j | j |(| j t8 j |d d S d S )Nrl r Fz?Pipe transport is only for pipes, sockets and character devicesaix) r( r) r r rL r r bytearray_buffer
_conn_lostr r! r r r r r r r# r r r r r2 platform
startswithr r r
r ) r+ r rl rm rn ro r is_charis_fifo is_socketr- s r r) z _UnixWritePipeTransport.__init__] s
%%% " F
{{}} ! {{
x %%-,t$$-%%M$'' E7 Ei E DJ DL !DN D E E
E e,,,
T^ ;TBBB
A A )@)@)G)G A J !7!% t/?
A
A
A J !E!'
/
/
/
/
/ r c | j j g}| j | d n | j r| d | d| j t
| j dd }| j |t j || j t j }|r| d n| d | }| d| n2| j | d n| d d
d
| S ) Nr r r r r r zbufsize=r r r
)r- r r r r r r r r r
r EVENT_WRITEget_write_buffer_sizer r )r+ rR r, r r s r r z _UnixWritePipeTransport.__repr__ sL '( : KK ! ! ! !
] # KK " " " ($,(()))4:{D99 : !h&:%:$, (=? ?G
$ I&&&& F###0022G KK,7,, - - - -
Z
# KK KK ! ! !}}SXXd^^,,,r c * t | j S r )lenrN r s r rW z-_UnixWritePipeTransport.get_write_buffer_size s 4< r c | j rt j d| | j r#| t
d S | d S )Nr )r r r rR rN r/ BrokenPipeErrorr s r r z#_UnixWritePipeTransport._read_ready sd : ! ! 7 K/ 6 6 6 < KK)) * * * * * KKMMMMMr c t |t rt | }|sd S | j s| j r;| j t
j k rt j d | xj dz
c_ d S | j s t j | j | }nc# t t f$ r d}Y nNt t f$ r t" $ r1}| xj dz
c_ | |d Y d }~d S d }~ww xY w|t' | k rd S |dk rt | |d }| j | j | j | xj |z
c_ | d S )Nz=pipe closed by peer or os.write(pipe, data) raised exception.r r #Fatal write error on pipe transport)rf rM
memoryviewrO r r !LOG_THRESHOLD_FOR_CONNLOST_WRITESr warningrN r! writer r r r| r} r~ r rY r _add_writer _write_ready_maybe_pause_protocol)r+ r= nrW s r ra z _UnixWritePipeTransport.write s dI & & $ d##D F ? dm )"MMM H I I I OOq OO F| D
HT\400#%56
12
1$!!#'LMMM
CII~~Q!$''+ J " "4<1B C C C ""$$$$$s :B C5*C5&C00C5c t j | j | j }|t | j k r| j | j | j | | j r4| j
| j | d d S |dk r | j d |= d S d S # t t f$ r Y d S t t f$ r t $ ri}| j | xj dz
c_ | j | j | |d Y d }~d S d }~ww xY w)Nr r r] )r! ra r rN rY r9 r _remove_writer_maybe_resume_protocolr r r r r r| r} r~ rO r )r+ re rW s r rc z$_UnixWritePipeTransport._write_ready s % t|44A C %%%% ""$$$
))$,777++---= 5J--dl;;;..t444QL!$$$ ) !12 DD -. J J J L OOq OO
J % %dl 3 3 3 c#H I I I I I I I I I
Js C E-*E-A E((E-c dS rB r r s r
can_write_eofz%_UnixWritePipeTransport.can_write_eof tr c | j rd S d| _ | j sA| j | j | j | j d d S d S rB )r rN r r r r r r s r write_eofz!_UnixWritePipeTransport.write_eof sh = F
| C J % %dl 3 3 3 J !;T B B B B B C Cr c || _ d S r r# r$ s r r% z$_UnixWritePipeTransport.set_protocol r& r c | j S r r# r s r r( z$_UnixWritePipeTransport.get_protocol r) r c | j S r r+ r s r r, z"_UnixWritePipeTransport.is_closing r- r c R | j | j s| d S d S d S r )r r rm r s r r1 z _UnixWritePipeTransport.close s5 : !$- ! NN " ! ! !r c v | j 1 |d| t | | j d S d S r1 r2 r3 s r r5 z _UnixWritePipeTransport.__del__ r6 r c 0 | d d S r )r/ r s r abortz _UnixWritePipeTransport.abort s Dr r7 c t |t r2| j rt j d| |d n$| j ||| | j d | | d S r9 ) rf rM r r r r r? r r/ r@ s r r z$_UnixWritePipeTransport._fatal_error s c7 # # z##%%
E XtWtDDDD J - -" ! N / /
Cr c d| _ | j r | j | j | j | j | j | j | j | d S rB ) r rN r rg r r9 r r r rC s r r/ z _UnixWritePipeTransport._close sx
< 4 J % %dl 3 3 3
!!$,///
T 7=====r c | j | | j d | _ d | _ d | _ d S # | j d | _ d | _ d | _ w xY wr rE rC s r r z-_UnixWritePipeTransport._call_connection_lost rG rH r rI r )r r r r) r rW r ra rc rj rm r% r( r, r1 r6 r7 r5 rt r r/ r r r s @r rr rr Z sH #/ #/ #/ #/ #/ #/J- - -0! ! ! !% !% !%F% % %8 C C C" " "
%M
> > > > r rr c e Zd Zd ZdS )rx c
d }|t j k r5t j d rt j \ }} t j |f||||d|d|| _ |D| t | d| | j _ d }|*| | d S d S # |)| | w w xY w)NrL F)r r r r universal_newlinesr wb) buffering)
subprocessPIPEr2 rP rQ r
socketpairPopen_procr1 r detachr ) r+ rV r r r r r r stdin_ws r _startz _UnixSubprocessTransport._start) s JO # # (?(?(F(F #
$ . 0 0NE7 #)E !vf#('E E=CE EDJ "
#'(8(8$'#R#R#R
"
#"w"
#s
A$C -DN)r r r r r r r rx rx ' s# r rx c : e Zd Z d Zd Zd Zd Zd Zd Zd Z dS ) r c t r NotImplementedErrorr+ r rU rV s r ry z&AbstractChildWatcher.add_child_handlerV s "###r c t r r r+ r s r remove_child_handlerz)AbstractChildWatcher.remove_child_handlera s 1
"###r c t r r r+ r s r attach_loopz AbstractChildWatcher.attach_loopi s "###r c t r r r s r r1 zAbstractChildWatcher.closes s "###r c t r r r s r rv z AbstractChildWatcher.is_activez s "###r c t r r r s r __enter__z AbstractChildWatcher.__enter__ s * "###r c t r r r+ abcs r __exit__z AbstractChildWatcher.__exit__ s (!###r N)
r r r ry r r r1 rv r r r r r r r ? s , $ $ $$ $ $$ $ $$ $ $$ $ $$ $ $ $ $ $ $ $r r c F e Zd Z d Zd Zd Zd Zd Zd Zd Z d Z
d Z d
S ) r c " d | _ i | _ d S r r
_callbacksr s r r) zPidfdChildWatcher.__init__
r c | S r r r s r r zPidfdChildWatcher.__enter__ r c d S r r )r+ exc_type exc_value
exc_tracebacks r r zPidfdChildWatcher.__exit__ r c F | j d uo| j S r r
is_runningr s r rv zPidfdChildWatcher.is_active " z%A$**?*?*A*AAr c 0 | d d S r r r s r r1 zPidfdChildWatcher.close r c 6 | j #|!| j rt j dt | j D ]4\ }}}| j | t j | 5| j || _ d S NzCA loop is being detached from a child watcher with pending handlers)
r r r6 r7 RuntimeWarningvaluesr r! r1 r9 )r+ r pidfd_s r r z PidfdChildWatcher.attach_loop s : !dltl M=
?1133 KE1a J % %e , , , HUOOOO
r c | j | }||d ||f| j |< d S t j | }| j || j | |||f| j |< d S r )r r\ r!
pidfd_openr r _do_wait)r+ r rU rV existingr s r ry z#PidfdChildWatcher.add_child_handler s~ ?&&s++ #+A;$#>DOC M#&&E J " "5$- = = =#((D#8DOC r c R | j | \ }}}| j | t j |d \ }}t
| }n'# t $ r d}t j d| Y nw xY wt j
| |||g|R d S )Nr zJchild process pid %d exit status already read: will report returncode 255) r popr r r! waitpidr" ChildProcessErrorr r` r1 )r+ r r rU rV r r$ r s r r zPidfdChildWatcher._do_wait s $ 3 3C 8 8 x
!!%((( 8
3**IAv 077JJ ! J N.
j(4((((((s A" "!BBc | j | \ }}}n# t $ r Y dS w xY w| j | t j | dS )NFT)r r r` r r r! r1 )r+ r r r s r r z&PidfdChildWatcher.remove_child_handler sn /--c22KE1aa 55
!!%(((
ts !
//N) r r r r) r r rv r1 r ry r r r r r r r s
B B B
9 9 9) ) )& r r c 8 e Zd Zd Zd Zd Zd Zd Zd Zd Z dS ) BaseChildWatcherc " d | _ i | _ d S r r r s r r) zBaseChildWatcher.__init__ r r c 0 | d d S r r r s r r1 zBaseChildWatcher.close r r c F | j d uo| j S r r r s r rv zBaseChildWatcher.is_active r r c t r r )r+ expected_pids r _do_waitpidz BaseChildWatcher._do_waitpid !###r c t r r r s r _do_waitpid_allz BaseChildWatcher._do_waitpid_all r r c 8 | j #|!| j rt j dt | j $| j t j || _ |;| t j | j |
d S d S r ) r r r6 r7 r r5 rI SIGCHLDrZ _sig_chldr r s r r z BaseChildWatcher.attach_loop s : !dltl M=
: ! J , ,V^ < < <
# #FNDN C C C
" " " " " r c | d S # t t f$ r t $ r(}| j d|d Y d }~d S d }~ww xY w)N$Unknown exception in SIGCHLD handler)r< r= )r r| r} r~ r r? rC s r r zBaseChildWatcher._sig_chld s " " " " " -.
J - -A / /
s A AAN)
r r r r) r1 rv r r r r r r r r r s B B B$ $ $$ $ $# # #( r r c D e Zd Z fdZd Zd Zd Zd Zd Zd Z xZ
S )r c z | j t d S r )r r9 r( r1 r+ r- s r r1 zSafeChildWatcher.close s,
r c | S r r r s r r zSafeChildWatcher.__enter__ r r c d S r r r s r r zSafeChildWatcher.__exit__# r r c H ||f| j |< | | d S r )r r r s r ry z"SafeChildWatcher.add_child_handler& s/ ($ /
r c : | j |= dS # t $ r Y dS w xY wNTFr r` r s r r z%SafeChildWatcher.remove_child_handler, 8 $4 55
c ^ t | j D ]}| | d S r r4 r r r s r r z SafeChildWatcher._do_waitpid_all3 s< (( " "C S ! ! ! ! " "r c t j |t j \ }}|dk rd S t | }| j rt
j d|| n)# t $ r |}d}t
j d| Y nw xY w | j
| \ }} |||g|R d S # t $ r7 | j rt
j d|d Y d S Y d S w xY w)Nr $process %s exited with returncode %sr 8Unknown child process pid %d, will report returncode 255'Child watcher got an unexpected pid: %rTr: )
r! r WNOHANGr" r r r r r r` r r r` )r+ r r r$ r rU rV s r r z SafeChildWatcher._do_waitpid8 so 7 *\2:>>KC axx/77Jz##%%
7 C ):7 7 7 ! C J NJ
$ - !_ 0 0 5 5NHd
HS* ,t , , , , , , 3 3 3 z##%%
3 H "T3 3 3 3 3 3 3
3
3
3 3s# "A+ +#BB B> >:C?>C?) r r r r1 r r ry r r r r r s @r r r s
" " "
- - - - - - -r r c H e Zd Z fdZ fdZd Zd Zd Zd Zd Z xZ
S )r c t t j | _ i | _ d| _ d S r )r( r) threadingLock_lock_zombies_forksr s r r) zFastChildWatcher.__init__e s:
^%%
r c | j | j t d S r )r r9 r r( r1 r s r r1 zFastChildWatcher.closek s@
r c h | j 5 | xj dz
c_ | cd d d S # 1 swxY w Y d S )Nr )r r r s r r zFastChildWatcher.__enter__p s
Z KK1 KK s '++c | j 5 | xj dz c_ | j s| j s d d d d S t | j }| j d d d n # 1 swxY w Y t j d| d S )Nr z5Caught subprocesses termination from unknown pids: %s)r r r rO r9 r r` )r+ r r r collateral_victimss r r zFastChildWatcher.__exit__v s
Z " " KK1 KK{
$-
" " " " " " " " "%T]!3!3 M ! ! ! " " " " " " " " " " " " " " " C s A.-A..A25A2c | j 5 | j | }n(# t $ r ||f| j |< Y d d d d S w xY w d d d n # 1 swxY w Y |||g|R d S r )r r r r` r )r+ r rU rV r s r ry z"FastChildWatcher.add_child_handler s Z
!] . .s 3 3
'/~$
j(4((((((s0 A%AA
A A
AA !A c : | j |= dS # t $ r Y dS w xY wr r r s r r z%FastChildWatcher.remove_child_handler r r c ~ t j dt j \ }}|dk rd S t | }n# t $ r Y d S w xY w| j 5 | j | \ }}| j rt j d|| n_# t $ rR | j
rF|| j |< | j rt j d|| Y d d d d }Y nw xY wd d d n # 1 swxY w Y |t j d|| n
|||g|R =)NTr@ r r z,unknown process %s exited with returncode %sz8Caught subprocess termination from unknown pid: %d -> %d)r! r r r" r r r r r r r r r` r r r` )r+ r r$ r rU rV s r r z FastChildWatcher._do_waitpid_all s % 1
< jRZ 8 8 V
!88F 3F ; ;
%
6
66%)_%8%8%=%=NHd z++-- 6 %K%(*6 6 6
$
$
${ !-7
c* ://11 : "L *>),j : : : !
6
6
6
6
6
6
6 $HHH
$
6
6
6
6
6
6
6
6
6
6
6
6
6
6
6& #Z1 1 1 1 j040000K% 1sR "=
A
A D B$40D$A
D .D;D =D?D DDD) r r r r) r1 r r ry r r r r s @r r r [ s
) ) ) (1 (1 (1 (1 (1 (1 (1r r c R e Zd Z d Zd Zd Zd Zd Zd Zd Z d Z
d Z d
Z d Z
d S )
r c " i | _ d | _ d S r )r _saved_sighandlerr s r r) z MultiLoopChildWatcher.__init__ s !% r c | j d uS r )r r s r rv z MultiLoopChildWatcher.is_active s %T11r c | j | j d S t j t j }|| j k rt j d n$t j t j | j d | _ d S )Nz+SIGCHLD handler was changed by outside code) r r9 r rI getsignalr r r r` )r+ rd s r r1 zMultiLoopChildWatcher.close s| ! ) F"6>22 dn $ $ NH I I I I M&.$*@ A A A!% r c | S r r r s r r z MultiLoopChildWatcher.__enter__ r r c d S r r r+ r exc_valexc_tbs r r z MultiLoopChildWatcher.__exit__ r r c p t j }|||f| j |< | | d S r )r get_running_loopr r )r+ r rU rV r s r ry z'MultiLoopChildWatcher.add_child_handler s? &(( $h 5
r c : | j |= dS # t $ r Y dS w xY wr r r s r r z*MultiLoopChildWatcher.remove_child_handler r r c | j d S t j t j | j | _ | j %t j d t j | _ t j t j d d S )NzaPrevious SIGCHLD handler was set by non-Python code, restore to default handler on watcher close.F)r rI r r r r` rc rQ r s r r z!MultiLoopChildWatcher.attach_loop sw
! - F!' v~t~!N!N ! ) N J
K
K
K%+^D " FNE22222r c ^ t | j D ]}| | d S r r r s r r z%MultiLoopChildWatcher._do_waitpid_all s< (( " "C S ! ! ! ! " "r c 4 t j |t j \ }}|dk rd S t | }d}n+# t $ r |}d}t j d| d}Y nw xY w | j | \ }}}| rt j d|| d S |r*|
rt j d|| |j |||g|R d S # t $ r t j d|d Y d S w xY w)
Nr Tr r F%Loop %r that handles pid %r is closedr r r: )r! r r r" r r r` r r is_closedr r r r` ) r+ r r r$ r debug_logr rU rV s r r z!MultiLoopChildWatcher._do_waitpid s *\2:>>KC axx/77J II ! C J NJ
III L#'?#6#6s#;#; D(D ~~
L FcRRRRR ; !1!1 ;L!G!-z; ; ;))(CKdKKKKKK / / /
ND
/
/
/
/
/
/
/ /s! "> %A&%A&* C2 2!DDc | d S # t t f$ r t $ r t j dd Y d S w xY w)Nr Tr: )r r| r} r~ r r` )r+ r r s r r z MultiLoopChildWatcher._sig_chld8 sy R " " " " " -. R R R NAD Q Q Q Q Q Q Q Rs 1A
A
N)r r r r) rv r1 r r ry r r r r r r r r r r s $& & &2 2 2
&
&
&
3 3 3"" " "#L #L #LJR R R R Rr r c Z e Zd Z d Zd Zd Zd Zd Zej fdZ
d Z d Z d Z
d
Zd S ) r c F t j d | _ i | _ d S r ) itertoolsr _pid_counter_threadsr s r r) z ThreadedChildWatcher.__init__N s %OA . .
r c dS rB r r s r rv z ThreadedChildWatcher.is_activeR rk r c d S r r r s r r1 zThreadedChildWatcher.closeU r r c | S r r r s r r z ThreadedChildWatcher.__enter__X r r c d S r r r s r r z ThreadedChildWatcher.__exit__[ r r c d t | j D }|r || j dt | d S d S )Nc : g | ]}| |S r )is_alive).0threads r
z0ThreadedChildWatcher.__del__.._ s6 ) ) )f oo'')6 ) ) )r z0 has registered but not finished child processesr/ )r4 r r r- r8 )r+ r4 threadss r r5 z ThreadedChildWatcher.__del__^ s} ) )T]-A-A-C-C(D(D ) ) ) ET^UUU!
r c t j }t j | j dt | j ||||fd }|| j |< | d S )Nzasyncio-waitpid-T)targetnamerV daemon) r r r Threadr nextr r start)r+ r rU rV r r s r ry z&ThreadedChildWatcher.add_child_handlerf sp &((!)9'S$t?P:Q:Q'S'S(,c8T'B)-/ / / $
c r c dS rB r r s r r z)ThreadedChildWatcher.remove_child_handlero s tr c d S r r r s r r z ThreadedChildWatcher.attach_loopu r r c t j |d \ }}t | }| rt j d|| n)# t $ r |}d}t j d| Y nw xY w| rt j d|| n |j |||g|R | j
| d S )Nr r r r r ) r! r r" r r r r r` r r r r )r+ r r rU rV r r$ r s r r z ThreadedChildWatcher._do_waitpidx s 7 *\155KC 077J~~
7 C ):7 7 7 ! C J NJ
>> H NBD# N N N N %D %hZ G$ G G G G
,'''''s A #A:9A:N)r r r r) rv r1 r r r6 r7 r5 ry r r r r r r r r A s
%M
( ( ( ( (r r c @ e Zd Z eZ fdZd Z fdZd Zd Z xZ
S )_UnixDefaultEventLoopPolicyc V t d | _ d S r )r( r) _watcherr s r r) z$_UnixDefaultEventLoopPolicy.__init__ s$
r c t j 5 | j t | _ d d d d S # 1 swxY w Y d S r )r r r r r s r
_init_watcherz)_UnixDefaultEventLoopPolicy._init_watcher s
\ 7 7}$ 4 6 6
7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7s 599c t | | j Bt j t j u r | j | d S d S d S r )r( set_event_loopr r current_thread main_threadr )r+ r r- s r r# z*_UnixDefaultEventLoopPolicy.set_event_loop sq t$$$ M %(**i.C.E.EEE M % %d + + + + +
& %EEr c H | j | | j S r )r r! r s r ru z-_UnixDefaultEventLoopPolicy.get_child_watcher s+ = } r c V | j | j || _ d S r )r r1 )r+ r s r set_child_watcherz-_UnixDefaultEventLoopPolicy.set_child_watcher s. 2 = $ M ! ! !
r ) r r r r&
_loop_factoryr) r! r# ru r( r r s @r r r s D*M 7 7 7
, , , , , r r )2rS r r r! r rI r r r} r2 r r6 r r r r r r r
r r r
logr __all__rP ImportErrorr r" BaseSelectorEventLoopr&
ReadTransportrj _FlowControlMixinWriteTransportrr BaseSubprocessTransportrx r r r r r r r BaseDefaultEventLoopPolicyr r r r r r r4 s 8
<7
+C
D
DD
N" N" N" N" N"_ B N" N" N"b M M M M M Z 5 M M M `J J J J J j : ( 7J J J Z F 0L$ L$ L$ L$ L$ L$ L$ L$^K K K K K, K K K\2 2 2 2 2+ 2 2 2jG- G- G- G- G-' G- G- G-Tf1 f1 f1 f1 f1' f1 f1 f1RzR zR zR zR zR 0 zR zR zRzO( O( O( O( O(/ O( O( O(d- - - - - &"C - - - ` + 4 r