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 ]

3

� f*�@s�dd
dgZddl
Z
ddlZddlZddlZddlZddlZddlZddlm	Z	m
Z

ddlZddlm
Z

ddlmZ
ejjZdd	lmZmZmZmZmZ
Gd
d�de�Ze�ZGdd�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)dd
�
Zd*dd�
Zdd�Z	dd�Z
dd�Zdd�Zdd�Z
dd�Zdd�Zdd�Zd d!�Zed"d#��
Zed$d%��
Zed&d'��
ZdS)+r
rc
Cs�|
d
k
rddlm
}

|
|_tjdd�
\|_|_|j�|_t	j
�|_tj
dkrTd|_n
|j�|_|j|
�
|_d|_|j�
tj
dkr�t|tj�
dS)Nrr)
�
SEM_VALUE_MAXF)
�duplex�win32)Zsynchronizer�_maxsizer�Pipe�_reader�_writer�Lock�_rlock�os�getpid�_opid�sys�platform�_wlockZBoundedSemaphore�_sem�
_ignore_epipe�_after_forkr
r
)�self�maxsize�ctx�r$�;/opt/alt/python36/lib64/python3.6/multiprocessing/queues.py�__init__$s













zQueue.__init__c

Cs.tj
|�

|j|j|j|j|j|j|j|j	fS)
N)
r	�assert_spawningrrrrrrrr)
r!r$r$r%�__getstate__9s



zQueue.__getstate__c	Cs0|
\|_|_
|_|_|_|_|_|_|j�
dS)
N)	rrrrrrrrr )r!�stater$r$r%�__setstate__>s$
zQueue.__setstate__c

Csbtd
�

t
jt
j��
|_tj�|_d|_d|_	d|_
d|_d|_|j
j|_|jj|_|jj|_dS)NzQueue._after_fork()F)r
�	threading�	Conditionr�	_notempty�collections�deque�_buffer�_thread�_jointhread�_joincancelled�_closed�_closer�
send_bytes�_send_bytesr�
recv_bytes�_recv_bytes�poll�_poll)
r!r$r$r%r Cs













zQueue._after_forkTNc	CsP|jj
||�st�
|j�.
|jdkr,|j�
|jj|
�

|jj�
WdQRXdS)
N)	r�acquirerr-r1�
_start_threadr0�append�notify)r!�obj�block�timeoutr$r$r%�putPs





z	Queue.putc
Cs�|
r2|dkr2|j�
|j
�}WdQRX|jj�
nr|
rBtj�|}|jj|
|�sTt�
zB|
rv|tj�}|j|�
s�t�
n|j�s�t�
|j
�}|jj�
Wd|jj�
Xt	j
|�
S)
N)rr9r�release�timeZ	monotonicr<rr;�_ForkingPickler�loads)r!rArB�resZdeadliner$r$r%�get[s&
















z	Queue.getc

Cs|j|j
jj�S)
N)rr�_semlockZ
_get_value)
r!r$r$r%�qsizesszQueue.qsizec


Cs
|j�S)
N)
r;)
r!r$r$r%�emptyws
zQueue.emptyc


Cs|jj
j�S)
N)rrJ�_is_zero)
r!r$r$r%�fullzs
z
Queue.fullc

Cs
|jd
�
S)NF)
rI)
r!r$r$r%�
get_nowait}s
zQueue.get_nowaitcCs|j|
d
�S)NF)
rC)r!r@r$r$r%�
put_nowait�s
zQueue.put_nowaitc
Cs2d
|_z|j
j�
Wd|j}
|
r,d|_|
�
XdS)NT)r4r�closer5)r!rQr$r$r%rQ�s





zQueue.closec

Cstd
�

|j
r|j
�
dS)NzQueue.join_thread())r
r2)
r!r$r$r%�join_thread�s

zQueue.join_threadc

Cs6td
�

d|_
y|jj�
Wntk
r0


YnXdS)NzQueue.cancel_join_thread()T)r
r3r2Zcancel�AttributeError)
r!r$r$r%�cancel_join_thread�s





zQueue.cancel_join_threadc

Cs�td
�

|j
j�
tjtj|j
|j|j|j	|j
j|jfdd�|_
d|j
_td�

|j
j�
td�

|js�t|j
tjtj|j
�
g
d
d�|_t|tj|j
|jgd	d�|_dS)NzQueue._start_thread()ZQueueFeederThread)�target�args�nameTzdoing self._thread.start()z... done self._thread.start()�)
Zexitpriority�
���)r
r0�clearr+ZThreadr
�_feedr-r7rrrQrr1Zdaemon�startr3r�_finalize_join�weakref�refr2�_finalize_closer5)
r!r$r$r%r=�s(



















zQueue._start_threadc
Cs4td
�

|�}
|
dk	r(|
j
�
td�

ntd�

dS)Nzjoining queue threadz... queue thread joinedz... queue thread already dead)r
�join)ZtwrZthreadr$r$r%r^�s




zQueue._finalize_joinc	Cs.td
�

|
�
|j
t�

|
j�
WdQRXdS)Nztelling queue thread to quit)r
r>�	_sentinelr?)�buffer�notemptyr$r$r%ra�s



zQueue._finalize_closecCsP
td
�

|
j
}|
j}|
j}|j}	t}
tjdkr<|j
}|j}nd}�
xy�|�
z|sX|�
Wd|�
Xybx\|	�}
|
|
kr�td�

|�
dStj	|
�
}
|dkr�||
�

qh|�
z||
�

Wd|�
XqhWWnt
k
r�


YnXWqDtk
�
rF
}
zJ|�
rt|dd�t
jk�
rdSt��
r&td|�
dSddl}|j�
WYdd}~XqDXqDWdS)Nz$starting thread to feed data to piperz%feeder thread got sentinel -- exiting�errnorzerror in queue thread: %s)r
r<rD�wait�popleftrcrrrF�dumps�
IndexError�	Exception�getattrrfZEPIPErr�	traceback�	print_exc)rdrer6Z	writelockrQZignore_epipeZnacquireZnreleaseZnwaitZbpopleft�sentinelZwacquireZwreleaser@�
ermr$r$r%r\�sR





































zQueue._feed)
r)TN)TN)�__name__�
__module__�__qualname__r&r(r*r rCrIrKrLrNrOrPrQrRrTr=�staticmethodr^rar\r$r$r$r%r
"s$




c@s@eZ
dZddd�
Zdd�Zdd�Zdd
d�
Zdd
�Zdd�Zd	S)rrc
Cs*tj
||
|d
�
|jd�
|_|j�|_dS)N)
r#r)r
r&Z	Semaphore�_unfinished_tasksr,�_cond)r!r"r#r$r$r%r&
s


zJoinableQueue.__init__c

Cstj
|�
|j|jfS)
N)r
r(rvru)
r!r$r$r%r(
s
zJoinableQueue.__getstate__cCs,tj
||
dd��
|
dd�\|_|_dS)N����rx)r
r*rvru)r!r)r$r$r%r*
s

zJoinableQueue.__setstate__TNcCsl|jj
||�st�
|j�J
|j�8
|jdkr4|j�
|jj|
�

|j	j
�
|jj�
WdQRXWdQRXdS)
N)rr<rr-rvr1r=r0r>rurDr?)r!r@rArBr$r$r%rC
s







zJoinableQueue.putc

	Cs@|j�0
|j
jd
�
std�
�
|j
jj�r2|jj�
WdQRXdS)NFz!task_done() called too many times)rvrur<�
ValueErrorrJrMZ
notify_all)
r!r$r$r%�	task_done'
s





zJoinableQueue.task_donec

	Cs,|j�
|j
jj�s|jj�
WdQRXdS)
N)rvrurJrMrg)
r!r$r$r%rb.
s


zJoinableQueue.join)
r)TN)	rqrrrsr&r(r*rCrzrbr$r$r$r%r

s

c@s<eZ
dZd
d�Zdd�Zdd�Zdd�Zd	d
�Zdd�Zd
S)rc

CsHtj
d
d�
\|_|_|
j�|_|jj|_tj	dkr:d|_
n
|
j�|_
dS)NF)
rr)rrrrrrr:r;rrr)r!r#r$r$r%r&9
s







zSimpleQueue.__init__c


Cs
|j�S)
N)
r;)
r!r$r$r%rLB
s
zSimpleQueue.emptyc

Cstj
|�

|j|j|j|jfS)
N)r	r'rrrr)
r!r$r$r%r(E
s


zSimpleQueue.__getstate__cCs"|
\|_|_
|_|_|jj|_dS)
N)rrrrr:r;)r!r)r$r$r%r*I
s

zSimpleQueue.__setstate__c
	Cs&|j�
|j
j�}
WdQRXtj|
�
S)
N)rrr8rFrG)r!rHr$r$r%rIM
s

zSimpleQueue.getc	CsDtj
|
�
}
|jdkr"|jj|
�

n|j�
|jj|
�

WdQRXdS)
N)rFrirrr6)r!r@r$r$r%rCS
s




zSimpleQueue.putN)	rqrrrsr&rLr(r*rIrCr$r$r$r%r7
s	)�__all__rrr+r.rEr_rfZqueuerrZ_multiprocessing�rr	Z	reductionZForkingPicklerrF�utilr
rrr
r�objectr
rcrrr$r$r$r%�<module>
s$








b
*