✘✘ 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�|
dusJd
�
�
tt
�
}tj|f
|_tj��|_t��|_tj	|_
d|_d|_||_
t|�
|_t|�
|_|p�t|�
jdd�dd�|jD�
�
|_|du
r�||_t�|�

dS)Nz#group argument must be None for nowF�
-�
: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

Csz|��
|j
d
usJd�
�
|jt��ks0Jd�
�
tj�d�
rDJd�
�
t�
|�	|�
|_
|j
j
|_|`|`
|`t�|�

d
S)z%
        Start child process
        Nzcannot start a process twicez:can only start a process object created by current processrz3daemonic processes are not allowed to have children)r<rr&r$r%rr"�getr
r�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	rB�s
zBaseProcess.terminatec

Cs|��
|j
��
d
S)zT
        Terminate process; sends SIGKILL signal or uses TerminateProcess()
        N)r<r�killrrrr	rC�s
zBaseProcess.killcCsR|��
|j
t��ksJd
�
�
|jdu
s0Jd�
�
|j�|
�
}|du
rNt�|�

dS)z5
        Wait until child process terminates
        zcan only join a child processNzcan only join a started process)r<r&r$r%r�waitrr)r�timeout�resrrr	r1�s




zBaseProcess.joinc
Cs`|��
|t
urd
S|jt��ks*Jd�
�
|jdur8dS|j��}
|
durNd
St�|�

dSdS)z1
        Return whether process is alive
        Tzcan only test a child processNF)	r<rr&r$r%rrr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	rI�s








zBaseProcess.closec


Cs|jSr)
r2rrrr	r'�szBaseProcess.namecCst|
t
�sJd
�
�
|
|_dS)Nzname must be a string)�
isinstancerr2)rr'rrr	r'�s
c

Cs|j�
d
d�S)z4
        Return whether process is a daemon
        rF)r"r>rrrr	r�szBaseProcess.daemoncCs |jd
usJd�
�
|
|j
d<d
S)z1
        Set whether process is a daemon
        Nzprocess has already startedr)rr")r�daemonicrrr	r�s
c

Cs
|jd
S)N�authkey)
r"rrrr	rL�szBaseProcess.authkeycCst|
�
|j
d
<dS)z2
        Set authorization key of process
        rLN)�AuthenticationStringr")rrLrrr	rL�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�appendrO�_exitcode_to_namer>rr1)rrN�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�coderJ�int�sys�stderr�writer�	tracebackr'�	print_exc�	_shutdown�_flush_std_streams)r�parent_sentinelr^r_�old_processrN�
ervrrr	�
_bootstrap"
sT












�

























�


zBaseProcess._bootstrap)
N)
N)r0�
__module__�__qualname__�__doc__rr:r<r=rArBrCr1rHrI�propertyr'�setterrrLrNrPrOr?r\r}rrrr	r
GsD

�














	




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

|
�durtd�
�
tt|�
f
fS)Nr])
�get_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)r_r��	TypeErrorrM�bytes)rr�rrr	�
__reduce__X
s




�zAuthenticationString.__reduce__N)r0r~rr�rrrr	rMW
s
rMc@s6eZ
dZd
d�Zdd�Zedd��
Zd
dd	�
ZeZdS)rgcCs4d
|_|
|_
||_d|_d|_d|_||_i|_dS)NrF)r!r2�_pidr&rr)r@r")rr'rOr?rrr	r:h
s







z_ParentProcess.__init__c
Csd
dlm
}

|
|jg
d
d�S)Nr�
rD�
rE��multiprocessing.connectionrDr@)rrDrrr	rHr
s

z_ParentProcess.is_alivec


Cs|jSr)
r�rrrr	rPv
sz_ParentProcess.identNcCs d
dlm
}
||jg
|
d�
dS)z6
        Wait until parent process terminates
        rr�r�Nr�)rrErDrrr	r1z
s
z_ParentProcess.join)
N)	r0r~rr:rHr�rPr1rOrrrr	rgf
s



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

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






�z_MainProcess.__init__c


CsdSrrrrrr	rI�
s
z_MainProcess.closeN)r0r~rr:rIrrrr	r��
sr�r]�ZSIG�
_r)$�__all__r$rs�signalrdrh�_weakrefsetr�path�abspath�getcwd�ORIGINAL_DIR�OSErrorrrrr
�objectr
r�rMrgr�r
rr9r rerrYr�__dict__�itemsr'�signumr3rrrr	�<module>
s<










!