B
ˆ fv ã @ s d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl
m Z ddl
m Z ddl
m
Z
ddl
mZ ddl
mZ dd l
mZ dd
l
mZ dd lmZ d ZdZd
ZdZdZdZdZG dd„ de
jƒZ G dd„ de
jƒZ G dd„ de ƒZ G dd„ de ƒZ G dd„ de ƒZ!G d d „ d ej"ƒZ#G d d „ d ej$ƒZ%G d d!„ d!ƒZ&G d"d#„ d#e j'ƒZ(e#Z)G d$d%„ d%e j*ƒZ+G d&d'„ d'e j*ƒZ,e+Z-dS )(z.Selector and proactor event loops for Windows.é Né )Úevents)Úbase_subprocess)Úfutures)Úproactor_events)Úselector_events)Útasks)Ú
windows_utils)Úlogger)ÚSelectorEventLoopÚProactorEventLoopÚ IocpProactorÚDefaultEventLoopPolicyÚ WindowsSelectorEventLoopPolicyÚ WindowsProactorEventLoopPolicyl ÿÿ iÉ iÔ gü©ñÒMbP?gš™™™™™¹?c s^ e Zd ZdZddœ‡ fdd„
Z‡ fdd„Zdd „ Z‡ fd
d „Z‡ fd d
„Z‡ fdd„Z ‡ Z
S )Ú_OverlappedFuturez†Subclass of Future which represents an overlapped operation.
Cancelling it will immediately cancel the overlapped operation.
N)Úloopc s& t ƒ j|d | jr | jd= || _d S )N)r éÿÿÿÿ)ÚsuperÚ__init__Ú_source_tracebackÚ_ov)ÚselfÚovr )Ú __class__© ú;/opt/alt/python37/lib64/python3.7/asyncio/windows_events.pyr 0 s z_OverlappedFuture.__init__c sH t ƒ ¡ }| jd k rD| jjr dnd}| dd|› d| jjd›d¡ |S )NÚpendingZ completedr z overlapped=)r Ú
_repr_infor r ÚinsertÚaddress)r ÚinfoÚstate)r r r r 6 s
z _OverlappedFuture._repr_infoc
C sr | j d krd S y| j ¡ W nJ tk
rf } z,d|| dœ}| jrJ| j|d< | j |¡ W d d }~X Y nX d | _ d S )Nz&Cancelling an overlapped future failed)ÚmessageÚ exceptionÚfutureÚsource_traceback)r ÚcancelÚOSErrorr Ú_loopÚcall_exception_handler)r ÚexcÚcontextr r r Ú_cancel_overlapped= s
z$_OverlappedFuture._cancel_overlappedc s | ¡ tƒ ¡ S )N)r. r r( )r )r r r r( M s z_OverlappedFuture.cancelc s t ƒ |¡ | ¡ d S )N)r Ú
set_exceptionr. )r r% )r r r r/ Q s z _OverlappedFuture.set_exceptionc s t ƒ |¡ d | _d S )N)r Ú
set_resultr )r Úresult)r r r r0 U s z _OverlappedFuture.set_result) Ú__name__Ú
__module__Ú __qualname__Ú__doc__r r r. r( r/ r0 Ú
__classcell__r r )r r r * s r c sn e Zd ZdZddœ‡ fdd„
Zdd„ Z‡ fdd „Zd
d „ Zd d
„ Z‡ fdd„Z ‡ fdd„Z
‡ fdd„Z ‡ Z S )Ú_BaseWaitHandleFuturez2Subclass of Future which represents a wait handle.N)r c s8 t ƒ j|d | jr | jd= || _|| _|| _d| _d S )N)r r T)r r r r Ú_handleÚ _wait_handleÚ _registered)r r ÚhandleÚ wait_handler )r r r r ] s z _BaseWaitHandleFuture.__init__c C s t | jd¡t jkS )Nr )Ú_winapiZWaitForSingleObjectr8 Z
WAIT_OBJECT_0)r r r r Ú_pollk s z_BaseWaitHandleFuture._pollc sd t ƒ ¡ }| d| jd›¡ | jd k rB| ¡ r4dnd}| |¡ | jd k r`| d| jd›¡ |S )Nzhandle=z#xZsignaledZwaitingz wait_handle=)r r Úappendr8 r> r9 )r r" r# )r r r r p s
z _BaseWaitHandleFuture._repr_infoc C s
d | _ d S )N)r )r Úfutr r r Ú_unregister_wait_cbz s z)_BaseWaitHandleFuture._unregister_wait_cbc
C s” | j s
d S d| _ | j}d | _yt |¡ W nZ tk
r„ } z<|jtjkrtd|| dœ}| jrd| j|d< | j |¡ d S W d d }~X Y nX |
d ¡ d S )NFz$Failed to unregister the wait handle)r$ r% r& r' ) r: r9 Ú _overlappedZUnregisterWaitr) ÚwinerrorÚERROR_IO_PENDINGr r* r+ rA )r r< r, r- r r r Ú_unregister_wait s"
z&_BaseWaitHandleFuture._unregister_waitc s | ¡ tƒ ¡ S )N)rE r r( )r )r r r r( — s z _BaseWaitHandleFuture.cancelc s | ¡ tƒ |¡ d S )N)rE r r/ )r r% )r r r r/ › s z#_BaseWaitHandleFuture.set_exceptionc s | ¡ tƒ |¡ d S )N)rE r r0 )r r1 )r r r r0 Ÿ s z _BaseWaitHandleFuture.set_result)
r2 r3 r4 r5 r r> r rA rE r( r/ r0 r6 r r )r r r7 Z s
r7 c sF e Zd ZdZddœ‡ fdd„
Zdd„ Z‡ fdd „Z‡ fd
d „Z‡ ZS ) Ú_WaitCancelFuturezoSubclass of Future which represents a wait for the cancellation of a
_WaitHandleFuture using an event.
N)r c s t ƒ j||||d d | _d S )N)r )r r Ú_done_callback)r r Úeventr< r )r r r r © s z_WaitCancelFuture.__init__c C s t dƒ‚d S )Nz'_WaitCancelFuture must not be cancelled)Ú RuntimeError)r r r r r( ® s z_WaitCancelFuture.cancelc s$ t ƒ |¡ | jd k r | | ¡ d S )N)r r0 rG )r r1 )r r r r0 ± s
z _WaitCancelFuture.set_resultc s$ t ƒ |¡ | jd k r | | ¡ d S )N)r r/ rG )r r% )r r r r/ ¶ s
z _WaitCancelFuture.set_exception) r2 r3 r4 r5 r r( r0 r/ r6 r r )r r rF ¤ s
rF c s6 e Zd Zddœ‡ fdd„
Z‡ fdd„Zdd„ Z‡ ZS ) Ú_WaitHandleFutureN)r c s< t ƒ j||||d || _d| _t d ddd ¡| _d | _d S )N)r TF)r r Ú _proactorZ_unregister_proactorrB Z CreateEventÚ_eventÚ
_event_fut)r r r; r< Úproactorr )r r r r ½ s
z_WaitHandleFuture.__init__c sF | j d k r"t | j ¡ d | _ d | _| j | j¡ d | _tƒ |¡ d S )N) rL r= Ú CloseHandlerM rK Ú _unregisterr r rA )r r@ )r r r rA Ä s
z%_WaitHandleFuture._unregister_wait_cbc
C s¢ | j s
d S d| _ | j}d | _yt || j¡ W nZ tk
rˆ } z<|jtjkrxd|| dœ}| jrh| j|d< | j
|¡ d S W d d }~X Y nX | j | j| j
¡| _d S )NFz$Failed to unregister the wait handle)r$ r% r& r' )r: r9 rB ZUnregisterWaitExrL r) rC rD r r* r+ rK Ú _wait_cancelrA rM )r r< r, r- r r r rE Ö s$
z"_WaitHandleFuture._unregister_wait)r2 r3 r4 r rA rE r6 r r )r r rJ ¼ s rJ c @ s< e Zd ZdZdd„ Zdd„ Zdd„ Zdd „ Zd
d „ ZeZ d S )
Ú
PipeServerzXClass representing a pipe server.
This is much like a bound, listening socket.
c C s, || _ t ¡ | _d | _d | _| d¡| _d S )NT)Ú_addressÚweakrefÚWeakSetÚ_free_instancesÚ_pipeÚ_accept_pipe_futureÚ_server_pipe_handle)r r! r r r r õ s
zPipeServer.__init__c C s | j | d¡ }| _ |S )NF)rW rY )r Útmpr r r Ú_get_unconnected_pipeÿ s z PipeServer._get_unconnected_pipec
C sr | ¡ r d S tjtjB }|r&|tjO }t | j|tjtjB tj B tj
t j t j tj
tj¡}t |¡}| j |¡ |S )N)Úclosedr= ZPIPE_ACCESS_DUPLEXZFILE_FLAG_OVERLAPPEDZ FILE_FLAG_FIRST_PIPE_INSTANCEZCreateNamedPiperS ZPIPE_TYPE_MESSAGEZPIPE_READMODE_MESSAGEZ PIPE_WAITZPIPE_UNLIMITED_INSTANCESr ZBUFSIZEZNMPWAIT_WAIT_FOREVERÚNULLÚ
PipeHandlerV Úadd)r ÚfirstÚflagsÚhÚpiper r r rY s
z PipeServer._server_pipe_handlec C s
| j d kS )N)rS )r r r r r\ s zPipeServer.closedc C sV | j d k r| j ¡ d | _ | jd k rRx| jD ] }| ¡ q,W d | _d | _| j ¡ d S )N)rX r( rS rV ÚcloserW Úclear)r rc r r r rd s
zPipeServer.closeN)
r2 r3 r4 r5 r r[ rY r\ rd Ú__del__r r r r rR ð s
rR c @ s e Zd ZdZdS )Ú_WindowsSelectorEventLoopz'Windows version of selector event loop.N)r2 r3 r4 r5 r r r r rg + s rg c s< e Zd ZdZd ‡ fdd„ Zdd„ Zdd„ Zd d d
„Z‡ ZS )
r z2Windows version of proactor event loop using IOCP.Nc s |d krt ƒ }tƒ |¡ d S )N)r
r r )r rN )r r r r 2 s zProactorEventLoop.__init__c à s8 | j |¡}|I d H }|ƒ }| j||d|id}||fS )NÚaddr)Úextra)rK Ú connect_pipeÚ_make_duplex_pipe_transport)r Úprotocol_factoryr! Úfrc ÚprotocolÚtransr r r Úcreate_pipe_connection7 s
z(ProactorEventLoop.create_pipe_connectionc ƒ s. t ˆ ƒ‰d‡ ‡‡‡‡fdd„ ‰ˆ ˆ¡ ˆgS )Nc
s d }yj| rL| ¡ }ˆj |¡ ˆ ¡ r2| ¡ d S ˆƒ }ˆj||dˆ id ˆ ¡ }|d kr`d S ˆj |¡} W n„ t k
rÒ } zF|r¬|
¡ dkr¬ˆ d||dœ¡ | ¡ nˆj rÂt
jd|dd W d d }~X Y n2 tjk
rò |rî| ¡ Y nX | ˆ_| ˆ¡ d S ) Nrh )ri r zPipe accept failed)r$ r% rc z Accept pipe failed on pipe %rT)Úexc_info)r1 rV Údiscardr\ rd rk r[ rK Ú accept_piper) Úfilenor+ Z_debugr
Zwarningr ÚCancelledErrorrX Úadd_done_callback)rm rc rn r, )r! Úloop_accept_piperl r Úserverr r rw B s<
z>ProactorEventLoop.start_serving_pipe..loop_accept_pipe)N)rR Z call_soon)r rl r! r )r! rw rl r rx r Ústart_serving_pipe? s (
z$ProactorEventLoop.start_serving_pipec Ë sl | ¡ }
t| |||||||f|
|dœ| —Ž} y|
I d H W n, tk
rf | ¡ | ¡ I d H ‚ Y nX | S )N)Úwaiterri )Ú
create_futureÚ_WindowsSubprocessTransportÚ Exceptionrd Z_wait) r rn ÚargsÚshellÚstdinÚstdoutÚstderrÚbufsizeri Úkwargsrz Ztranspr r r Ú_make_subprocess_transportm s
z,ProactorEventLoop._make_subprocess_transport)N)N) r2 r3 r4 r5 r rp ry r… r6 r r )r r r / s
0r c @ sæ e Zd ZdZd7dd„Zdd„ Zdd„ Zd d
„ Zd8d d
„Zdd„ Z d9dd„Z
d:dd„Z d;dd„Z dd„ Z
dd„ Zdd „ Zd d „ Zd d „ Zdr
z#Proactor implementation using IOCP.ì ÿÿ c C sD d | _ g | _t tjtd|¡| _i | _t ¡ | _
g | _ t ¡ | _ d S )Nr )
r* Ú_resultsrB ÚCreateIoCompletionPortÚINVALID_HANDLE_VALUEr] Ú_iocpÚ_cacherT rU r: Ú
_unregisteredÚ_stopped_serving)r Z concurrencyr r r r ‚ s
zIocpProactor.__init__c C s | j d krtdƒ‚d S )NzIocpProactor is closed)rŠ rI )r r r r Ú
_check_closedΠs
zIocpProactor._check_closedc C sF dt | jƒ dt | jƒ g}| jd kr0| d¡ d| jjd |¡f S )Nzoverlapped#=%sz
result#=%sr\ z<%s %s>ú )Úlenr‹ r‡ rŠ r? r r2 Újoin)r r" r r r Ú__repr__ s
zIocpProactor.__repr__c C s
|| _ d S )N)r* )r r r r r Úset_loop— s zIocpProactor.set_loopNc C s | j s| |¡ | j }g | _ |S )N)r‡ r> )r ÚtimeoutrZ r r r Úselectš s
zIocpProactor.selectc C s | j ¡ }| |¡ |S )N)r* r{ r0 )r Úvaluer@ r r r Ú_result¡ s
zIocpProactor._resultr c C sz | |¡ t t¡}y4t|tjƒr6| | ¡ ||¡ n| | ¡ |¡ W n t k
rb |
d¡S X dd„ }| |||¡S )Nó c
S sP y| ¡ S tk
rJ } z$|jtjtjfkr8t|jŽ ‚n‚ W d d }~X Y nX d S )N)Ú getresultr) rC rB ÚERROR_NETNAME_DELETEDÚERROR_OPERATION_ABORTEDÚConnectionResetErrorr~ )ro Úkeyr r, r r r Ú finish_recv± s
z&IocpProactor.recv..finish_recv) Ú_register_with_iocprB Ú
Overlappedr] Ú
isinstanceÚsocketZWSARecvrt ZReadFileÚBrokenPipeErrorr— Ú _register)r ÚconnÚnbytesra r rž r r r Úrecv¦ s
zIocpProactor.recvc C sz | |¡ t t¡}y4t|tjƒr6| | ¡ ||¡ n| | ¡ |¡ W n t k
rb |
d¡S X dd„ }| |||¡S )Nr˜ c
S sP y| ¡ S tk
rJ } z$|jtjtjfkr8t|jŽ ‚n‚ W d d }~X Y nX d S )N)r™ r) rC rB rš r› rœ r~ )ro r r r, r r r rž È s
z+IocpProactor.recv_into..finish_recv) rŸ rB r r] r¡ r¢ Z WSARecvIntort Z ReadFileIntor£ r— r¤ )r r¥ Úbufra r rž r r r Ú recv_into½ s
zIocpProactor.recv_intoc C sZ | |¡ t t¡}t|tjƒr4| | ¡ ||¡ n| | ¡ |¡ dd„ }| |||¡S )Nc
S sP y| ¡ S tk
rJ } z$|jtjtjfkr8t|jŽ ‚n‚ W d d }~X Y nX d S )N)r™ r) rC rB rš r› rœ r~ )ro r r r, r r r Ú finish_sendÜ s
z&IocpProactor.send..finish_send)
rŸ rB r r] r¡ r¢ ZWSASendrt Z WriteFiler¤ )r r¥ r¨ ra r rª r r r ÚsendÔ s
zIocpProactor.sendc sv | ˆ¡ | ˆj¡‰ t t¡}| ˆ ¡ ˆ ¡ ¡ ‡ ‡fdd„}dd„ }| |ˆ|¡}||ˆ ƒ}t j
|| j d |S )Nc sD | ¡ t dˆ ¡ ¡}ˆ tjtj|¡ ˆ ˆ
¡ ¡ ˆ ˆ ¡ fS )Nz@P) r™ ÚstructZpackrt Ú
setsockoptr¢ Ú
SOL_SOCKETrB ZSO_UPDATE_ACCEPT_CONTEXTÚ
settimeoutZ
gettimeoutZ getpeername)ro r r r¨ )r¥ Úlistenerr r Ú
finish_acceptî s
z*IocpProactor.accept..finish_acceptc Ó s4 y| I d H W n t jk
r. | ¡ ‚ Y nX d S )N)r ru rd )r& r¥ r r r Ú accept_coro÷ s
z(IocpProactor.accept..accept_coro)r ) rŸ Ú_get_accept_socketÚfamilyrB r r] ZAcceptExrt r¤ r Z
ensure_futurer* )r r° r r± r² r& Úcoror )r¥ r° r Úacceptè s
zIocpProactor.acceptc
s˜ | ˆ ¡ yt ˆ ¡ ˆ j¡ W nB tk
rb } z$|jtjkr@‚ ˆ ¡ d dkrR‚ W d d }~X Y nX t
t ¡}| ˆ ¡ |¡ ‡ fdd„}|
|ˆ |¡S )Nr r c s | ¡ ˆ tjtjd¡ ˆ S )Nr )r™ r r¢ r® rB ZSO_UPDATE_CONNECT_CONTEXT)ro r r )r¥ r r Úfinish_connect s
z,IocpProactor.connect..finish_connect)rŸ rB Z BindLocalrt r´ r) rC ÚerrnoZ WSAEINVALZ getsocknamer r] Z ConnectExr¤ )r r¥ r! Úer r· r )r¥ r Úconnect s
zIocpProactor.connectc C sb | |¡ t t¡}|d@ }|d? d@ }| | ¡ t | ¡ ¡|||dd¡ dd„ }| |||¡S )Nl ÿÿ é r c
S sP y| ¡ S tk
rJ } z$|jtjtjfkr8t|jŽ ‚n‚ W d d }~X Y nX d S )N)r™ r) rC rB rš r› rœ r~ )ro r r r, r r r Úfinish_sendfile% s
z.IocpProactor.sendfile..finish_sendfile) rŸ rB r r] Z TransmitFilert ÚmsvcrtZ
get_osfhandler¤ ) r ZsockÚfileÚoffsetÚcountr Z
offset_lowZ offset_highr¼ r r r Úsendfile s
zIocpProactor.sendfilec sJ | ˆ ¡ t t¡}| ˆ ¡ ¡}|r0| ˆ ¡S ‡ fdd„}| |ˆ |¡S )Nc s | ¡ ˆ S )N)r™ )ro r r )rc r r Úfinish_accept_pipe; s z4IocpProactor.accept_pipe..finish_accept_pipe)rŸ rB r r] ZConnectNamedPipert r— r¤ )r rc r Z connectedr r )rc r rs 0 s
zIocpProactor.accept_pipec
à sz t }xjyt |¡}P W n0 tk
rF } z|jtjkr6‚ W d d }~X Y nX t|d tƒ}tj || j
dI d H qW t |¡S )Né )r )
ÚCONNECT_PIPE_INIT_DELAYrB Z ConnectPiper) rC ZERROR_PIPE_BUSYÚminÚCONNECT_PIPE_MAX_DELAYr Zsleepr* r r^ )r r! Zdelayr; r, r r r rj A s
zIocpProactor.connect_pipec C s | ||d¡S )z°Wait 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 r; r” r r r Úwait_for_handleT s z IocpProactor.wait_for_handlec C s | |d d¡}||_|S )NT)rÇ rG )r rH Z
done_callbackr@ r r r rQ \ s zIocpProactor._wait_cancelc s¢ | ¡ |d krtj}nt |d ¡}t t¡}t || j |j
|¡}|r\t |||| j d‰ nt
|||| | j d‰ ˆ jr~ˆ jd= ‡ fdd„}ˆ |d|f| j|j
< ˆ S )Ng @@)r r c s ˆ ¡ S )N)r> )ro r r )rm r r Úfinish_wait_for_handley s z=IocpProactor._wait_for_handle..finish_wait_for_handler )rŽ r= ÚINFINITEÚmathÚceilrB r r] ZRegisterWaitWithQueuerŠ r! rF r* rJ r r‹ )r r; r” Z
_is_cancelÚmsr r< rÉ r )rm r rÇ c s
z IocpProactor._wait_for_handlec C s0 || j kr,| j |¡ t | ¡ | jdd¡ d S )Nr )r: r_ rB rˆ rt rŠ )r Úobjr r r rŸ … s
z IocpProactor._register_with_iocpc
C sŠ | ¡ t|| jd}|jr$|jd= |jsry|d d |ƒ}W n, tk
rf } z| |¡ W d d }~X Y n X | |¡ ||||f| j|j < |S )N)r r )
rŽ r r* r r r) r/ r0 r‹ r! )r r rÎ Úcallbackrm r– r¹ r r r r¤ s
zIocpProactor._registerc C s | ¡ | j |¡ dS )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 r r r rP ¯ s zIocpProactor._unregisterc C s t |¡}| d¡ |S )Nr )r¢ r¯ )r r´ Úsr r r r³ ¹ s
z IocpProactor._get_accept_socketc C sŒ |d krt }n0|dk r tdƒ‚n t |d ¡}|t kr>tdƒ‚xt | j|¡}|d krZP d}|\}}}}y| j |¡\}} }
} W nV t k
rØ | j
¡ rº| j
dd||||f dœ¡ |dtj
fkrÒt |¡ wBY nX |
| jkrî| ¡ qB| ¡ sBy| ||| ƒ} W n: tk
r@ }
z| |
¡ | j |¡ W d d }
~
X Y qBX | | ¡ | j |¡ qBW x | jD ]} | j | jd ¡ qdW | j ¡ d S )Nr znegative timeoutg @@ztimeout too bigz8GetQueuedCompletionStatus() returned an unexpected eventz)err=%s transferred=%s key=%#x address=%#x)r$ Ústatus)rÊ Ú
ValueErrorrË rÌ rB ZGetQueuedCompletionStatusrŠ r‹ ÚpopÚKeyErrorr* Z get_debugr+ r‰ r= rO r r( Zdoner) r/ r‡ r? r0 rŒ r! re )r r” rÍ rÑ ÚerrZ transferredr r! rm r rÎ rÏ r– r¹ r r r r> ¾ sJ
zIocpProactor._pollc C s | j |¡ d S )N)r r_ )r rÎ r r r Ú
_stop_servingõ s zIocpProactor._stop_servingc C s | j d krd S xšt| j ¡ ƒD ]ˆ\}\}}}}| ¡ r8q t|tƒrDq y | ¡ W q tk
r¤ } z6| j d k r”d||dœ}|j
rˆ|j
|d< | j |¡ W d d }~X Y q X q W d}t
¡ } | | }
xD| jr|
t
¡ kröt d| t
¡ | ¡ t
¡ | }
| |¡ qÀW g | _t | j ¡ d | _ d S )NzCancelling a future failed)r$ r% r& r' g ð?z,%r is running after closing for %.1f seconds)rŠ Úlistr‹ ÚitemsZ cancelledr¡ rF r( r) r* r r+ ÚtimeZ monotonicr
Údebugr> r‡ r= rO ) r r! r@ r rÎ rÏ r, r- Z
msg_updateZ
start_timeZnext_msgr r r rd û s:
"
zIocpProactor.closec C s | ¡ d S )N)rd )r r r r rf * s zIocpProactor.__del__)r† )N)r )r )r )N)N) r2 r3 r4 r5 r rŽ r’ r“ r• r— r§ r© r« r¶ rº rÁ rs rj rÈ rQ rÇ rŸ r¤ rP r³ r> rÖ rd rf r r r r r
s4
"
7/r
c @ s e Zd Zdd„ ZdS )r| c
sP t j|f|||||dœ|—Žˆ _‡ fdd„}ˆ jj tˆ jjƒ¡} | |¡ d S )N)r r€ r r‚ rƒ c s ˆ j ¡ }ˆ |¡ d S )N)Ú_procZpollZ_process_exited)rm Ú
returncode)r r r rÏ 5 s
z4_WindowsSubprocessTransport._start..callback) r ÚPopenrÛ r* rK rÈ Úintr8 rv )
r r~ r r€ r r‚ rƒ r„ rÏ rm r )r r Ú_start0 s z"_WindowsSubprocessTransport._startN)r2 r3 r4 rß r r r r r| . s r| c @ s e Zd ZeZdS )r N)r2 r3 r4 r Ú
_loop_factoryr r r r r @ s r c @ s e Zd ZeZdS )r N)r2 r3 r4 r rà r r r r r D s r ).r5 rB r= r¸ rË r½ r¢ r¬ rÙ rT Ú r r r r r r r Úlogr
Ú__all__r] rÊ ZERROR_CONNECTION_REFUSEDZERROR_CONNECTION_ABORTEDrÄ rÆ ZFuturer r7 rF rJ ÚobjectrR ZBaseSelectorEventLooprg ZBaseProactorEventLoopr r
ZBaseSubprocessTransportr| r ZBaseDefaultEventLoopPolicyr r r r r r r Ú sP 0J4;P 2