python (3.12.0)
ˑe} d Z ddlZej dk7 r ed ddlZddlZddlZddlZddlZddl Z ddl
Z
ddl Z ddl Z ddl
mZ ddl
mZ ddl
mZ dd l
mZ dd
l
mZ dd l
mZ dd l
mZ dd
l
mZ ddlmZ dZej2 Zej4 ZdZdZ dZ dZ G d dej> Z G d dej> Z! G d de! Z" G d de! Z# G d d e$ Z% G d d ejL Z' G d d!ejP Z) G d" d# Z* G d$ d%ejV Z,e'Z- G d& d'ej\ Z/ G d( d)ej\ Z0e0Z1y)*z.Selector and proactor event loops for Windows. Nwin32z
win32 only )events)base_subprocess)futures)
exceptions)proactor_events)selector_events)tasks)
windows_utils)logger)SelectorEventLoopProactorEventLoop IocpProactorDefaultEventLoopPolicy WindowsSelectorEventLoopPolicy WindowsProactorEventLoopPolicyi i gMbP?g?c X e Zd ZdZdd fd
Z fdZd Zd
fd Z fdZ fd Z xZ
S ) _OverlappedFuturezSubclass of Future which represents an overlapped operation.
Cancelling it will immediately cancel the overlapped operation.
Nloopc f t | | | j r
| j d= || _ y Nr )super__init___source_traceback_ov)selfovr __class__s J/BuggyBox/python/3.12.0/bootstrap/lib/python3.12/asyncio/windows_events.pyr z_OverlappedFuture.__init__6 s1
d# ! !&&r* c t | }| j H| j j rdnd}|j dd| d| j j
dd |S )Npending completedr z overlapped=<z, #x>)r
_repr_infor r% insertaddressr infostater! s r" r) z _OverlappedFuture._repr_info< s\ w!# 88 !%!1!1I{E KK\%4883C3CB2GqI J r# c | j y | j j d | _ y # t $ rM}d|| d}| j r| j |d< | j j | Y d }~d | _ y d }~ww xY w)Nz&Cancelling an overlapped future failedmessage exceptionfuturesource_traceback)r cancelOSErrorr _loopcall_exception_handler)r exccontexts r" _cancel_overlappedz$_OverlappedFuture._cancel_overlappedC s 88
7 HHOO 7C G
%%.2.D.D*+ JJ - -g 6 6 7s 1 B<BBc D | j t | | S N)msg)r; r r5 r r> r! s r" r5 z_OverlappedFuture.cancelS s !w~#~&&r# c D t | | | j y N)r
set_exceptionr; r r2 r! s r" rB z _OverlappedFuture.set_exceptionW s
i( !r# c 2 t | | d | _ y rA )r
set_resultr r resultr! s r" rE z _OverlappedFuture.set_result[ s
6"r# rA ) __name__
__module__ __qualname____doc__r r) r; r5 rB rE
__classcell__r! s @r" r r 0 s0
$( '" r# r c d e Zd ZdZdd fd
Zd Z fdZd Zd Zd fd Z fd
Z
fd Z xZ S )
_BaseWaitHandleFuturez2Subclass of Future which represents a wait handle.Nr c t | | | j r
| j d= || _ || _ || _ d| _ y )Nr r T)r r r r _handle _wait_handle _registered)r r handle wait_handler r! s r" r z _BaseWaitHandleFuture.__init__c sL
d# ! !&&r* ' r# c d t j | j d t j k( S Nr )_winapiWaitForSingleObjectrQ
WAIT_OBJECT_0r s r" _pollz_BaseWaitHandleFuture._pollq s) ++DLL!<%%& 'r# c t | }|j d| j d | j %| j rdnd}|j | | j
|j d| j
d |S )Nzhandle=r' signaledwaitingz wait_handle=)r r) appendrQ r\ rR r, s r" r) z _BaseWaitHandleFuture._repr_infov s| w!# gdll2 ./0 << #"&**,JIE KK ( KK,t'8'8&<= > r# c d | _ y rA )r )r futs r" _unregister_wait_cbz)_BaseWaitHandleFuture._unregister_wait_cb s r# c | j sy d| _ | j }d | _ t j | | j d y # t $ rh}|j
t j k7 rAd|| d}| j r| j |d< | j j | Y d }~y Y d }~~d }~ww xY wNFz$Failed to unregister the wait handler0 r4 ) rS rR _overlappedUnregisterWaitr6 winerrorERROR_IO_PENDINGr r7 r8 rc r rU r9 r: s r" _unregister_waitz&_BaseWaitHandleFuture._unregister_wait s '' & &{ 3
&
||{ ; ;; E!$ "
))262H2HG ./
11': <
s A CAB<<Cc D | j t | | S r= )rk r r5 r? s r" r5 z _BaseWaitHandleFuture.cancel s w~#~&&r# c D | j t | | y rA )rk r rB rC s r" rB z#_BaseWaitHandleFuture.set_exception s
i(r# c D | j t | | y rA )rk r rE rF s r" rE z _BaseWaitHandleFuture.set_result s
6"r# rA )
rH rI rJ rK r r\ r) rc rk r5 rB rE rL rM s @r" rO rO ` s6 <8< '
'0')# #r# rO c B e Zd ZdZdd fd
Zd Z fdZ fdZ xZS )_WaitCancelFuturezoSubclass of Future which represents a wait for the cancellation of a
_WaitHandleFuture using an event.
Nr c : t | |||| d | _ y )Nr )r r _done_callback)r r eventrU r r! s r" r z_WaitCancelFuture.__init__ s!
UKd; "r# c t d )Nz'_WaitCancelFuture must not be cancelled) RuntimeErrorr[ s r" r5 z_WaitCancelFuture.cancel s DEEr# c ` t | | | j | j | y y rA )r rE rr rF s r" rE z _WaitCancelFuture.set_result s/
6" * % +r# c ` t | | | j | j | y y rA )r rB rr rC s r" rB z _WaitCancelFuture.set_exception s/
i( * % +r# ) rH rI rJ rK r r5 rE rB rL rM s @r" rp rp s' 8< #
F&
& &r# rp c 4 e Zd Zdd fd
Z fdZd Z xZS )_WaitHandleFutureNr c t | |||| || _ d| _ t j
d ddd | _ d | _ y )Nr TF)r r _proactor_unregister_proactorrf CreateEvent_event
_event_fut)r r rT rU proactorr r! s r" r z_WaitHandleFuture.__init__ sG
V[t<!$(!!--dD%F r# c | j -t j | j d | _ d | _ | j j | j d | _ t | ! | y rA ) r~ rX CloseHandler r{ _unregisterr r rc )r rb r! s r" rc z%_WaitHandleFuture._unregister_wait_cb sY ;; " , DK "DO
""488,
#C(r# c | j sy d| _ | j }d | _ t j || j | j j | j | j | _ y # t
$ rh}|j t j k7 rAd|| d}| j r| j |d< | j j | Y d }~y Y d }~d }~ww xY wre )rS rR rf UnregisterWaitExr~ r6 rh ri r r7 r8 r{ _wait_cancelrc r rj s r" rk z"_WaitHandleFuture._unregister_wait s '' ( (dkk B ..55dkk6:6N6NP
||{ ; ;; E!$ "
))262H2HG ./
11': <
s A? ? C0AC++C0)rH rI rJ r rc rk rL rM s @r" ry ry s BF )$Pr# ry c 2 e Zd ZdZd Zd Zd Zd Zd ZeZ y)
PipeServerzXClass representing a pipe server.
This is much like a bound, listening socket.
c || _ t j | _ d | _ d | _ | j
d | _ y NT)_addressweakrefWeakSet_free_instances_pipe_accept_pipe_future_server_pipe_handle)r r+ s r" r zPipeServer.__init__ s;
& 0
#' --d3
r# c L | j | j d c}| _ |S )NF)r r )r tmps r" _get_unconnected_pipez PipeServer._get_unconnected_pipe s%
**d&>&>u&ETZ
r# c
, | j ry t j t j z }|r|t j z }t j
| j |t j t j z t j z t j t j t j t j t j }t j | }| j j# | |S rA )closedrX 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 z PipeServer._server_pipe_handle
s ;;=**W-I-II W:: :E # # MM5 % %(E(E E
, , ! !=#8#8 ( (',,
8 ''* & r# c | j d u S rA )r r[ s r" r zPipeServer.closed s
%&r# c
| j !| j j d | _ | j J| j D ] }|j d | _ d | _ | j j
y y rA )r r5 r r closer clear)r r s r" r zPipeServer.close" su # # / $ $ + + -'+D $ == $ ,,
DJ DM & & ( %r# N)
rH rI rJ rK r r r r r __del__ r# r" r r s' 4$'
) Gr# r c e Zd ZdZy)_WindowsSelectorEventLoopz'Windows version of selector event loop.N)rH rI rJ rK r r# r" r r 1 s 1r# r c D e Zd ZdZd fd Z fdZd Zd Z ddZ xZ S )r z2Windows version of proactor event loop using IOCP.c < |
t }t | | y rA )r r r )r r r! s r" r zProactorEventLoop.__init__8 s #~H
"r# c | j J | j | j t | | j U| j j
}| j j
|| j j | d | _ y y # | j U| j j
}| j j
|| j j | d | _ w w xY wrA ) _self_reading_future call_soon_loop_self_readingr run_foreverr r5 r{ r )r r r! s r" r z ProactorEventLoop.run_forever= s 1,,4 4 NN422 3 G !((4..22))002 >NN..r2,0) 5t((4..22))002 >NN..r2,0) 5s 7B A#C?c K | j j | }| d { } | }| j ||d|i }||fS 7 %w)Naddrextra)r{ connect_pipe_make_duplex_pipe_transport)r protocol_factoryr+ fr protocoltranss r" create_pipe_connectionz(ProactorEventLoop.create_pipe_connectionP sZ NN ' ' 0w#%00x8>7H 1 Jh s !A A &A c f K t d fd j gS w)Nc J d } | ri| j }j j | j r|j y }j ||di j
}|y j j | } | _ | j y # t $ r9 |r#|j dk7 r|j j Y y t $ rz}|r9|j dk7 r&j d||d |j n$j rt# j$ d|d j Y d }~y d }~wt& j( $ r |r|j Y y Y y w xY w) Nr r r zPipe accept failed)r1 r2 r z Accept pipe failed on pipe %rT)exc_info)rG r discardr r r r r{ accept_piper add_done_callbackBrokenPipeErrorfilenor r6 r8 _debugr
warningr CancelledError) r r r r9 r+ loop_accept_piper r servers r" r z>ProactorEventLoop.start_serving_pipe.<locals>.loop_accept_pipe[ st D)
6 88:D**2248 }}
/ 1H44 hvw.? 5 A 335<NN..t4* ./*##$45+ #
1DKKMR /JJL /0
1DKKMR ///#7%( $1
JJL[[NN#B#'$8 /00 ,,
!JJL
!s1 A
B7 /B7 B7 7?F"8F" A0E55(F"!F"rA )r r )r r r+ r r s ```@@r" start_serving_pipez$ProactorEventLoop.start_serving_pipeX s2 G$+ 6 + 6Z
'(xs *1c
K | j }
t | |||||||f|
|d| } |
d { | S 7 # t t f$ r t $ r+ | j | j
d { 7 w xY ww)N)waiterr )
create_future_WindowsSubprocessTransport
SystemExitKeyboardInterrupt
BaseExceptionr _wait) r r argsshellstdinstdoutstderrbufsizer kwargsr transps r" _make_subprocess_transportz,ProactorEventLoop._make_subprocess_transport s ##%,T8T5-2FFG74:%7 067 LL
-. LLN,,. s1 'A>8 68 A>8 ;A;3A64A;;A>rA )
rH rI rJ rK r r r r r rL rM s @r" r r 5 s% <#
1& 1j 04r# r c e Zd ZdZefdZd Zd Zd Zd dZ d Z
e d Z d!d
Z
d!d Zd!d Zd!d
Zd"dZd!dZd Zd Zd Zd Zd Zd dZd Zd Zd Zd Z d Z d Z d d Z d Z d Z!d Z"y)#r z#Proactor implementation using IOCP.c d | _ g | _ t j t j t
d| | _ i | _ t j | _
g | _ t j | _ y rW )
r7 _resultsrf CreateIoCompletionPortINVALID_HANDLE_VALUEr _iocp_cacher r rS
_unregistered_stopped_serving)r concurrencys r" r zIocpProactor.__init__ s_
77 , ,dA{D
"??, ' 1 r# c 2 | j t d y )NzIocpProactor is closed)r ru r[ s r"
_check_closedzIocpProactor._check_closed s :: 78 8 r# c dt | j z dt | j z g}| j |j d d| j
j ddj | dS )Nzoverlapped#=%sz
result#=%sr < r( )lenr r r r` r! rH join)r r- s r" __repr__zIocpProactor.__repr__ s_ 3t{{#33 s4== 113 :: KK ! NN 3 3SXXd^DDr# c || _ y rA )r7 )r r s r" set_loopzIocpProactor.set_loop s
r# Nc z | j s| j | | j }g | _ |d }S # d }w xY wrA )r r\ )r timeoutr s r" selectzIocpProactor.select s: }} JJw mm
C$Cs 6 :c \ | j j }|j | |S rA )r7 r rE )r valuerb s r" _resultzIocpProactor._result s% jj&&( u
r# c |j S # t $ rD}|j t j t j
fv rt
|j d }~ww xY wrA getresultr6 rh rf ERROR_NETNAME_DELETEDERROR_OPERATION_ABORTEDConnectionResetErrorr r keyr r9 s r" finish_socket_funcz IocpProactor.finish_socket_func sY <<> ! || A A + C C E E*CHH55 A ?AA c | j | t j t } t |t
j
r"|j
|j || n |j |j | | j ||| j S # t $ r | j d cY S w xY w)Nr# )
_register_with_iocprf
Overlappedr
isinstancesocketWSARecvr ReadFiler r _registerr r connnbytesr r s r" recvzIocpProactor.recv s &
#
#D
) %$
.
4;;=&%8 DKKM62 ~~b$(?(?@@ %<<$ $ % A B% %CCc | j | t j t } t |t
j
r"|j
|j || n |j |j | | j ||| j S # t $ r | j d cY S w xY wrW )
r rf r r r r WSARecvIntor ReadFileIntor r r r r r bufr r s r" recv_intozIocpProactor.recv_into s &
#
#D
) #$
.t{{}c59
s3 ~~b$(?(?@@ #<<? " #r c | j | t j t } |j |j || | j ||| j S # t $ r | j d cY S w xY w)N)r# N)
r rf r r WSARecvFromr r r r r r
s r" recvfromzIocpProactor.recvfrom sv &
#
#D
) - NN4;;=&% 8 ~~b$(?(?@@ -<< , , -s !A* *BBc | j | t j t } |j |j || d }| j ||| S # t $ r | j d cY S w xY w)Nr Nc |j S # t $ rD}|j t j t j
fv rt
|j d }~ww xY wrA r r s r" finish_recvz/IocpProactor.recvfrom_into.<locals>.finish_recv sY
||~%
<<K$E$E$/$G$G$I I.99
r ) r rf r r WSARecvFromIntor r r r )r r r r r r s r"
recvfrom_intozIocpProactor.recvfrom_into sw &
#
#D
) + t{{}c5 9 ~~b$ 44 +<< * * +s !A# #B ?B c | j | t j t }|j |j ||| | j
||| j S rA )r rf r r WSASendTor r r )r r r r r r s r" sendtozIocpProactor.sendto
sQ &
#
#D
)
T[[]C5~~b$(?(?@@r# c H | j | t j t }t |t
j
r"|j
|j || n |j |j | | j ||| j S rA ) r rf r r r r WSASendr WriteFiler r r s r" sendzIocpProactor.send sq &
#
#D
) dFMM * JJt{{}c5 1 LL ,~~b$(?(?@@r# c | | j | j j t j t
}|j
j j fd}d }| j || } || }t j || j |S )Nc , |j t j dj }j t
j t j | j j j fS )Nz@P) r structpackr
setsockoptr
SOL_SOCKETrf SO_UPDATE_ACCEPT_CONTEXT
settimeout
gettimeout getpeername)r r r r r listeners r"
finish_acceptz*IocpProactor.accept.<locals>.finish_accept% sl LLN++dHOO$56C OOF - - ' @ @#
G OOH / / 1 2))++ +r# c v K | d { y 7 # t j $ r |j w xY wwrA )r r r )r3 r s r" accept_coroz(IocpProactor.accept.<locals>.accept_coro. s2
,,
s 9 9 %69r ) r _get_accept_socketfamilyrf r r AcceptExr r r
ensure_futurer7 )r r2 r r3 r5 r3 coror s ` @r" acceptzIocpProactor.accept s *&&x7
#
#D
)
HOO%t{{}5 , Hm<64(
Dtzz2
r# c j t j k( rQt j j | | j j }|j d |S | j t j j j t j" t$ }|j' j | fd}| j) || S # t $ r?}|j t j k7 r j! d dk( r Y d }~d }~ww xY w)Nr r c |j j t j t j
d S rW )r r, r r- rf SO_UPDATE_CONNECT_CONTEXT)r r r r s r" finish_connectz,IocpProactor.connect.<locals>.finish_connectQ s1 LLN OOF - - ' A A1
FKr# )typer
SOCK_DGRAMrf
WSAConnectr r7 r rE r BindLocalr7 r6 rh errno WSAEINVAL getsocknamer r ConnectExr )r r r+ rb er r? s ` r" connectzIocpProactor.connect; s 99)) )
" "4;;=' :****,C NN4 J & ! !$++- =
#
#D
)
T[[]G, ~~b$77! zzU__, !!$) * s .D E
5EE c 6 | j | t j t }|dz }|dz dz }|j |j t
j |j |||dd | j ||| j S )Nl r )
r rf r r TransmitFiler msvcrt
get_osfhandler r )r sockfileoffsetcountr
offset_low offset_highs r" sendfilezIocpProactor.sendfileZ s &
#
#D
)k)
|{2
,,T[[];"K q! %
~~b$(?(?@@r# c | j t j t }|j j }|r| j
S fd}| j || S )Nc ( |j S rA )r )r r r r s r" finish_accept_pipez4IocpProactor.accept_pipe.<locals>.finish_accept_pipeq s LLNKr# )r rf r r ConnectNamedPiper r r )r r r connectedrX s ` r" r zIocpProactor.accept_pipef sf &
#
#D
)''
6 <<% % ~~b$(:;;r# c < K t } t j | } t j | S # t $ r(}|j t j
k7 r Y d }~nd }~ww xY wt
|dz t }t j | d { 7 w)N ) CONNECT_PIPE_INIT_DELAYrf ConnectPiper6 rh ERROR_PIPE_BUSYminCONNECT_PIPE_MAX_DELAYr sleepr r )r r+ delayrT r9 s r" r zIocpProactor.connect_pipew s '
$009 ''//
<<;#>#>> ?
#9:E++e$ $ $ s6 B 6 B A' A" B "A''.B BB c ( | j ||d S )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 rT r s r" wait_for_handlez IocpProactor.wait_for_handle s $$VWe<<r# c : | j |d d }||_ |S r )re rr )r rs
done_callbackrb s r" r zIocpProactor._wait_cancel s% ##E46 +
r# c | j |t j }nt j |dz }t j t }t j || j |j | }|rt |||| j nt |||| | j j r
j d= fd}|d|f| j |j < S )N @@r r c $ j S rA )r\ )r r r r s r" finish_wait_for_handlez=IocpProactor._wait_for_handle.<locals>.finish_wait_for_handle s 779 r# r )r rX INFINITEmathceilrf r r RegisterWaitWithQueuer r+ rp r7 ry r r ) r rT r
_is_cancelmsr rU rl r s @r" re z IocpProactor._wait_for_handle s ?!!B 7S=)B
#
#D
)!77 DJJ
B0 !"fk
KA!"fk4'+zz3A ##B' $%b!-C"D BJJ r# c || j vrL| j j | t j |j | j
dd y y rW )rS r rf r r r r objs r" r z IocpProactor._register_with_iocp sI d&& & % . .szz|TZZA N 'r# c ^ | j t || j }|j r
|j d= |j s |d d | }|j | ||||f| j |j < |S # t $ r}|j | Y d }~>d }~ww xY wr )
r r r7 r r% rE r6 rB r r+ )r r ru callbackr r rH s r" r zIocpProactor._register s
btzz 2 ##B'zz
$ tR0 U# $%b#x"8 BJJ
#""
#s
B B,B''B,c Z | j | j j | y)a
Unregister 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 r` )r r s r" r zIocpProactor._unregister s$
!!"%r# c R t j | }|j d |S rW )r r/ )r r7 ss r" r6 z IocpProactor._get_accept_socket s MM& ! Qr# c " |t }n<|dk r t d t j |dz }|t k\ r t d t j
| j | }|nd}|\ }}}} | j j | \ }} }
} |
| j v r|j# nI|j% s9 | ||| } |j' | | j( j+ | d }| j0 D ]( } | j j | j2 d * | j0 j5 y # t $ rl | j j r%| j j dd||||fz d |dt j fvrt j | Y }w xY w# t, $ r7}
|j/ |
| j( j+ | Y d }
~
d }
~
ww xY w# d }w xY w)Nr znegative timeoutrj ztimeout too bigz8GetQueuedCompletionStatus() returned an unexpected eventz)err=%s transferred=%s key=%#x address=%#x)r1 status)rm
ValueErrorrn ro rf GetQueuedCompletionStatusr r popKeyErrorr7 get_debugr8 r rX r r r5 donerE r r` r6 rB r r+ r )r r rr r| err transferredr r+ r r ru rw r rH s r" r\ zIocpProactor._poll s ?B
q[ /0 0 7S=)BX~ !233 ::4::rJF~B-3 *Cc7
'+{{w'?$2sH d+++
VVX $[#r :E
LL'MM((+ AM R $$ .B KKOOBJJ - . "E
::'')JJ55%7#N&);W%E$F7 q+"B"B CC'',
, ,OOA&MM((++, AsC 4 E
G ,H
A1GG H,H<H
HH
Hc : | j j | y rA )r r rt s r"
_stop_servingzIocpProactor._stop_serving- s
!!#&r# c 4 | j y t | j j D ]: \ }}}}|j rt |t r* |j < d}t j }||z } | j rx| t j k rCt j d| t j |z
t j |z } | j! | | j rxg | _ t% j& | j d | _ y # t $ rS}| j <d||d}|j r|j |d< | j j | Y d }~ad }~ww xY w)NzCancelling a future failedr0 r4 g ?z,%r is running after closing for %.1f seconds)r listr values cancelledr rp r5 r6 r7 r r8 time monotonicr
debugr\ r rX r )
r rb r ru rw r9 r:
msg_update
start_timenext_msgs
r" r zIocpProactor.close3 sa :: '+4;;+=+=+?&@ C "CS(}}C!23 CJJL C0
^^%
*kk4>>++ K !4>>#3j#@B >>+j8
JJz " kk
DJJ'
; Czz-'C),&)#
00:=:O:OG$6 7
99'B Cs D;; FAFFc $ | j y rA )r r[ s r" r zIocpProactor.__del__b s
r# rA )r r )#rH rI rJ rK rm r r r r r r staticmethodr r r r r r# r' r; rI rU r r rf r re r r r r6 r\ r r r r r# r" r r s -#+ 29E
A AA5(AA8 8>
A<"0&= DO @&
7#r' -^r# r c e Zd Zd Zy)r c t j |f|||||d| _ fd} j j j t
j j } | j | y )N)r r r r r c \ j j }j | y rA )_procpoll_process_exited)r
returncoder s r" rw z4_WindowsSubprocessTransport._start.<locals>.callbackm s! *J ,r# ) r Popenr r7 r{ rf intrQ r )
r r r r r r r r rw r s
` r" _startz"_WindowsSubprocessTransport._starth so "(( ' U6&' %'
-
JJ 0 0TZZ5G5G1H I H%r# N)rH rI rJ r r r# r" r r f s
&r# r c e Zd ZeZy)r N)rH rI rJ r
_loop_factoryr r# r" r r x %Mr# r c e Zd ZeZy)r N)rH rI rJ r r r r# r" r r | r r# r )2rK sysplatform ImportErrorrf rX rD rn rM r r* r r r r r r r r
r r logr
__all__r rm ERROR_CONNECTION_REFUSEDERROR_CONNECTION_ABORTEDr] ra Futurer rO rp ry objectr BaseSelectorEventLoopr BaseProactorEventLoopr r BaseSubprocessTransportr r BaseDefaultEventLoopPolicyr r r r r# r" <module>r sY 4
<<7
l
##
|| - -`G#GNN G#T&- &01P- 1Ph8 8v2 E E 2g== gTD DN &/"I"I & . &V%F%F &&V%F%F & 8 r# 
Browse
Usage
Versions