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

�=?hZ-�@s
gd�
Zd
dl
Z
d
dlZd
dlZd
dlZd
dlZddlmZ
ddlmZ
ddlm	Z	
z
d
dlm
Z
mZ
Wney?


ed�
�
we
ed	�
�
\ZZej
jZGd
d�de�Z
Gdd
�d
e
�ZGdd�de�ZGdd�de
�ZGdd�de
�ZGdd�de�ZGdd�de�ZGdd�de
j�ZdS))�Lock�RLock�	Semaphore�BoundedSemaphore�	Condition�Event�N�
)
�context)
�process)
�util)�SemLock�
sem_unlinkz�This platform lacks a functioning sem_open implementation, therefore, the required synchronization primitives needed will not function, see issue 3770.�c@s\eZ
dZe��Zd
d�Zedd��
Zdd�Z	dd�Z
d	d
�Zdd�Zd
d�Z
edd��
ZdS)rc
	Cs�|dur	tj
��}|��}tjd
kp|dk}td�
D]}zt�|
|||�	�|�}|_
Wn	ty5


Yqw
ntd�
�
t�
d|j�

|��
tjd
krWdd�}	t�||	�
|j
jdu
rydd	lm}

|
|j
jd
�
tj|tj|j
jf
dd�
dSdS)
N�win32�fork�dzcannot find name for semaphorezcreated semlock with handle %sc

Ss|j�
�
dS�
N)�_semlock�_after_fork)
�obj�r�B/opt/alt/python310/lib64/python3.10/multiprocessing/synchronize.pyrGs
z%SemLock.__init__.<locals>._after_forkr)
�register�	semaphorer)
Zexitpriority)r	Z_default_contextZget_contextZget_start_method�sys�platform�range�_multiprocessingr�
_make_namer�FileExistsErrorr�debug�handle�
_make_methodsZregister_after_fork�name�resource_trackerrZFinalize�_cleanup)�self�kind�value�maxvalue�ctxr#Z
unlink_now�
i�slrrrrr�__init__2s6









�
�






��zSemLock.__init__c
Cs"d
dlm
}

t|�

|
|d�
dS)Nr)
�
unregisterr)r$r.r
)r#r.rrrr%Ts

zSemLock._cleanupc

C�|jj
|_
|jj|_dSr)r�acquire�release�
r&rrrr"Z�


zSemLock._make_methodsc

C�
|j�
�Sr)r�	__enter__r2rrrr5^�

zSemLock.__enter__c
G�|jj
|
�Sr)r�__exit__�r&�argsrrrr8a�
zSemLock.__exit__c
CsDt�
|�

|j}
tjd
krt���|
j�
}n|
j}||
j|
j	|
j
fS)Nr)r	�assert_spawningrrrZget_spawning_popenZduplicate_for_childr!r'r)r#)r&r,�
hrrr�__getstate__ds






zSemLock.__getstate__cCs,tj
j|
�|_t�d
|
d�

|��
dS)Nz recreated blocker with handle %rr)rrZ_rebuildrrr r"�r&�staterrr�__setstate__ms


zSemLock.__setstate__cCsd
t�
�jdttj�
fS)Nz%s-%sZ	semprefix)r
�current_processZ_config�nextr�_randrrrrrrs
�zSemLock._make_nameN)�__name__�
__module__�__qualname__�tempfileZ_RandomNameSequencerDr-�staticmethodr%r"r5r8r>rArrrrrr.s"

	
rc@s&eZ
dZd	dd�
Zdd�Zdd�ZdS)
rrc
Cstj
|t|
t|d
�
dS�N�
r*)rr-�	SEMAPHORE�
SEM_VALUE_MAX�r&r(r*rrrr-}�
zSemaphore.__init__c

Cr4r)r�
_get_valuer2rrr�	get_value�r6zSemaphore.get_valuec
Cs6z|j�
�}
Wnty


d
}
Yn
wd|jj|
fS)N�unknownz<%s(value=%s)>)rrP�	Exception�	__class__rE�r&r(rrr�__repr__�s



�zSemaphore.__repr__N�
r)rErFrGr-rQrVrrrrr{s
rc@seZ
dZddd�
Zdd�ZdS)rrc
Cstj
|t|
|
|d
�
dSrJ�rr-rLrNrrrr-�rOzBoundedSemaphore.__init__c
Cs<z|j�
�}
Wnty


d
}
Yn
wd|jj|
|jjfS)NrRz<%s(value=%s, maxvalue=%s)>)rrPrSrTrEr)rUrrrrV�s



�
�zBoundedSemaphore.__repr__NrW�rErFrGr-rVrrrrr�s
rc@�eZ
dZd
d�Zdd�ZdS)r
c

C�tj
|td
d
|
d�
dS�NrrKrX�r&r*rrrr-�rOz
Lock.__init__c
Cs�z3|j�
�rt��j}
t��jd
kr|
dt��j7}
n|j��dkr&d}
n|j��dkr0d}
nd}
Wnt	y>


d}
Yn
wd	|j
j|
fS)
N�
MainThread�
|r�Noner�SomeOtherThread�SomeOtherProcessrRz<%s(owner=%s)>)r�_is_miner
rBr#�	threading�current_threadrP�_countrSrTrE)r&r#rrrrV�s 






�



�

�z
Lock.__repr__NrYrrrrr
��r
c@rZ)rc

Cr[r\)rr-�RECURSIVE_MUTEXr]rrrr-�rOzRLock.__init__c
Cs�z>|j�
�r!t��j}
t��jd
kr|
dt��j7}
|j��}n|j��dkr-d\}
}n|j��dkr9d\}
}nd\}
}Wn
t	yK


d\}
}Yn
wd	|j
j|
|fS)
Nr^r_r)r`rr)ra�nonzero)rbri)rRrR�<%s(%s, %s)>)rrcr
rBr#rdrerfrPrSrTrE)r&r#�countrrrrV�s 













�

�zRLock.__repr__NrYrrrrr�rgrc@sleZ
dZddd�
Zdd�Zdd�Zdd	�Zd
d�Zdd
�Zdd�Z	ddd�
Z
ddd�
Zdd�Zddd�
Z
d
S)rNc
Cs>|
p|��|_
|�d
�
|_|�d
�
|_|�d
�
|_|��
dS�Nr)r�_lockr�_sleeping_count�_woken_count�_wait_semaphorer")r&�lockr*rrrr-�s





zCondition.__init__c

Cst�
|�

|j|j|j|jfSr)r	r<rmrnrorpr2rrrr>�s



�zCondition.__getstate__cCs |
\|_|_
|_|_|��
dSr)rmrnrorpr"r?rrrrA�s
�

zCondition.__setstate__c

Cr4r)rmr5r2rrrr5�r6zCondition.__enter__c
Gr7r)rmr8r9rrrr8�r;zCondition.__exit__c

Cr/r)rmr0r1r2rrrr"�r3zCondition._make_methodsc
CsHz|jj
��|jj
��}
Wnty


d
}
Yn
wd|jj|j|
fS)NrRrj)rnrrProrSrTrErm)r&Znum_waitersrrrrV�s




�
�zCondition.__repr__c	Cs�|jj
��s
Jd
�
�
|j��
|jj
��}t|�
D]}|j��
qz|j�d|
�W|j	��
t|�
D]}|j��
q2S|j	��
t|�
D]}|j��
qDw)Nz,must acquire() condition before using wait()T)
rmrrcrnr1rfrrpr0ro)r&�timeoutrkr+rrr�wait�s"

�




�
�
�zCondition.waitrcCs�|jj
��s
Jd
�
�
|j�d�
rJd�
�
|j�d�
r,|j�d�
}|s&Jd�
�
|j�d�
sd}||
krK|j�d�
rK|j��
|d7}||
krK|j�d�
s8|rht|�
D]}|j��
qQ|j�d�
rj	|j�d�
s_dSdSdS)Nzlock is not ownedFz<notify: Should not have been able to acquire _wait_semaphorez>notify: Bug in sleeping_count.acquire- res should not be Falserr)	rmrrcrpr0rornr1r)r&�
n�resZsleepersr+rrr�notify
s.


�
�

�



�


��zCondition.notifyc

Cs|jt
jd
�

dS)N)
rt)rvr�maxsizer2rrr�
notify_all(
s
zCondition.notify_allcCsj|
�}|r|S|du
rt�
�|}nd}d}|s3|du
r)|t�
�}|d
k
r)	|S|�|�

|
�}|r|Srl)�time�	monotonicrs)r&Z	predicaterr�resultZendtimeZwaittimerrr�wait_for+
s"











�
�zCondition.wait_forrrW)rErFrGr-r>rAr5r8r"rVrsrvrxr|rrrrr�s


rc@s6eZ
dZd
d�Zdd�Zdd�Zdd�Zdd
d�
Zd	S)
rc

Cs |
�|
�
��
|_|
�d
�
|_dSrl)rr
�_condr�_flagr]rrrr-C
s

zEvent.__init__c

CsV|j�
|j
�d
�
r|j
��
	Wd�
dS	Wd�
d
S1s$w



Y
dS�NFT)r}r~r0r1r2rrr�is_setG
s




�$�zEvent.is_setc

CsL|j�
|j
�d
�

|j
��
|j��
Wd�
dS1sw



Y
dS�NF)r}r~r0r1rxr2rrr�setN
s





"�z	Event.setc

Cs8|j�
|j
�d
�

Wd�
dS1sw



Y
dSr�)r}r~r0r2rrr�clearT
s

"�zEvent.clearNcCsz|j�0
|j
�d
�
r|j
��
n|j�|
�

|j
�d
�
r*|j
��
	Wd�
dS	Wd�
d
S1s6w



Y
dSr)r}r~r0r1rs)r&rrrrrrsX
s





�	$�z
Event.waitr)rErFrGr-r�r�r�rsrrrrrA
src@sZeZ
dZddd�
Zdd�Zdd�Zedd	��
Zejd
d	��
Zedd��
Z	e	jd
d��
Z	d
S)�BarrierNc
	CsRd
dl}ddl
m}
||�d�
d�
}|��}|�|
||||f�

d
|_d
|_dS)Nrr)
�
BufferWrapperr+r)�structZheapr�ZcalcsizerrA�_staterf)	r&Zparties�actionrrr*r�r��wrapperZcondrrrr-j
s







zBarrier.__init__cCs.|
\|_|_
|_|_|_|j���d
�
|_dS)Nr+)�_parties�_action�_timeoutr}�_wrapperZcreate_memoryview�cast�_arrayr?rrrrAs
s�

zBarrier.__setstate__c

Cs|j|j
|j|j|jfSr)r�r�r�r}r�r2rrrr>x
s

�zBarrier.__getstate__c

C�
|jd
Srl�
r�r2rrrr�|
�
zBarrier._statecC�|
|jd
<dSrlr�rUrrrr��
�c

Cr��Nrr�r2rrrrf�
r�zBarrier._countcCr�r�r�rUrrrrf�
r�)NN)
rErFrGr-rAr>�propertyr��setterrfrrrrr�h
s
	






r�)�__all__rdrrHrry�r	r
rrr
�ImportError�listrrhrLrM�objectrrr
rrrr�rrrr�<module>
s0	








�

Mo'