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 ]

a

XC?hZ-�@s"
gd�
Zd
dl
Z
d
dlZd
dlZd
dlZd
dlZddlmZ
ddlmZ
ddlm	Z	
zd
dlm
Z
mZ
Wney�


ed�
�
Yn0e
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�|durtj
��}|��}tjd
kp*|dk}td�
D]<}z t�|
|||�	�|�}|_
Wntyj


Yq40
qzq4td�
�
t�
d|j�

|��
tjd
kr�dd�}	t�||	�
|j
jdu
r�dd	lm}

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

Ss|j�
�
dS�
N)�_semlock�_after_fork)
�obj�r�@/opt/alt/python39/lib64/python3.9/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__2s2









�






�zSemLock.__init__c
Cs"d
dlm
}

t|�

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

zSemLock._cleanupc

Cs|jj
|_
|jj|_dSr)r�acquire�release�
r&rrrr"Zs


zSemLock._make_methodsc

Cs
|j�
�Sr)r�	__enter__r1rrrr2^s
zSemLock.__enter__c
Gs|jj
|
�Sr)r�__exit__�r&�argsrrrr3as
zSemLock.__exit__c
CsDt�
|�

|j}
tjd
kr,t���|
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_RandomNameSequencer>r-�staticmethodr%r"r2r3r8r;rrrrrr.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-}s
zSemaphore.__init__c

Cs
|j�
�Sr)r�
_get_valuer1rrr�	get_value�s
zSemaphore.get_valuec
Cs6z|j�
�}
Wnty$


d
}
Yn0d|jj|
fS)N�unknownz<%s(value=%s)>)rrI�	Exception�	__class__r?�r&r(rrr�__repr__�s






zSemaphore.__repr__N)
r)r?r@rAr-rJrOrrrrr{s
rc@seZ
dZddd�
Zdd�ZdS)rrc
Cstj
|t|
|
|d
�
dSrD�rr-rFrHrrrr-�s
zBoundedSemaphore.__init__c
Cs<z|j�
�}
Wnty$


d
}
Yn0d|jj|
|jjfS)NrKz<%s(value=%s, maxvalue=%s)>)rrIrLrMr?r)rNrrrrO�s






�zBoundedSemaphore.__repr__N)
r�r?r@rAr-rOrrrrr�s
rc@seZ
dZd
d�Zdd�ZdS)r
c

Cstj
|td
d
|
d�
dS�NrrErP�r&r*rrrr-�s
z
Lock.__init__c
Cs�zf|j�
�r8t��j}
t��jd
krd|
dt��j7}
n,|j��dkrLd}
n|j��dkr`d}
nd}
Wnt	y|


d}
Yn0d	|j
j|
fS)
N�
MainThread�
|r�Noner�SomeOtherThread�SomeOtherProcessrKz<%s(owner=%s)>)r�_is_miner
r<r#�	threading�current_threadrI�_countrLrMr?)r&r#rrrrO�s














z
Lock.__repr__NrQrrrrr
�sr
c@seZ
dZd
d�Zdd�ZdS)rc

Cstj
|td
d
|
d�
dSrR)rr-�RECURSIVE_MUTEXrSrrrr-�s
zRLock.__init__c
Cs�z||j�
�rBt��j}
t��jd
kr6|
dt��j7}
|j��}n8|j��dkrZd\}
}n |j��dkrrd\}
}nd\}
}Wnt	y�


d\}
}Yn0d	|j
j|
|fS)
NrTrUr)rVrr)rW�nonzero)rXr^)rKrK�<%s(%s, %s)>)rrYr
r<r#rZr[r\rIrLrMr?)r&r#�countrrrrO�s
















zRLock.__repr__NrQrrrrr�src@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	r6rbrcrdrer1rrrr8�s



�zCondition.__getstate__cCs |
\|_|_
|_|_|��
dSr)rbrcrdrer"r9rrrr;�s�


zCondition.__setstate__c

Cs
|j�
�Sr)rbr2r1rrrr2�s
zCondition.__enter__c
Gs|jj
|
�Sr)rbr3r4rrrr3�s
zCondition.__exit__c

Cs|jj
|_
|jj|_dSr)rbr/r0r1rrrr"�s


zCondition._make_methodsc
CsHz|jj
��|jj
��}
Wnty2


d
}
Yn0d|jj|j|
fS)NrKr_)rcrrIrdrLrMr?rb)r&Znum_waitersrrrrO�s




�


zCondition.__repr__c	Cs�|jj
��sJd
�
�
|j��
|jj
��}t|�
D]}|j��
q2zD|j�d|
�W|j	��
t|�
D]}|j��
qdS]}|j��
qvn$|j	��
t|�
D]}|j��
q�0dS)Nz,must acquire() condition before using wait()T)
rbrrYrcr0r\rrer/rd)r&�timeoutr`r+rrr�wait�s&

�




�
�

zCondition.waitrcCs�|jj
��sJd
�
�
|j�d�
r(Jd�
�
|j�d�
rN|j�d�
}|s(Jd�
�
q(d}||
krz|j�d�
rz|j��
|d7}qR|r�t|�
D]}|j��
q�|j�d�
r�q�dS)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)	rbrrYrer/rdrcr0r)r&�
n�resZsleepersr+rrr�notify
s$


�
�









zCondition.notifyc

Cs|jt
jd
�

dS)N)
ri)rkr�maxsizer1rrr�
notify_all(
s
zCondition.notify_allcCsd|
�}|r|S|du
r$t�
�|}nd}d}|s`|du
rN|t�
�}|d
k
rNq`|�|�

|
�}q,|Sra)�time�	monotonicrh)r&Z	predicaterg�resultZendtimeZwaittimerrr�wait_for+
s














zCondition.wait_for)
N)
N)
r)
N)r?r@rAr-r8r;r2r3r"rOrhrkrmrqrrrrr�s


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

Cs |
�|
�
��
|_|
�d
�
|_dSra)rr
�_condr�_flagrSrrrr-C
s

zEvent.__init__c

CsR|j�8
|j
�d
�
r.|j
��
Wd�
dSWd�
d
S1sD0


Y
dS�NFT)rrrsr/r0r1rrr�is_setG
s






zEvent.is_setc

CsJ|j�0
|j
�d
�

|j
��
|j��
Wd�
n1s<0


Y
dS�NF)rrrsr/r0rmr1rrr�setN
s




z	Event.setc

Cs6|j�
|j
�d
�

Wd�
n1s(0


Y
dSrv)rrrsr/r1rrr�clearT
s

zEvent.clearNcCsv|j�\
|j
�d
�
r |j
��
n|j�|
�

|j
�d
�
rR|j
��
Wd�
dSWd�
d
S1sh0


Y
dSrt)rrrsr/r0rh)r&rgrrrrhX
s






z
Event.wait)
N)r?r@rAr-rurwrxrhrrrrrA
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)�struct�heaprzZcalcsizerr;�_stater\)	r&Zparties�actionrgr*r{rz�wrapperZcondrrrr-j
s






zBarrier.__init__cCs.|
\|_|_
|_|_|_|j���d
�
|_dS)Nr+)�_parties�_action�_timeoutrr�_wrapperZcreate_memoryview�cast�_arrayr9rrrr;s
s�

zBarrier.__setstate__c

Cs|j|j
|j|j|jfSr)r�r�r�rrr�r1rrrr8x
s

�zBarrier.__getstate__c

Cs
|jd
Sra�
r�r1rrrr}|
szBarrier._statecCs|
|jd
<dSrar�rNrrrr}�
sc

Cs
|jd
S�Nrr�r1rrrr\�
szBarrier._countcCs|
|jd
<dSr�r�rNrrrr\�
s)NN)
r?r@rAr-r;r8�propertyr}�setterr\rrrrryh
s
	






ry)�__all__rZrrBrrn�r	r
rrr
�ImportError�listrr]rFrG�objectrrr
rrrryrrrr�<module>
s,








	
Mo'