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

��2a/�@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_openz( implementation, therefore, the requiredz+ synchronization primitives needed will notz function, see issue 3770.�c@s\eZ
dZej�Zd
d�Zedd��
Zdd�Z	dd�Z
d	d
�Zdd�Zd
d�Z
edd��
ZdS)rc

Cs�|dkrtj
j�}|j�}tjd
kp*|dk}xPtd�
D]<}y tj|
|||j	�|�}|_
Wntk
rn


Yq6XPq6Wtd�
�
tj
d|j�

|j�
tjd
kr�dd�}	tj||	�
|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|jj
�
dS)
N)�_semlock�_after_fork)
�obj�r�0/opt/alt/python36/lib64/python3.6/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
|jj
�S)
N)r�	__enter__)
r$rrrr/^s
zSemLock.__enter__c
Gs|jj
|
�S)
N)r�__exit__)r$�argsrrrr0as
zSemLock.__exit__c
CsDtj
|�

|j}
tjd
kr,tj�j|
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|
�|_tjd
|
d�

|j�
dS)Nz recreated blocker with handle %rr)rrZ_rebuildrrrr )r$�staterrr�__setstate__ms


zSemLock.__setstate__cCsd
tj
�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
|jj
�S)
N)r�
_get_value)
r$rrr�	get_value�s
zSemaphore.get_valuec
Cs8y|jj
�}
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|jj
�}
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|jj
�r8tj�j}
tj�jd
krd|
dtj�j7}
n,|jj�dkrLd}
n|jj�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||jj
�rBtj�j}
tj�jd
kr6|
dtj�j7}
|jj�}n8|jj�dkrZd\}
}n |jj�dkrrd\}
}nd
\}
}Wnt	k
r�


d\}
}YnXd
|j
j|
|fS)NrGrHrrIrrJ�nonzerorKrCz<%s(%s, %s)>)rIr)rJrQ)rKrQ)rCrC)rrLr
r7r!rMrNrOrArDrEr:)r$r!�countrrrrF�s
















zRLock.__repr__N)r:r;r<r+rFrrrrr�sc@sjeZ
dZddd�
Zdd�Zdd�Zdd	�Zd
d�Zdd
�Zdd�Z	ddd�
Z
dd�Zdd�Zddd�
Z
d
S)rNc
Cs>|
p
|j�|_
|jd
�
|_|jd
�
|_|jd
�
|_|j�
dS)Nr)r�_lockr�_sleeping_count�_woken_count�_wait_semaphorer )r$�lockr(rrrr+�s





zCondition.__init__c

Cstj
|�

|j|j|j|jfS)
N)r	r2rSrTrUrV)
r$rrrr4�s



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


Cs
|jj
�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
j�|jj
j�}
Wntk
r4


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







zCondition.__repr__cCsn|jj
�
|jjj�}xt|�
D]}|jj
�
q Wz|jjd
|
�S|jj
�
xt|�
D]}|jj�
qVWXdS)NT)	rTr.rSrrOrrVr-rU)r$�timeoutrRr)rrr�wait�s




zCondition.waitc
CsNx|jj
d
�
r|jj
d
�
}
qW|jj
d
�
rJ|jj�
|jj
�
|jj
d
�

dS)NF)rUr-rTrVr.)r$�resrrr�notify
s





zCondition.notifyc
Cs|x|jj
d
�
r|jj
d
�
}
qWd}x"|jj
d
�
rD|jj�
|d7}q$W|rxxt|�
D]}|jj
�
qTWx|jj
d
�
rvqhWdS)NFrr)rUr-rTrVr.r)r$rZZsleepersr)rrr�
notify_all
s








zCondition.notify_allcCsh|
�}|r|S|dk	r$tj
�|}nd}d}x6|sb|dk	rP|tj
�}|d
k
rPP|j|�

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















zCondition.wait_for)
N)
N)
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 |
j|
j
��
|_|
jd
�
|_dS)Nr)rr
�_condr�_flag)r$r(rrrr+N
s

zEvent.__init__c

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






zEvent.is_setc

	Cs6|j�&
|j
jd
�

|j
j�
|jj�
WdQRXdS)NF)rarbr-r.r\)
r$rrr�setY
s




z	Event.setc

	Cs"|j�
|j
jd
�

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

zEvent.clearNc	CsT|j�D
|j
jd
�
r |j
j�
n|jj|
�

|j
jd
�
rF|j
j�
dSd
SQRXdS)NFT)rarbr-r.rY)r$rXrrrrYc
s






z
Event.wait)
N)r:r;r<r+rcrdrerYrrrrrL
s
c@sZeZ
dZddd�
Zdd�Zdd�Zedd	��
Zejd
d	��
Zedd��
Z	e	jd
d��
Z	d
S)�BarrierNc
	CsRd
dl}ddl
m}
||jd�
d�
}|j�}|j|
||||f�

d
|_d
|_dS)Nrr)
�
BufferWrapperr)r)�struct�heaprg�calcsizerr6�_staterO)	r$Zparties�actionrXr(rhrg�wrapperZcondrrrr+u
s






zBarrier.__init__cCs.|
\|_|_
|_|_|_|jj�jd
�
|_dS)Nr))�_parties�_action�_timeoutra�_wrapperZcreate_memoryview�cast�_array)r$r5rrrr6~
s
zBarrier.__setstate__c

Cs|j|j
|j|j|jfS)
N)rnrorprarq)
r$rrrr4�
s

zBarrier.__getstate__c

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

Cs
|jd
S)Nr)
rs)
r$rrrrO�
szBarrier._countcCs|
|jd
<dS)Nr)
rs)r$r&rrrrO�
s)NN)
r:r;r<r+r6r4�propertyrk�setterrOrrrrrfs
s
	rfzRThis platform lacks a functioning sem_open implementation, therefore, the requiredz}This platform lacks a functioning sem_open implementation, therefore, the required synchronization primitives needed will notz�This platform lacks a functioning sem_open implementation, therefore, the required synchronization primitives needed will not function, see issue 3770.)�__all__rMrr=rr]�r	r
rrr
�ImportError�listrrPr?r@�objectrrr
rrrrfrrrr�<module>s0










Mz'