$86 GRAYBYTE WORDPRESS FILE MANAGER $87

3

� fn.�@s�
dd
lZdd
l
Z
dd
lZdd
lZdd
lZdd
lZddlmZ
ddlm	Z	
ddddd	d
ddd
ddddddgZ
dZdZdZ
dZdZdZdZd
adadd�Zdd�Zdd�Zdd�Zdd	�Zd6d d
�
Zd!d�Zej�Ze
j�Zd"d#�Zd$d�Z iZ!e
j�Z"Gd%d�de#�Z$d7d&d'�
Z%d(d
�Z&da'eee%e	j(e	j)fd)d*�
Z*ej+e*�

Gd+d�de#�Z,Gd,d�dej-�Z.yej/d-�
Z0Wne1k
�
r�


d.Z0YnXd/d�Z2d0d1�Z3d2d3�Z4d4d5�Z5d
S)8�N)
�_args_from_interpreter_flags�
)
�process�	sub_debug�debug�info�sub_warning�
get_logger�
log_to_stderr�get_temp_dir�register_after_fork�
is_exiting�Finalize�ForkAwareThreadLock�ForkAwareLocal�close_all_fds_except�SUBDEBUG�
SUBWARNING��
��Zmultiprocessingz+[%(levelname)s/%(processName)s] %(message)sFc
Gstrtj
t|f|
��
dS)
N)�_logger�logr)�msg�args�r�9/opt/alt/python36/lib64/python3.6/multiprocessing/util.pyr,s

c
Gstrtj
t|f|
��
dS)
N)rr�DEBUG)rrrrrr0s

c
Gstrtj
t|f|
��
dS)
N)rr�INFO)rrrrrr4s

c
Gstrtj
t|f|
��
dS)
N)rrr)rrrrrr8s

c

Cs|d
dl}|j
�
z\tsj|jt�
ad
t_ttd�rFtjt	�

tj
t	�

n$tjjt	fif�

tjj
t	fif�

Wd|j�
XtS)z0
    Returns logger used by multiprocessing
    r
N�
unregister)�loggingZ_acquireLockrZ	getLogger�LOGGER_NAMEZ	propagate�hasattr�atexitr �_exit_function�registerZ
_exithandlers�remove�appendZ_releaseLock)
r!rrrr	<s









c
CsJd
dl}
t
�}|
jt�
}|
j�}|j|�

|j|�

|rB|j|�

dat	S)zB
    Turn on logging and add a handler which prints to stderr
    r
NT)
r!r	Z	Formatter�DEFAULT_LOGGING_FORMATZ
StreamHandlerZsetFormatterZ
addHandlerZsetLevel�_log_to_stderrr)�levelr!ZloggerZ	formatterZhandlerrrrr
Ws










cCsdtj
�jjd
�
}|dkr`ddl}
ddl}|jdd�
}td|�
td|
j	|g
dd�
|tj
�jd
<|S)	N�tempdirr
zpymp-)
�prefixzcreated temp directory %s�d)r�exitpriorityi����)
r�current_processZ_config�get�shutil�tempfileZmkdtemprrZrmtree)r,r2r3rrrrms







cCsjtt
j��
}|j�
xP|D]H\\}
}}}y||�

Wqtk
r`
}
ztd
|�
WYdd}~XqXqWdS)Nz after forker raised exception %s)�list�_afterfork_registry�items�sort�	Exceptionr)r6�indexZident�func�obj�
errr�_run_after_forkerss






r=cCs|tt
t�
t|�
|
f<dS)
N)r5�next�_afterfork_counter�id)r;r:rrrr�s
c@sLeZ
dZd
Zfddfdd�
Zdeeejfdd�
Z	dd�Z
d	d
�Zdd�ZdS)
rzA
    Class which supports object finalization using weakrefs
    NcCsx|dkst|�
t
kst�
|
dk	r0tj|
|�|_n|dk	s<t�
||_||_|pNi|_|t	t
�
f|_tj
�|_|t|j<dS)
N)�type�int�AssertionError�weakref�ref�_weakref�	_callback�_args�_kwargsr>�_finalizer_counter�_key�os�getpid�_pid�_finalizer_registry)�selfr;�callbackr�kwargsr/rrr�__init__�s







zFinalize.__init__c
Cs�y||j=Wnt
k
r(


|d
�

YnbX|j|�krD|d�

d}n$|d|j|j|j�
|j|j|j�
}d|_|_|_|_|_|SdS)zQ
        Run the callback unless it has already been called or cancelled
        zfinalizer no longer registeredz+finalizer ignored because different processNz/finalizer calling %s with args %s and kwargs %s)rK�KeyErrorrNrGrHrIrF)rP�wrrOrrM�resrrr�__call__�s







zFinalize.__call__c

CsDyt|j
=Wntk
r 


Yn Xd
|_|_|_|_|_
d
S)z3
        Cancel finalization of the object
        N)rOrKrTrFrGrHrI)
rPrrr�cancel�s



zFinalize.cancelc

Cs
|jt
kS)
zS
        Return whether this finalizer is still waiting to invoke callback
        )rKrO)
rPrrr�still_active�szFinalize.still_activec
Cs�y|j�}
Wnt
tfk
r(


d}
YnX|
dkr>d
|jjSd|jjt|jd|j�f}|jrr|dt|j�
7}|j	r�|dt|j	�
7}|j
ddk	r�|dt|j
d�
7}|dS)	Nz<%s object, dead>z<%s object, callback=%s�__name__z, args=z	, kwargs=r
z, exitprority=�
>)rF�AttributeError�	TypeError�	__class__rZ�getattrrGrH�strrIrK)rPr;�
xrrr�__repr__�s 














zFinalize.__repr__)
rZ�
__module__�__qualname__�__doc__rSrOrrLrMrWrXrYrbrrrrr�s

c
s�td
krd
S�
d
krdd��n�
f
dd���f
dd�t
t�
D�
}
|
jdd�

xX|
D]P}tj|�
}|d
k	rRtd	|�
y
|�
WqRtk
r�


d
d
l}|j�
YqRXqRW�
d
kr�tj�
d
S)z�
    Run all finalizers whose exit priority is not None and at least minpriority

    Finalizers with highest priority are called first; finalizers with
    the same priority will be called in reverse order of creation.
    Nc

Ss|d
dk	S)Nr
r)
�
prrr�<lambda>�sz!_run_finalizers.<locals>.<lambda>c

s|d
dk	o|d
�kS)Nr
r)
rf)
�minpriorityrrrg�sc
sg|]}
�|
�
r|
�qSrr)�.0�key)
�
frr�
<listcomp>�sz#_run_finalizers.<locals>.<listcomp>T)
�reversez
calling %sr
)	rOr4r7r1rr8�	traceback�	print_exc�clear)rh�keysrj�	finalizerrnr)rkrhr�_run_finalizers�s$














rscCstp
td
kS)z6
    Returns true if the process is shutting down
    N)
�_exitingrrrrr

scCs�ts�d
a|d�

|
d�

|d�

|�dk	rzx*|�D] }|j
r2|d|j�
|jj�
q2Wx"|�D]}|d|j�
|j�
q^W|
d�

|�
dS)NTzprocess shutting downz2running all "atexit" finalizers with priority >= 0r
z!calling terminate() for daemon %szcalling join() for process %sz)running the remaining "atexit" finalizers)rtZdaemon�nameZ_popenZ	terminate�join)rrrs�active_childrenr0rfrrrr%
s	









r%c@s,eZ
dZd
d�Zdd�Zdd�Zdd�Zd	S)
rc

Cs|j�
t
|tj�
dS)
N)�_resetrr)
rPrrrrSK
s

zForkAwareThreadLock.__init__c

Cs"tj
�|_|jj|_|jj|_dS)
N)�	threadingZLock�_lock�acquire�release)
rPrrrrxO
s




zForkAwareThreadLock._resetc


Cs
|jj
�S)
N)rz�	__enter__)
rPrrrr}T
s
zForkAwareThreadLock.__enter__c
Gs|jj
|
�S)
N)rz�__exit__)rPrrrrr~W
s
zForkAwareThreadLock.__exit__N)rZrcrdrSrxr}r~rrrrrJ
s
c@seZ
dZd
d�Zdd�ZdS)rc

Cst|d
d��
dS)Nc


Ss
|jj
�S)
N)�__dict__rp)
r;rrrrg]
sz)ForkAwareLocal.__init__.<locals>.<lambda>)
r)
rPrrrrS\
s
zForkAwareLocal.__init__c

Cst|�
ffS)
N)
rA)
rPrrr�
__reduce__^
s
zForkAwareLocal.__reduce__N)rZrcrdrSr�rrrrr[
s
�SC_OPEN_MAX�
c
Csft|�
dt
g}|j�
|dt
ks,td�
�
x4tt|�
d
�
D] }
tj||
d
||
d
�
q>WdS)Nrzfd too large���r�)r4�MAXFDr7rC�range�lenrL�
closerange)Zfds�
irrrrj
s





c
Cs�tj
dkrdSytj
j�
Wnttfk
r4


YnXy@tjtjtj�}yt|d
d�t_
Wn


tj|�

�YnXWnttfk
r�


YnXdS)NF)
�closefd)	�sys�stdin�close�OSError�
ValueErrorrL�open�devnull�O_RDONLY)
�fdrrr�_close_stdint
s














r�cCsTytj
j�
Wnttfk
r&


YnXytjj�
Wnttfk
rN


YnXdS)
N)r��stdout�flushr\r��stderrrrrr�_flush_std_streams�
s







r�cCstd
dl}t
ttt|��
�
}tj�\}}z2|j|
tj|�
g
d|ddddddd	d
||ddd�Stj	|�

tj	|�

XdS)Nr
TrFr�r�r�r�r�r�)
�_posixsubprocess�tuple�sorted�maprBrL�pipeZ	fork_exec�fsencoder�)�pathrZpassfdsr�Zerrpipe_readZ
errpipe_writerrr�spawnv_passfds�
s










r�)
N)
N)6rL�	itertoolsr�rDr$ry�
subprocessr�r�__all__ZNOTSETrrrrr"r)rr*rrrrr	r
r�WeakValueDictionaryr5�countr?r=rrOrJ�objectrrsr
rtrwr0r%r&rZlocalr�sysconfr�r8rr�r�r�rrrr�<module>
sf

















	
S
,

(