B
YI~dv ã @ sŒ d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZddl m
Z
ddl m Z ddl m Z ddl m
Z
ddl mZ ddl mZ dd l mZ dd
lmZ d Zd Zd Zd
ZdZdZdZG dd„ de jƒZG dd„ de jƒZ G dd„ de ƒZ G dd„ de ƒZ G dd„ de ƒZ G dd „ d ej!ƒZ"G d d „ d e
j#ƒ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 )'é 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 sZ e Zd Zddœ‡ fdd„
Z‡ fdd„Zdd„ Z‡ fd d
„Z‡ fd d „Z‡ fd
d„Z‡ Z S )Ú_OverlappedFutureN)Ú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__r r r. r( r/ r0 Ú
__classcell__r r )r r r * s r c sj e Zd Zddœ‡ fdd„
Zdd„ Z‡ fdd„Zd d
„ Zd d „ Z‡ fd
d„Z‡ fdd„Z ‡ fdd„Z
‡ Z S )Ú_BaseWaitHandleFutureN)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 )Ú_winapiZWaitForSingleObjectr7 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 Úappendr7 r= r8 )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' ) r9 r8 Ú _overlappedZUnregisterWaitr) ÚwinerrorÚERROR_IO_PENDINGr r* r+ r@ )r r; r, r- r r r Ú_unregister_wait s"
z&_BaseWaitHandleFuture._unregister_waitc s | ¡ tƒ ¡ S )N)rD r r( )r )r r r r( — s z _BaseWaitHandleFuture.cancelc s | ¡ tƒ |¡ d S )N)rD r r/ )r r% )r r r r/ › s z#_BaseWaitHandleFuture.set_exceptionc s | ¡ tƒ |¡ d S )N)rD r r0 )r r1 )r r r r0 Ÿ s z _BaseWaitHandleFuture.set_result) r2 r3 r4 r r= r r@ rD r( r/ r0 r5 r r )r r r6 Z s
r6 c sB e Zd Zddœ‡ fdd„
Zdd„ Z‡ fdd„Z‡ fd d
„Z‡ ZS ) Ú_WaitCancelFutureN)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 rF )r r1 )r r r r0 ± s
z _WaitCancelFuture.set_resultc s$ t ƒ |¡ | jd k r | | ¡ d S )N)r r/ rF )r r% )r r r r/ ¶ s
z _WaitCancelFuture.set_exception)r2 r3 r4 r r( r0 r/ r5 r r )r r rE ¤ s rE 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_proactorrA 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) rK r< Ú CloseHandlerL rJ Ú _unregisterr r r@ )r r? )r r r r@ Ä 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' )r9 r8 rA ZUnregisterWaitExrK r) rB rC r r* r+ rJ Ú _wait_cancelr@ rL )r r; r, r- r r r rD Ö s$
z"_WaitHandleFuture._unregister_wait)r2 r3 r4 r r@ rD r5 r r )r r rI ¼ s rI c @ s8 e Zd Zdd„ Zdd„ Zdd„ Zdd„ Zd d
„ ZeZd S ) Ú
PipeServerc 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)rV rX )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_INSTANCEZCreateNamedPiperR ZPIPE_TYPE_MESSAGEZPIPE_READMODE_MESSAGEZ PIPE_WAITZPIPE_UNLIMITED_INSTANCESr ZBUFSIZEZNMPWAIT_WAIT_FOREVERÚNULLÚ
PipeHandlerU Úadd)r ÚfirstÚflagsÚhÚpiper r r rX s
z PipeServer._server_pipe_handlec C s
| j d kS )N)rR )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)rW r( rR rU ÚcloserV Úclear)r rb r r r rc s
zPipeServer.closeN) r2 r3 r4 r rZ rX r[ rc Ú__del__r r r r rQ ð s
rQ c @ s e Zd ZdS )Ú_WindowsSelectorEventLoopN)r2 r3 r4 r r r r rf + s rf c s8 e Zd Zd
‡ fdd„ Zdd„ Zdd„ Zd dd „Z‡ ZS ) r Nc s |d krt ƒ }tƒ |¡ d S )N)r
r r )r rM )r r r r 2 s zProactorEventLoop.__init__c à s8 | j |¡}|I d H }|ƒ }| j||d|id}||fS )NÚaddr)Úextra)rJ Ú connect_pipeÚ_make_duplex_pipe_transport)r Úprotocol_factoryr! Úfrb Ú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 ) Nrg )rh r zPipe accept failed)r$ r% rb z Accept pipe failed on pipe %rT)Úexc_info)r1 rU Údiscardr[ rc rj rZ rJ Ú accept_piper) Úfilenor+ Z_debugr
Zwarningr ÚCancelledErrorrW Úadd_done_callback)rl rb rm r, )r! Úloop_accept_piperk r Úserverr r rv B s<
z>ProactorEventLoop.start_serving_pipe..loop_accept_pipe)N)rQ Z call_soon)r rk r! r )r! rv rk r rw 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)Úwaiterrh )Ú
create_futureÚ_WindowsSubprocessTransportÚ Exceptionrc Z_wait) r rm ÚargsÚshellÚstdinÚstdoutÚstderrÚbufsizerh Úkwargsry Ztranspr r r Ú_make_subprocess_transportm s
z,ProactorEventLoop._make_subprocess_transport)N)N)r2 r3 r4 r ro rx r„ r5 r r )r r r / s 0r c @ sâ e Zd Zd6dd„Zdd„ Zdd„ Zdd „ Zd7d d „Zd
d„ Zd8dd„Z d9dd„Z
d:dd„Z dd„ Z dd„ Z
dd„ Zd d „ Zd d „ Zd;d d!„Zd"d#„ Zd$d%„ Zd&d'„ Zd(d)„ Zd*d+„ Zd,d-„ Zdú )Ú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 ÚtimeoutrY r r r Úselectš s
zIocpProactor.selectc C s | j ¡ }| |¡ |S )N)r* rz 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) rB rA ÚERROR_NETNAME_DELETEDÚERROR_OPERATION_ABORTEDÚConnectionResetErrorr} )rn Úkeyr r, r r r Ú finish_recv± s
z&IocpProactor.recv..finish_recv) Ú_register_with_iocprA Ú
Overlappedr\ Ú
isinstanceÚsocketZWSARecvrs ZReadFileÚBrokenPipeErrorr– Ú _register)r ÚconnÚnbytesr` 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) rB rA r™ rš r› r} )rn rœ r r, r r r r È s
z+IocpProactor.recv_into..finish_recv) rž rA rŸ r\ r r¡ Z WSARecvIntors Z ReadFileIntor¢ r– r£ )r r¤ Úbufr` 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) rB rA r™ rš r› r} )rn rœ r r, r r r Ú finish_sendÜ s
z&IocpProactor.send..finish_send)
rž rA rŸ r\ r r¡ ZWSASendrs Z WriteFiler£ )r r¤ r§ r` 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˜ ÚstructÚpackrs Ú
setsockoptr¡ Ú
SOL_SOCKETrA ZSO_UPDATE_ACCEPT_CONTEXTÚ
settimeoutZ
gettimeoutZ getpeername)rn 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 rt rc )r& r¤ r r r Ú accept_coro÷ s
z(IocpProactor.accept..accept_coro)r ) rž Ú_get_accept_socketÚfamilyrA rŸ r\ ZAcceptExrs 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® rA ZSO_UPDATE_CONNECT_CONTEXT)rn rœ r )r¤ r r Úfinish_connect s
z,IocpProactor.connect..finish_connect)rž rA Z BindLocalrs r´ r) rB Ú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) rB rA r™ rš r› r} )rn rœ r r, r r r Úfinish_sendfile% s
z.IocpProactor.sendfile..finish_sendfile) rž rA rŸ r\ Z TransmitFilers Ú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˜ )rn rœ r )rb r r Úfinish_accept_pipe; s z4IocpProactor.accept_pipe..finish_accept_pipe)rž rA rŸ r\ ZConnectNamedPipers r– r£ )r rb r Z connectedr r )rb r rr 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_DELAYrA Z ConnectPiper) rB ZERROR_PIPE_BUSYÚminÚCONNECT_PIPE_MAX_DELAYr Zsleepr* r r] )r r! Zdelayr: r, r r r ri A s
zIocpProactor.connect_pipec C s | ||d¡S )NF)Ú_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Ç rF )r rG Z
done_callbackr? r r r rP \ 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= )rn rœ r )rl r r Úfinish_wait_for_handley s z=IocpProactor._wait_for_handle..finish_wait_for_handler )r r< ÚINFINITEÚmathÚceilrA rŸ r\ ZRegisterWaitWithQueuer‰ r! rE r* rI r rŠ )r r: r“ Z
_is_cancelÚmsr r; rÉ r )rl r rÇ c s
z IocpProactor._wait_for_handlec C s0 || j kr,| j |¡ t | ¡ | jdd¡ d S )Nr )r9 r^ rA r‡ rs 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Î Úcallbackrl r• r¹ r r r r£ s
zIocpProactor._registerc C s | ¡ | j |¡ d S )N)r r‹ r> )r r r r r rO ¯ 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Ì rA ZGetQueuedCompletionStatusr‰ rŠ ÚpopÚKeyErrorr* Z get_debugr+ rˆ r< rN rŒ r( Zdoner) r/ r† r> r0 r‹ r! rd )r r“ rÍ rÑ ÚerrZ transferredrœ r! rl 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 rE r( r) r* r r+ ÚtimeZ monotonicr
Údebugr= r† r< rN ) r r! r? r rÎ rÏ r, r- Z
msg_updateZ
start_timeZnext_msgr r r rc û s:
"
zIocpProactor.closec C s | ¡ d S )N)rc )r r r r re * s zIocpProactor.__del__)r… )N)r )r )r )N)N) r2 r3 r4 r r r‘ r’ r” r– r¦ r¨ rª r¶ rº rÁ rr ri rÈ rP rÇ rž r£ rO r³ r= rÖ rc re r r r r r
s2
"
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)rl Ú
returncode)r r r rÏ 5 s
z4_WindowsSubprocessTransport._start..callback) r ÚPopenrÛ r* rJ rÈ Úintr7 ru )
r r} r~ r r€ r r‚ rƒ rÏ rl 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 )-rA r< r¸ rË r½ r¡ r« rÙ rS Ú r r r r r r r Úlogr
Ú__all__r\ rÊ ZERROR_CONNECTION_REFUSEDZERROR_CONNECTION_ABORTEDrÄ rÆ ZFuturer r6 rE rI ÚobjectrQ ZBaseSelectorEventLooprf ZBaseProactorEventLoopr r
ZBaseSubprocessTransportr{ r ZBaseDefaultEventLoopPolicyr r r r r r r Ú sN 0J4;P 2