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 ]

B

� fA-�@s,
dd
ddddgZddl
Z
ddlZddlZddlZddlZdd	lmZ
dd
lmZ
ddlm	Z	
ydd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}xPtd�
D]<}y t�|
|||�	�|�}|_
Wntk
rn


Yq6XPq6Wtd�
�
t�
d|j�

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

|
|j
j�

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

Ss|j�
�
dS)
N)�_semlock�_after_fork)
�obj�r�@/opt/alt/python37/lib64/python3.7/multiprocessing/synchronize.pyrGs
z%SemLock.__init__.<locals>._after_forkr)
�registerr)
Zexitpriority)r	Z_default_contextZget_contextZget_start_method�sys�platform�range�_multiprocessingr�
_make_namer�FileExistsErrorr�debug�handle�
_make_methodsZregister_after_fork�name�semaphore_trackerrZFinalize�_cleanup)�self�kind�value�maxvalue�ctxr!Z
unlink_now�
i�slrrrrr�__init__2s.

















zSemLock.__init__c
Cs d
dlm
}

t|�

|
|�

dS)Nr)
�
unregister)r"r,r
)r!r,rrrr#Ts

zSemLock._cleanupc

Cs|jj
|_
|jj|_dS)
N)r�acquire�release)
r$rrrr Zs


zSemLock._make_methodsc

Cs
|j�
�S)
N)r�	__enter__)
r$rrrr/^s
zSemLock.__enter__c
Gs|jj
|
�S)
N)r�__exit__)r$�argsrrrr0as
zSemLock.__exit__c
CsDt�
|�

|j}
tjd
kr,t���|
j�
}n|
j}||
j|
j	|
j
fS)Nr)r	�assert_spawningrrrZget_spawning_popenZduplicate_for_childrr%r'r!)r$r*�
hrrr�__getstate__ds






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

|��
dS)Nz recreated blocker with handle %rr)rrZ_rebuildrrrr )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_RandomNameSequencer9r+�staticmethodr#r r/r0r4r6rrrrrr.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�
�S)
N)r�
_get_value)
r$rrr�	get_value�s
zSemaphore.get_valuec
Cs8y|j�
�}
Wntk
r&


d
}
YnXd|jj|
fS)N�unknownz<%s(value=%s)>)rrA�	Exception�	__class__r:)r$r&rrr�__repr__�s






zSemaphore.__repr__N)
r)r:r;r<r+rBrFrrrrr{s
c@seZ
dZddd�
Zdd�ZdS)rrc
Cstj
|t|
|
|d
�
dS)N)
r()rr+r?)r$r&r(rrrr+�s
zBoundedSemaphore.__init__c
Cs>y|j�
�}
Wntk
r&


d
}
YnXd|jj|
|jjfS)NrCz<%s(value=%s, maxvalue=%s)>)rrArDrEr:r')r$r&rrrrF�s






zBoundedSemaphore.__repr__N)
r)r:r;r<r+rFrrrrr�s
c@seZ
dZd
d�Zdd�ZdS)r
c

Cstj
|td
d
|
d�
dS)Nr)
r()rr+r?)r$r(rrrr+�s
z
Lock.__init__c
Cs�yf|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�SomeOtherProcessrCz<%s(owner=%s)>)r�_is_miner
r7r!�	threading�current_threadrA�_countrDrEr:)r$r!rrrrF�s














z
Lock.__repr__N)r:r;r<r+rFrrrrr
�sc@seZ
dZd
d�Zdd�ZdS)rc

Cstj
|td
d
|
d�
dS)Nr)
r()rr+�RECURSIVE_MUTEX)r$r(rrrr+�s
zRLock.__init__c
Cs�y||j�
�rBt��j}
t��jd
kr6|
dt��j7}
|j��}n8|j��dkrZd\}
}n |j��dkrrd\}
}nd\}
}Wnt	k
r�


d\}
}YnXd	|j
j|
|fS)
NrGrHr)rIrr)rJ�nonzero)rKrQ)rCrCz<%s(%s, %s)>)rrLr
r7r!rMrNrOrArDrEr:)r$r!�countrrrrF�s
















zRLock.__repr__N)r:r;r<r+rFrrrrr�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|jfS)
N)r	r2rSrTrUrV)
r$rrrr4�s



zCondition.__getstate__cCs |
\|_|_
|_|_|��
dS)
N)rSrTrUrVr )r$r5rrrr6�s
zCondition.__setstate__c

Cs
|j�
�S)
N)rSr/)
r$rrrr/�s
zCondition.__enter__c
Gs|jj
|
�S)
N)rSr0)r$r1rrrr0�s
zCondition.__exit__c

Cs|jj
|_
|jj|_dS)
N)rSr-r.)
r$rrrr �s


zCondition._make_methodsc
CsJy|jj
��|jj
��}
Wntk
r4


d
}
YnXd|jj|j|
fS)NrCz<%s(%s, %s)>)rTrrArUrDrEr:rS)r$Znum_waitersrrrrF�s







zCondition.__repr__c	Csn|j�
�
|jj��}xt|�
D]}|j�
�
q Wz|j�d
|
�S|j�
�
xt|�
D]}|j��
qVWXdS)NT)	rTr.rSrrOrrVr-rU)r$�timeoutrRr)rrr�wait�s




zCondition.waitrcCs�x|j�
d
�
r|j�
d
�
}qWd}x*||
krL|j�
d
�
rL|j��
|d7}q$W|r�xt|�
D]}|j�
�
q\Wx|j�
d
�
r~qpWdS)NFrr)rUr-rTrVr.r)r$�
nZresZsleepersr)rrr�notify
s








zCondition.notifyc

Cs|jt
jd
�

dS)N)
rZ)r[r�maxsize)
r$rrr�
notify_all(
s
zCondition.notify_allcCsh|
�}|r|S|dk	r$t�
�|}nd}d}x6|sb|dk	rP|t�
�}|d
k
rPP|�|�

|
�}q.W|S)Nr)�timeZ	monotonicrY)r$Z	predicaterX�resultZendtimeZwaittimerrr�wait_for+
s















zCondition.wait_for)
N)
N)
r)
N)r:r;r<r+r4r6r/r0r rFrYr[r]r`rrrrr�s


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

Cs |
�|
�
��
|_|
�d
�
|_dS)Nr)rr
�_condr�_flag)r$r(rrrr+C
s

zEvent.__init__c

	Cs0|j� 
|j
�d
�
r"|j
��
dSd
SQRXdS)NFT)rarbr-r.)
r$rrr�is_setG
s






zEvent.is_setc

	Cs6|j�&
|j
�d
�

|j
��
|j��
WdQRXdS)NF)rarbr-r.r])
r$rrr�setN
s




z	Event.setc

	Cs"|j�
|j
�d
�

WdQRXdS)NF)rarbr-)
r$rrr�clearT
s

zEvent.clearNc	CsT|j�D
|j
�d
�
r |j
��
n|j�|
�

|j
�d
�
rF|j
��
dSd
SQRXdS)NFT)rarbr-r.rY)r$rXrrrrYX
s






z
Event.wait)
N)r:r;r<r+rcrdrerYrrrrrA
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�heaprgZcalcsizerr6�_staterO)	r$Zparties�actionrXr(rhrg�wrapperZcondrrrr+j
s






zBarrier.__init__cCs.|
\|_|_
|_|_|_|j���d
�
|_dS)Nr))�_parties�_action�_timeoutra�_wrapperZcreate_memoryview�cast�_array)r$r5rrrr6s
s
zBarrier.__setstate__c

Cs|j|j
|j|j|jfS)
N)rmrnrorarp)
r$rrrr4x
s

zBarrier.__getstate__c

Cs
|jd
S)Nr)
rr)
r$rrrrj|
szBarrier._statecCs|
|jd
<dS)Nr)
rr)r$r&rrrrj�
sc

Cs
|jd
S)Nr)
rr)
r$rrrrO�
szBarrier._countcCs|
|jd
<dS)Nr)
rr)r$r&rrrrO�
s)NN)
r:r;r<r+r6r4�propertyrj�setterrOrrrrrfh
s
	rf)�__all__rMrr=rr^�r	r
rrr
�ImportError�listrrPr?r@�objectrrr
rrrrfrrrr�<module>s.









Mo'