*j$ S r SSKr\R S:w a \" S5 eSSKrSSKrSSKrSSKJr SSK r SSK
r
SSK r SSK r SSK
r
SSKrSSKJr SSKJr SS KJr SS
KJr SS KJr SS KJr SS
KJr SSKJr SSKJr Sr\R6 r\R8 r Sr Sr Sr Sr " S S\RB 5 r" " S S\RB 5 r# " S S\#5 r$ " S S \#5 r% " S S \&5 r' " S S \RP 5 r) " S! S"\RT 5 r+ " S# S$5 r, " S% S&\RZ 5 r.\)r/ " S' S(\R` 5 r1 " S) S*\R` 5 r2\2r3\+r4g)+z.Selector and proactor event loops for Windows. Nwin32z
win32 only)partial )events)base_subprocess)futures)
exceptions)proactor_events)selector_events)tasks)
windows_utils)logger)SelectorEventLoopProactorEventLoop IocpProactorDefaultEventLoopPolicy WindowsSelectorEventLoopPolicy WindowsProactorEventLoopPolicy EventLoopi i gMbP?g?c n ^ \ rS rSrSrSS.U 4S jjrU 4S jrS rS U 4S jjrU 4S jr U 4S
jr
S r U =r $ )
_OverlappedFuture1 z~Subclass of Future which represents an overlapped operation.
Cancelling it will immediately cancel the overlapped operation.
Nloopc h > [ TU ] US9 U R ( a
U R S Xl g Nr )super__init___source_traceback_ov)selfovr __class__s =/opt/alt/python313/lib64/python3.13/asyncio/windows_events.pyr _OverlappedFuture.__init__7 s/
d# ! !&&r* c > [ TU ] 5 nU R bM U R R ( a SOSnUR SSU SU R R
S S35 U$ )Npending completedr z overlapped=)r
_repr_infor! r) insertaddressr" infostater$ s r% r- _OverlappedFuture._repr_info= s\ w!# 88 !%!1!1I{E KK\%4883C3CB2GqI J r' c U R c g U R R 5 S U l g ! [ aK nSUU S.nU R ( a U R US' U R R U5 S nANXS nAff = f)Nz&Cancelling an overlapped future failedmessage exceptionfuturesource_traceback)r! cancelOSErrorr _loopcall_exception_handler)r" exccontexts r% _cancel_overlapped$_OverlappedFuture._cancel_overlappedD s~ 88
7 HHOO 7C G
%%.2.D.D*+ JJ - -g 6 6 7s 2
BABBc > > U R 5 [ TU ] US9$ N)msg)r@ r r: r" rD r$ s r% r: _OverlappedFuture.cancelT s !w~#~&&r' c D > [ TU ] U5 U R 5 g N)r
set_exceptionr@ r" r7 r$ s r% rI _OverlappedFuture.set_exceptionX s
i( !r' c 2 > [ TU ] U5 S U l g rH )r
set_resultr! r" resultr$ s r% rM _OverlappedFuture.set_result\ s
6"r' r! rH )
__name__
__module__ __qualname____firstlineno____doc__r r- r@ r: rI rM __static_attributes__
__classcell__r$ s @r% r r 1 s5
$( '" r' r c z ^ \ rS rSrSrSS.U 4S jjrS rU 4S jrS rS r SU 4S
jjr
U 4S jr U 4S jr S
r
U =r$ )_BaseWaitHandleFuturea z2Subclass of Future which represents a wait handle.Nr c > [ TU ] US9 U R ( a
U R S Xl X l X0l SU l g )Nr r T)r r r r! _handle _wait_handle _registered)r" r# handle wait_handler r$ s r% r _BaseWaitHandleFuture.__init__d sF
d# ! !&&r* ' r' c f [ R " U R S5 [ R :H $ Nr )_winapiWaitForSingleObjectr^
WAIT_OBJECT_0r" s r% _poll_BaseWaitHandleFuture._pollr s) ++DLL!<%%& 'r' c ( > [ TU ] 5 nUR SU R S 35 U R b* U R 5 ( a SOSnUR U5 U R
b UR SU R
S 35 U$ )Nzhandle=r+ signaledwaitingz wait_handle=)r r- appendr^ rj r_ r0 s r% r- _BaseWaitHandleFuture._repr_infow s~ w!# gdll2 ./0 << #"&**,,JIE KK ( KK,t'8'8&<= > r' c S U l g rH rQ )r" futs r% _unregister_wait_cb)_BaseWaitHandleFuture._unregister_wait_cb s r' c U R ( d g SU l U R nS U l [ R " U5 U R S 5 g ! [ an nUR
[ R :w aF SUU S.nU R ( a U R US' U R R U5 S nAg S nANS nAff = fNFz$Failed to unregister the wait handler5 r9 ) r` r_ _overlappedUnregisterWaitr; winerrorERROR_IO_PENDINGr r< r= rs r" rb r> r? s r% _unregister_wait&_BaseWaitHandleFuture._unregister_wait s '' & &{ 3
&
||{ ; ;; E!$ "
))262H2HG ./
11': <
s A
C A C Cc > > U R 5 [ TU ] US9$ rC )r| r r: rE s r% r: _BaseWaitHandleFuture.cancel s w~#~&&r' c D > U R 5 [ TU ] U5 g rH )r| r rI rJ s r% rI #_BaseWaitHandleFuture.set_exception s
i(r' c D > U R 5 [ TU ] U5 g rH )r| r rM rN s r% rM _BaseWaitHandleFuture.set_result s
6"r' )r^ r! r` r_ rH )rR rS rT rU rV r rj r- rs r| r: rI rM rW rX rY s @r% r[ r[ a s; <8< '
'0')# #r' r[ c R ^ \ rS rSrSrSS.U 4S jjrS rU 4S jrU 4S jrS r U =r
$ )
_WaitCancelFuture zgSubclass of Future which represents a wait for the cancellation of a
_WaitHandleFuture using an event.
Nr c 0 > [ TU ] XX4S9 S U l g )Nr )r r _done_callback)r" r# eventrb r r$ s r% r _WaitCancelFuture.__init__ s
K; "r' c [ S5 e)Nz'_WaitCancelFuture must not be cancelled) RuntimeErrorri s r% r: _WaitCancelFuture.cancel s DEEr' c b > [ TU ] U5 U R b U R U 5 g g rH )r rM r rN s r% rM _WaitCancelFuture.set_result s/
6" * % +r' c b > [ TU ] U5 U R b U R U 5 g g rH )r rI r rJ s r% rI _WaitCancelFuture.set_exception s/
i( * % +r' )r ) rR rS rT rU rV r r: rM rI rW rX rY s @r% r r s, 8< # #
F&
& &r' r c B ^ \ rS rSrSS.U 4S jjrU 4S jrS rSrU =r$ )_WaitHandleFuture Nr c > [ TU ] XX5S9 X@l SU l [ R
" S SSS 5 U l S U l g )Nr TF)r r _proactor_unregister_proactorrw CreateEvent_event
_event_fut)r" r# ra rb proactorr r$ s r% r _WaitHandleFuture.__init__ sA
[<!$(!!--dD%F r' c > U R b. [ R " U R 5 S U l S U l U R R U R 5 S U l [ TU ]! U5 g rH ) r rf CloseHandler r _unregisterr! r rs )r" rr r$ s r% rs %_WaitHandleFuture._unregister_wait_cb sY ;; " , DK "DO
""488,
#C(r' c U R ( d g SU l U R nS U l [ R " XR 5 U R R U R U R 5 U l g ! [
an nUR [ R :w aF SUU S.nU R ( a U R US' U R R U5 S nAg S nANS nAff = frv )r` r_ rw UnregisterWaitExr r; ry rz r r< r= r _wait_cancelrs r r{ s r% r| "_WaitHandleFuture._unregister_wait s '' ( (kk B ..55dkk6:6N6NP
||{ ; ;; E!$ "
))262H2HG ./
11': <
s B
C<A C77C<)r r r r` r r_ ) rR rS rT rU r rs r| rW rX rY s @r% r r s! BF )$P Pr' r c : \ rS rSrSrS rS rS rS rS r \ r
Sr g )
PipeServer zPClass representing a pipe server.
This is much like a bound, listening socket.
c Xl [ R " 5 U l S U l S U l U R
S5 U l g NT)_addressweakrefWeakSet_free_instances_pipe_accept_pipe_future_server_pipe_handle)r" r/ s r% r PipeServer.__init__ s9
& 0
#' --d3
r' c J U R U R S5 sol U$ )NF)r r )r" tmps r% _get_unconnected_pipe PipeServer._get_unconnected_pipe s#
**d&>&>u&EZ
r' c
D U R 5 ( a g [ R [ R - nU( a U[ R - n[ R
" U R U[ R [ R - [ R - [ R [ R [ R [ R [ R 5 n[ R " U5 nU R R# U5 U$ rH )closedrf PIPE_ACCESS_DUPLEXFILE_FLAG_OVERLAPPED FILE_FLAG_FIRST_PIPE_INSTANCECreateNamedPiper PIPE_TYPE_MESSAGEPIPE_READMODE_MESSAGE PIPE_WAITPIPE_UNLIMITED_INSTANCESr
BUFSIZENMPWAIT_WAIT_FOREVERNULL
PipeHandler add)r" firstflagshpipes r% r PipeServer._server_pipe_handle s ;;==**W-I-II W:: :E # # MM5 % %(E(E E
, , ! !=#8#8 ( (',,
8 ''* & r' c U R S L $ rH )r ri s r% r PipeServer.closed s
%&r' c U R b! U R R 5 S U l U R bL U R H nUR 5 M S U l S U l U R R
5 g g rH )r r: r r closer clear)r" r s r% r PipeServer.close# sp # # / $ $ + + -'+D $ == $ ,,
- DJ DM & & ( %r' )r r r r N) rR rS rT rU rV r r r r r __del__rW r' r% r r s' 4$'
) Gr' r c \ rS rSrSrSrg)_WindowsSelectorEventLoopi2 z'Windows version of selector event loop.r N)rR rS rT rU rV rW r r' r% r r 2 s 1r' r c ` ^ \ rS rSrSrS
U 4S jjrU 4S jrU 4S jrS rS r S
S jr
S r U =r $ ) r i6 z2Windows version of proactor event loop using IOCP.c > > Uc
[ 5 n[ TU ] U5 g rH )r r r )r" r r$ s r% r ProactorEventLoop.__init__9 s #~H
"r' c v > U R b eU R U R 5 [ TU ] 5 g rH )_self_reading_future call_soon_loop_self_readingr _run_forever_setup)r" r$ s r% r $ProactorEventLoop._run_forever_setup> s2 ((000 t../
"$r' c
> [ TU ] 5 U R bg U R R nU R R 5 Ub, UR
( d U R R U5 S U l g g rH )r _run_forever_cleanupr r! r: r) r r )r" r# r$ s r% r &ProactorEventLoop._run_forever_cleanupC si
$& $ $ 0**..B % % , , . ~bjj**2.(,D % 1r' c # U R R U5 nUI S h vN nU" 5 nU R XESU0S9nXe4$ N 7f)Naddrextra)r connect_pipe_make_duplex_pipe_transport)r" protocol_factoryr/ fr protocoltranss r% create_pipe_connection(ProactorEventLoop.create_pipe_connectionR sU NN ' ' 0w#%008>7H 1 J s !AA!Ac j ^ ^^^^# [ T5 mSUUUU U4S jjmT R T5 T/$ 7f)Nc > S n U ( aj U R 5 nTR R U5 TR 5 ( a UR 5 g T" 5 nTR XST0S9 TR
5 nUc g TR R U5 n U Tl U R T5 g ! [ a? U( a$ UR 5 S:w a UR 5 TR T5 g [ a nU( a: UR 5 S:w a& TR SUUS.5 UR 5 O'TR ( a [" R$ " SUSS9 TR T5 S nAg S nAf[& R( a U( a UR 5 g g f = f) Nr r r zPipe accept failed)r6 r7 r z Accept pipe failed on pipe %rT)exc_info)rO r discardr r r r r accept_piper add_done_callbackBrokenPipeErrorfilenor r; r= _debugr warningr CancelledError) r r r r> r/ loop_accept_piper r" servers r% r >ProactorEventLoop.start_serving_pipe..loop_accept_pipe] st D)
6 88:D**2248 }}
/ 1H44 vw.? 5 A 335<NN..t4* ./*##$45+ #
1DKKMR /JJL /0
1DKKMR ///#7%( $1
JJL[[NN#B#'$8 /00 ,,
!JJL
!s2 AB> ,B>
B> >AG G A9F
.G ?G rH )r r )r" r r/ r r s ```@@r% start_serving_pipe$ProactorEventLoop.start_serving_pipeZ s1 G$+ 6 + 6Z
'(xs ,3c
# U R 5 n
[ XX#XEXg4XS.U D6n U
I S h vN U $ N! [ [ 4 a e [ a+ U R 5 U R
5 I S h vN e f = f7f)N)waiterr )
create_future_WindowsSubprocessTransport
SystemExitKeyboardInterrupt
BaseExceptionr _wait) r" r argsshellstdinstdoutstderrbufsizer kwargsr transps r% _make_subprocess_transport,ProactorEventLoop._make_subprocess_transport s ##%,TT-2F74:7 067 LL
-. LLN,,. s1 "A;3 13 A;3 =A80A31A88A;)r rH )
rR rS rT rU rV r r r r r r rW rX rY s @r% r r 6 s/ <#
%
- 1j 04 r' r c
\ rS rSrSr\4S jrS rS rS r S#S jr
S r \ S
5 r
\S 5 rS$S jrS$S
jrS$S jrS$S jrS%S jrS$S jrS rS rS rS rS rS#S jrS r S r S r S r S r S r!S#S jr"S r#S r$S! r%S"r&g)&r i z#Proactor implementation using IOCP.c S U l / U l [ R " [ R [
SU5 U l 0 U l [ R " 5 U l
/ U l [ R " 5 U l g re )
r< _resultsrw CreateIoCompletionPortINVALID_HANDLE_VALUEr _iocp_cacher r r`
_unregistered_stopped_serving)r" concurrencys r% r IocpProactor.__init__ s_
77 , ,dA{D
"??, ' 1 r' c 4 U R c [ S5 eg )NzIocpProactor is closed)r r ri s r%
_check_closedIocpProactor._check_closed s :: 78 8 r' c S[ U R 5 - S[ U R 5 - /nU R c UR S5 SU R
R < SSR U5 < S3$ )Nzoverlapped#=%sz
result#=%sr < r, )lenr r r ro r$ rR join)r" r1 s r% __repr__IocpProactor.__repr__ s_ 3t{{#33 s4== 113 :: KK ! NN 3 3SXXd^DDr' c Xl g rH )r< )r" r s r% set_loopIocpProactor.set_loop s
r' Nc U R ( d U R U5 U R n/ U l US n$ ! S nf = frH )r rj )r" timeoutr s r% selectIocpProactor.select s: }} JJw mm
C$Cs ; ?c \ U R R 5 nUR U5 U$ rH )r< r rM )r" valuerr s r% _resultIocpProactor._result s% jj&&( u
r' c UR 5 $ ! [ aF nUR [ R [ R
4; a [
UR 6 ee S nAff = frH ) getresultr; ry rw ERROR_NETNAME_DELETEDERROR_OPERATION_ABORTEDConnectionResetErrorr )r keyr# r> s r% finish_socket_func IocpProactor.finish_socket_func sY <<> ! || A A + C C E E*CHH55 s
A"AA A"c U R XU5 $ ! [ a- nUR [ R :X a US 4s S nA$ e S nAff = frH )r4 r; ry rw ERROR_PORT_UNREACHABLE)clsr r3 r# empty_resultr> s r% _finish_recvfrom IocpProactor._finish_recvfrom sL ))%b9 9 ||{ A AA#T))
s
A !AA AA c U R U5 [ R " [ 5 n [ U[
R
5 ( a! UR
UR 5 X#5 O!UR UR 5 U5 U R XAU R 5 $ ! [ a U R S5 s $ f = f)Nr' )
_register_with_iocprw
Overlappedr
isinstancesocketWSARecvr ReadFiler r, _registerr4 r" connnbytesr r# s r% recvIocpProactor.recv s &
#
#D
) %$
..
4;;=&8 DKKM62 ~~b(?(?@@ %<<$ $ % ?B* - B* *CCc U R U5 [ R " [ 5 n [ U[
R
5 ( a! UR
UR 5 X#5 O!UR UR 5 U5 U R XAU R 5 $ ! [ a U R S5 s $ f = fre )
r= rw r> r r? r@ WSARecvIntor ReadFileIntor r, rC r4 r" rE bufr r# s r% recv_intoIocpProactor.recv_into s &
#
#D
) #$
..t{{}c9
s3 ~~b(?(?@@ #<<? " #rI c $ U R U5 [ R " [ 5 n UR UR 5 X#5 U R XA[ U R SS95 $ ! [ a U R S5 s $ f = f)N)r' Nr' r9 ) r= rw r> r WSARecvFromr r r, rC r r: rD s r% recvfromIocpProactor.recvfrom s &
#
#D
) - NN4;;=& 8 ~~b0E0E=@)B C C -<< , , - A1 1BBc $ U R U5 [ R " [ 5 n UR UR 5 X#5 U R XA[ U R SS95 $ ! [ a U R S5 s $ f = f)Nr Nr rR ) r= rw r> r WSARecvFromIntor r r, rC r r: rM s r%
recvfrom_intoIocpProactor.recvfrom_into s &
#
#D
) + t{{}c 9 ~~b0E0E=>)@ A A +<< * * +rV c U R U5 [ R " [ 5 nUR UR 5 X#U5 U R
XQU R 5 $ rH )r= rw r> r WSASendTor rC r4 )r" rE rN r r r# s r% sendtoIocpProactor.sendto sM &
#
#D
)
T[[]C5~~b(?(?@@r' c P U R U5 [ R " [ 5 n[ U[
R
5 ( a! UR
UR 5 X#5 O UR UR 5 U5 U R XAU R 5 $ rH ) r= rw r> r r? r@ WSASendr WriteFilerC r4 rM s r% sendIocpProactor.send sp &
#
#D
) dFMM * * JJt{{}c 1 LL ,~~b(?(?@@r' c z ^^ U R T5 U R TR 5 m[ R " [
5 nUR
TR 5 TR 5 5 UU4S jnS nU R UTU5 nU" UT5 n[ R " X`R S9 U$ )Nc . > UR 5 [ R " STR 5 5 nTR [
R [ R U5 TR TR 5 5 TTR 5 4$ )Nz@P) r/ structpackr
setsockoptr@
SOL_SOCKETrw SO_UPDATE_ACCEPT_CONTEXT
settimeout
gettimeout getpeername)r r3 r# rN rE listeners r%
finish_accept*IocpProactor.accept..finish_accept+ sl LLN++dHOO$56C OOF - - ' @ @#
G OOH / / 1 2))++ +r' c x # U I S h vN g N! [ R a UR 5 e f = f7frH )r r r )r8 rE s r% accept_coro(IocpProactor.accept..accept_coro4 s1
,,
s : : &7:r ) r= _get_accept_socketfamilyrw r> r AcceptExr rC r
ensure_futurer< )r" ro r# rp rs r8 cororE s ` @r% acceptIocpProactor.accept% s *&&x7
#
#D
)
HOO%t{{}5 , Hm<64(
Dzz2
r' c ^ TR [ R :X aR [ R " TR 5 U5 U R R 5 nUR S 5 U$ U R T5 [ R " TR 5 TR 5 [ R" " [$ 5 nUR' TR 5 U5 U4S jnU R) UTU5 $ ! [ aA nUR [ R :w a e TR! 5 S S:X a e S nANS nAff = f)Nr r c > UR 5 TR [ R [ R
S5 T$ re )r/ ri r@ rj rw SO_UPDATE_CONNECT_CONTEXT)r r3 r# rE s r% finish_connect,IocpProactor.connect..finish_connectW s1 LLN OOF - - ' A A1
FKr' )typer@
SOCK_DGRAMrw
WSAConnectr r< r rM r= BindLocalrv r; ry errno WSAEINVAL getsocknamer> r ConnectExrC )r" rE r/ rr er# r s ` r% connectIocpProactor.connectA s 99)) )
" "4;;=' :****,C NN4 J & ! !$++- =
#
#D
)
T[[]G, ~~b$77! zzU__, !!$) * s /D
E7E Ec X U R U5 [ R " [ 5 nUS- nUS- S- nUR U5 UR UR
5 [ R " UR
5 5 XgUSS5 U R XQU R 5 $ )Nl r ) r= rw r> r seek TransmitFiler msvcrt
get_osfhandlerC r4 )r" sockfileoffsetcountr#
offset_low offset_highs r% sendfileIocpProactor.sendfile` s &
#
#D
)k)
|{2
&
,,T[[];" q! %
~~b(?(?@@r' c ^ U R T5 [ R " [ 5 nUR TR 5 5 nU( a U R
T5 $ U4S jnU R UTU5 $ )Nc ( > UR 5 T$ rH )r/ )r r3 r# r s r% finish_accept_pipe4IocpProactor.accept_pipe..finish_accept_pipez s LLNKr' )r= rw r> r ConnectNamedPiper r, rC )r" r r# connectedr s ` r% r IocpProactor.accept_pipeo sf &
#
#D
)''
6 <<% % ~~b$(:;;r' c H # [ n [ R " U5 n [ R " U5 $ ! [ a) nUR [ R
:w a e S nAOS nAff = f[
US- [ 5 n[ R " U5 I S h vN M 7f)N ) CONNECT_PIPE_INIT_DELAYrw ConnectPiper; ry ERROR_PIPE_BUSYminCONNECT_PIPE_MAX_DELAYr sleepr
r )r" r/ delayra r> s r% r IocpProactor.connect_pipe s '
$009 ''//
<<;#>#>> ?
#9:E++e$ $ $ s7 B"8 B"
A+ A&!B"&A++/B"B B"c & U R XS5 $ )zWait for a handle.
Return a Future object. The result of the future is True if the wait
completed, or False if the wait did not complete (on timeout).
F)_wait_for_handle)r" ra r' s r% wait_for_handle IocpProactor.wait_for_handle s $$Ve< TR 5 $ rH )rj )r r3 r# r s r% finish_wait_for_handle=IocpProactor._wait_for_handle..finish_wait_for_handle s 779 r' r )r rf INFINITEmathceilrw r> r RegisterWaitWithQueuer r/ r r< r r r ) r" ra r'
_is_cancelmsr# rb r r s @r% r IocpProactor._wait_for_handle s ?!!B 7S=)B
#
#D
)!77 JJ
B0 !"k
KA!"k'+zz3A ##B' $%b!-C"D BJJ r' c XR ; aM U R R U5 [ R " UR 5 U R
SS5 g g re )r` r rw r r r r" objs r% r= IocpProactor._register_with_iocp sG && & % . .szz|TZZA N 'r' c h U R 5 [ XR S9nUR ( a
UR S UR ( d U" S S U5 nUR U5 XAX#4U R UR ' U$ ! [ a nUR U5 S nAN=S nAff = fr )
r r r< r r) rM r; rI r r/ )r" r# r callbackr r+ r s r% rC IocpProactor._register s
bzz 2 ##B'zz
$ tR0 U# $%#"8 BJJ
#""
#s
B
B1B,,B1c Z U R 5 U R R U5 g)zUnregister an overlapped object.
Call this method when its future has been cancelled. The event can
already be signalled (pending in the proactor event queue). It is also
safe if the event is never signalled (because it was cancelled).
N)r r ro )r" r# s r% r IocpProactor._unregister s$
!!"%r' c T [ R " U5 nUR S5 U$ re )r@ rl )r" rv ss r% ru IocpProactor._get_accept_socket s MM& ! Qr' c H Uc [ nO?US: a [ S5 e[ R " US- 5 nU[ : a [ S5 e [ R
" U R U5 nUc OSnUu pEpg U R R U5 u ppXR ; a UR# 5 OMUR% 5 ( d8 U " XVU 5 n UR' U 5 U R( R+ U5 S nM U R0 H) n U R R U R2 S 5 M+ U R0 R5 5 g ! [ as U R R 5 ( a# U R R SSXEXg4- S.5 US[ R 4; a [ R " U5 GM f = f! [, a7 n
UR/ U
5 U R( R+ U5 S n
A
GNS n
A
ff = f! S nf = f)Nr znegative timeoutr ztimeout too bigz8GetQueuedCompletionStatus() returned an unexpected eventz)err=%s transferred=%s key=%#x address=%#x)r6 status)r
ValueErrorr r rw GetQueuedCompletionStatusr r popKeyErrorr< get_debugr= r rf r r r: donerM r ro r; rI r r/ r )r" r' r r err transferredr3 r/ r r# r r r+ r s r% rj IocpProactor._poll s ?B
q[ /0 0 7S=)BX~ !233 ::4::rJF~B-3 *Cc
'+{{w'?$s +++
VVXX $[r :E
LL'MM((+ AM R $$B KKOOBJJ - % "E
::''))JJ55%7#N&)%E$F7 q+"B"B CC'',
, ,OOA&MM((++, AsC 8 E G ,H A8GG
H#,HH HH H!c : U R R U5 g rH )r r r s r%
_stop_servingIocpProactor._stop_serving6 s
!!#&r' c U R c g [ U R R 5 5 HE u pp4UR 5 ( a M [ U[ 5 ( a M4 UR 5 MG Sn[ R " 5 nX- n U R ( a U [ R " 5 :: aF [ R " SU [ R " 5 U-
5 [ R " 5 U- n U R! U5 U R ( a M / U l [$ R& " U R 5 S U l g ! [ aa nU R bH SUUS.nUR ( a UR US' U R R U5 S nAGM S nAGM S nAff = f)NzCancelling a future failedr5 r9 g ?z,%r is running after closing for %.1f seconds)r listr values cancelledr? r r: r; r< r r= time monotonicr debugrj r rf r )
r" rr r# r r r> r?
msg_update
start_timenext_msgs
r% r IocpProactor.close< sc :: '+4;;+=+=+?&@ "CS}}C!233 CJJL 'A0
^^%
*kk4>>++ K !4>>#3j#@B >>+j8
JJz " kkk
DJJ'
; Czz-'C),&)#
00:=:O:OG$6 7
99'BB . Cs 'E
G#AF??Gc $ U R 5 g rH )r ri s r% r IocpProactor.__del__k s
r' )r r r< r` r r r rH )r rX )'rR rS rT rU rV r r r r! r$ r( r, staticmethodr4 classmethodr: rG rO rT rZ r^ rc rz r r r r r r r r= rC r ru rj r r r rW r r' r% r r s -#+ 29E
A A C AAA8 8>
A <"0&= DO @&
7#r' -^r' r c \ rS rSrS rSrg)r io c ^ [ R " U4X#XEUS.UD6T l U 4S jnT R R R [
T R R 5 5 n U R U5 g )N)r r r r r c \ > TR R 5 nTR U5 g rH )_procpoll_process_exited)r
returncoder" s r% r 4_WindowsSubprocessTransport._start..callbackv s! *J ,r' ) r
Popenr r< r r intr^ r )
r" r r r r r r r
r r s
` r% _start"_WindowsSubprocessTransport._startq sk "(( ' 6' %'
-
JJ 0 0TZZ5G5G1H I H%r' )r N)rR rS rT rU r rW r r' r% r r o s
&r' r c \ rS rSr\rSrg)r i r N)rR rS rT rU r
_loop_factoryrW r r' r% r r %Mr' r c \ rS rSr\rSrg)r i r N)rR rS rT rU r r rW r r' r% r r r r' r )5rV sysplatform ImportErrorrw rf r functoolsr r r r@ rg r r r r r r r
r r r
logr __all__r r ERROR_CONNECTION_REFUSEDERROR_CONNECTION_ABORTEDr r Futurer r[ r r objectr BaseSelectorEventLoopr BaseProactorEventLoopr r BaseSubprocessTransportr r BaseDefaultEventLoopPolicyr r r r r r' r% r sa 4
<<7
l
##
|| - -`G#GNN G#T&- &01P- 1Ph8 8v2 E E 2h== hVK K\ &/"I"I & . &V%F%F &&V%F%F & 8 r'