a
´i*Ê ã @ sâ d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
Z
d dl Z ddl m
Z
ddl mZ ddl mZ ddl mZ ddl mZ ddl mZ dd l mZ dd
l mZ dd l mZ dd l mZ dd
lmZ dZe jdkrúedƒ‚dd„ Z G dd„ dej ƒZ G dd„ dej ƒZ G dd„ dej!ej"ƒZ#G dd„ dej$ƒZ%G dd „ d ƒZ&G d d „ d e&ƒZ'd d „ Z(G d!d"„ d"e&ƒZ)G d#d$„ d$e)ƒZ*G d%d&„ d&e)ƒZ+G d'd(„ d(e&ƒZ,G d)d*„ d*e&ƒZ-G d+d,„ d,ej.ƒZ/e Z0e/Z1dS )-é Né )Ú base_events)Úbase_subprocess)Ú constants)Ú
coroutines)Úevents)Ú
exceptions)Úfutures)Úselector_events)Útasks)Ú
transports)Úlogger)ÚSelectorEventLoopÚAbstractChildWatcherÚSafeChildWatcherÚFastChildWatcherÚPidfdChildWatcherÚMultiLoopChildWatcherÚThreadedChildWatcherÚDefaultEventLoopPolicyÚwin32z+Signals are not really supported on Windowsc C s d S ©N© )ÚsignumÚframer r ú+/usr/lib64/python3.9/asyncio/unix_events.pyÚ_sighandler_noop* s r c sÆ e Zd Zd(‡ fdd„ Z‡ fdd„Zdd„ Zdd „ Zd
d „ Zd d
„ Zdd„ Z d)dd„Z
d*dd„Z d+dd„Z dd„ Z
d,dddddœdd„Zd-ddddd d œd d „Zd d!„ Zd"d#„ Zd$d%„ Zd&d'„ Z‡ ZS ).Ú_UnixSelectorEventLoopNc s t ƒ |¡ i | _d S r )ÚsuperÚ__init__Ú_signal_handlers)ÚselfÚselector©Ú __class__r r r 5 s z _UnixSelectorEventLoop.__init__c sZ t ƒ ¡ t ¡ s.t| jƒD ]}| |¡ q n(| jrVtjd| ›dt | d | j
¡ d S )NzClosing the loop z@ on interpreter shutdown stage, skipping signal handlers removal©Úsource) r ÚcloseÚsysÚ
is_finalizingÚlistr Úremove_signal_handlerÚwarningsÚwarnÚResourceWarningÚclear©r! Úsigr# r r r' 9 s
üz _UnixSelectorEventLoop.closec C s |D ]}|sq| |¡ qd S r )Ú_handle_signal)r! Údatar r r r Ú_process_self_dataG s z)_UnixSelectorEventLoop._process_self_datac
G sR t |¡st |¡r tdƒ‚| |¡ | ¡ zt | j ¡ ¡ W n4 t
t fyv } zt t
|ƒƒ‚W Y d }~n
d }~0 0 t ||| d ¡}|| j|< z t |t¡ t |d¡ W nž t yL } z„| j|= | jszt d¡ W n6 t
t fy } zt d|¡ W Y d }~n
d }~0 0 |jtjkr6t d|› dƒ‚n‚ W Y d }~n
d }~0 0 d S )Nz3coroutines cannot be used with add_signal_handler()Féÿÿÿÿú set_wakeup_fd(-1) failed: %súsig ú cannot be caught)r Z iscoroutineZiscoroutinefunctionÚ TypeErrorÚ
_check_signalÚ
_check_closedÚsignalÚ
set_wakeup_fdZ_csockÚfilenoÚ
ValueErrorÚOSErrorÚ RuntimeErrorÚstrr ÚHandler r Ú siginterruptr
ÚinfoÚerrnoÚEINVAL)r! r1 ÚcallbackÚargsÚexcÚhandleZnexcr r r Úadd_signal_handlerN s2
ÿ
"
"z)_UnixSelectorEventLoop.add_signal_handlerc C s8 | j |¡}|d u rd S |jr*| |¡ n
| |¡ d S r )r ÚgetZ
_cancelledr+ Z_add_callback_signalsafe)r! r1 rK r r r r2 { s z%_UnixSelectorEventLoop._handle_signalc
C sè | |¡ z | j|= W n ty* Y dS 0 |tjkr>tj}ntj}zt ||¡ W nD ty˜ } z,|jtj kr‚t
d|› dƒ‚n‚ W Y d }~n
d }~0 0 | jsäzt d¡ W n4 t tfyâ } zt
d|¡ W Y d }~n
d }~0 0 dS )NFr7 r8 r5 r6 T)r: r ÚKeyErrorr< ÚSIGINTÚdefault_int_handlerÚSIG_DFLr@ rF rG rA r= r? r
rE )r! r1 ÚhandlerrJ r r r r+ … s(
"z,_UnixSelectorEventLoop.remove_signal_handlerc C s6 t |tƒstd|›ƒ‚|t ¡ vr2td|› ƒ‚d S )Nzsig must be an int, not zinvalid signal number )Ú
isinstanceÚintr9 r< Ú
valid_signalsr? r0 r r r r: ¥ s
z$_UnixSelectorEventLoop._check_signalc C s t | ||||ƒS r )Ú_UnixReadPipeTransport©r! ÚpipeÚprotocolÚwaiterÚextrar r r Ú_make_read_pipe_transport± s z0_UnixSelectorEventLoop._make_read_pipe_transportc C s t | ||||ƒS r )Ú_UnixWritePipeTransportrW r r r Ú_make_write_pipe_transportµ s z1_UnixSelectorEventLoop._make_write_pipe_transportc
Ë sÌ t ¡ °}
|
¡ stdƒ‚| ¡ } t| |||||||f| |dœ| ¤Ž} |
| ¡ | j| ¡ z| I d H W n@ t t
fy€ ‚ Y n* t y¨ | ¡ |
¡ I d H ‚ Y n0 W d ƒ n1 s¾0 Y | S )NzRasyncio.get_child_watcher() is not activated, subprocess support is not installed.)rZ r[ )r Úget_child_watcherÚ is_activerA Ú
create_futureÚ_UnixSubprocessTransportÚadd_child_handlerZget_pidÚ_child_watcher_callbackÚ
SystemExitÚKeyboardInterruptÚ
BaseExceptionr' Ú_wait)
r! rY rI ÚshellÚstdinÚstdoutÚstderrÚbufsizer[ ÚkwargsÚwatcherrZ Útranspr r r Ú_make_subprocess_transport¹ s.
ÿþý
ÿ &z1_UnixSelectorEventLoop._make_subprocess_transportc C s | |j|¡ d S r )Úcall_soon_threadsafeZ_process_exited)r! ÚpidÚ
returncoderp r r r rd × s z._UnixSelectorEventLoop._child_watcher_callback)ÚsslÚsockÚserver_hostnameÚssl_handshake_timeoutc à s
|r|d u r6t dƒ‚n |d ur&t dƒ‚|d ur6t dƒ‚|d ur¤|d urNt dƒ‚t |¡}t tjtjd¡}z | d¡ | ||¡I d H W qä | ¡ ‚ Y qä0 n@|d u r´t dƒ‚|j tjksÌ|j
tjkrÚt d|›ƒ‚| d¡ | j |||||d I d H \}}||fS )
Nz/you have to pass server_hostname when using sslz+server_hostname is only meaningful with sslú1ssl_handshake_timeout is only meaningful with sslú3path 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 )rx ) r? ÚosÚfspathÚsocketÚAF_UNIXÚ SOCK_STREAMÚ setblockingZ sock_connectr' ÚfamilyÚtypeZ _create_connection_transport) r! Úprotocol_factoryÚpathru rv rw rx Ú transportrY r r r Úcreate_unix_connectionÚ sL ÿÿÿ
ÿÿ
þz-_UnixSelectorEventLoop.create_unix_connectionéd T)rv Úbacklogru rx Ú
start_servingc
à sÈ t |tƒrtdƒ‚|d ur&|s&tdƒ‚|d urJ|d ur@tdƒ‚t |¡}t tjtj¡}|d dvrÊz t
t |¡j ¡r„t |¡ W nB t
y˜ Y n2 tyÈ } zt d||¡ W Y d }~n
d }~0 0 z| |¡ W nn ty2 } z@| ¡ | jtjkr d|›d}
ttj|
ƒd ‚n‚ W Y d } ~ n d } ~ 0 | ¡ ‚ Y n0 n<|d u r\td ƒ‚|jtjksx|jtjkr†td
|›ƒ‚| d ¡ t | |g||||¡} |rÄ| ¡ t d¡I d H | S ) Nz*ssl argument must be an SSLContext or Nonery rz 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) rS Úboolr9 r? r| r} r~ r r€ ÚstatÚS_ISSOCKÚst_modeÚremoveÚFileNotFoundErrorr@ r
ÚerrorÚbindr' rF Z
EADDRINUSEr‚ rƒ r r ZServerZ_start_servingr Úsleep) r! r„ r… rv r‰ ru rx rŠ ÚerrrJ ÚmsgZserverr r r Úcreate_unix_server sh
ÿ
ÿ
ÿ
ÿ
ÿÿ
ÿz)_UnixSelectorEventLoop.create_unix_serverc
à sÖ z
t j W n ty& t d¡‚Y n0 z | ¡ }W n4 ttjfyh } zt d¡‚W Y d }~n
d }~0 0 zt |¡j }W n t
y– t d¡‚Y n0 |r |n|}|s¬dS | ¡ } | | d |||||d¡ | I d H S )Nz os.sendfile() is not availableznot a regular filer )
r| ÚsendfileÚAttributeErrorr ÚSendfileNotAvailableErrorr> ÚioÚUnsupportedOperationÚfstatÚst_sizer@ ra Ú_sock_sendfile_native_impl)
r! rv ÚfileÚoffsetÚcountr> r• ÚfsizeÚ blocksizeÚfutr r r Ú_sock_sendfile_nativeJ s,
ÿ
ÿz,_UnixSelectorEventLoop._sock_sendfile_nativec C s, | ¡ } |d ur| |¡ | ¡ r4| |||¡ d S |rd|| }|dkrd| |||¡ | |¡ d S zt | |||¡}
W nD ttfyÄ |d u r | ||¡ |
| | j || ||||||¡
Y nd t yj } zŽ|d ur| j
t
jkrt| ƒturtdt
jƒ} | | _| } |dkr>t d¡}
| |||¡ | |
¡ n| |||¡ | | ¡ W Y d } ~ nÆd } ~ 0 ttfy‚ ‚ Y n¦ ty¾ } z$| |||¡ | | ¡ W Y d } ~ nrd } ~ 0 0 |
dkrä| |||¡ | |¡ nD||
7 }||
7 }|d u r
| ||¡ |
| | j || ||||||¡
d S )Nr zsocket is not connectedzos.sendfile call failed)r> Ú
remove_writerÚ cancelledÚ _sock_sendfile_update_fileposÚ
set_resultr| r˜ ÚBlockingIOErrorÚInterruptedErrorÚ _sock_add_cancellation_callbackZ
add_writerrŸ r@ rF ZENOTCONNrƒ ÚConnectionErrorÚ __cause__r rš Ú
set_exceptionre rf rg )r! r¥ Z
registered_fdrv r> r¡ r¢ r¤ Ú
total_sentÚfdÚsentrJ Únew_excr• r r r rŸ a sp
þ
ÿ
þÿ
ÿ
þz1_UnixSelectorEventLoop._sock_sendfile_native_implc C s |dkrt ||t j¡ d S ©Nr )r| ÚlseekÚSEEK_SET)r! r> r¡ r± r r r r© § s z4_UnixSelectorEventLoop._sock_sendfile_update_fileposc s ‡ ‡fdd„}| |¡ d S )Nc s& | ¡ r"ˆ ¡ }|dkr"ˆ |¡ d S )Nr5 )r¨ r> r§ )r¥ r² ©r! rv r r Úcb¬ s zB_UnixSelectorEventLoop._sock_add_cancellation_callback..cb)Úadd_done_callback)r! r¥ rv r¹ r r¸ r r « s z6_UnixSelectorEventLoop._sock_add_cancellation_callback)N)NN)NN)N)N)N)Ú__name__Ú
__module__Ú __qualname__r r' r4 rL r2 r+ r: r\ r^ rq rd r‡ r— r¦ rŸ r© r Ú
__classcell__r r r# r r / s@ -
ÿ
ÿ
þ
ÿü . ÿü CFr c sŠ e Zd ZdZd ‡ fdd„ Zdd„ Zdd„ Zd d
„ Zd d „ Zd
d„ Z dd„ Z
dd„ Z dd„ Z e
jfdd„Zd dd„Zdd„ Zd d „ Z‡ ZS ) rV i Nc sÚ t ƒ |¡ || jd< || _|| _| ¡ | _|| _d| _d| _ t
| j¡j }t
|¡s„t
|¡s„t
|¡s„d | _d | _d | _tdƒ‚t
| jd¡ | j | jj| ¡ | j | jj| j| j¡ |d urÖ| j tj|d ¡ d S )NrX Fz)Pipe transport is for pipes/sockets only.)r r Ú_extraÚ_loopÚ_piper> Ú_filenoÚ _protocolÚ_closingÚ_pausedr| r r r ÚS_ISFIFOrŽ ÚS_ISCHRr? Ú set_blockingÚ call_soonÚconnection_madeÚ _add_readerÚ _read_readyr Ú _set_result_unless_cancelled)r! ÚlooprX rY rZ r[ Úmoder# r r r ¸ s6
ÿþ ÿ
ÿz _UnixReadPipeTransport.__init__c C sÀ | j jg}| jd u r | d¡ n| jr0| d¡ | d| j› ¡ t| jdd ƒ}| jd ur|d urt || jt
j ¡}|r„| d¡ q°| d¡ n | jd ur¦| d¡ n
| d¡ d d
|¡¡S )
NÚclosedÚclosingúfd=Ú _selectorÚpollingÚidleÚopenú<{}>ú )r$ r» rÁ ÚappendrÄ r ÚgetattrrÀ r
Ú_test_selector_eventÚ selectorsÚ
EVENT_READÚformatÚjoin)r! rE r" rÔ r r r Ú__repr__Ö s$
ÿ
z _UnixReadPipeTransport.__repr__c
C sº zt | j| j¡}W nD ttfy* Y nŒ tyX } z| |d¡ W Y d }~nfd }~0 0 |rl| j |¡ nJ| j
¡ r‚t
d| ¡ d| _| j
| j¡ | j
| jj¡ | j
| jd ¡ d S )Nz"Fatal read error on pipe transportú%r was closed by peerT)r| Úreadr Úmax_sizer« r¬ r@ Ú _fatal_errorrà Z
data_receivedrÀ Ú get_debugr
rE rÄ Ú_remove_readerrÉ Z eof_receivedÚ_call_connection_lost)r! r3 rJ r r r rÌ ë s "
z"_UnixReadPipeTransport._read_readyc C s> | j s | jrd S d| _| j | j¡ | j ¡ r:t d| ¡ d S )NTz%r pauses reading)rÄ rÅ rÀ ræ r rå r
Údebug©r! r r r Ú
pause_readingý s
z$_UnixReadPipeTransport.pause_readingc C sB | j s | jsd S d| _| j | j| j¡ | j ¡ r>t d| ¡ d S )NFz%r resumes reading) rÄ rÅ rÀ rË r rÌ rå r
rè ré r r r Úresume_reading s
z%_UnixReadPipeTransport.resume_readingc C s
|| _ d S r ©rà ©r! rY r r r Ú set_protocol
s z#_UnixReadPipeTransport.set_protocolc C s | j S r rì ré r r r Ú get_protocol s z#_UnixReadPipeTransport.get_protocolc C s | j S r ©rÄ ré r r r Ú
is_closing s z!_UnixReadPipeTransport.is_closingc C s | j s| d ¡ d S r )rÄ Ú_closeré r r r r' s z _UnixReadPipeTransport.closec C s, | j d ur(|d| ›t| d | j ¡ d S ©Nzunclosed transport r% ©rÁ r. r' ©r! Ú_warnr r r Ú__del__ s
z _UnixReadPipeTransport.__del__ú Fatal error on pipe transportc C sZ t |tƒr4|jtjkr4| j ¡ rLtjd| |dd n| j ||| | j dœ¡ |
|¡ d S ©Nz%r: %sT©Úexc_info)ÚmessageÚ exceptionr† rY ) rS r@ rF ZEIOrÀ rå r
rè Úcall_exception_handlerrà rò ©r! rJ rü r r r rä s
üz#_UnixReadPipeTransport._fatal_errorc C s( d| _ | j | j¡ | j | j|¡ d S ©NT)rÄ rÀ ræ r rÉ rç ©r! rJ r r r rò - s z _UnixReadPipeTransport._closec C sP z,| j |¡ W | j ¡ d | _d | _ d | _n | j ¡ d | _d | _ d | _0 d S r ©rà Zconnection_lostrÁ r' rÀ r r r r rç 2 s
ý
z,_UnixReadPipeTransport._call_connection_lost)NN)rø )r» r¼ r½ rã r rà rÌ rê rë rî rï rñ r' r, r- r÷ rä rò rç r¾ r r r# r rV ´ s
rV c s¨ e Zd Zd%‡ fdd„ Zdd„ Zdd„ Zdd „ Zd
d „ Zd d
„ Zdd„ Z dd„ Z
dd„ Z dd„ Z dd„ Z
dd„ Zejfdd„Zd d „ Zd&d d „Zd'd!d"„Zd#d$„ Z‡ ZS )(r] Nc
sþ t ƒ ||¡ || jd< || _| ¡ | _|| _tƒ | _d| _ d| _
t | j¡j
}t |¡}t |¡}t |¡} |s”|s”| s”d | _d | _d | _tdƒ‚t | jd¡ | j | jj| ¡ | sÈ|ràtj d¡sà| j | jj| j| j¡ |d urú| j t j |d ¡ d S )NrX r Fz?Pipe transport is only for pipes, sockets and character devicesZaix) r r r¿ rÁ r> r rÃ Ú bytearrayÚ_bufferÚ
_conn_lostrÄ r| r r r rÇ rÆ rŽ r? rÈ rÀ rÉ rÊ r( ÚplatformÚ
startswithrË rÌ r rÍ )
r! rÎ rX rY rZ r[ rÏ Zis_charÚis_fifoÚ is_socketr# r r r ? s6
ÿ
ÿz _UnixWritePipeTransport.__init__c C sØ | j jg}| jd u r | d¡ n| jr0| d¡ | d| j› ¡ t| jdd ƒ}| jd ur¨|d ur¨t || jt
j ¡}|r„| d¡ n
| d¡ | ¡ }| d|› ¡ n | jd ur¾| d¡ n
| d¡ d
d
|¡¡S ) NrÐ rÑ rÒ rÓ rÔ rÕ zbufsize=rÖ r× rØ )r$ r» rÁ rÙ rÄ r rÚ rÀ r
rÛ rÜ Ú EVENT_WRITEÚget_write_buffer_sizerÞ rß )r! rE r" rÔ rm r r r rà d s(
ÿ
z _UnixWritePipeTransport.__repr__c C s
t | jƒS r )Úlenr ré r r r r | s z-_UnixWritePipeTransport.get_write_buffer_sizec C s6 | j ¡ rt d| ¡ | jr*| tƒ ¡ n| ¡ d S )Nrá )rÀ rå r
rE r rò ÚBrokenPipeErrorré r r r rÌ s
z#_UnixWritePipeTransport._read_readyc
C s. t |tƒrt|ƒ}|sd S | js&| jrN| jtjkr| j ¡ | j
d7 _
| j | j¡ |
|d¡ W Y d }~nnd }~0 0 |t| jƒkræ| j ¡ | j | j¡ | ¡ | jrâ| j | j¡ | d ¡ d S |dkrú| jd |…= d S )Nr r r )r| r r r r« r¬ re rf rg r/ r rÀ Ú_remove_writerrä r Z_maybe_resume_protocolrÄ ræ rç )r! r rJ r r r r « s*
"
z$_UnixWritePipeTransport._write_readyc C s dS r r ré r r r Ú
can_write_eofÇ s z%_UnixWritePipeTransport.can_write_eofc C s8 | j r
d S d| _ | js4| j | j¡ | j | jd ¡ d S r )rÄ r rÀ ræ r rÉ rç ré r r r Ú write_eofÊ s z!_UnixWritePipeTransport.write_eofc C s
|| _ d S r rì rí r r r rî Ó s z$_UnixWritePipeTransport.set_protocolc C s | j S r rì ré r r r rï Ö s z$_UnixWritePipeTransport.get_protocolc C s | j S r rð ré r r r rñ Ù s z"_UnixWritePipeTransport.is_closingc C s | j d ur| js| ¡ d S r )rÁ rÄ r ré r r r r' Ü s z _UnixWritePipeTransport.closec C s, | j d ur(|d| ›t| d | j ¡ d S ró rô rõ r r r r÷ á s
z _UnixWritePipeTransport.__del__c C s | d ¡ d S r )rò ré r r r Úabortæ s z _UnixWritePipeTransport.abortrø c C sN t |tƒr(| j ¡ r@tjd| |dd n| j ||| | jdœ¡ | |¡ d S rù ) rS r@ rÀ rå r
rè rþ rà rò rÿ r r r rä é s
üz$_UnixWritePipeTransport._fatal_errorc C sF d| _ | jr| j | j¡ | j ¡ | j | j¡ | j | j|¡ d S r ) rÄ r rÀ r r r/ ræ rÉ rç r r r r rò ÷ s
z _UnixWritePipeTransport._closec C sP z,| j |¡ W | j ¡ d | _d | _ d | _n | j ¡ d | _d | _ d | _0 d S r r r r r r rç ÿ s
ý
z-_UnixWritePipeTransport._call_connection_lost)NN)rø )N)r» r¼ r½ r rà r rÌ r r r r rî rï rñ r' r, r- r÷ r rä rò rç r¾ r r r# r r] < s" % #
r] c @ s e Zd Zdd„ ZdS )rb c K s¢ d }|t jkrt ¡ \}}zht j|f||||d|dœ|¤Ž| _|d urh| ¡ t| ¡ d|d| j_ d }W |d urž| ¡ | ¡ n|d urœ| ¡ | ¡ 0 d S )NF)ri rj rk rl Úuniversal_newlinesrm Úwb)Ú buffering)
Ú
subprocessÚPIPEr~ Ú
socketpairÚPopenÚ_procr' rÖ Údetachrj ) r! rI ri rj rk rl rm rn Zstdin_wr r r Ú_start s,
ÿþþ
þz _UnixSubprocessTransport._startN)r» r¼ r½ r! r r r r rb s rb c @ sD e Zd Zdd„ Zdd„ Zdd„ Zdd„ Zd d
„ Zd d „ Zd
d„ Z dS )r c G s
t ƒ ‚d S r ©ÚNotImplementedError©r! rs rH rI r r r rc 9 s z&AbstractChildWatcher.add_child_handlerc C s
t ƒ ‚d S r r" ©r! rs r r r Úremove_child_handlerD s z)AbstractChildWatcher.remove_child_handlerc C s
t ƒ ‚d S r r" ©r! rÎ r r r Ú attach_loopL s z AbstractChildWatcher.attach_loopc C s
t ƒ ‚d S r r" ré r r r r' V s zAbstractChildWatcher.closec C s
t ƒ ‚d S r r" ré r r r r` ] s z AbstractChildWatcher.is_activec C s
t ƒ ‚d S r r" ré r r r Ú __enter__f s z AbstractChildWatcher.__enter__c C s
t ƒ ‚d S r r" ©r! ÚaÚbÚcr r r Ú__exit__l s z AbstractChildWatcher.__exit__N)
r» r¼ r½ rc r& r( r' r` r) r. r r r r r " s
r c @ sT e Zd Zdd„ Zdd„ Zdd„ Zdd„ Zd d
„ Zd d „ Zd
d„ Z dd„ Z
dd„ Z dS )r c C s d | _ i | _d S r ©rÀ Ú
_callbacksré r r r r } s zPidfdChildWatcher.__init__c C s | S r r ré r r r r) s zPidfdChildWatcher.__enter__c C s d S r r )r! Úexc_typeÚ exc_valueÚ
exc_tracebackr r r r. „ s zPidfdChildWatcher.__exit__c C s | j d uo| j ¡ S r ©rÀ Z
is_runningré r r r r` ‡ s zPidfdChildWatcher.is_activec C s | d ¡ d S r ©r( ré r r r r' Š s zPidfdChildWatcher.closec C sd | j d ur$|d u r$| jr$t dt¡ | j ¡ D ] \}}}| j |¡ t |¡ q.| j ¡ || _ d S ©NzCA loop is being detached from a child watcher with pending handlers)
rÀ r0 r, r- ÚRuntimeWarningÚvaluesræ r| r' r/ )r! rÎ ÚpidfdÚ_r r r r( s ý
z PidfdChildWatcher.attach_loopc G sZ | j |¡}|d ur*|d ||f| j |< n,t |¡}| j || j|¡ |||f| j |< d S rµ )r0 rM r| Ú
pidfd_openrÀ rË Ú_do_wait)r! rs rH rI Úexistingr9 r r r rc ™ s
z#PidfdChildWatcher.add_child_handlerc C s~ | j |¡\}}}| j |¡ zt |d¡\}}W n" tyT d}t d|¡ Y n
0 t |ƒ}t
|¡ |||g|¢R Ž d S )Nr éÿ zJchild process pid %d exit status already read: will report returncode 255) r0 ÚpoprÀ ræ r| ÚwaitpidÚChildProcessErrorr
r Ú_compute_returncoder' )r! rs r9 rH rI r: Ústatusrt r r r r< ¢ s ý
zPidfdChildWatcher._do_waitc C sF z| j |¡\}}}W n ty* Y dS 0 | j |¡ t |¡ dS )NFT)r0 r? rN rÀ ræ r| r' )r! rs r9 r: r r r r& µ s
z&PidfdChildWatcher.remove_child_handlerN) r» r¼ r½ r r) r. r` r' r( rc r< r& r r r r r q s r c C s2 t | ¡rt | ¡ S t | ¡r*t | ¡S | S d S r )r| Ú WIFSIGNALEDÚWTERMSIGÚ WIFEXITEDÚ WEXITSTATUS)rC r r r rB ¿ s
rB c @ sD e Zd Zdd„ Zdd„ Zdd„ Zdd„ Zd d
„ Zd d „ Zd
d„ Z dS )ÚBaseChildWatcherc C s d | _ i | _d S r r/ ré r r r r Ï s zBaseChildWatcher.__init__c C s | d ¡ d S r r5 ré r r r r' Ó s zBaseChildWatcher.closec C s | j d uo| j ¡ S r r4 ré r r r r` Ö s zBaseChildWatcher.is_activec C s
t ƒ ‚d S r r" )r! Ú expected_pidr r r Ú _do_waitpidÙ s z BaseChildWatcher._do_waitpidc C s
t ƒ ‚d S r r" ré r r r Ú_do_waitpid_allÜ s z BaseChildWatcher._do_waitpid_allc C sf | j d ur$|d u r$| jr$t dt¡ | j d ur<| j tj¡ || _ |d urb| tj| j ¡ |
¡ d S r6 ) rÀ r0 r, r- r7 r+ r< ÚSIGCHLDrL Ú _sig_chldrK r' r r r r( ß s ý
z BaseChildWatcher.attach_loopc
C s^ z | ¡ W nL ttfy$ ‚ Y n6 tyX } z | j d|dœ¡ W Y d }~n
d }~0 0 d S )Nú$Unknown exception in SIGCHLD handler)rü rý )rK re rf rg rÀ rþ r r r r rM ó s þzBaseChildWatcher._sig_chldN)
r» r¼ r½ r r' r` rJ rK r( rM r r r r rH Í s rH c sL e Zd Z‡ fdd„Zdd„ Zdd„ Zdd„ Zd d
„ Zd d „ Zd
d„ Z ‡ Z
S )r c s | j ¡ tƒ ¡ d S r )r0 r/ r r' ré r# r r r'
s
zSafeChildWatcher.closec C s | S r r ré r r r r) s zSafeChildWatcher.__enter__c C s d S r r r* r r r r. s zSafeChildWatcher.__exit__c G s ||f| j |< | |¡ d S r )r0 rJ r$ r r r rc s z"SafeChildWatcher.add_child_handlerc C s( z| j |= W dS ty" Y dS 0 d S ©NTF©r0 rN r% r r r r& s
z%SafeChildWatcher.remove_child_handlerc C s t | jƒD ]}| |¡ q
d S r ©r* r0 rJ r% r r r rK $ s z SafeChildWatcher._do_waitpid_allc C s zt |t j¡\}}W n& ty< |}d}t d|¡ Y n.0 |dkrJd S t|ƒ}| j ¡ rjt d||¡ z| j
|¡\}}W n, t yª | j ¡ r¦tjd|dd Y n0 |||g|¢R Ž d S )Nr> ú8Unknown child process pid %d, will report returncode 255r ú$process %s exited with returncode %sú'Child watcher got an unexpected pid: %rTrú )
r| r@ ÚWNOHANGrA r
r rB rÀ rå rè r0 r? rN )r! rI rs rC rt rH rI r r r rJ ) s0 þ
ÿ
ÿ z SafeChildWatcher._do_waitpid) r» r¼ r½ r' r) r. rc r& rK rJ r¾ r r r# r r s r c sP e Zd Z‡ fdd„Z‡ fdd„Zdd„ Zdd„ Zd d
„ Zd d „ Zd
d„ Z ‡ Z
S )r c s$ t ƒ ¡ t ¡ | _i | _d| _d S rµ )r r Ú threadingÚLockÚ_lockÚ_zombiesÚ_forksré r# r r r V s
zFastChildWatcher.__init__c s" | j ¡ | j ¡ tƒ ¡ d S r )r0 r/ rY r r' ré r# r r r' \ s
zFastChildWatcher.closec C s< | j " | jd7 _| W d ƒ S 1 s.0 Y d S )Nr )rX rZ ré r r r r) a s zFastChildWatcher.__enter__c C st | j N | jd8 _| js"| js2W d ƒ d S t| jƒ}| j ¡ W d ƒ n1 sZ0 Y t d|¡ d S )Nr z5Caught subprocesses termination from unknown pids: %s)rX rZ rY rB r/ r
r )r! r+ r, r- Zcollateral_victimsr r r r. g s
(þzFastChildWatcher.__exit__c G s| | j P z| j |¡}W n. tyF ||f| j|< Y W d ƒ d S 0 W d ƒ n1 s\0 Y |||g|¢R Ž d S r )rX rY r? rN r0 )r! rs rH rI rt r r r rc u s 2z"FastChildWatcher.add_child_handlerc C s( z| j |= W dS ty" Y dS 0 d S rO rP r% r r r r& ƒ s
z%FastChildWatcher.remove_child_handlerc C s zt dt j¡\}}W n ty* Y d S 0 |dkr8d S t|ƒ}| jŒ z| j |¡\}}W nN tyª | j r¢|| j
|< | j ¡ r’t
d||¡ Y W d ƒ q d }Y n0 | j ¡ rÄt
d||¡ W d ƒ n1 sØ0 Y |d u rút
d||¡ q |||g|¢R Ž q d S )Nr5 r z,unknown process %s exited with returncode %srS z8Caught subprocess termination from unknown pid: %d -> %d)r| r@ rU rA rB rX r0 r? rN rZ rY rÀ rå r
rè r )r! rs rC rt rH rI r r r rK Š s:
þ
ÿ"þz FastChildWatcher._do_waitpid_all) r» r¼ r½ r r' r) r. rc r& rK r¾ r r r# r r L s
r c @ sd e Zd Zdd„ Zdd„ Zdd„ Zdd„ Zd d
„ Zd d „ Zd
d„ Z dd„ Z
dd„ Z dd„ Z dd„ Z
dS )r c C s i | _ d | _d S r )r0 Ú_saved_sighandlerré r r r r È s z MultiLoopChildWatcher.__init__c C s
| j d uS r )r[ ré r r r r` Ì s z MultiLoopChildWatcher.is_activec C sT | j ¡ | jd u rd S t tj¡}|| jkr:t d¡ nt tj| j¡ d | _d S )Nz+SIGCHLD handler was changed by outside code) r0 r/ r[ r< Ú getsignalrL rM r
r )r! rR r r r r' Ï s
zMultiLoopChildWatcher.closec C s | S r r ré r r r r) Û s z MultiLoopChildWatcher.__enter__c C s d S r r ©r! r1 Úexc_valÚexc_tbr r r r. Þ s z MultiLoopChildWatcher.__exit__c G s& t ¡ }|||f| j|< | |¡ d S r )r Úget_running_loopr0 rJ )r! rs rH rI rÎ r r r rc á s z'MultiLoopChildWatcher.add_child_handlerc C s( z| j |= W dS ty" Y dS 0 d S rO rP r% r r r r& è s
z*MultiLoopChildWatcher.remove_child_handlerc C sN | j d urd S t tj| j¡| _ | j d u r rR Fr TrT rú ú%Loop %r that handles pid %r is closedrS )r| r@ rU rA r
r rB r0 r? rN Ú is_closedrå rè rr ) r! rI rs rC rt Z debug_logrÎ rH rI r r r rJ s6 þ
ÿ ÿz!MultiLoopChildWatcher._do_waitpidc C sH z | ¡ W n6 ttfy$ ‚ Y n tyB tjddd Y n0 d S )NrN Trú )rK re rf rg r
r )r! r r r r r rM ) s z MultiLoopChildWatcher._sig_chldN)r» r¼ r½ r r` r' r) r. rc r& r( rK rJ rM r r r r r µ s %r c @ sj e Zd Zdd„ Zdd„ Zdd„ Zdd„ Zd d
„ Zd d „ Ze j
fd
d„Z dd„ Z dd„ Z
dd„ Zdd„ ZdS )r c C s t d¡| _i | _d S rµ )Ú itertoolsr¢ Ú _pid_counterÚ_threadsré r r r r ? s z ThreadedChildWatcher.__init__c C s dS r r ré r r r r` C s z ThreadedChildWatcher.is_activec C s | ¡ d S r )Ú
_join_threadsré r r r r' F s zThreadedChildWatcher.closec C s. dd„ t | j ¡ ƒD ƒ}|D ] }| ¡ q d S )Nc S s g | ]}| ¡ r|js|‘qS r )Úis_aliveÚdaemon©Ú.0Úthreadr r r Ú
K s ÿz6ThreadedChildWatcher._join_threads..)r* re r8 rß )r! Úthreadsrk r r r rf I s z"ThreadedChildWatcher._join_threadsc C s | S r r ré r r r r) P s z ThreadedChildWatcher.__enter__c C s d S r r r] r r r r. S s z ThreadedChildWatcher.__exit__c C s6 dd„ t | j ¡ ƒD ƒ}|r2|| j› dt| d d S )Nc S s g | ]}| ¡ r|‘qS r )rg ri r r r rl W s ÿz0ThreadedChildWatcher.__del__..z0 has registered but not finished child processesr% )r* re r8 r$ r. )r! rö rm r r r r÷ V s þz ThreadedChildWatcher.__del__c G sF t ¡ }tj| jdt| jƒ› ||||fdd}|| j|< | ¡ d S )Nzwaitpid-T)ÚtargetÚnamerI rh ) r r` rV ÚThreadrJ Únextrd re Ústart)r! rs rH rI rÎ rk r r r rc ^ s
ý
z&ThreadedChildWatcher.add_child_handlerc C s dS r r r% r r r r& g s z)ThreadedChildWatcher.remove_child_handlerc C s d S r r r' r r r r( m s z ThreadedChildWatcher.attach_loopc C s˜ zt |d¡\}}W n& ty: |}d}t d|¡ Y n 0 t|ƒ}| ¡ rZt d||¡ | ¡ rrt d||¡ n|j |||g|¢R Ž | j
|¡ d S )Nr r> rR rS ra ) r| r@ rA r
r rB rå rè rb rr re r? )r! rÎ rI rH rI rs rC rt r r r rJ p s$ þ
ÿz ThreadedChildWatcher._do_waitpidN)r» r¼ r½ r r` r' rf r) r. r, r- r÷ rc r& r( rJ r r r r r 2 s
r c sD e Zd ZeZ‡ fdd„Zdd„ Z‡ fdd„Zdd„ Zd d
„ Z ‡ Z
S ) Ú_UnixDefaultEventLoopPolicyc s t ƒ ¡ d | _d S r )r r Ú_watcherré r# r r r s
z$_UnixDefaultEventLoopPolicy.__init__c C s\ t jB | jd u r:tƒ | _t ¡ t ¡ u r:| j | jj ¡ W d ƒ n1 sN0 Y d S r )
r rX rt r rV Úcurrent_threadÚ main_threadr( Ú_localrÀ ré r r r Ú
_init_watcher“ s
z)_UnixDefaultEventLoopPolicy._init_watcherc s6 t ƒ |¡ | jd ur2t ¡ t ¡ u r2| j |¡ d S r )r Úset_event_looprt rV ru rv r( r' r# r r ry š s
ÿz*_UnixDefaultEventLoopPolicy.set_event_loopc C s | j d u r| ¡ | j S r )rt rx ré r r r r_ ¨ s
z-_UnixDefaultEventLoopPolicy.get_child_watcherc C s | j d ur| j ¡ || _ d S r )rt r' )r! ro r r r Úset_child_watcher² s
z-_UnixDefaultEventLoopPolicy.set_child_watcher) r» r¼ r½ r Z
_loop_factoryr rx ry r_ rz r¾ r r r# r rs ‹ s
rs )2rF r› rc r| rÜ r< r~ r r r( rV r, Ú r r r r r r r r
r r Úlogr
Ú__all__r Ú ImportErrorr ZBaseSelectorEventLoopr Z
ReadTransportrV Z_FlowControlMixinZWriteTransportr] ZBaseSubprocessTransportrb r r rB rH r r r r ZBaseDefaultEventLoopPolicyrs r r r r r r Ú s`
ÿ NON5Ji}Y2