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 ]

U

e5dZ-�@s,
dd
ddddgZddl
Z
ddlZddlZddlZddlZdd	lmZ
dd
lmZ
ddlm	Z	
zddlm
Z
mZ
Wnek
r�


ed
�
�
YnXe
ed�
�
\ZZej
jZGdd�de�Z
Gdd�de
�ZGdd�de�ZGdd�de
�ZGdd
�d
e
�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�|dkrtj
��}|��}tjd
kp*|dk}td�
D]>}z t�|
|||�	�|�}|_
Wntk
rl


Yq4X
q|q4td�
�
t�
d|j�

|��
tjd
kr�dd�}	t�||	�
|j
jdk	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�3/usr/lib64/python3.8/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__2s8









�






�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
Cs8z|j�
�}
Wntk
r&


d
}
YnXd|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
c@seZ
dZddd�
Zdd�ZdS)rrc
Cstj
|t|
|
|d
�
dSrD�rr-rFrHrrrr-�s
zBoundedSemaphore.__init__c
Cs>z|j�
�}
Wntk
r&


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






�zBoundedSemaphore.__repr__N)
r�r?r@rAr-rOrrrrr�s
c@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	k
r~


d}
YnXd	|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
�sc@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	k
r�


d\}
}YnXd	|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�sc@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
CsJz|jj
��|jj
��}
Wntk
r4


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




�


zCondition.__repr__c	Csj|j�
�
|jj��}t|�
D]}|j�
�
qz|j�d
|
�W�S|j�
�
t|�
D]}|j��
qTXdS)NT)	rcr0rbrr\rrdr/re)r&�timeoutr`r+rrr�wait�s




zCondition.waitrcCst|j�
d
�
r|j�
d
�
}qd}||
krF|j�
d
�
rF|j��
|d7}q|rpt|�
D]}|j�
�
qR|j�
d
�
rpqbdS)NFrr)rdr/rcrer0r)r&�
n�resZsleepersr+rrr�notify
s









zCondition.notifyc

Cs|jt
jd
�

dS)N)
ri)rkr�maxsizer1rrr�
notify_all(
s
zCondition.notify_allcCsd|
�}|r|S|dk	r$t�
�|}nd}d}|s`|dk	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


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

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

zEvent.__init__c

	CsD|j�4
|j
�d
�
r,|j
��
W5QR�dSW5QR�d
SQRXdS�NFT)rrrsr/r0r1rrr�is_setG
s






zEvent.is_setc

	Cs6|j�&
|j
�d
�

|j
��
|j��
W5QRXdS�NF)rrrsr/r0rmr1rrr�setN
s




z	Event.setc

	Cs"|j�
|j
�d
�

W5QRXdSrv)rrrsr/r1rrr�clearT
s

zEvent.clearNc	Csh|j�X
|j
�d
�
r |j
��
n|j�|
�

|j
�d
�
rP|j
��
W5QR�dSW5QR�d
SQRXdSrt)rrrsr/r0rh)r&rgrrrrhX
s






z
Event.wait)
N)r?r@rAr-rurwrxrhrrrrrA
s
c@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>s8�








	
Mo'