✘✘ GRAYBYTE WORDPRESS FILE MANAGER ✘✘

a

�i�.�@s�gd�
Zd
dl
Z
d
dlZd
dlZd
dlZd
dlZd
dlZd
dlZd
dlZd
dl	m
Z
mZ
d
dlZddl
mZ
ddl
mZ
ejjZddlmZmZmZmZmZ
Gdd	�d	e�Ze�ZGd
d�de�ZGdd
�d
e�ZdS))�Queue�SimpleQueue�
JoinableQueue�N)�Empty�Full�
)
�
connection)
�context)�debug�info�Finalize�register_after_fork�
is_exitingc@s�eZ
dZd-dd�
Zdd�Zdd�Zdd	�Zd.dd�
Zd/dd�
Zd0dd�
Z	dd�Z
dd�Zdd�Zdd�Z
dd�Zdd�Zdd �Zd!d"�Zd#d$�Zed%d&��
Zed'd(��
Zed)d*��
Zed+d,��
ZdS)1r
rc
Cs�|
d
k
rddlm
}

|
|_tjdd�
\|_|_|��|_t	�
�|_tj
dkrTd|_n
|��|_|�|
�
|_d|_|��
tj
dkr�t|tj�
dS)Nrr)
�
SEM_VALUE_MAXF�
�duplex�win32)�synchronizer�_maxsizer�Pipe�_reader�_writer�Lock�_rlock�os�getpid�_opid�sys�platform�_wlock�BoundedSemaphore�_sem�
_ignore_epipe�_resetr
r
�_after_fork��self�maxsize�ctx�r)�./usr/lib64/python3.9/multiprocessing/queues.py�__init__%s














zQueue.__init__c

Cs.t�
|�

|j|j|j|j|j|j|j|j	fS�
N)
r	�assert_spawningr"rrrrrr!r�
r&r)r)r*�__getstate__9s



�zQueue.__getstate__c	Cs0|
\|_|_
|_|_|_|_|_|_|��
dSr,)	r"rrrrrr!rr#�r&�stater)r)r*�__setstate__>s�

zQueue.__setstate__c

Cstd
�

|j
dd�

dS)NzQueue._after_fork()T)
�
after_fork)r
r#r.r)r)r*r$Cs

zQueue._after_forkFcCsj|
r|j�
�
nt�t���
|_t��|_d|_d|_	d
|_
d
|_d|_|j
j|_|jj|_|jj|_dS�NF)�	_notempty�_at_fork_reinit�	threading�	Conditionr�collections�deque�_buffer�_thread�_jointhread�_joincancelled�_closed�_closer�
send_bytes�_send_bytesr�
recv_bytes�_recv_bytes�poll�_poll)r&r3r)r)r*r#Gs













zQueue._resetTNcCsz|jrt
d
|�d��
�
|j�||�s(t�
|j�8
|jdurB|��
|j�	|
�

|j�
�
Wd�
n1sl0


Y
dS�NzQueue z
 is closed)r?�
ValueErrorr!�acquirerr5r<�
_start_threadr;�append�notify�r&�obj�block�timeoutr)r)r*�putVs








z	Queue.putcCs�|jrt
d
|�d��
�
|
r\|dur\|j�
|��}Wd�
n1sF0


Y
|j��
n||
rlt��|}|j�|
|�s~t	�
zL|
r�|t��}|�
|�
s�t	�
n|�
�s�t	�
|��}|j��
W|j��
n|j��
0t�|�
SrG)
r?rHrrDr!�release�time�	monotonicrIrrF�_ForkingPickler�loads)r&rOrP�res�deadliner)r)r*�getbs*




&













z	Queue.getc

Cs|j|j
j��Sr,)rr!�_semlock�
_get_valuer.r)r)r*�qsize|szQueue.qsizec

Cs
|��Sr,�
rFr.r)r)r*�empty�s
zQueue.emptyc

Cs|jj
��Sr,)r!rZ�_is_zeror.r)r)r*�full�s
z
Queue.fullc

Cs
|�d
�
Sr4)
rYr.r)r)r*�
get_nowait�s
zQueue.get_nowaitcCs|�|
d
�Sr4)
rQ�r&rNr)r)r*�
put_nowait�s
zQueue.put_nowaitc
Cs d
|_|j
}
|
rd|_
|
�
dS)NT)r?r@)r&�closer)r)r*rd�s





zQueue.closec

Cstd
�

|j
r|�
�
dS)NzQueue.join_thread())r
r=r.r)r)r*�join_thread�s

zQueue.join_threadc

Cs4td
�

d|_
z|j��
Wnty.


Yn0dS)NzQueue.cancel_join_thread()T)r
r>r=�cancel�AttributeErrorr.r)r)r*�cancel_join_thread�s





zQueue.cancel_join_threadc

Cs�td
�

|j
��
tjtj|j
|j|j|j	|j
j|jj|j
|j|jf	dd�|_d|j_td�

|j��
td�

|js�t|jtjt�|j�
g
dd�|_t|tj|j
|jgd	d�|_dS)
NzQueue._start_thread()�QueueFeederThread)�target�args�nameTzdoing self._thread.start()z... done self._thread.start()���)
�exitpriority�
)r
r;�clearr7�Threadr
�_feedr5rBrrrdrr"�_on_queue_feeder_errorr!r<�daemon�startr>r�_finalize_join�weakref�refr=�_finalize_closer@r.r)r)r*rJ�s4







��






�



�zQueue._start_threadc
Cs4td
�

|�}
|
du
r(|
�
�
td�

ntd�

dS)Nzjoining queue threadz... queue thread joinedz... queue thread already dead)r
�join)�twr�threadr)r)r*rv�s




zQueue._finalize_joincCsBtd
�

|
�"
|�
t�

|
��
Wd�
n1s40


Y
dS)Nztelling queue thread to quit)r
rK�	_sentinelrL)�buffer�notemptyr)r)r*ry�s



zQueue._finalize_closec	
Csr
td
�

|
j
}	|
j}
|
j}|j}t}
tjdkr<|j
}|j}nd}z�|	�
z|sT|�
W|
�
n|
�
0zn|�}||
ur�td�

|�
|�
WWdSt�	|�
}|dur�||�

qh|�
z||�

W|�
qh|�
0qhWnt
y�


Yn0Wq@t�
yj
}
zf|�
r$t|dd�t
jk�
r$WYd}~dSt��
rDtd|�
WYd}~dS|��
|||�
WYd}~q@d}~00q@dS)Nz$starting thread to feed data to piperz%feeder thread got sentinel -- exiting�errnorzerror in queue thread: %s)r
rIrR�wait�popleftr}rrrU�dumps�
IndexError�	Exception�getattrr��EPIPErr)r~rrA�	writelock�reader_close�writer_close�ignore_epipe�onerror�	queue_sem�nacquire�nrelease�nwait�bpopleft�sentinel�wacquire�wreleaserN�
er)r)r*rr�sP



































zQueue._feedcCsd
dl}|�
�
dS)Nr)�	traceback�	print_exc)r�rNr�r)r)r*rs
s
zQueue._on_queue_feeder_error)
r)
F)TN)TN)�__name__�
__module__�__qualname__r+r/r2r$r#rQrYr\r^r`rarcrdrerhrJ�staticmethodrvryrrrsr)r)r)r*r
#s0



!

	



>
r
c@s@eZ
dZddd�
Zdd�Zdd�Zdd
d�
Zdd
�Zdd�Zd	S)rrc
Cs*tj
||
|d
�
|�d�
|_|��|_dS)N)
r(r)r
r+�	Semaphore�_unfinished_tasksr8�_condr%r)r)r*r+(
s


zJoinableQueue.__init__c

Cst�
|�
|j|jfSr,)r
r/r�r�r.r)r)r*r/-
s
zJoinableQueue.__getstate__cCs,t�
||
dd
��
|
d
d�\|_|_dS)N���)r
r2r�r�r0r)r)r*r20
s

zJoinableQueue.__setstate__TNc	Cs�|jrt
d
|�d��
�
|j�||�s(t�
|j�h
|j�B
|jdurJ|��
|j	�
|
�

|j��
|j�
�
Wd�
n1s~0


Y
Wd�
n1s�0


Y
dSrG)r?rHr!rIrr5r�r<rJr;rKr�rRrLrMr)r)r*rQ4
s










zJoinableQueue.putc

CsT|j�:
|j
�d
�
std�
�
|j
j��r2|j��
Wd�
n1sF0


Y
dS)NFz!task_done() called too many times)r�r�rIrHrZr_�
notify_allr.r)r)r*�	task_doneA
s





zJoinableQueue.task_donec

Cs@|j�&
|j
j��s|j��
Wd�
n1s20


Y
dSr,)r�r�rZr_r�r.r)r)r*rzH
s


zJoinableQueue.join)
r)TN)	r�r�r�r+r/r2rQr�rzr)r)r)r*r&
s


rc@sNeZ
dZd
d�Zdd�Zdd�Zdd�Zd	d
�Zdd�Zd
d�Z	e
ej�
Z
dS)rc

CsHtj
d
d�
\|_|_|
��|_|jj|_tj	dkr:d|_
n
|
��|_
dS)NFrr)rrrrrrrErFrrr)r&r(r)r)r*r+S
s







zSimpleQueue.__init__c

Cs|j�
�
|j�
�
dSr,)rrdrr.r)r)r*rd\
s


zSimpleQueue.closec

Cs
|��Sr,r]r.r)r)r*r^`
s
zSimpleQueue.emptyc

Cst�
|�

|j|j|j|jfSr,)r	r-rrrrr.r)r)r*r/c
s


zSimpleQueue.__getstate__cCs"|
\|_|_
|_|_|jj|_dSr,)rrrrrErFr0r)r)r*r2g
s

zSimpleQueue.__setstate__c
Cs:|j�
|j
��}
Wd�
n1s&0


Y
t�|
�
Sr,)rrrCrUrV)r&rWr)r)r*rYk
s

(zSimpleQueue.getcCsXt�
|
�
}
|jdur"|j�|
�

n2|j�
|j�|
�

Wd�
n1sJ0


Y
dSr,)rUr�rrrArbr)r)r*rQq
s




zSimpleQueue.putN)r�r�r�r+rdr^r/r2rYrQ�classmethod�types�GenericAlias�__class_getitem__r)r)r)r*rQ
s	
r)�__all__rrr7r9rSr�rwr��queuerr�_multiprocessing�rr	�	reduction�ForkingPicklerrU�utilr
rrr
r�objectr
r}rrr)r)r)r*�<module>
s&








z
+