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 ]



���]/�@s�
dd
ddddgZddl
Z
ddlZddlZddlZddlmZ
d	d
lmZ
d	dlm	Z	
d	dlm
Z

ydd
lmZmZ
Wn*e
k
r�


e
dddd�
�
Yn
Xeed�
�
\ZZejjZGdd�de�ZGdd�de�ZGdd�de�ZGdd�de�ZGdd
�d
e�ZGdd�de�ZGdd�de�ZGdd�de
j�ZdS)�Lock�RLock�	Semaphore�BoundedSemaphore�	Condition�Event�N)
�time�
)
�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

CsK
|dkrtj
j�}|j�}tjd
kp?|dk}xbtd�
D]H}y,tj|
|||j	�|�}|_
Wntk
r�


YqOXPqOWtd�
�
tj
d|j�

|j�
tjd
kr�dd�}	tj||	�
|j
jdk	rG
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/python35/lib64/python3.5/synchronize.pyrHs
z%SemLock.__init__.<locals>._after_forkr	)
�register�exitpriorityr)r
�_default_context�get_context�get_start_method�sys�platform�range�_multiprocessingr
�
_make_namer�FileExistsErrorr�debug�handle�
_make_methods�register_after_fork�name�semaphore_trackerr�Finalize�_cleanup)�self�kind�value�maxvalue�ctxr'Z
unlink_now�
i�slrrrrr�__init__3s.

















zSemLock.__init__c
Cs(d
dlm
}

t|�

|
|�

dS)Nr	)
�
unregister)r(r3r)r'r3rrrr*Us


zSemLock._cleanupc

Cs"|jj
|_
|jj|_dS)
N)r�acquire�release)
r+rrrr%[s

zSemLock._make_methodsc


Cs
|jj
�S)
N)r�	__enter__)
r+rrrr6_s
zSemLock.__enter__c
Gs|jj
|
�S)
N)r�__exit__)r+�argsrrrr7bs
zSemLock.__exit__c
Csbtj
|�

|j}
tjd
kr@tj�j|
j�
}n	|
j}||
j|
j	|
j
fS)Nr)r
�assert_spawningrrr�get_spawning_popen�duplicate_for_childr$r,r.r')r+r1�
hrrr�__getstate__es


	

	
zSemLock.__getstate__cCs8tj
j|
�|_tjd
|
d�

|j�
dS)Nz recreated blocker with handle %rr)r r
�_rebuildrrr#r%)r+�staterrr�__setstate__ns


zSemLock.__setstate__cCs$d
tj
�jdttj�
fS)Nz%s-%s�	semprefix)r�current_process�_config�nextr
�_randrrrrr!ss
zSemLock._make_nameN)�__name__�
__module__�__qualname__�tempfile�_RandomNameSequencerEr2�staticmethodr*r%r6r7r=r@r!rrrrr
/s"	r
c@s7eZ
dZd
dd�
Zdd�Zdd�ZdS)	rr	c
Cs tj
|t|
td
|�

dS)Nr/)r
r2�	SEMAPHORE�
SEM_VALUE_MAX)r+r-r/rrrr2~s
zSemaphore.__init__c


Cs
|jj
�S)
N)r�
_get_value)
r+rrr�	get_value�s
zSemaphore.get_valuec
CsBy|jj
�}
Wntk
r-


d
}
Yn
Xd|jj|
fS)N�unknownz<%s(value=%s)>)rrN�	Exception�	__class__rF)r+r-rrr�__repr__�s






zSemaphore.__repr__N)rFrGrHr2rOrSrrrrr|sc@s+eZ
dZd
dd�
Zdd�ZdS)rr	c
Cs tj
|t|
|
d
|�

dS)Nr/)r
r2rL)r+r-r/rrrr2�s
zBoundedSemaphore.__init__c
CsKy|jj
�}
Wntk
r-


d
}
Yn
Xd|jj|
|jjfS)NrPz<%s(value=%s, maxvalue=%s)>)rrNrQrRrFr.)r+r-rrrrS�s






zBoundedSemaphore.__repr__N)rFrGrHr2rSrrrrr�sc@s(eZ
dZd
d�Zdd�ZdS)r
c

Cs tj
|td
d
d|
�

dS)Nr	r/)r
r2rL)r+r/rrrr2�s
z
Lock.__init__c
Cs�y�|jj
�rPtj�j}
tj�jd
kr�|
dtj�j7}
nB|jj�dkrnd}
n$|jj�dkr�d}
nd}
Wnt	k
r�


d}
Yn
Xd	|j
j|
fS)
N�
MainThread�
|r	�Noner�SomeOtherThread�SomeOtherProcessrPz<%s(owner=%s)>)r�_is_minerrBr'�	threading�current_threadrN�_countrQrRrF)r+r'rrrrS�s






	

	




z
Lock.__repr__N)rFrGrHr2rSrrrrr
�sc@s(eZ
dZd
d�Zdd�ZdS)rc

Cs tj
|td
d
d|
�

dS)Nr	r/)r
r2�RECURSIVE_MUTEX)r+r/rrrr2�s
zRLock.__init__c
Cs�y�|jj
�r_tj�j}
tj�jd
krM|
dtj�j7}
|jj�}nT|jj�dkr�d\}
}n0|jj�dkr�d\}
}nd
\}
}Wnt	k
r�


d\}
}Yn
Xd
|j
j|
|fS)NrTrUr	rVrrW�nonzerorXrPz<%s(%s, %s)>)rVr)rWr^)rXr^)rPrP)rrYrrBr'rZr[r\rNrQrRrF)r+r'�countrrrrS�s













zRLock.__repr__N)rFrGrHr2rSrrrrr�sc@s�eZ
dZd
dd�
Zdd�Zdd�Zdd	�Zd
d�Zdd
�Zdd�Z	d
dd�
Z
dd�Zdd�Zd
dd�
Z
d
S)rNc
CsY|
p|j�|_
|jd
�
|_|jd
�
|_|jd
�
|_|j�
dS)Nr)r�_lockr�_sleeping_count�_woken_count�_wait_semaphorer%)r+�lockr/rrrr2�s





zCondition.__init__c

Cs)tj
|�

|j|j|j|jfS)
N)r
r9r`rarbrc)
r+rrrr=�s



zCondition.__getstate__cCs,|
\|_|_
|_|_|j�
dS)
N)r`rarbrcr%)r+r?rrrr@�s
zCondition.__setstate__c


Cs
|jj
�S)
N)r`r6)
r+rrrr6�s
zCondition.__enter__c
Gs|jj
|
�S)
N)r`r7)r+r8rrrr7�s
zCondition.__exit__c

Cs"|jj
|_
|jj|_dS)
N)r`r4r5)
r+rrrr%�s

zCondition._make_methodsc
Cs[y&|jj
j�|jj
j�}
Wntk
r@


d
}
Yn
Xd|jj|j|
fS)NrPz<%s(%s, %s)>)rarrNrbrQrRrFr`)r+Znum_waitersrrrrS�s






zCondition.__repr__cCs�|jj
�
|jjj�}x!t|�
D]}|jj
�
q,Wz|jjd
|
�SWd|jj
�
x!t|�
D]}|jj�
qwWXdS)NT)	rar5r`rr\rrcr4rb)r+�timeoutr_r0rrr�wait�s




zCondition.waitc
Cskx(|jj
d
�
r*|jj
d
�
}
qW|jj
d
�
rg|jj�
|jj
�
|jj
d
�

dS)NF)rbr4rarcr5)r+�resrrr�notify
s





zCondition.notifyc
Cs�x(|jj
d
�
r*|jj
d
�
}
qWd}x-|jj
d
�
r`|jj�
|d7}q4W|r�x!t|�
D]}|jj
�
qtWx|jj
d
�
r�q�WdS)NFrr	)rbr4rarcr5r)r+rgZsleepersr0rrr�
notify_all 
s








zCondition.notify_allcCs�|
�}|r|S|dk	r/t�|}nd}d}xF|s�|dk	rj|t�}|d
k
rjP|j
|�

|
�}q>W|S)Nr)�_timerf)r+�	predicatere�result�endtime�waittimerrr�wait_for7
s
	





	










zCondition.wait_for)rFrGrHr2r=r@r6r7r%rSrfrhrirorrrrr�sc@sOeZ
dZd
d�Zdd�Zdd�Zdd�Zd	d
d�
Zd	S)rc

Cs.|
j|
j
��
|_|
jd
�
|_dS)Nr)rr
�_condr�_flag)r+r/rrrr2O
s

zEvent.__init__c

	Cs<|j�,
|j
jd
�
r-|j
j�
dSd
SWdQRXdS)NFT)rprqr4r5)
r+rrr�is_setS
s







zEvent.is_setc

	Cs?|j�/
|j
jd
�

|j
j�
|jj�
WdQRXdS)NF)rprqr4r5ri)
r+rrr�setZ
s





z	Event.setc

	Cs%|j�
|j
jd
�

WdQRXdS)NF)rprqr4)
r+rrr�clear`
s


zEvent.clearNc	Csn|j�^
|j
jd
�
r,|j
j�
n|jj|
�

|j
jd
�
r_|j
j�
dSd
SWdQRXdS)NFT)rprqr4r5rf)r+rerrrrfd
s







z
Event.wait)rFrGrHr2rrrsrtrfrrrrrM
s
c@s�eZ
dZd
d
dd�Zdd�Zdd�Zedd	��
Zejd
d	��
Zedd��
Z	e	jd
d��
Z	d
S)�BarrierNc
	Cssd
dl}ddl
m}
||jd�
d�
}|j�}|j|
||||f�

d
|_d
|_dS)Nrr	)
�
BufferWrapperr0r)�struct�heaprv�calcsizerr@�_stater\)	r+�parties�actionrer/rwrv�wrapperZcondrrrr2v
s





	
zBarrier.__init__cCsC|
\|_|_
|_|_|_|jj�jd
�
|_dS)Nr0)�_parties�_action�_timeoutrp�_wrapperZcreate_memoryview�cast�_array)r+r?rrrr@
s$
zBarrier.__setstate__c

Cs"|j|j
|j|j|jfS)
N)r~rr�rpr�)
r+rrrr=�
s

zBarrier.__getstate__c

Cs|jd
S)Nr)
r�)
r+rrrrz�
szBarrier._statecCs|
|jd
<dS)Nr)
r�)r+r-rrrrz�
sc

Cs|jd
S)Nr	)
r�)
r+rrrr\�
szBarrier._countcCs|
|jd
<dS)Nr	)
r�)r+r-rrrr\�
s)
rFrGrHr2r@r=�propertyrz�setterr\rrrrrut
s	ru)�__all__rZrrIr rrj�r
rrr
r�ImportError�listrr]rLrM�objectrrr
rrrrurrrr�<module>s0










Mz'