*jp S SK r S SKrS SKrS SKrS SKrS SKrS SKrS SKrS SKrS SK r S SK
r
S SK r SSK J
r
SSK Jr SSK Jr SSK Jr SSK Jr SSK Jr SS K Jr SS
K Jr SS K Jr SS K Jr SS
KJr Sr\ R4 S:X a \" S5 eS r S r " S S\R< 5 r " S S\R@ 5 r! " S S\RD \RF 5 r$ " S S\RJ 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 r0\ r1\0r2\1r3g), 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 N )signumframes :/opt/alt/python313/lib64/python3.13/asyncio/unix_events.py_sighandler_noopr + s c T [ R " U 5 $ ! [ a U s $ f = fr )oswaitstatus_to_exitcode
ValueError)statuss r r# r# 0 s. ((00
s ''c ^ \ rS rSrSU 4S jjrU 4S jrS rS rS rS r S r
SS
jr SS jr SS jr
S
r SSSSSSS.S jjr SSSSSSSSS.S jjrS rS rS rS rU 4S jrSrU =r$ ) _UnixSelectorEventLoop: 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 S 5 nXPR U' [ R " U[" 5 [ R$ " US5 g ! [ [ 4 a n[ [ U5 5 eS nAff = f! [ a nU R U U R ( dL [ R " S5 O4! [ [ 4 a! n[& R( " SU5 S nAOS nAff = fUR* [* R, :X a [ SU S35 ee S nAff = f)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_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 g UR ( a U R U5 g U R U5 g r )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 S nAff = f! [ [ 4 a! n[ R " SU5 S nAgS nAff = f)NFrH rI rF 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 )Nzsig must be an int, not zinvalid signal number )
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 # U( 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 ) 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 & 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= B E- %E EE B E- E+
E-E E((E-d 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__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 rB r rA 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 rA r rH 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 rO 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 rA r rH call_exception_handlerr r^ r. r] rl s r rE #_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 rB r r rD 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 rt s r rD ,_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 rI rL rQ rU rZ r5 r: r; re rE r^ rD 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. r/ zbufsize=r0 r1 r2 )r0 r r r3 r r r4 r r r5 r6 EVENT_WRITEget_write_buffer_sizer8 r9 )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 rA r rX r r^ BrokenPipeErrorr' s r r #_UnixWritePipeTransport._read_ready sC :: ! ! KK/ 6 << KK) * KKMr c F [ 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 R, 5 U =R U-
sl U R/ 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 r
memoryviewr r r !LOG_THRESHOLD_FOR_CONNLOST_WRITESr warningr r" writer r r r r r rE r r _add_writer _write_ready_maybe_pause_protocol)r. rB nr] s r r _UnixWritePipeTransport.write s: dI & & d#D ??dmm)"M"MM H I OOq O ||
HHT\\40 CI~Q!$'+ JJ " "4<<1B1B C ""$ $%56
12
1$!!#'LM
s '!E F F /'FF c $ [ 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)Nr r r )r" r r r r r= r _remove_writer_maybe_resume_protocolr rB rD r r r r r r rE )r. r r] s r r $_UnixWritePipeTransport._write_ready s. % t||4A C %% ""$
))$,,7++-==JJ--dll;..t4QLL!$ ) !12 -. J LL OOq O
JJ % %dll 3 c#H I I
Js +C4 4FF A&F
Fc grs r r' s r
can_write_eof%_UnixWritePipeTransport.can_write_eof r c U R ( a g SU l U R ( dL U R R U R 5 U R R U R S 5 g g rs )r r r rB r r rD r' s r write_eof!_UnixWritePipeTransport.write_eof sO ==
|| JJ % %dll 3 JJ !;!;T B r c Xl g r rO rP s r rQ $_UnixWritePipeTransport.set_protocol rS r c U R $ r rO r' s r rU $_UnixWritePipeTransport.get_protocol rW r c U R $ r rY r' s r rZ "_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 ra rb rc s r re _UnixWritePipeTransport.__del__% rg 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 ri ) ro rS r rA r rH ro r r^ rp s r rE $_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 rs ) r r r r r r= rB r rD rt 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 rw rt s r rD -_UnixWritePipeTransport._call_connection_lostC rz r{ )r r r r r r r r r| r )r r r
r r+ r: r r r r r r rQ rU rZ r5 r: r; re r rE r^ rD 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 r0 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 H \ rS rSrS S jrS rS rS rS rS r S r
S
r S r g)
r ie 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 er NotImplementedErrorr. r r[ r\ s r r &AbstractChildWatcher.add_child_handler s
"##r c [ 5 er r r. r s r remove_child_handler)AbstractChildWatcher.remove_child_handler s
"##r c [ 5 er r r. r s r attach_loop AbstractChildWatcher.attach_loop s
"##r c [ 5 er r r' s r r5 AbstractChildWatcher.close s
"##r c [ 5 er r r' s r r AbstractChildWatcher.is_active s
"##r c [ 5 er r r' s r __enter__ AbstractChildWatcher.__enter__ s
"##r c [ 5 er r r. abcs r __exit__ AbstractChildWatcher.__exit__ s !##r r )returnN)
r r r
r r r r r r5 r r r r r r r r r e s* .. $$$$$$ $r r c D \ rS rSrS rS rS rS rS rS r S r
S r S
r g ) r i 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 grs 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 rB 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 grs r r s r r &PidfdChildWatcher.remove_child_handler r r N)
r r r
r r r r r5 r r r r r r r r r r s+
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 p U 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) r r r: r; RuntimeWarningr9 rO SIGCHLDr` _sig_chldr r s r r BaseChildWatcher.attach_loop s :: !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)rl rm )r r r r r ro rt 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 X ^ \ rS rSrU 4S jrU 4S jrS rS rS rS r S r
S r S
r U =r
$ ) r i* 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 r, 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 [ 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: %rTrj )
r" r WNOHANGr# r rA r rH r
r r poprh )r. r r r% r r[ r\ s r r SafeChildWatcher._do_waitpidX s 7 **\2::>KC ax/7Jzz##%% C )7 - !__ 0 0 5NH
S ,t ,7 ! C J NNJ
( 3 zz##%% H "T3 & 3s# 'B 2 C %C C?DDr )r r r
r r+ r5 r r r r r r r r
r s @r r r * s0 .
"
- -r r c R ^ \ rS rSrU 4S jrU 4S jrS rS rS rS r S r
S r U =r $ )
r i{ 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 r, s r r+ FastChildWatcher.__init__ sC
^^%
/ ;%, .r c > U R R 5 U R R 5 [ TU ] 5 g r )r r= rK r* r5 r, s r r5 FastChildWatcher.close s,
r c ~ U R U =R S-
sl U sS S S 5 $ ! , ( d f g = f)Nr )rJ rL 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)rJ rL rK 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 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= fr )rJ rK rD rh r )r. r r[ r\ r s r r "FastChildWatcher.add_child_handler sm ZZ
!]] . .s 3
j(4(
'/~$
Z
Zs& A&>A#A&"A##A&&
A4c @ U R U g! [ a gf = fr7 r8 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 r@ z,unknown process %s exited with returncode %sz8Caught subprocess termination from unknown pid: %d -> %d)r" r rC r# r
rJ r rD r rA r rH rh rL rK 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 )rL rJ rK )
r r r
r r+ r5 r r r r r r r
r s @r r r { s+ .
) (1 (1r r c V \ rS rSrS rS rS rS rS rS r S r
S r S
r S r
S rS
rg)r i 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 )r] 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= r] 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 = fr7 r8 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)r] 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 r= r s r r %MultiLoopChildWatcher._do_waitpid_all7 s# (C S ! )r c H [ 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 rA F%Loop %r that handles pid %r is closedr@ rB rj )r" r rC r# r
r r r rD is_closedrA rH r rh ) r. r r r% r debug_logr r[ r\ s r r !MultiLoopChildWatcher._do_waitpid; s **\2::>KC ax/7J I L#'??#6#6s#; DD ~~ FR !1!1LL!G!-;))(KdK= ! C J NNJ
I $ /
NND
/ /s" 'C C> 'C;:C;> D! D!c U R 5 g ! [ [ 4 a e [ a [ R
" SSS9 g f = f)Nr( Trj )r r r r r r )r. r r s r r% MultiLoopChildWatcher._sig_chld` sE R " -. R NNAD Q Rs /AA)r r] N)r r r
r r+ r r5 r r r r r r r r% r r r r r r s< &.2
&
3""#LJRr r c j \ rS rSrS rS rS rS rS r\ R 4S jr S r S r
S
rS rS rg
)r ii 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 grs 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 rg 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. rd threadthreadss r re 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 rH 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 grs 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 [ 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 r@ r rA rt ) r" r r# rA r rH r
r ru r r~ rD )r. r r r[ r\ r r% r s r r ThreadedChildWatcher._do_waitpid s 7 **\15KC 07J~~ C )7 >> NNBD N % %hZ G$ G
,'' ! C J NNJ
s B/ /%CC)r} r~ N)r r r
r r+ r r5 r r r: r; re r r r r r r r r r r i s=
%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 J ^ \ rS rSr\rU 4S jrS rU 4S jrS r S r
Sr U =r $ )_UnixDefaultEventLoopPolicyi c 0 > [ TU ] 5 S U l g r )r* r+ _watcherr, 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 rJ 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 g g g r )r* set_event_loopr rH 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 $ )Nr r r r )r r r: r r' s r r -_UnixDefaultEventLoopPolicy.get_child_watcher s@
== 0 :BI K }} r c U R b U R R 5 Xl [ R " SSSS9 g )Nset_child_watcherr r r )r r5 r: r )r. r s r r -_UnixDefaultEventLoopPolicy.set_child_watcher s=
== $ MM !
0 :BI Kr )r )
r r r
r r'
_loop_factoryr+ r r r r r r
r s @r r r s( *M ; , K Kr r )4rY r r| r" r6 rO r r r r6 rH 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 si
<<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