✘✘ GRAYBYTE WORDPRESS FILE MANAGER ✘✘

a

�i�.�@s2
gd�
Zd
dl
Z
d
dlZd
dlZd
dlZd
dlZd
dlmZ
ze
j�	e
�
��
ZWneyf


dZYn0dd�Z
dd�Zdd	�Zd
d�ZGdd
�d
e�ZGdd�de�ZGdd�de�ZGdd�de�Zdae�ae�d�
ae�a[iZeej� ��
D]0\Z!Z"e!dd�dkr�de!v
r�de!��ee"<q�e�Z#dS))�BaseProcess�current_process�active_children�parent_process�N)
�WeakSetc
CstS)
z@
    Return process object representing the current process
    )
�_current_process�rr�//usr/lib64/python3.9/multiprocessing/process.pyr%srcCst�
t
t�
S)
zN
    Return list of process objects corresponding to live child processes
    )�_cleanup�list�	_childrenrrrr	r+s
rc
CstS)
z?
    Return process object representing the parent process
    )
�_parent_processrrrr	r3src
Cs*tt
�
D]}|j��du
rt
�|�

qdS�
N)rr�_popen�poll�discard)
�
prrr	r
=s

r
c@s�eZ
dZd
Zdd�Zddddifdd�
dd�Zd	d
�Zdd�Zd
d�Zdd�Z	dd�Z
d,dd�
Zdd�Zdd�Z
edd��
Zejdd��
Zedd��
Zejdd��
Zedd ��
Zejd!d ��
Zed"d#��
Zed$d%��
ZeZed&d'��
Zd(d)�Zd-d*d+�
ZdS).r
z�
    Process objects represent activity that is run in a separate process

    The class is analogous to `threading.Thread`
    c


Cst�
dSr)
�NotImplementedError�
�selfrrr	�_PopenMs
zBaseProcess._PopenNr)
�daemonc
Cs�tt
�
}tj|f
|_tj��|_t��|_tj	|_
d|_d
|_||_
t|�
|_t|�
|_|p�t|�
jdd�dd�|jD�
�
|_|du
r�||_t�|�

dS)NF�
-�
:c
ss|]}
t|
�
V
qdSr)
�str)�.0�
irrr	�	<genexpr>^�z'BaseProcess.__init__.<locals>.<genexpr>)�next�_process_counterr�	_identity�_config�copy�os�getpid�_parent_pid�name�_parent_namer�_closed�_target�tuple�_args�dict�_kwargs�type�__name__�join�_namer�	_dangling�add)r�group�targetr'�args�kwargsr�countrrr	�__init__Ps 













�

zBaseProcess.__init__c

Cs|jrt
d
�
�
dS)Nzprocess object is closed)r)�
ValueErrorrrrr	�
_check_closedcs

zBaseProcess._check_closedc

Cs|jr|j|j
i|j�
�

d
S)zQ
        Method to be run in sub-process; can be overridden in sub-class
        N)r*r,r.rrrr	�rungs
zBaseProcess.runc

Cs>|��
t
�
|�|�
|_|jj|_|`|`|`t	�
|�

d
S)z%
        Start child process
        N)r<r
rr�sentinel�	_sentinelr*r,r.rr4rrrr	�startns



zBaseProcess.startc

Cs|��
|j
��
d
S)zT
        Terminate process; sends SIGTERM signal or uses TerminateProcess()
        N)r<r�	terminaterrrr	rA�s
zBaseProcess.terminatec

Cs|��
|j
��
d
S)zT
        Terminate process; sends SIGKILL signal or uses TerminateProcess()
        N)r<r�killrrrr	rB�s
zBaseProcess.killcCs*|��
|j
�|
�
}|d
u
r&t�|�

d
S)z5
        Wait until child process terminates
        N)r<r�waitrr)r�timeout�resrrr	r1�s

zBaseProcess.joinc
CsJ|��
|t
urd
S|jdur"dS|j��}
|
dur8d
St�|�

dSdS)z1
        Return whether process is alive
        TNF)r<rrrrr)r�
returncoderrr	�is_alive�s








zBaseProcess.is_alivec

CsH|jd
u
r>|j�
�d
ur td�
�
|j��
d
|_|`t�|�

d|_d
S)z�
        Close the Process object.

        This method releases resources held by the Process object.  It is
        an error to call this method if the child process is still running.
        Nz^Cannot close a process while it is still running. You should first call join() or terminate().T)rrr;�closer?rrr)rrrr	rH�s








zBaseProcess.closec


Cs|jSr�
r2rrrr	r'�szBaseProcess.namecCs
|
|_dSrrI)rr'rrr	r'�sc

Cs|j�
d
d�S)z4
        Return whether process is a daemon
        rF)r"�getrrrr	r�szBaseProcess.daemoncCs|
|jd
<dS)z1
        Set whether process is a daemon
        rN�
r")r�daemonicrrr	r�sc

Cs
|jd
S)N�authkeyrKrrrr	rM�szBaseProcess.authkeycCst|
�
|j
d
<dS)z2
        Set authorization key of process
        rMN)�AuthenticationStringr")rrMrrr	rM�sc

Cs"|��
|j
d
ur|j
S|j
��S)zM
        Return exit code of process or `None` if it has yet to stop
        N)r<rrrrrr	�exitcode�s



zBaseProcess.exitcodec

Cs*|��
|t
urt��S|jo$|jjSd
S)zU
        Return identifier (PID) of process or `None` if it has yet to start
        N)r<rr$r%r�pidrrrr	�ident�s

zBaseProcess.identc

Cs2|��
z|j
WSty,


td
�
d�Yn0dS)z{
        Return a file descriptor (Unix) or handle (Windows) suitable for
        waiting for process termination.
        zprocess not startedN)r<r?�AttributeErrorr;rrrr	r>�s




zBaseProcess.sentinelc
Cs�d}
|turd
}nL|j
rd}n@|jt��kr2d}n,|jdurBd}n|j��}
|
du
rZd}nd
}t|�
jd|j	g}|jdu
r�|�
d|jj�

|�
d|j�

|�
|�

|
du
r�t�
|
|
�}
|�
d	|
�

|jr�|�
d
�

dd�|�
S)
N�started�closed�unknown�initial�stoppedzname=%rzpid=%sz	parent=%szexitcode=%srz<%s>�
 )rr)r&r$r%rrr/r0r2�appendrP�_exitcode_to_namerJrr1)rrO�status�inforrr	�__repr__
s0

























zBaseProcess.__repr__c
Cs�
d
dlm
}m}
�
z`z�|jdu
r,|�|j�

t�d
�
at�a	|�
�
t}|at|j
|j|
�atjrnt����
z|j��
|��
W~n~0|�d�

z|��
d}W|��
n
|��
0Wn�t�
y 
}
zJ|jdur�d}n.t|jt�r�|j}ntj� t!|j�
d�

d
}WYd}~n:d}~0


d
}ddl"}tj� d|j#�

|�$�
Yn0Wt�%�
|�d|�

|�&�
n t�%�
|�d|�

|�&�
0|S)N�
)�util�contextz child process calling self.run()r�

zProcess %s:
z process exiting with exitcode %d)'�r_r`�
_start_method�_force_start_method�	itertoolsr9r �setr�_close_stdinr�_ParentProcessr(r&r
�	threading�_HAVE_THREAD_NATIVE_ID�main_thread�_set_native_id�_finalizer_registry�clear�_run_after_forkersr\r=�_exit_function�
SystemExit�code�
isinstance�int�sys�stderr�writer�	tracebackr'�	print_exc�	_shutdown�_flush_std_streams)r�parent_sentinelr_r`�old_processrO�
erxrrr	�
_bootstrap"
sT












�

























�


zBaseProcess._bootstrap)
N)
N)r0�
__module__�__qualname__�__doc__rr:r<r=r@rArBr1rGrH�propertyr'�setterrrMrOrQrPr>r]rrrrr	r
GsD

�














	




r
c@seZ
dZd
d�ZdS)rNc
Cs,d
dlm
}

|
�durtd�
�
tt|�
f
fS)Nr^)
�get_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)r`r��	TypeErrorrN�bytes)rr�rrr	�
__reduce__X
s




�zAuthenticationString.__reduce__N)r0r�r�r�rrrr	rNW
s
rNc@s6eZ
dZd
d�Zdd�Zedd��
Zd
dd	�
ZeZdS)rhcCs4d
|_|
|_
||_d|_d|_d|_||_i|_dS)NrF)r!r2�_pidr&rr)r?r")rr'rPr>rrr	r:h
s







z_ParentProcess.__init__c
Csd
dlm
}

|
|jg
d
d�S)Nr�
rC�
rD��multiprocessing.connectionrCr?)rrCrrr	rGr
s

z_ParentProcess.is_alivec


Cs|jSr)
r�rrrr	rQv
sz_ParentProcess.identNcCs d
dlm
}
||jg
|
d�
dS)z6
        Wait until parent process terminates
        rr�r�Nr�)rrDrCrrr	r1z
s
z_ParentProcess.join)
N)	r0r�r�r:rGr�rQr1rPrrrr	rhf
s



rhc@seZ
dZd
d�Zdd�ZdS)�_MainProcessc

Cs8d
|_d|_
d|_d|_d|_tt�d�
�
dd�|_dS)Nr�MainProcessF� z/mp)rM�	semprefix)	r!r2r&rr)rNr$�urandomr"rrrr	r:�
s






�z_MainProcess.__init__c


CsdSrrrrrr	rH�
s
z_MainProcess.closeN)r0r�r�r:rHrrrr	r��
sr�r^�ZSIG�
_r)$�__all__r$ru�signalreri�_weakrefsetr�path�abspath�getcwd�ORIGINAL_DIR�OSErrorrrrr
�objectr
r�rNrhr�r
rr9r rfrrZr�__dict__�itemsr'�signumr3rrrr	�<module>
s<










!