Operation   : Linux premium131.web-hosting.com 4.18.0-553.44.1.lve.el8.x86_64 #1 SMP Thu Mar 13 14:29:12 UTC 2025 x86_64
Software     : Apache
Server IP    : 162.0.232.56 | Your IP: 216.73.216.111
Domains      : 1034 Domain(s)
Permission   : [ 0755 ]

B

� f؟�@s�
dZd
dl
Z
d
dlZd
dlZd
dlZd
dlZd
dlZd
dlZd
dlZd
dl	Z	d
dl
Z
d
dlZddlm
Z

ddlmZ
ddlmZ
ddlmZ
ddlmZ
dd	lmZ
dd
lmZ
ddlmZ
ddlmZ
dd
lmZ
dZe	jdkr�ed�
�
dd�ZGdd�dej�ZGdd�dej�ZGdd�dej ej!�Z"Gdd�dej#�Z$Gdd�d�Z%Gdd�de%�Z&Gdd �d e&�Z'Gd!d"�d"e&�Z(Gd#d$�d$ej)�Z*eZ+e*Z,dS)%z2Selector event loop for Unix with signal handling.�N�
)
�base_events)
�base_subprocess)
�	constants)
�
coroutines)
�events)
�futures)
�selector_events)
�tasks)
�
transports)
�logger)�SelectorEventLoop�AbstractChildWatcher�SafeChildWatcher�FastChildWatcher�DefaultEventLoopPolicyZwin32z+Signals are not really supported on Windowsc
Csd
S)zDummy signal handler.N�)�signum�framerr�8/opt/alt/python37/lib64/python3.7/asyncio/unix_events.py�_sighandler_noop'srcs�eZ
dZd
Zd)�f
dd�	Z�f
dd�Zdd�Zd	d
�Zdd�Zd
d�Z	dd�Z
d*dd�
Zd+dd�
Zd,dd�
Z
dd�Zd-ddddd�dd�Zd.dddddd�dd �Zd!d"�Zd#d$�Zd%d&�Zd'd(�Z�ZS)/�_UnixSelectorEventLoopzdUnix event loop.

    Adds signal handling and UNIX Domain Socket support to SelectorEventLoop.
    Ncst��
|
�

i|_dS)
N)�super�__init__�_signal_handlers)�self�selector)
�	__class__rrr2s

z_UnixSelectorEventLoop.__init__c
s^t��
�
t��s2xFt|j�
D]}
|�|
�

qWn(|jrZtjd
|�d�t	|d�
|j�
�
dS)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�sig)
rrrr6s







z_UnixSelectorEventLoop.closecCs"x|
D]}|sq|�|�

qWdS)
N)
�_handle_signal)r�datarrrr�_process_self_dataDs



z)_UnixSelectorEventLoop._process_self_datac
GsL
t�
|�
st�|�
rtd
�
�
|�|
�

|��
yt�|j�	��

Wn2t
tfk
rt
}
ztt
|�
�
�
Wdd}~XYnXt�|||d�}||j|
<yt�|
t�
t�|
d�
Wn�tk
�
rF
}
zz|j|
=|j�
syt�d�

Wn4t
tfk
�
r
}
zt�d|�
Wdd}~XYnX|jtjk�
r4td|
�d��
�
n�Wdd}~XYnXdS)z�Add a handler for a signal.  UNIX only.

        Raise ValueError if the signal number is invalid or uncatchable.
        Raise RuntimeError if there is a problem setting up the handler.
        z3coroutines cannot be used with add_signal_handler()NF���zset_wakeup_fd(-1) failed: %szsig z cannot be caught)rZiscoroutineZiscoroutinefunction�	TypeError�
_check_signalZ
_check_closed�signal�
set_wakeup_fdZ_csock�fileno�
ValueError�OSError�RuntimeError�strrZHandlerr�siginterruptr�info�errno�EINVAL)rr(�callback�args�exc�handleZnexcrrr�add_signal_handlerKs0


















z)_UnixSelectorEventLoop.add_signal_handlercCs8|j�
|
�
}|d
krd
S|jr*|�|
�

n
|�|�

d
S)z2Internal helper that is the actual signal handler.N)r�getZ
_cancelledr#Z_add_callback_signalsafe)rr(r=rrrr)xs



z%_UnixSelectorEventLoop._handle_signalc
Cs�|�|
�

y|j
|
=Wntk
r*


d
SX|
tjkr>tj}ntj}yt�|
|�
WnBtk
r�
}
z$|jtj	kr�t
d|
�d��
�
n�Wdd}~XYnX|j
s�yt�d�

Wn2ttfk
r�
}
zt
�d|�
Wdd}~XYnXdS)zwRemove a handler for a signal.  UNIX only.

        Return True if a signal handler was removed, False if not.
        Fzsig z cannot be caughtNr,zset_wakeup_fd(-1) failed: %sT)r.r�KeyErrorr/�SIGINT�default_int_handler�SIG_DFLr3r8r9r4r0r2rr7)rr(Zhandlerr<rrrr#�s(














z,_UnixSelectorEventLoop.remove_signal_handlercCsLt|
t
�std
|
���
�
d|
k
r.tjksHn
td|
�dtj�d��
�
dS)z�Internal helper to validate a signal.

        Raise ValueError if the signal number is invalid or uncatchable.
        Raise RuntimeError if there is a problem setting up the handler.
        zsig must be an int, not rzsig z out of range(1, �
)N)�
isinstance�intr-r/�NSIGr2)rr(rrrr.�s


z$_UnixSelectorEventLoop._check_signalcCst||
|||�S)
N)
�_UnixReadPipeTransport)r�pipe�protocol�waiter�extrarrr�_make_read_pipe_transport�sz0_UnixSelectorEventLoop._make_read_pipe_transportcCst||
|||�S)
N)
�_UnixWritePipeTransport)rrIrJrKrLrrr�_make_write_pipe_transport�sz1_UnixSelectorEventLoop._make_write_pipe_transportc	

�s�t�
���}
|��}t||
||||||f||d
�|	��
}|
�|��|j|�
y|IdH
Wn,tk
r�


|��
|�	�IdH
�YnXWdQRX|S)N)rKrL)
r�get_child_watcher�
create_future�_UnixSubprocessTransport�add_child_handlerZget_pid�_child_watcher_callback�	ExceptionrZ_wait)
rrJr;�shell�stdin�stdout�stderr�bufsizerL�kwargs�watcherrK�transprrr�_make_subprocess_transport�s
















z1_UnixSelectorEventLoop._make_subprocess_transportcCs|�|j
|�
dS)
N)Zcall_soon_threadsafeZ_process_exited)r�pid�
returncoder]rrrrT�s
z._UnixSelectorEventLoop._child_watcher_callback)�ssl�sock�server_hostname�ssl_handshake_timeoutc	�s 
|dkst|t
�st�
|r,|dkrLtd
�
�
n |dk	r<td�
�
|dk	rLtd�
�
|dk	r�|dk	rdtd�
�
t�|�
}t�tjtjd�}y |�	d�

|�
||�IdH
Wq�


|��
�Yq�Xn@|dkr�td�
�
|jtjks�|j
tjkr�td|���
�
|�	d�

|j||
|||d	�IdH\}}||fS)
Nz/you have to pass server_hostname when using sslz+server_hostname is only meaningful with sslz1ssl_handshake_timeout is only meaningful with sslz3path and sock can not be specified at the same timer
Fzno path and sock were specifiedz.A UNIX Domain Stream Socket was expected, got )
rd)rEr5�AssertionErrorr2�os�fspath�socket�AF_UNIX�SOCK_STREAM�setblockingZsock_connectr�family�typeZ_create_connection_transport)	r�protocol_factory�pathrarbrcrd�	transportrJrrr�create_unix_connection�sB






























z-_UnixSelectorEventLoop.create_unix_connection�dT)rb�backlogrard�
start_servingc
�s�
t|t
�rtd
�
�
|dk	r&|s&td�
�
|dk	�
rH|dk	r@td�
�
t�|�
}t�tjtj�}|ddkr�y t	�
t�	|�
j�
r�t�|�

WnBt
k
r�


Yn0tk
r�
}
zt�d||�
Wdd}~XYnXy|�|�

Wnltk
�
r0
}	
z8|��
|	jtjk�
rd|�d�}
ttj|
�d�n�Wdd}	~	XYn


|��
�YnXn<|dk�
rZtd	�
�
|jtjk�
sv|jtjk�
r�td
|���
�
|�d�

t�||g
|
|||�}|�
r�|��
tjd|d�IdH
|S)
Nz*ssl argument must be an SSLContext or Nonez1ssl_handshake_timeout is only meaningful with sslz3path and sock can not be specified at the same timer
)r
�
z2Unable to check or remove stale UNIX socket %r: %rzAddress z is already in usez-path was not specified, and no sock specifiedz.A UNIX Domain Stream Socket was expected, got F)
�loop)rE�boolr-r2rfrgrhrirj�stat�S_ISSOCK�st_mode�remove�FileNotFoundErrorr3r�errorZbindrr8Z
EADDRINUSErlrmrkrZServerZ_start_servingr
Zsleep)rrnrorbrsrardrt�errr<�msgZserverrrr�create_unix_server�sZ





































z)_UnixSelectorEventLoop.create_unix_serverc
�s�y
tj

Wn,tk
r6
}
zt�d
�
�
Wdd}~XYnXy|��}Wn2ttjfk
rv
}
zt�d�
�
Wdd}~XYnXyt�|�
j	}Wn,t
k
r�
}
zt�d�
�
Wdd}~XYnX|r�|n|}	|	s�dS|��}
|�|
d|
||||	d�
|
IdHS)Nzos.sendfile() is not availableznot a regular filer
)
rf�sendfile�AttributeErrorr�SendfileNotAvailableErrorr1�io�UnsupportedOperation�fstat�st_sizer3rQ�_sock_sendfile_native_impl)rrb�file�offset�countr<r1r~Zfsize�	blocksize�futrrr�_sock_sendfile_native>
s(



















z,_UnixSelectorEventLoop._sock_sendfile_nativec	Cs|��}	|dk	r|�
|�

|
��r4|�|||�
dS|rd||}|d
k
rd|�|||�
|
�|�

dSyt�|	|||�}
W�
n*ttfk
r�


|dkr�|�	|
|�
|�
|	|j|
|	||||||�

Y�
nHtk
�
rj
}
z�|dk	�
r|j
t
jk�
rt|�
tk	�
rtdt
j�}||_|}|d
k�
rBt�d�
}
|�|||�
|
�|
�

n|�|||�
|
�|�

Wdd}~XYn�tk
�
r�
}
z|�|||�
|
�|�

Wdd}~XYnjX|
d
k�
r�|�|||�
|
�|�

nD||
7}||
7}|dk�
r�|�	|
|�
|�
|	|j|
|	||||||�

dS)Nr
zsocket is not connectedzos.sendfile call failed)r1�
remove_writer�	cancelled�_sock_sendfile_update_fileposZ
set_resultrfr��BlockingIOError�InterruptedError�_sock_add_cancellation_callbackZ
add_writerr�r3r8ZENOTCONNrm�ConnectionError�	__cause__rr�Z
set_exceptionrU)rr�Z
registered_fdrbr1r�r�r��
total_sent�fdZsentr<�new_excr~rrrr�U
s`













































z1_UnixSelectorEventLoop._sock_sendfile_native_implcCs|d
krt�
|
|tj�
dS)Nr
)rf�lseek�SEEK_SET)rr1r�r�rrrr��
s

z4_UnixSelectorEventLoop._sock_sendfile_update_fileposcs��
fd
d�}|
�|�

dS)Nc
s&|��r"�
�
�}
|
d
kr"��|
�

dS)Nr,)r�r1r�)r�r�)rrbrr�cb�
s



zB_UnixSelectorEventLoop._sock_add_cancellation_callback.<locals>.cb)
Zadd_done_callback)rr�rbr�r)rrbrr��
s
z6_UnixSelectorEventLoop._sock_add_cancellation_callback)
N)NN)NN)
N)
N)
N)�__name__�
__module__�__qualname__�__doc__rrr+r>r)r#r.rMrOr^rTrqr�r�r�r�r��
__classcell__rr)
rrr,s4-
 







*


?Drcs�eZ
dZd
Zd�f
dd�	Zdd�Zdd�Zd	d
�Zdd�Zd
d�Z	dd�Z
dd�Zdd�Zdd�Z
ddd�
Zdd�Zdd�Z�ZS) rHiNcs�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�
|dk	r�|j�tj|d�
dS)NrIFz)Pipe transport is for pipes/sockets only.)rr�_extra�_loop�_piper1�_fileno�	_protocol�_closing�_pausedrfr�rzrx�S_ISFIFOry�S_ISCHRr2�set_blocking�	call_soon�connection_made�_add_reader�_read_readyr�_set_result_unless_cancelled)rrvrIrJrKrL�mode)
rrrr�
s.























z_UnixReadPipeTransport.__init__c
Cs�|jj
g
}
|jdkr |
�d
�

n|jr0|
�d�

|
�d|j���

t|jdd�}|jdk	r�|dk	r�t�	||jt
j�}|r�|
�d�

q�|
�d�

n |jdk	r�|
�d�

n
|
�d
�

d�d	�
|
�
�
S)
N�closed�closingzfd=�	_selector�polling�idle�openz<{}>�
 )rr�r��appendr�r��getattrr�r	�_test_selector_event�	selectorsZ
EVENT_READ�format�join)rr7rr�rrr�__repr__�
s"



















z_UnixReadPipeTransport.__repr__c

Cs�yt�
|j|j�}
WnDttfk
r,


Yn�tk
rX
}
z|�|d
�
Wdd}~XYn^X|
rl|j�	|
�

nJ|j
��r�t�
d|�
d|_|j
�|j�

|j
�|jj�

|j
�|jd�
dS)Nz"Fatal read error on pipe transportz%r was closed by peerT)rf�readr��max_sizer�r�r3�_fatal_errorr�Z
data_receivedr��	get_debugrr7r��_remove_readerr�Zeof_received�_call_connection_lost)rr*r<rrrr��
s












z"_UnixReadPipeTransport._read_readyc

Cs>|js|j
rdSd
|_
|j�|j�

|j��r:t�d|�
dS)NTz%r pauses reading)r�r�r�r�r�r�r�debug)
rrrr�
pause_reading�
s






z$_UnixReadPipeTransport.pause_readingc

CsB|js|j
sdSd
|_
|j�|j|j�
|j��r>t�d|�
dS)NFz%r resumes reading)	r�r�r�r�r�r�r�rr�)
rrrr�resume_reading�
s






z%_UnixReadPipeTransport.resume_readingcCs
|
|_dS)
N)
r�)rrJrrr�set_protocol�
s
z#_UnixReadPipeTransport.set_protocolc


Cs|jS)
N)
r�)
rrrr�get_protocols
z#_UnixReadPipeTransport.get_protocolc


Cs|jS)
N)
r�)
rrrr�
is_closings
z!_UnixReadPipeTransport.is_closingc

Cs|js|�
d�

dS)
N)r��_close)
rrrrrs

z_UnixReadPipeTransport.closec

Cs.|jdk	r*t
jd
|��t|d�
|j��
dS)Nzunclosed transport )
r)r�r$r%r&r)
rrrr�__del__s




z_UnixReadPipeTransport.__del__�Fatal error on pipe transportcCsZt|
t
�r4|
jtjkr4|j��rLtjd
||dd�
n|j�||
||j	d��

|�
|
�

dS)Nz%r: %sT)
�exc_info)�message�	exceptionrprJ)rEr3r8ZEIOr�r�rr��call_exception_handlerr�r�)rr<r�rrrr�s






z#_UnixReadPipeTransport._fatal_errorcCs(d
|_|j
�|j�

|j
�|j|
�
dS)NT)r�r�r�r�r�r�)rr<rrrr� s


z_UnixReadPipeTransport._closecCs4z|j�
|
�

Wd|j��
d|_d|_d|_XdS)
N)r��connection_lostr�rr�)rr<rrrr�%s





z,_UnixReadPipeTransport._call_connection_lost)NN)
r�)r�r�r�r�rr�r�r�r�r�r�r�rr�r�r�r�r�rr)
rrrH�
s
rHcs�eZ
dZd%�f
dd�	Zdd�Zdd�Zdd	�Zd
d�Zdd
�Zdd�Z	dd�Z
dd�Zdd�Zdd�Z
dd�Zdd�Zdd�Zd&dd �
Zd'd!d"�
Zd#d$�Z�ZS)(rNNc
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�
|dk	r�|j�tj|d�
dS)NrIr
Fz?Pipe transport is only for pipes, sockets and character devicesZaix)rrr�r�r1r�r��	bytearray�_buffer�
_conn_lostr�rfr�rzrxr�r�ryr2r�r�r�r�r �platform�
startswithr�r�rr�)
rrvrIrJrKrLr�Zis_charZis_fifoZ	is_socket)
rrrr2s2
























z _UnixWritePipeTransport.__init__c
Cs�|jj
g
}
|jdkr |
�d
�

n|jr0|
�d�

|
�d|j���

t|jdd�}|jdk	r�|dk	r�t�	||jt
j�}|r�|
�d�

n
|
�d�

|��}|
�d|���

n |jdk	r�|
�d�

n
|
�d
�

d	�
d
�|
�
�
S)Nr�r�zfd=r�r�r�zbufsize=r�z<{}>r�)rr�r�r�r�r�r�r�r	r�r�ZEVENT_WRITE�get_write_buffer_sizer�r�)rr7rr�rZrrrr�Ws&





















z _UnixWritePipeTransport.__repr__c

Cs
t|j
�
S)
N)�lenr�)
rrrrr�os
z-_UnixWritePipeTransport.get_write_buffer_sizec

Cs6|j�
�rt�d
|�
|jr*|�t��

n|��
dS)Nz%r was closed by peer)r�r�rr7r�r��BrokenPipeError)
rrrrr�rs




z#_UnixWritePipeTransport._read_readyc
Cs2
t|
t
ttf�stt|
�
�
�
t|
t�r.t|
�
}
|
s6dS|jsB|jrj|jtj	krXt
�d
�

|jd7_dS|j�
syt
�|j|
�}WnVttfk
r�


d}Yn<tk
r�
}
z|jd7_|�|d�
dSd}~XYnX|t|
�
kr�dS|dk�
rt|
�
|d�}
|j�|j|j�
|j|
7_|��
dS)Nz=pipe closed by peer or os.write(pipe, data) raised exception.rr
z#Fatal write error on pipe transport)rE�bytesr��
memoryviewre�reprr�r�rZ!LOG_THRESHOLD_FOR_CONNLOST_WRITESr�warningr�rf�writer�r�r�rUr�r�r�Z_add_writer�_write_readyZ_maybe_pause_protocol)rr*�
nr<rrrr�{s4























z_UnixWritePipeTransport.writec

Cs�|jst
d
�
�
yt�|j|j�}
Wnjttfk
r:


Yn�tk
r�
}
z6|j��
|j	d7_	|j
�|j�

|�|d�
Wdd}~XYnfX|
t
|j�
kr�|j��
|j
�|j�

|��
|jr�|j
�|j�

|�d�

dS|
dkr�|jd|
�=dS)NzData should not be emptyrz#Fatal write error on pipe transportr
)r�rerfr�r�r�r�rUr'r�r��_remove_writerr�r�Z_maybe_resume_protocolr�r�r�)rr�r<rrrr��s(



















z$_UnixWritePipeTransport._write_readyc


Csd
S)NTr)
rrrr�
can_write_eof�s
z%_UnixWritePipeTransport.can_write_eofc

CsB|jr
dS|j
st�
d
|_|js>|j�|j�

|j�|jd�
dS)NT)	r�r�rer�r�r�r�r�r�)
rrrr�	write_eof�s







z!_UnixWritePipeTransport.write_eofcCs
|
|_dS)
N)
r�)rrJrrrr��s
z$_UnixWritePipeTransport.set_protocolc


Cs|jS)
N)
r�)
rrrrr��s
z$_UnixWritePipeTransport.get_protocolc


Cs|jS)
N)
r�)
rrrrr��s
z"_UnixWritePipeTransport.is_closingc

Cs|jdk	r|j
s|��
dS)
N)r�r�r�)
rrrrr�s
z_UnixWritePipeTransport.closec

Cs.|jdk	r*t
jd
|��t|d�
|j��
dS)Nzunclosed transport )
r)r�r$r%r&r)
rrrrr��s




z_UnixWritePipeTransport.__del__c

Cs|�d�

dS)
N)
r�)
rrrr�abort�s
z_UnixWritePipeTransport.abort�Fatal error on pipe transportcCsNt|
t
�r(|j��r@tjd
||dd�
n|j�||
||jd��

|�|
�

dS)Nz%r: %sT)
r�)r�r�rprJ)	rEr3r�r�rr�r�r�r�)rr<r�rrrr��s







z$_UnixWritePipeTransport._fatal_errorcCsFd
|_|j
r|j�|j�

|j
��
|j�|j�

|j�|j|
�
dS)NT)	r�r�r�r�r�r'r�r�r�)rr<rrrr��s






z_UnixWritePipeTransport._closecCs4z|j�
|
�

Wd|j��
d|_d|_d|_XdS)
N)r�r�r�rr�)rr<rrrr��s





z-_UnixWritePipeTransport._call_connection_lost)NN)
r�)
N)r�r�r�rr�r�r�r�r�r�r�r�r�r�rr�r�r�r�r�r�rr)
rrrN/s"%	!	

rNc@seZ
dZd
d�ZdS)rRc		Ks�d}|tj
krt��\}}zPtj|
f
||||d
|d�|��
|_|dk	rh|��
t|��d|d�|j_	d}Wd|dk	r�|��
|��
XdS)NF)rVrWrXrYZuniversal_newlinesrZ�wb)
�	buffering)
�
subprocess�PIPErhZ
socketpair�Popen�_procrr��detachrW)	rr;rVrWrXrYrZr[Zstdin_wrrr�_start�s












z_UnixSubprocessTransport._startN)r�r�r�r�rrrrrR�srRc@s@eZ
dZd
Zdd�Zdd�Zdd�Zdd	�Zd
d�Zdd
�Z	dS)raHAbstract base class for monitoring child processes.

    Objects derived from this class monitor a collection of subprocesses and
    report their termination or interruption by a signal.

    New callbacks are registered with .add_child_handler(). Starting a new
    process must be done within a 'with' block to allow the watcher to suspend
    its activity until the new process if fully registered (this is needed to
    prevent a race condition in some implementations).

    Example:
        with watcher:
            proc = subprocess.Popen("sleep 1")
            watcher.add_child_handler(proc.pid, callback)

    Notes:
        Implementations of this class must be thread-safe.

        Since child watcher objects may catch the SIGCHLD signal and call
        waitpid(-1), there should be only one active object per process.
    c
Gs
t��
d
S)a
Register a new child handler.

        Arrange for callback(pid, returncode, *args) to be called when
        process 'pid' terminates. Specifying another callback for the same
        process replaces the previous handler.

        Note: callback() must be thread-safe.
        N)
�NotImplementedError)rr_r:r;rrrrS)s	z&AbstractChildWatcher.add_child_handlerc
Cs
t��
d
S)z�Removes the handler for process 'pid'.

        The function returns True if the handler was successfully removed,
        False if there was nothing to remove.N)
r�)rr_rrr�remove_child_handler4sz)AbstractChildWatcher.remove_child_handlerc
Cs
t��
d
S)z�Attach the watcher to an event loop.

        If the watcher was previously attached to an event loop, then it is
        first detached before attaching to the new loop.

        Note: loop may be None.
        N)
r�)rrvrrr�attach_loop<sz AbstractChildWatcher.attach_loopc


Cs
t��
d
S)zlClose the watcher.

        This must be called to make sure that any underlying resource is freed.
        N)
r�)
rrrrrFszAbstractChildWatcher.closec


Cs
t��
d
S)zdEnter the watcher's context and allow starting new processes

        This function must return selfN)
r�)
rrrr�	__enter__MszAbstractChildWatcher.__enter__c
Cs
t��
d
S)zExit the watcher's contextN)
r�)r�
a�
b�
crrr�__exit__SszAbstractChildWatcher.__exit__N)
r�r�r�r�rSr�r�rr�r�rrrrrs
rc@sDeZ
dZd
d�Zdd�Zdd�Zdd�Zd	d
�Zdd�Zd
d�Z	dS)�BaseChildWatcherc

Csd|_i|_
dS)
N)r��
_callbacks)
rrrrrZs

zBaseChildWatcher.__init__c

Cs|�d�

dS)
N)
r�)
rrrrr^s
zBaseChildWatcher.closec
Cs
t��
dS)
N)
r�)r�expected_pidrrr�_do_waitpidas
zBaseChildWatcher._do_waitpidc


Cs
t��
dS)
N)
r�)
rrrr�_do_waitpid_allds
z BaseChildWatcher._do_waitpid_allcCs~|
dkst|
t
j�st�
|jdk	r<|
dkr<|jr<t�d
t�
|jdk	rT|j�	t
j�

|
|_|
dk	rz|
�t
j|j
�
|��
dS)NzCA loop is being detached from a child watcher with pending handlers)rErZAbstractEventLooprer�r�r$r%�RuntimeWarningr#r/�SIGCHLDr>�	_sig_chldr�)rrvrrrr�gs






zBaseChildWatcher.attach_loopc

CsFy|��
Wn4t
k
r@
}

z|j�d
|
d��

Wdd}
~
XYnXdS)Nz$Unknown exception in SIGCHLD handler)r�r�)r�rUr�r�)rr<rrrr�{s




zBaseChildWatcher._sig_chldcCs2t�
|
�
rt�|
�
St�|
�
r*t�|
�
S|
SdS)
N)rf�WIFSIGNALED�WTERMSIG�	WIFEXITED�WEXITSTATUS)r�statusrrr�_compute_returncode�s





z$BaseChildWatcher._compute_returncodeN)
r�r�r�rrr�r�r�r�r
rrrrr�Xsr�csPeZ
dZd
Z�f
dd�Zdd�Zdd�Zdd	�Zd
d�Zdd
�Z	dd�Z
�ZS)rad
'Safe' child watcher implementation.

    This implementation avoids disrupting other code spawning processes by
    polling explicitly each process in the SIGCHLD handler instead of calling
    os.waitpid(-1).

    This is a safe solution but it has a significant overhead when handling a
    big number of children (O(n) each time SIGCHLD is raised)
    c

s|j�
�
t���
dS)
N)r�r'rr)
r)
rrrr�s


zSafeChildWatcher.closec


Cs|S)
Nr)
rrrrr��s
zSafeChildWatcher.__enter__c
CsdS)
Nr)rr�r�r�rrrr��s
zSafeChildWatcher.__exit__cGs.|jdkrt
d
�
�
||f|j|
<|�|
�

dS)NzICannot add child handler, the child watcher does not have a loop attached)r�r4r�r�)rr_r:r;rrrrS�s




z"SafeChildWatcher.add_child_handlercCs&y|j|
=d
St
k
r 


dSXdS)NTF)r�r@)rr_rrrr��s





z%SafeChildWatcher.remove_child_handlerc
Cs"xt|j
�
D]}
|�|
�

qWdS)
N)r"r�r�)rr_rrrr��s
z SafeChildWatcher._do_waitpid_allcCs�|
d
kst�
yt
�|
t
j�\}}Wn(tk
rJ


|
}d}t�d|�
Yn0X|d
krXdS|�|�
}|j�	�rzt�
d|
|�
y|j�|�
\}}Wn.t
k
r�


|j�	�r�tjd|dd�
YnX|||f|��
dS)Nr
�z8Unknown child process pid %d, will report returncode 255z$process %s exited with returncode %sz'Child watcher got an unexpected pid: %rT)
r�)rerf�waitpid�WNOHANG�ChildProcessErrorrr�r
r�r�r�r��popr@)rr�r_r
r`r:r;rrrr��s,
















zSafeChildWatcher._do_waitpid)r�r�r�r�rr�r�rSr�r�r�r�rr)
rrr�s	rcsTeZ
dZd
Z�f
dd�Z�f
dd�Zdd�Zdd	�Zd
d�Zdd
�Z	dd�Z
�ZS)raW
'Fast' child watcher implementation.

    This implementation reaps every terminated processes by calling
    os.waitpid(-1) directly, possibly breaking other code spawning processes
    and waiting for their termination.

    There is no noticeable overhead when handling a big number of children
    (O(1) each time a child terminates).
    c

s$t��
�
t��|_i|_d
|_dS)Nr
)rr�	threadingZLock�_lock�_zombies�_forks)
r)
rrrr�s





zFastChildWatcher.__init__c

s"|j�
�
|j�
�
t���
dS)
N)r�r'r

rr)
r)
rrrr�s




zFastChildWatcher.closec

	Cs$|j�
|j
d
7_
|SQRXdS)Nr)r
r
)
rrrrr��s

zFastChildWatcher.__enter__c	CsT|j�8
|j
d
8_
|j
s"|js&dSt|j�
}|j��
WdQRXt�d|�
dS)Nrz5Caught subprocesses termination from unknown pids: %s)r
r
r

r5r'rr�)rr�r�r�Zcollateral_victimsrrrr��s






zFastChildWatcher.__exit__c	Gsz|jst
d
�
�
|jdkr td�
�
|j�:
y|j�|
�
}Wn"tk
rZ


||f|j|
<dSXWdQRX||
|f|��
dS)NzMust use the context managerzICannot add child handler, the child watcher does not have a loop attached)	r
rer�r4r
r

r

r@r�)rr_r:r;r`rrrrS
s







z"FastChildWatcher.add_child_handlercCs&y|j|
=d
St
k
r 


dSXdS)NTF)r�r@)rr_rrrr� s





z%FastChildWatcher.remove_child_handlerc
	Cs�x�yt�
d
tj�\}
}Wntk
r,


dSX|
dkr:dS|�|�
}|j�v
y|j�|
�
\}}WnBtk
r�


|j	r�||j
|
<|j��r�t
�d|
|�
wd}YnX|j��r�t
�d|
|�
WdQRX|dkr�t
�d|
|�
q||
|f|��
qWdS)Nr,r
z,unknown process %s exited with returncode %sz$process %s exited with returncode %sz8Caught subprocess termination from unknown pid: %d -> %d)rfr
r
r	
r
r
r�r

r@r
r

r�r�rr�r�)rr_r
r`r:r;rrrr�'s6




















z FastChildWatcher._do_waitpid_all)r�r�r�r�rrr�r�rSr�r�r�rr)
rrr�s	
rcsHeZ
dZd
ZeZ�f
dd�Zdd�Z�f
dd�Zdd	�Z	d
d�Z
�ZS)�_UnixDefaultEventLoopPolicyz:UNIX event loop policy with a watcher for child processes.c

st��
�
d|_dS)
N)rr�_watcher)
r)
rrrrVs


z$_UnixDefaultEventLoopPolicy.__init__c

	CsHtj
�8
|jdkr:t�|_tt��tj�r:|j�|j	j
�

WdQRXdS)
N)rr
r
rrEr
�current_thread�_MainThreadr��_localr�)
rrrr�
_init_watcherZs






z)_UnixDefaultEventLoopPolicy._init_watchercs6t��
|
�

|jd
k	r2tt��tj�r2|j�|
�

d
S)z�Set the event loop.

        As a side effect, if a child watcher was set before, then calling
        .set_event_loop() from the main thread will call .attach_loop(loop) on
        the child watcher.
        N)r�set_event_loopr
rEr
r
r
r�)rrv)
rrrr
bs


z*_UnixDefaultEventLoopPolicy.set_event_loopc

Cs|jd
kr|�
�
|jS)zzGet the watcher for child processes.

        If not yet set, a SafeChildWatcher object is automatically created.
        N)r
r
)
rrrrrPps

z-_UnixDefaultEventLoopPolicy.get_child_watchercCs4|
d
kst|
t
�st�
|jd
k	r*|j��
|
|_d
S)z$Set the watcher for child processes.N)rErrer
r)rr\rrr�set_child_watcherzs


z-_UnixDefaultEventLoopPolicy.set_child_watcher)r�r�r�r�rZ
_loop_factoryrr
r
rPr
r�rr)
rrr
Rs


r
)-r�r8r�rfr�r/rhrxr�r r
r$�rrrrrrr	r
r�logr�__all__r��ImportErrorrZBaseSelectorEventLooprZ
ReadTransportrHZ_FlowControlMixinZWriteTransportrNZBaseSubprocessTransportrRrr�rrZBaseDefaultEventLoopPolicyr
r
rrrrr�<module>
sR




















|

JF=On3