*jp S r SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK
r
SSK r SSK r SSK
Jr SSK
Jr SSK
Jr SSK
Jr SSK
Jr SS K
Jr SS
K
Jr SS K
Jr SS K
Jr SS
K
Jr SSKJr Sr\
R6 S:X a \ " S5 eS r S r " S S\R> 5 r " S S\RB 5 r" " S S\RF \RH 5 r% " S S\RL 5 r' " S S 5 r( " S S \(5 r) " S S!\(5 r* " S" S#\*5 r+ " S$ S%\*5 r, " S& S'\(5 r- " S( S)\(5 r.S* r/ " S+ S,\R` 5 r1\ r2\1r3\2r4g)-z2Selector event loop for Unix with signal handling. N ) base_events)base_subprocess) constants)
coroutines)events)
exceptions)futures)selector_events)tasks)
transports)logger) SelectorEventLoopAbstractChildWatcherSafeChildWatcherFastChildWatcherPidfdChildWatcherMultiLoopChildWatcherThreadedChildWatcherDefaultEventLoopPolicy EventLoopwin32z+Signals are not really supported on Windowsc g)zDummy signal handler.N )signumframes :/opt/alt/python313/lib64/python3.13/asyncio/unix_events.py_sighandler_noopr + s c T [ R " U 5 $ ! [ a U s $ f = fN)oswaitstatus_to_exitcode
ValueError)statuss r r# r# 0 s. ((00
s ''c ^ \ rS rSrSrSU 4S jjrU 4S jrS rS rS r S r
S
r S S jr S S jr
SS
jrS r SSSSSSS.S jjr SSSSSSSSS.S jjrS rS rS rS rU 4S jrSrU =r$ ) _UnixSelectorEventLoop: z\Unix event loop.
Adds signal handling and UNIX Domain Socket support to
SelectorEventLoop.
Nc @ > [ TU ] U5 0 U l 0 U l g r! )super__init___signal_handlers_unix_server_sockets)selfselector __class__s r r+ _UnixSelectorEventLoop.__init__A s
" " $&!r c H > [ TU ] 5 [ R " 5 ( d. [ U R
5 H nU R
U5 M g U R
( a: [ R " SU < S3[ U S9 U R
R 5 g g )NzClosing the loop z@ on interpreter shutdown stage, skipping signal handlers removalsource) r* closesys
is_finalizinglistr, remove_signal_handlerwarningswarnResourceWarningclear)r. sigr0 s r r5 _UnixSelectorEventLoop.closeF s
""D 1 12**3/ 3 $$
1$ :H I .%) +
%%++-
%r c J U H nU( d M U R U5 M g r! )_handle_signal)r. datar s r _process_self_data)_UnixSelectorEventLoop._process_self_dataT s F ' r c [ R " U5 ( d [ R " U5 ( a [ S5 eU R U5 U R 5 [ R " U R R 5 5 [ R " X#U S5 nXPR U' [ R " U[" 5 [ R$ " US5 g! [ [ 4 a n[ [ U5 5 eSnAff = f! [ a nU R U U R ( dL [ R " S5 O4! [ [ 4 a! n[& R( " SU5 SnAOSnAff = fUR* [* R, :X a [ SU S35 ee SnAff = f)zAdd a handler for a signal. UNIX only.
Raise ValueError if the signal number is invalid or uncatchable.
Raise RuntimeError if there is a problem setting up the handler.
z3coroutines cannot be used with add_signal_handler()NF 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_handler)_UnixSelectorEventLoop.add_signal_handler[ ss
" "8 , ,..x88 8 9
9 3 )
!3!3!5 6 xtT:%+ c"
MM# / 0
U + G$ ) s3x( ( ) %%c*((F((,"G, FKK >EEF yyELL("T#.?#@AA sZ $.C, 92D ,D<DD
F?" F:EF:F (F?F:F 1F::F?c U R R U5 nUc gUR ( a U R U5 gU R U5 g)z2Internal helper that is the actual signal handler.N)r, get
_cancelledr9 _add_callback_signalsafe)r. r> r^ s r rA %_UnixSelectorEventLoop._handle_signal sE &&**3/ > & &s + ) )& 1r c 4 U R U5 U R U U[ R :X a [ R
nO[ R n [ R " X5 U R ( d [ R " S5 gg! [ a gf = f! [ a3 nUR [ R :X a [ SU S35 ee SnAff = f! [ [ 4 a! n[ R " SU5 SnAgSnAff = f)zgRemove a handler for a signal. UNIX only.
Return True if a signal handler was removed, False if not.
FrH rI NrF rG T)rM r, KeyErrorrO SIGINTdefault_int_handlerSIG_DFLrS rY rZ rT rP r$ r rX )r. r> handlerr] s r r9 ,_UnixSelectorEventLoop.remove_signal_handler s
3 %%c* &-- 00G nnG MM# ' $$
A$$R( - yyELL("T#.?#@AA (
A :C@@
AsA
B B& >C&
B#"B#&
C#0.C C#&D6DDc [ U[ 5 ( d [ SU< 35 eU[ R " 5 ; a [ SU 35 eg)zInternal helper to validate a signal.
Raise ValueError if the signal number is invalid or uncatchable.
Raise RuntimeError if there is a problem setting up the handler.
zsig must be an int, not zinvalid signal number N)
isinstanceintrL rO
valid_signalsr$ )r. r> s r rM $_UnixSelectorEventLoop._check_signal sM #s## 6sg >? ? f**, , 5cU ;< < -r c [ XX#U5 $ r! )_UnixReadPipeTransportr. pipeprotocolwaiterextras r _make_read_pipe_transport0_UnixSelectorEventLoop._make_read_pipe_transport s %d(EJJr c [ XX#U5 $ r! )_UnixWritePipeTransportru s r _make_write_pipe_transport1_UnixSelectorEventLoop._make_write_pipe_transport s &t8UKKr c # [ R " 5 [ R " S[ 5 [ R
" 5 n
S S S 5 W
U
R
5 ( d [ S5 eU R 5 n [ XX#XEXg4XS.U D6n U
R U R 5 U R U 5 U I S h vN S S S 5 U $ ! , ( d f N= f N ! [ [ 4 a e [ a+ U R! 5 U R# 5 I S h vN e f = f! , ( d f W $ = f7f)NignorezRasyncio.get_child_watcher() is not activated, subprocess support is not installed.)rx ry )r: catch_warnings simplefilterDeprecationWarningr get_child_watcher is_activerT
create_future_UnixSubprocessTransportadd_child_handlerget_pid_child_watcher_callback
SystemExitKeyboardInterrupt
BaseExceptionr5 _wait)
r. rw r\ shellstdinstdoutstderrbufsizery kwargswatcherrx transps
r _make_subprocess_transport1_UnixSelectorEventLoop._make_subprocess_transport s)
$
$
& ! !(,> ? ..0G ' $$&&
# $G H H'')F-dd,166396 /56F
% %fnn&6$($@$@&
J
! 0
9 '
&( 12
lln$$
' W0
se E1C
EA-D1C)C'C)
E
C$ E'C))=D.&D)'D..D11
E ;Ec < U R UR U5 g r! )call_soon_threadsafe_process_exited)r. pid
returncoder s r r ._UnixSelectorEventLoop._child_watcher_callback s !!&"8"8*Er )sslsockserver_hostnamessl_handshake_timeoutssl_shutdown_timeoutc # Ub [ U[ 5 ( d eU( a Uc [ S5 eO*Ub [ S5 eUb [ S5 eUb [ S5 eUb Ub [ S5 e[ R " U5 n[
R
" [
R [
R S5 n UR S5 U R XB5 I S h vN OjUc [ S5 eUR [
R :w d UR [
R :w a [ S U< 35 eUR S5 U R XAX5UUS
9I S h vN u pX4$ N! UR 5 e = f N!7f) 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 )ro rU r$ r" fspathsocketAF_UNIX SOCK_STREAM setblocking sock_connectr5 familytype _create_connection_transport)
r. protocol_factorypathr r r r r transportrw s
r create_unix_connection-_UnixSelectorEventLoop.create_unix_connection s &*_c*J*JJJ & EG G ' * !NOO$0 GI I#/ FH H IK K 99T?D== 1C1CQGD
'''333 | !BCC v~~-II!3!33 DTHMO O U #$($E$E C"7!5 %F %7 7 ""% 4
7s= B6F9%E/ E- E/ #B F#F$ F-E/ /FFd T)r backlogr r r
start_servingcleanup_socketc # [ U[ 5 ( a [ S5 eUb U( d [ S5 eUb U( d [ S5 eUb Ub [ S5 e[ R
" U5 n[ R " [ R [ R 5 nUS S; aP [ R " [ R " U5 R 5 ( a [ R " U5 UR# U5 OYUc [ S
5 eUR* [ R :w d UR, [ R :w a [ S U< 35 eU ( aG UR/ 5 nUS S; a. [ R " U5 R0 U R2 U' UR5 S 5 [6 R8 " X/UXTUU5 n
U( a. U
R; 5 [< R> " S5 I S h vN U
$ ! [ a GN*[ a" n
[ R " SX*5 S n
A
GNPS n
A
ff = f! [ aV n UR% 5 U R& [& R( :X a" SU< S 3n [ [& R( U 5 S ee S n A f UR% 5 e = f! [ a GN f = f N7f)
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) ro boolrL r$ r" r r r r statS_ISSOCKst_moderemoveFileNotFoundErrorrS r errorbindr5 rY
EADDRINUSEr r getsocknamest_inor- r r Server_start_servingr sleep)r. r r r r r r r r r errr] msgservers r create_unix_server)_UnixSelectorEventLoop.create_unix_server s c4 HI I ,S CE
E +C BD
D IK K 99T?D== 1C1CDD Awk)6}}RWWT]%:%:;; $
$ | CE E v~~-II!3!33 DTHMO O ##%DAwk)68ggdm6J6JD--d3
##D&2B$'2G$8: ! ! # ++a.
e ) 6LL "*+/6 66
99 0 00 %TH,>?C!%"2"2C8dB
" )
!s B.K 1AH I A:K
-K :A K K K
I'K * I3I
K IK
K "AJ33K K
KK KK c
# [ R UR 5 n [ R " U5 R nU( a UOUnU( d gU R 5 n U R U S XX4US5 U I S h vN $ ! [ a [ R " S5 ef = f! [ [ R 4 a n[ R " S5 eS nAff = f! [ a [ R " S5 ef = f N7f)Nz os.sendfile() is not availableznot a regular filer )
r" sendfileAttributeErrorr SendfileNotAvailableErrorrR ioUnsupportedOperationfstatst_sizerS r _sock_sendfile_native_impl)
r. r fileoffsetcountrR r fsize blocksizefuts
r _sock_sendfile_native,_UnixSelectorEventLoop._sock_sendfile_nativen s 2 KK M[[]F MHHV$,,E #E " ''T4(.y! Ey% 2 6602
2 2
7 78 M 667KL L M M 667KL L M sV D B B- C% >D D D !B**D -C"C C""D %!DD c
UR 5 n Ub U R U5 UR 5 ( a U R XE5 g U( a- Xh-
nUS:: a# U R XE5 UR U5 g [ U[ R S- S- 5 n [ R " XXW5 n
U
S:X a# U R XE5 UR U5 g XZ-
nX-
nUc U R X5 U R XR UXUXVXx5
g ! [ [ 4 a7 Uc U R X5 U R XR UXUXVXx5
g [ a n UbR U R [ R" :X a4 [% U 5 [& La" [' S[ R" 5 n Xl U n US:X a= [* R, " S5 n
U R XE5 UR/ U
5 S n A g U R XE5 UR/ U 5 S n A g S n A f[0 [2 4 a e [4 a, n U R XE5 UR/ U 5 S n A g S n A ff = f)Nr r zsocket is not connectedzos.sendfile call failed)rR
remove_writer cancelled _sock_sendfile_update_filepos
set_resultminr6 maxsizer" r _sock_add_cancellation_callback
add_writerr BlockingIOErrorInterruptedErrorrS rY ENOTCONNr ConnectionError __cause__r r
set_exceptionr r r )r. r
registered_fdr rR r r r
total_sentfdsentr] new_excr s r r 1_UnixSelectorEventLoop._sock_sendfile_native_impl s5
[[] $
} - ==?? . .v > *IA~226Bz* 3;;>A#56 1 F;;r6=DJ qy226Bz*"
(88C$C$CS "& &yF[ !12 B $44S? OOB ? ? f "9
B ' )II /I_4
*-u~~?$'! Q
!::-/226B!!#&&226B!!#&& -. # . .v > c " " #s2 !D AI5$ I5-BH,"H,, I5 "I00I5c N [ R " X[ R 5 g r! )r" lseekSEEK_SET)r. rR r s r r 4_UnixSelectorEventLoop._sock_sendfile_update_filepos s
-r c 8 ^ ^ U U4S jnUR U5 g )Nc > U R 5 ( a) TR 5 nUS:w a TR U5 g g g )NrF )r rR r )r r r. r s r cbB_UnixSelectorEventLoop._sock_add_cancellation_callback..cb s8 }}[[]8&&r* r )add_done_callback)r. r r r s ` ` r r 6_UnixSelectorEventLoop._sock_add_cancellation_callback s +
b!r c > XR ; a UR 5 nOS n[ TU ]
U5 UbY U R U nU R U [ R
" U5 R U:X a [ R " U5 g g g ! [ a g [ a! n[ R " SX$5 S nAg S nAff = f)Nz/Unable to clean up listening UNIX socket %r: %r) r- r r*
_stop_servingr" r r unlinkr rS r r )r. r r prev_inor r0 s r r $_UnixSelectorEventLoop._stop_serving s ,, ,##%DD
d# 006H))$/
2774=''83IIdO 4 %
2 &'+2 2
2s :B
C C%CC)r, r- r! NN)__name__
__module__ __qualname____firstlineno____doc__r+ r5 rC r` rA r9 rM rz r~ r r r r r r r r r __static_attributes__
__classcell__r0 s @r r' r' : s '
. (+Z2 @
= @D(,K AE)-L 04 BF *.0#4 "&!% 0#f *.Ps"&!% t Pd.GFR."2 2r r' c ^ \ rS rSrSrSU 4S jjrS rS rS rS r S r
S r S
r S r
S rS
r\R" 4S jrSS jrS rS rSrU =r$ )rt i i c V > [ TU ] U5 X R S' Xl X l UR 5 U l X0l SU l SU l [ R " U R 5 R n[ R " U5 ( dV [ R " U5 ( d; [ R " U5 ( d S U l S U l S U l [# S5 e[ R$ " U R S5 U R R' U R R( U 5 U R R' U R* U R U R, 5 Ub, U R R' [. R0 US 5 g g )Nrv Fz)Pipe transport is for pipes/sockets only.)r* r+ _extra_loop_piperR _fileno _protocol_closing_pausedr" r r r S_ISFIFOr S_ISCHRr$ set_blocking call_soonconnection_made _add_reader _read_readyr
_set_result_unless_cancelled)r. looprv rw rx ry moder0 s r r+ _UnixReadPipeTransport.__init__ s/
" F
{{} !
xx %--
d##
d## T"" DJ DL !DN HI I
e,
T^^ ; ;TB
T - - !\\4+;+; = JJ !E!E!'
/ r c f U R 5 ( d g U R R X5 g r! )
is_readingr r )r. r r[ s r r "_UnixReadPipeTransport._add_reader s$
r,r c T U R ( + =( a U R ( + $ r! )r r r. s r r% !_UnixReadPipeTransport.is_reading s << 5
$55r c U R R /nU R c UR S5 O"U R ( a UR S5 UR SU R
35 [
U R SS 5 nU R b] UbZ [ R " X R
[ R 5 nU( a UR S5 OBUR S5 O0U R b UR S5 OUR S5 SR S R U5 5 $ )
Nclosedclosingfd= _selectorpollingidleopen<{}> )r0 r r appendr r getattrr r _test_selector_event selectors
EVENT_READformatjoin)r. rX r/ r/ s r __repr__ _UnixReadPipeTransport.__repr__ s ''( :: KK !
]] KK " c$,, ()4::{D9 :: !h&:%::,, (<(<>G I& F#
ZZ
# KK KK !}}SXXd^,,r c [ R " U R U R 5 nU( a U R R U5 g U R R 5 ( a [ R " SU 5 SU l
U R R U R 5 U R R U R R 5 U R R U R S 5 g ! [ [ 4 a g [" a nU R% US5 S nAg S nAff = f)N%r was closed by peerTz"Fatal read error on pipe transport)r" readr max_sizer
data_receivedr get_debugr rX r _remove_readerr eof_received_call_connection_lostr r rS _fatal_error)r. rB r] s r r "_UnixReadPipeTransport._read_ready/ s G774<< 7D ,,T2::''))KK 7> $
))$,,7
$$T^^%@%@A
$$T%?%?F !12 I c#G H H Is +D D? D?#D::D?c U R 5 ( d g SU l U R R U R 5 U R R 5 ( a [ R " SU 5 g g )NTz%r pauses reading)r% r r rC r rB r debugr( s r
pause_reading$_UnixReadPipeTransport.pause_readingA sV
!!$,,/ :: ! ! LL,d 3 "r c & U R ( d U R ( d g SU l U R R U R U R
5 U R R
5 ( a [ R " SU 5 g g )NFz%r resumes reading) r r r r r r rB r rI r( s r resume_reading%_UnixReadPipeTransport.resume_readingI s^ ==
t||T-=-=> :: ! ! LL-t 4 "r c Xl g r! r r. rw s r set_protocol#_UnixReadPipeTransport.set_protocolQ !r c U R $ r! rP r( s r get_protocol#_UnixReadPipeTransport.get_protocolT ~~ r c U R $ r! r r( s r
is_closing!_UnixReadPipeTransport.is_closingW }} r c J U R ( d U R S 5 g g r! )r _closer( s r r5 _UnixReadPipeTransport.closeZ s }} KK r c t U R b+ U" SU < 3[ U S9 U R R 5 g g Nzunclosed transport r3 r r< r5 r. _warns r __del__ _UnixReadPipeTransport.__del__^ 5 :: ! 'x0/$ O JJ "r c L [ U[ 5 ( aT UR [ R :X a6 U R R 5 ( a [ R " SXSS9 O*U R R UUU U R S.5 U R U5 g Nz%r: %sTexc_info)message exceptionr rw ) ro rS rY EIOr rB r rI call_exception_handlerr r_ r. r] rm s r rF #_UnixReadPipeTransport._fatal_errorc sw sG $ $eii)?zz##%% XttD JJ - -" ! NN /
Cr c SU l U R R U R 5 U R R U R
U5 g NT)r r rC r r rE r. r] s r r_ _UnixReadPipeTransport._closeq s9
!!$,,/
T 7 7=r c U R R U5 U R R 5 S U l S U l S U l g ! U R R 5 S U l S U l S U l f = fr! r connection_lostr r5 r ru s r rE ,_UnixReadPipeTransport._call_connection_lostv g NN * *3 / JJ DJ !DN DJ
JJ DJ !DN DJ A
1A>)r r r r r r r z Fatal error on pipe transport)r r r
r r@ r+ r r% r; r rJ rM rR rV r[ r5 r: r; rf rF r_ rE r
r r s @r rt rt sb H /<-
6-*G$45" %MM
>
r rt c ^ \ rS rSrSU 4S jjrS rS rS rS rS r S r
S r S
r S r
S rS
r\R" 4S jrS rSS jrSS jrS rSrU =r$ )r} i c > [ T
U ] XQ5 X R S' X l UR 5 U l X0l [ 5 U l SU l SU l
[ R " U R
5 R n[ R " U5 n[ R " U5 n[ R" " U5 n U( d. U( d' U ( d S U l S U l S U l [% S5 e[ R& " U R
S5 U R( R+ U R R, U 5 U ( d+ U( ai [. R0 R3 S5 ( dE U R( R+ U R( R4 U R
U R6 5 Ub, U R( R+ [8 R: US 5 g g )Nrv r Fz?Pipe transport is only for pipes, sockets and character devicesaix) r* r+ r r rR r r bytearray_buffer
_conn_lostr r" r r r r r r r$ r r r r r6 platform
startswithr r r
r ) r. r! rv rw rx ry r" is_charis_fifo is_socketr0 s r r+ _UnixWritePipeTransport.__init__ sd
% " F
{{} ! {
xx %--,,t$--%MM$' 7i DJ DL !DN D E
E e,
T^^ ; ;TB
)@)@)G)G JJ !7!7!% t/?/?
A JJ !E!E!'
/ r c U R R /nU R c UR S5 O"U R ( a UR S5 UR SU R
35 [
U R SS 5 nU R b Ub~ [ R " X R
[ R 5 nU( a UR S5 OUR S5 U R 5 nUR SU 35 O0U R b UR S5 OUR S5 S R S
R U5 5 $ ) Nr+ r, r- r. r/ r0 zbufsize=r1 r2 r3 )r0 r r r4 r r r5 r r r6 r7 EVENT_WRITEget_write_buffer_sizer9 r: )r. rX r/ r/ r s r r; _UnixWritePipeTransport.__repr__ s ''( :: KK !
]] KK " c$,, ()4::{D9 :: !h&:%::,, (=(=?G I& F#002G KK(7), -
ZZ
# KK KK !}}SXXd^,,r c , [ U R 5 $ r! )lenr r( s r r -_UnixWritePipeTransport.get_write_buffer_size s 4<< r c U R R 5 ( a [ R " SU 5 U R ( a U R [
5 5 g U R 5 g )Nr> )r rB r rX r r_ BrokenPipeErrorr( s r r #_UnixWritePipeTransport._read_ready sC :: ! ! KK/ 6 << KK) * KKMr c [ U[ [ [ 45 ( d [ U5 5 e[ U[ 5 ( a [ U5 nU( d g U R
( d U R ( aJ U R
[ R : a [ R " S5 U =R
S-
sl g U R ( dv [ R " U R U5 nU[+ U5 :X a g US: a [ U5 US nU R, R/ U R U R0 5 U =R U-
sl U R3 5 g ! [ [ 4 a Sn N[" [$ 4 a e [& a1 nU =R
S-
sl U R) US5 S nAg S nAff = f)Nz=pipe closed by peer or os.write(pipe, data) raised exception.r r #Fatal write error on pipe transport)ro bytesr
memoryviewreprr r r !LOG_THRESHOLD_FOR_CONNLOST_WRITESr warningr r" writer r r r r r rF r r _add_writer _write_ready_maybe_pause_protocol)r. rB nr] s r r _UnixWritePipeTransport.write s] $ : >??KdK? dI & & d#D ??dmm)"M"MM H I OOq O ||
HHT\\40 CI~Q!$'+ JJ " "4<<1B1B C ""$ $%56
12
1$!!#'LM
s !E2 2GG 'G Gc T U R ( d S5 e [ R " U R U R 5 nU[ U R 5 :X a U R R 5 U R R U R 5 U R 5 U R ( a6 U R R U R 5 U R S 5 g US: a U R S U2 g g ! [ [ 4 a g [ [ 4 a e [ ap nU R R 5 U =R" S-
sl U R R U R 5 U R% US5 S nAg S nAff = f)NzData should not be emptyr r r )r r" r r r r= r _remove_writer_maybe_resume_protocolr rC rE r r r r r r rF )r. r r] s r r $_UnixWritePipeTransport._write_ready s@ ||7 77| % t||4A C %% ""$
))$,,7++-==JJ--dll;..t4QLL!$ ) !12 -. J LL OOq O
JJ % %dll 3 c#H I I
Js +D F' F'7A&F""F'c grt r r( s r
can_write_eof%_UnixWritePipeTransport.can_write_eof r c U R ( a g U R ( d eSU l U R ( dL U R R U R
5 U R R
U R S 5 g g rt )r r r r rC r r rE r( s r write_eof!_UnixWritePipeTransport.write_eof s[ == zzz
|| JJ % %dll 3 JJ !;!;T B r c Xl g r! rP rQ s r rR $_UnixWritePipeTransport.set_protocol rT r c U R $ r! rP r( s r rV $_UnixWritePipeTransport.get_protocol rX r c U R $ r! rZ r( s r r[ "_UnixWritePipeTransport.is_closing r] r c d U R b# U R ( d U R 5 g g g r! )r r r r( s r r5 _UnixWritePipeTransport.close s$ :: !$-- NN +8 !r c t U R b+ U" SU < 3[ U S9 U R R 5 g g rb rc rd s r rf _UnixWritePipeTransport.__del__% rh r c & U R S 5 g r! )r_ r( s r abort _UnixWritePipeTransport.abort* s Dr c [ U[ 5 ( a6 U R R 5 ( a [ R
" SXSS9 O*U R R
UUU U R S.5 U R U5 g rj ) ro rS r rB r rI rp r r_ rq s r rF $_UnixWritePipeTransport._fatal_error- sh c7 # #zz##%% XttD JJ - -" ! NN /
Cr c H SU l U R ( a% U R R U R 5 U R R 5 U R R
U R 5 U R R U R U5 g rt ) r r r r r r= rC r rE ru s r r_ _UnixWritePipeTransport._close; sf
<< JJ % %dll 3
!!$,,/
T 7 7=r c U R R U5 U R R 5 S U l S U l S U l g ! U R R 5 S U l S U l S U l f = fr! rx ru s r rE -_UnixWritePipeTransport._call_connection_lostC r{ r| )r r r r r r r r r} r! )r r r
r r+ r; r r r r r r rR rV r[ r5 r: r; rf r rF r_ rE r
r r s @r r} r} si #/J-0!!%F%8C"
%MM
> r r} c \ rS rSrS rSrg)r iM c
S nU[ R :X a; [ R R S5 ( a [
R " 5 u p8 [ R " U4X#XESUS.UD6U l Ub: UR 5 [ UR 5 SUS9U R l S nUb! UR 5 UR 5 g g ! Ub! UR 5 UR 5 f f = f)Nr F)r r r r universal_newlinesr wb) buffering)
subprocessPIPEr6 r r r
socketpairPopen_procr5 r1 detachr ) r. r\ r r r r r r stdin_ws r _start _UnixSubprocessTransport._startO s JOO # (?(?(F(F
$ . . 0NE #))E !v#('E=CEDJ "
#'(8$'#R
"
#w"
#s
A C &C<)r N)r r r
r r r
r r r r r M s r r c L \ rS rSrSrS
S jrS rS rS rS r S r
S
r S r S r
g)r ie a Abstract base class for monitoring child processes.
Objects derived from this class monitor a collection of subprocesses and
report their termination or interruption by a signal.
New callbacks are registered with .add_child_handler(). Starting a new
process must be done within a 'with' block to allow the watcher to suspend
its activity until the new process if fully registered (this is needed to
prevent a race condition in some implementations).
Example:
with watcher:
proc = subprocess.Popen("sleep 1")
watcher.add_child_handler(proc.pid, callback)
Notes:
Implementations of this class must be thread-safe.
Since child watcher objects may catch the SIGCHLD signal and call
waitpid(-1), there should be only one active object per process.
Nc Z U R [ :w a [ R " SSSS9 g g )Nr P{name!r} is deprecated as of Python 3.12 and will be removed in Python {remove}. r )r r r: _deprecated)clss r __init_subclass__&AbstractChildWatcher.__init_subclass__| s, >>X % !7 ;%,
. &r c [ 5 e)zRegister a new child handler.
Arrange for callback(pid, returncode, *args) to be called when
process 'pid' terminates. Specifying another callback for the same
process replaces the previous handler.
Note: callback() must be thread-safe.
NotImplementedErrorr. r r[ r\ s r r &AbstractChildWatcher.add_child_handler s
"##r c [ 5 e)zRemoves the handler for process 'pid'.
The function returns True if the handler was successfully removed,
False if there was nothing to remove.r r. r s r remove_child_handler)AbstractChildWatcher.remove_child_handler s
"##r c [ 5 e)zAttach the watcher to an event loop.
If the watcher was previously attached to an event loop, then it is
first detached before attaching to the new loop.
Note: loop may be None.
r r. r! s r attach_loop AbstractChildWatcher.attach_loop s
"##r c [ 5 e)z\Close the watcher.
This must be called to make sure that any underlying resource is freed.
r r( s r r5 AbstractChildWatcher.close s
"##r c [ 5 e)zReturn ``True`` if the watcher is active and is used by the event loop.
Return True if the watcher is installed and ready to handle process exit
notifications.
r r( s r r AbstractChildWatcher.is_active s
"##r c [ 5 e)z\Enter the watcher's context and allow starting new processes
This function must return selfr r( s r __enter__ AbstractChildWatcher.__enter__ s
"##r c [ 5 e)zExit the watcher's contextr r. abcs r __exit__ AbstractChildWatcher.__exit__ s !##r r )returnN)r r r
r r r r r r r5 r r r r
r r r r r e s/ ,. $$$$$$ $r r c H \ rS rSrSrS rS rS rS rS r S r
S r S
r S r
g )
r i a Child watcher implementation using Linux's pid file descriptors.
This child watcher polls process file descriptors (pidfds) to await child
process termination. In some respects, PidfdChildWatcher is a "Goldilocks"
child watcher implementation. It doesn't require signals or threads, doesn't
interfere with any processes launched outside the event loop, and scales
linearly with the number of subprocesses launched by the event loop. The
main disadvantage is that pidfds are specific to Linux, and only work on
recent (5.3+) kernels.
c U $ r! r r( s r r PidfdChildWatcher.__enter__ r c g r! r )r. exc_type exc_value
exc_tracebacks r r PidfdChildWatcher.__exit__ r c grt r r( s r r PidfdChildWatcher.is_active r r c g r! r r( s r r5 PidfdChildWatcher.close r r c g r! r r s r r PidfdChildWatcher.attach_loop r r c [ R " 5 n[ R " U5 nUR XPR
XX#5 g r! )r get_running_loopr"
pidfd_openr _do_wait)r. r r[ r\ r! pidfds r r #PidfdChildWatcher.add_child_handler s4 &&(
c"
s8Jr c * [ R " 5 nUR U5 [ R " US5 u pg[ U5 n[ R " U5 U" X/UQ76 g ! [ a Sn[ R " SU5 NEf = f)Nr zJchild process pid %d exit status already read: will report returncode 255)
r r rC r" waitpidr# ChildProcessErrorr r r5 ) r. r r r[ r\ r! _r% r s r r PidfdChildWatcher._do_wait s &&( E" 8
3*IA 07J
(4( ! J NN.
s A, ,#BBc grt r r s r r &PidfdChildWatcher.remove_child_handler r r N)r r r
r r r r r r5 r r r r r
r r r r r s0
K
)&r r c > \ rS rSrS rS rS rS rS rS r S r
S r g
) BaseChildWatcheri c S U l 0 U l g r! )r
_callbacksr( s r r+ BaseChildWatcher.__init__ s
r c & U R S 5 g r! )r r( s r r5 BaseChildWatcher.close s r c ` U R S L=( a U R R 5 $ r! )r
is_runningr( s r r BaseChildWatcher.is_active s# zz%A$***?*?*AAr c [ 5 er! r )r. expected_pids r _do_waitpid BaseChildWatcher._do_waitpid !##r c [ 5 er! r r( s r _do_waitpid_all BaseChildWatcher._do_waitpid_all r! r c Ub! [ U[ R 5 ( d eU R b/ Uc, U R ( a [
R " S[ 5 U R b) U R R [ R 5 Xl Ub; UR [ R U R 5 U R 5 g g )NzCA loop is being detached from a child watcher with pending handlers)ro r AbstractEventLoopr r r: r; RuntimeWarningr9 rO SIGCHLDr` _sig_chldr# r s r r BaseChildWatcher.attach_loop s |z$0H0H I III :: !dlt MM=
:: ! JJ , ,V^^ <
# #FNNDNN C
" r c U R 5 g ! [ [ 4 a e [ a( nU R R SUS.5 S nAg S nAff = f)N$Unknown exception in SIGCHLD handler)rm rn )r# r r r r rp ru s r r) BaseChildWatcher._sig_chld sX " -.
JJ - -A /
s A AA)r r N) r r r
r r+ r5 r r r# r r) r
r r r r r s& B$$#( r r c \ ^ \ rS rSrSrU 4S jrU 4S jrS rS rS r S r
S r S
r S r
U =r$ ) r i* aL 'Safe' child watcher implementation.
This implementation avoids disrupting other code spawning processes by
polling explicitly each process in the SIGCHLD handler instead of calling
os.waitpid(-1).
This is a safe solution but it has a significant overhead when handling a
big number of children (O(n) each time SIGCHLD is raised)
c N > [ TU ] 5 [ R " SSSS9 g )Nr r r r )r* r+ r: r r. r0 s r r+ SafeChildWatcher.__init__5 s'
/ ;%, .r c V > U R R 5 [ TU ]
5 g r! )r r= r* r5 r0 s r r5 SafeChildWatcher.close< s
r c U $ r! r r( s r r SafeChildWatcher.__enter__@ r r c g r! r r s r r SafeChildWatcher.__exit__C r r c F X#4U R U' U R U5 g r! )r r r s r r "SafeChildWatcher.add_child_handlerF s# ( /
r c @ U R U g! [ a gf = fNTFr rh r s r r %SafeChildWatcher.remove_child_handlerL ( $
c ^ [ U R 5 H nU R U5 M g r! r8 r r r s r r# SafeChildWatcher._do_waitpid_allS s# (C S ! )r c & US: d e [ R " U[ R 5 u p#US:X a g [ U5 nU R R 5 ( a [ R " SX5 U R R U5 u pVU" X$/UQ76 g ! [ a UnSn[ R " SU5 NOf = f! [ a: U R R 5 ( a [ R " SUSS9 g g f = f)Nr $process %s exited with returncode %sr 8Unknown child process pid %d, will report returncode 255'Child watcher got an unexpected pid: %rTrk )
r" r WNOHANGr# r rB r rI r
r r poprh )r. r r r% r r[ r\ s r r SafeChildWatcher._do_waitpidX s a 7 **\2::>KC ax/7Jzz##%% C )7 - !__ 0 0 5NH
S ,t ,7 ! C J NNJ
( 3 zz##%% H "T3 & 3s# 'B! : C !%C C ?DDr )r r r
r r r+ r5 r r r r r# r r
r r s @r r r * s5 .
"
- -r r c V ^ \ rS rSrSrU 4S jrU 4S jrS rS rS r S r
S r S
r U =r
$ ) r i{ a? 'Fast' child watcher implementation.
This implementation reaps every terminated processes by calling
os.waitpid(-1) directly, possibly breaking other code spawning processes
and waiting for their termination.
There is no noticeable overhead when handling a big number of children
(O(1) each time a child terminates).
c > [ TU ] 5 [ R " 5 U l 0 U l SU l [ R " SSSS9 g )Nr r r r r ) r* r+ threadingLock_lock_zombies_forksr: r r0 s r r+ FastChildWatcher.__init__ sC
^^%
/ ;%, .r c > U R R 5 U R R 5 [ TU ] 5 g r! )r r= rO r* r5 r0 s r r5 FastChildWatcher.close s,
r c ~ U R U =R S-
sl U sS S S 5 $ ! , ( d f g = f)Nr )rN rP r( s r r FastChildWatcher.__enter__ s$
ZZ KK1 K ZZs .
<c ^ U R U =R S- sl U R ( d U R ( d
S S S 5 g [ U R 5 nU R R 5 S S S 5 [
R " SW5 g ! , ( d f N&= f)Nr z5Caught subprocesses termination from unknown pids: %s)rN rP rO rU r= r r )r. r r r collateral_victimss r r FastChildWatcher.__exit__ sp
ZZ KK1 K{{$-- Z "%T]]!3 MM ! C Zs 9B /B
B,c U R ( d S5 eU R U R R U5 n S S S 5 U" UW/UQ76 g ! [ a X#4U R
U' S S S 5 g f = f! , ( d f NA= f)Nz Must use the context manager)rP rN rO rH rh r )r. r r[ r\ r s r r "FastChildWatcher.add_child_handler s} {{: ::{
ZZ
!]] . .s 3
j(4(
'/~$
Z
Zs( A>AA;0A>:A;;A>>
B c @ U R U g! [ a gf = fr; r< r s r r %FastChildWatcher.remove_child_handler r> r? c [ R " S[ R 5 u pUS:X a g [ U5 nU R
U R R U5 u pEU R R 5 ( a [ R " SX5 S S S 5 Wc [ R " SX5 O U" X/WQ76 M ! [ a g f = f! [ af U R ( aP X0R U' U R R 5 ( a [ R " SX5 S S S 5 GME S n Nf = f! , ( d f N= f)NrF r rD z,unknown process %s exited with returncode %sz8Caught subprocess termination from unknown pid: %d -> %d)r" r rG r# r
rN r rH r rB r rI rh rP rO r )r. r r% r r[ r\ s r r# FastChildWatcher._do_waitpid_all s0
< jjRZZ 8
!8 3F ;
6%)__%8%8%=NH zz++-- %K%(6! & #1 040K %
${{-7
c* :://11 "LL *>), : ! $H
$ sN 'C E
C'6E
CCA E :EE E
E E
E )rP rN rO )r r r
r r r+ r5 r r r r r# r
r r s @r r r { s0 .
) (1 (1r r c Z \ rS rSrSrS rS rS rS rS r S r
S r S
r S r
S rS
rSrg)r i ab A watcher that doesn't require running loop in the main thread.
This implementation registers a SIGCHLD signal handler on
instantiation (which may conflict with other code that
install own handler for this signal).
The solution is safe but it has a significant overhead when
handling a big number of processes (*O(n)* each time a
SIGCHLD is received).
c L 0 U l S U l [ R " SSSS9 g )Nr r r r )r _saved_sighandlerr: r r( s r r+ MultiLoopChildWatcher.__init__ s* !% 4 ;%, .r c U R S L$ r! )ra r( s r r MultiLoopChildWatcher.is_active s %%T11r c T U R R 5 U R c g [ R " [ R
5 nXR :w a [ R " S5 O/[ R " [ R
U R 5 S U l g )Nz+SIGCHLD handler was changed by outside code) r r= ra rO getsignalr( r) r r )r. rl s r r5 MultiLoopChildWatcher.close sl ! ! ) ""6>>2 nn $ NNH I MM&..$*@*@ A!% r c U $ r! r r( s r r MultiLoopChildWatcher.__enter__ r r c g r! r r. r exc_valexc_tbs r r MultiLoopChildWatcher.__exit__ r r c r [ R " 5 nXBU4U R U' U R U5 g r! )r r r r )r. r r[ r\ r! s r r 'MultiLoopChildWatcher.add_child_handler s3 &&( $ 5
r c @ U R U g! [ a gf = fr; r< r s r r *MultiLoopChildWatcher.remove_child_handler r> r? c B U R b g [ R " [ R U R 5 U l U R c+ [ R
" S5 [ R U l [ R " [ R S5 g )NzaPrevious SIGCHLD handler was set by non-Python code, restore to default handler on watcher close.F)ra rO r( r) r r rk rW r s r r !MultiLoopChildWatcher.attach_loop& so
! ! - !' v~~t~~!N ! ! ) NN J
K%+^^D " FNNE2r c ^ [ U R 5 H nU R U5 M g r! rA r s r r# %MultiLoopChildWatcher._do_waitpid_all7 s# (C S ! )r c X US: d e [ R " U[ R 5 u p#US:X a g [ U5 nSn U R R U5 u pgnUR 5 ( a [
R " SXb5 g U( a, UR 5 ( a [
R " SX5 UR " XrU/UQ76 g ! [ a UnSn[
R " SU5 Sn Nf = f! [ a [
R " SUSS 9 g f = f)
Nr Tr rE F%Loop %r that handles pid %r is closedrD rF rk )r" r rG r# r
r r r rH is_closedrB rI r rh ) r. r r r% r debug_logr! r[ r\ s r r !MultiLoopChildWatcher._do_waitpid; s a **\2::>KC ax/7J I L#'??#6#6s#; DD ~~ FR !1!1LL!G!-;))(KdK= ! C J NNJ
I $ /
NND
/ /s# 'C D 'DD D)(D)c U R 5 g ! [ [ 4 a e [ a [ R
" SSS9 g f = f)Nr, Trk )r# r r r r r )r. r r s r r) MultiLoopChildWatcher._sig_chld` sE R " -. R NNAD Q Rs /AA)r ra N)r r r
r r r+ r r5 r r r r r r# r r) r
r r r r r sA $.2
&
3""#LJRr r c n \ rS rSrSrS rS rS rS rS r \
R 4S jr S r
S
rS rS rS
rg)r ii a% Threaded child watcher implementation.
The watcher uses a thread per process
for waiting for the process finish.
It doesn't require subscription on POSIX signal
but a thread creation is not free.
The watcher has O(1) complexity, its performance doesn't depend
on amount of spawn processes.
c H [ R " S5 U l 0 U l g )Nr ) itertoolsr _pid_counter_threadsr( s r r+ ThreadedChildWatcher.__init__v s %OOA .
r c grt r r( s r r ThreadedChildWatcher.is_activez r r c g r! r r( s r r5 ThreadedChildWatcher.close} r r c U $ r! r r( s r r ThreadedChildWatcher.__enter__ r r c g r! r rk s r r ThreadedChildWatcher.__exit__ r r c [ U R R 5 5 Vs/ s H nUR 5 ( d M UPM nnU( a U" U R S3[
U S9 g g s snf )Nz0 has registered but not finished child processesr3 )r8 r valuesis_aliver0 r< )r. re threadthreadss r rf ThreadedChildWatcher.__del__ se (,T]]-A-A-C(D )(Df oo' (D ) T^^$$TU!
)s A-A-c [ R " 5 n[ R " U R S[ U R 5 3XAX#4SS9nXPR U' UR 5 g )Nzasyncio-waitpid-T)targetnamer\ daemon) r r rL Threadr nextr r start)r. r r[ r\ r! r s r r &ThreadedChildWatcher.add_child_handler s` &&(!!)9)9)9$t?P?P:Q9R'S(,8'B)-/ $
c r c grt r r s r r )ThreadedChildWatcher.remove_child_handler r r c g r! r r s r r ThreadedChildWatcher.attach_loop r r c US: d e [ R " US5 u pV[ U5 nUR 5 ( a [ R
" SX'5 UR 5 ( a [ R " SX5 OUR " X5U/UQ76 U R R U5 g ! [ a UnSn[ R " SU5 Nf = f)Nr rD r rE rx ) r" r r# rB r rI r
r ry r r rH )r. r! r r[ r\ r r% r s r r ThreadedChildWatcher._do_waitpid s a 7 **\15KC 07J~~ C )7 >> NNBD N % %hZ G$ G
,'' ! C J NNJ
s B7 7%C C )r r N)r r r
r r r+ r r5 r r r: r; rf r r r r r
r r r r r i sB
%MM
(r r c [ [ S5 ( d g [ R " 5 n [ R " [ R " U S5 5 g! [
a gf = f)Nr Fr T)hasattrr" getpidr5 r rS )r s r
can_use_pidfdr sR 2| $ $iik
sA&' s A A
A&%A&c N ^ \ rS rSrSr\rU 4S jrS rU 4S jr S r
S r Sr U =r
$ ) _UnixDefaultEventLoopPolicyi z:UNIX event loop policy with a watcher for child processes.c 0 > [ TU ] 5 S U l g r! )r* r+ _watcherr0 s r r+ $_UnixDefaultEventLoopPolicy.__init__ s
r c [ R U R c. [ 5 ( a [ 5 U l O[ 5 U l S S S 5 g ! , ( d f g = fr! )r rN r r r r r( s r
_init_watcher)_UnixDefaultEventLoopPolicy._init_watcher s8
\\}}$ ??$5$7DM$8$:DM \\s [ TU ] U5 U R bH [ R " 5 [ R
" 5 L a U R R
U5 ggg)zSet the event loop.
As a side effect, if a child watcher was set before, then calling
.set_event_loop() from the main thread will call .attach_loop(loop) on
the child watcher.
N)r* set_event_loopr rL current_thread main_threadr )r. r! r0 s r r *_UnixDefaultEventLoopPolicy.set_event_loop sS t$ MM %((*i.C.C.EE MM % %d + F
&r c U R c U R 5 [ R " SSSS9 U R $ )znGet the watcher for child processes.
If not yet set, a ThreadedChildWatcher object is automatically created.
r r r r )r r r: r r( s r r -_UnixDefaultEventLoopPolicy.get_child_watcher s@
== 0 :BI K }} r c Ub [ U[ 5 ( d eU R b U R R 5 Xl [ R
" SSSS9 g)z$Set the watcher for child processes.Nset_child_watcherr r r )ro r r r5 r: r )r. r s r r -_UnixDefaultEventLoopPolicy.set_child_watcher sU *W6J"K"KKK == $ MM !
0 :BI Kr )r )r r r
r r r'
_loop_factoryr+ r r r r r
r r s @r r r s+ D*M ; , K Kr r )5r rY r r r" r7 rO r r r r6 rL r: r r r r r r r
r r r
logr __all__r ImportErrorr r# BaseSelectorEventLoopr'
ReadTransportrt _FlowControlMixinWriteTransportr} BaseSubprocessTransportr r r r r r r r r BaseDefaultEventLoopPolicyr r r r r r r r sj 8
<<7
C
DD
s2_ B B s2l
M Z 5 5 M `J j : : ( 7 7J Z F F 0S$ S$l7, 7t2+ 2jN-' N-bj1' j1Z~R 0 ~RBO(/ O(b 6K&"C"C 6Kr + 4 r