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 ]

o

�=?h�.�@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�
Zd/dd�
Z	dd�Z
dd�Zdd�Zdd�Z
dd�Zdd�Zdd �Zd!d"�Zd#d$�Zed%d&��
Zed'd(��
Zed)d*��
Zed+d,��
ZdS)0r
rc
Cs�|
d
k
r
ddlm
}

|
|_tjdd�
\|_|_|��|_t	�
�|_tj
dkr*d|_n|��|_|�|
�
|_d|_|��
tj
dkrIt|tj�
dSdS)Nrr)
�
SEM_VALUE_MAXF�
Zduplex�win32)Zsynchronizer�_maxsizer�Pipe�_reader�_writer�Lock�_rlock�os�getpid�_opid�sys�platform�_wlockZBoundedSemaphore�_sem�
_ignore_epipe�_resetr
r
�_after_fork��self�maxsize�ctx�r&�=/opt/alt/python310/lib64/python3.10/multiprocessing/queues.py�__init__%s














�zQueue.__init__c

Cs.t�
|�

|j|j|j|j|j|j|j|j	fS�
N)
r	�assert_spawningrrrrrrrr�
r#r&r&r'�__getstate__9s



�zQueue.__getstate__c	Cs0|
\|_|_
|_|_|_|_|_|_|��
dSr))	rrrrrrrrr �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#r0r&r&r'r Gs













zQueue._resetTNcCs||jrt
d
|�d��
�
|j�||�st�
|j�
|jdur!|��
|j�	|
�

|j�
�
Wd�
dS1s7w



Y
dS�NzQueue z
 is closed)r<�
ValueErrorr�acquirerr2r9�
_start_threadr8�append�notify�r#�obj�block�timeoutr&r&r'�putVs








"�z	Queue.putcCs�|jrt
d
|�d��
�
|
r.|dur.|j�
|��}Wd�
n1s#w



Y
|j��
n>|
r6t��|}|j�|
|�s?t	�
z&|
rP|t��}|�
|�
sOt	�
n|�
�sVt	�
|��}|j��
W|j��
n|j��
wt�|�
SrD)
r<rErrAr�release�time�	monotonicrFrrC�_ForkingPickler�loads)r#rLrM�resZdeadliner&r&r'�getbs.





�








�



z	Queue.getc

Cs|j|j
j��Sr))rr�_semlockZ
_get_valuer+r&r&r'�qsize|szQueue.qsizec

C�
|��Sr)�
rCr+r&r&r'�empty��

zQueue.emptyc

Cs|jj
��Sr))rrV�_is_zeror+r&r&r'�full��
z
Queue.fullc

Cs
|�d
�
Sr1)
rUr+r&r&r'�
get_nowait�r[zQueue.get_nowaitcCs|�|
d
�Sr1)
rN�r#rKr&r&r'�
put_nowait�r^zQueue.put_nowaitc
Cs$d
|_|j
}
|
rd|_
|
�
dSdS)NT)r<r=)r#�closer&r&r'rb�s





�zQueue.closec

Cs2td
�

|j
sJd�|�
�
�
|jr|��
dSdS)NzQueue.join_thread()zQueue {0!r} not closed)r
r<�formatr:r+r&r&r'�join_thread�s




�zQueue.join_threadc

Cs4td
�

d|_
z|j��
WdSty


YdSw)NzQueue.cancel_join_thread()T)r
r;r:Zcancel�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�

|jsKt|jtjt�|j�
g
dd�|_t|tj|j
|jgd	d�|_dS)
NzQueue._start_thread()ZQueueFeederThread)�target�args�nameTzdoing self._thread.start()z... done self._thread.start()���)
Zexitpriority�
)r
r8�clearr4ZThreadr
�_feedr2r?rrrbrr�_on_queue_feeder_errorrr9Zdaemon�startr;r�_finalize_join�weakref�refr:�_finalize_closer=r+r&r&r'rG�s4







��






�



�zQueue._start_threadc
Cs6td
�

|�}
|
du
r|
�
�
td�

dStd�

dS)Nzjoining queue threadz... queue thread joinedz... queue thread already dead)r
�join)Ztwr�threadr&r&r'rp�s



zQueue._finalize_joincCsDtd
�

|
�
|�
t�

|
��
Wd�
dS1sw



Y
dS)Nztelling queue thread to quit)r
rH�	_sentinelrI)�buffer�notemptyr&r&r'rs�s





"�zQueue._finalize_closec	
Csf
td
�

|
j
}	|
j}
|
j}|j}t}
tjdkr|j
}|j}nd}	zT|	�
z
|s+|�
W|
�
n|
�
wz6	|�}||
urKtd�

|�
|�
WWdSt�	|�
}|durY||�

n|�
z	||�

W|�
n|�
wq6t
ys


Yn
wWn<ty�
}
z0|r�t|dd�t
jkr�WYd}~dSt�r�td|�
WYd}~dS|��
|||�
WYd}~nd}~w
wq!)Nz$starting thread to feed data to piperrz%feeder thread got sentinel -- exiting�errnorzerror in queue thread: %s)r
rFrO�wait�popleftrvrrrR�dumps�
IndexError�	Exception�getattrryZEPIPErr)rwrxr>Z	writelockZreader_closeZwriter_closeZignore_epipe�onerrorZ	queue_semZnacquireZnreleaseZnwaitZbpopleftZsentinelZwacquireZwreleaserK�
er&r&r'rm�sb













�














�
�







���zQueue._feedcCsd
dl}|�
�
dS)z�
        Private API hook called when feeding data in the background thread
        raises an exception.  For overriding by concurrent.futures.
        rN)�	traceback�	print_exc)r�rKr�r&r&r'rn
s
zQueue._on_queue_feeder_error�
r)
F�TN)�__name__�
__module__�__qualname__r(r,r/r!r rNrUrWrZr]r_rarbrdrfrG�staticmethodrprsrmrnr&r&r&r'r
#s2



!

	



>
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(Z	Semaphore�_unfinished_tasksr5�_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
r/r�r�r-r&r&r'r/0
s

zJoinableQueue.__setstate__TNc	Cs�|jrt
d
|�d��
�
|j�||�st�
|j�=
|j�!
|jdur%|��
|j	�
|
�

|j��
|j�
�
Wd�
n1s?w



Y
Wd�
dSWd�
dS1sWw



Y
dSrD)r<rErrFrr2r�r9rGr8rHr�rOrIrJr&r&r'rN4
s










P�zJoinableQueue.putc

Csf|j�&
|j
�d
�
std�
�
|j
j��r!|j��
Wd�
dSWd�
dS1s,w



Y
dS)NFz!task_done() called too many times)r�r�rFrErVr\Z
notify_allr+r&r&r'�	task_doneA
s




�"�zJoinableQueue.task_donec

CsR|j�
|j
j��s|j��
Wd�
dSWd�
dS1s"w



Y
dSr))r�r�rVr\rzr+r&r&r'rtH
s


�
"�zJoinableQueue.joinr�r�)	r�r�r�r(r,r/rNr�rtr&r&r&r'r&
s


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

CsJtj
d
d�
\|_|_|
��|_|jj|_tj	dkrd|_
dS|
��|_
dS)NFrr)rrrrrrrBrCrrr)r#r%r&r&r'r(S
s








zSimpleQueue.__init__c

Cs|j�
�
|j�
�
dSr))rrbrr+r&r&r'rb\
s


zSimpleQueue.closec

CrXr)rYr+r&r&r'rZ`
r[zSimpleQueue.emptyc

Cst�
|�

|j|j|j|jfSr))r	r*rrrrr+r&r&r'r,c
s


zSimpleQueue.__getstate__cCs"|
\|_|_
|_|_|jj|_dSr))rrrrrBrCr-r&r&r'r/g
s

zSimpleQueue.__setstate__c
Cs:|j�

|j
��}
Wd�
n1sw



Y
t�|
�
Sr))rrr@rRrS)r#rTr&r&r'rUk
s

�
zSimpleQueue.getcCs\t�
|
�
}
|jdur|j�|
�

dS|j�
|j�|
�

Wd�
dS1s'w



Y
dSr))rRr|rrr>r`r&r&r'rNq
s



"�zSimpleQueue.putN)r�r�r�r(rbrZr,r/rUrN�classmethod�types�GenericAlias�__class_getitem__r&r&r&r'rQ
s	
r)�__all__rrr4r6rPr�rqry�queuerrZ_multiprocessing�rr	Z	reductionZForkingPicklerrR�utilr
rrr
r�objectr
rvrrr&r&r&r'�<module>
s(	








z
+