⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.67
Server IP:
50.6.168.112
Server:
Linux server-617809.webnetzimbabwe.com 5.14.0-570.25.1.el9_6.x86_64 #1 SMP PREEMPT_DYNAMIC Wed Jul 9 04:57:09 EDT 2025 x86_64
Server Software:
Apache
PHP Version:
8.4.10
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
usr
/
lib64
/
python3.9
/
asyncio
/
__pycache__
/
View File Name :
unix_events.cpython-39.opt-2.pyc
a ÕDOg*Ê ã @ 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.<locals>.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<t d¡ | jd7 _d S | j szt | j |¡}W nn t tfy‚ d}Y nV ttfy˜ ‚ Y n@ tyÖ } z(| jd7 _| |d¡ W Y d }~d S d }~0 0 |t|ƒkrèd S |dkrt|ƒ|d … }| j | j | j¡ | j |7 _ | ¡ d S )Nz=pipe closed by peer or os.write(pipe, data) raised exception.r r ú#Fatal write error on pipe transport)rS r Ú memoryviewr rÄ r Z!LOG_THRESHOLD_FOR_CONNLOST_WRITESr Úwarningr r| Úwriter r« r¬ re rf rg rä r rÀ Z _add_writerÚ _write_readyZ_maybe_pause_protocol)r! r3 ÚnrJ r r r r ˆ s6 z _UnixWritePipeTransport.writec C sþ zt | j| j¡}W n€ ttfy* Y nÐ ttfy@ ‚ Y nº ty” } z>| 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<t d¡ tj| _ t tjd¡ d S )NzaPrevious SIGCHLD handler was set by non-Python code, restore to default handler on watcher close.F)r[ r< rL rM r r rQ rD r' r r r r( ï s z!MultiLoopChildWatcher.attach_loopc C s t | jƒD ]}| |¡ q d S r rQ r% r r r rK s z%MultiLoopChildWatcher._do_waitpid_allc C sà zt |t j¡\}}W n* ty@ |}d}t d|¡ d}Y n0 |dkrNd S t|ƒ}d}z| j |¡\}}}W n" t y’ tjd|dd Y nJ0 | ¡ r¬t d||¡ n0|rÆ| ¡ rÆt d ||¡ |j |||g|¢R Ž d S ) Nr> 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 Ú <listcomp>K s ÿz6ThreadedChildWatcher._join_threads.<locals>.<listcomp>)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__.<locals>.<listcomp>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 Ú<module> s` ÿ NON5Ji}Y2