GRAYBYTE WORDPRESS FILE MANAGER6502

a

�DOgM;�@s�dZd
dl
Z
d
dlZddlmZ
ddlmZ
Gdd�d�ZGdd	�d	e�ZGd
d�d�ZGdd
�d
e�Z	Gdd�de�Z
Gdd�de
�ZdS))�Lock�Event�	Condition�	Semaphore�BoundedSemaphore�N�
)
�events)
�
exceptionsc@seZ
dZd
d�Zdd�ZdS)�_ContextManagerMixinc

�s|��IdH
dS�
N)
�acquire�
�self�r�%/usr/lib64/python3.9/asyncio/locks.py�
__aenter__
s
z_ContextManagerMixin.__aenter__c�s|��
dSr)
�release)r�exc_type�exc�tbrrr�	__aexit__s
z_ContextManagerMixin.__aexit__N)�__name__�
__module__�__qualname__rrrrrrr
s
r
csJeZ
dZd
d�
dd�Z�f
dd�Zdd�Zd	d
�Zdd�Zd
d�Z�Z	S)r
N�
�loopc

Cs:d|_d
|_
|
dur t��|_n|
|_tjdtdd�
dS�NF�[The loop argument is deprecated since Python 3.8, and scheduled for removal in Python 3.10.��
�
stacklevel)�_waiters�_lockedr�get_event_loop�_loop�warnings�warn�DeprecationWarning�rrrrr�__init__Ms




�z
Lock.__init__c
sLt��
�}
|jrd
nd}|jr2|�dt|j�
��}d|
dd��d|�d�S�	N�locked�unlocked�
, waiters:�
<r���� [�]>)�super�__repr__r"r!�len�r�res�extra�
�	__class__rrr3Xs






z
Lock.__repr__c


Cs|jSr)
r"r
rrrr+_szLock.lockedc
	�s�|js.|j
dus$td
d�|j
D�
�
r.d|_dS|j
durBt��|_
|j��}
|j
�|
�

z.z|
IdH
W|j
�|
�

n|j
�|
�

0Wn$t	j
y�


|js�|��
�Yn0d|_dS)Nc
ss|]}
|
��V
qdSr)
�	cancelled)�.0�
wrrr�	<genexpr>j�zLock.acquire.<locals>.<genexpr>T)r"r!�all�collections�dequer$�
create_future�append�remover	�CancelledError�_wake_up_first�r�futrrrrcs&
�








 




zLock.acquirec

Cs"|jrd
|_|�
�
ntd�
�
dS)NFzLock is not acquired.)r"rF�RuntimeErrorr
rrrr�s


zLock.releasec
CsH|js
dSzt
t|j�
�
}
Wnty0


YdS0|
��sD|
�d
�

dS�NT)r!�next�iter�
StopIteration�done�
set_resultrGrrrrF�s





zLock._wake_up_first)
rrrr)r3r+rrrF�
__classcell__rrr8rr
s6 r
csJeZ
dZd
d�
dd�Z�f
dd�Zdd�Zd	d
�Zdd�Zd
d�Z�Z	S)rNrc

Cs>t�
�|_d
|_|
dur$t��|_n|
|_tjdt	dd�
dSr)
r@rAr!�_valuerr#r$r%r&r'r(rrrr)�s





�zEvent.__init__c
sLt��
�}
|jrd
nd}|jr2|�dt|j�
��}d|
dd��d|�d�S)	N�setZunsetr-r.rr/r0r1)r2r3rQr!r4r5r8rrr3�s






zEvent.__repr__c


Cs|jSr�
rQr
rrr�is_set�szEvent.is_setc
Cs.|js*d
|_|j
D]}
|
��s|
�d
�

qdSrJ)rQr!rNrOrGrrrrR�s




z	Event.setc

Cs
d
|_dS)NFrSr
rrr�clear�szEvent.clearc
	�sP|jr
d
S|j
��}
|j�|
�

z|
IdH
W|j�|
�

d
S|j�|
�

0dSrJ)rQr$rBr!rCrDrGrrr�wait�s






�z
Event.wait)
rrrr)r3rTrRrUrVrPrrr8rr�s	rcsNeZ
dZdd
d�
dd�Z�f
dd�Zdd�Zd	d
�Zddd
�
Zdd�Z�Z	S)rNrc
Cs~|durt�
�|_n||_tjd
tdd�
|
dur>t|d�
}
n|
j|ju
rRtd�
�
|
|_|
j	|_	|
j
|_
|
j|_t�
�|_dS)Nrrrrz"loop argument must agree with lock)rr#r$r%r&r'r
�
ValueError�_lockr+rrr@rAr!)r�lockrrrrr)�s


�




zCondition.__init__c
sNt��
�}
|��rd
nd}|jr4|�dt|j�
��}d|
dd��d|�d�Sr*)r2r3r+r!r4r5r8rrr3
s






zCondition.__repr__c
�s.
|��st
d
�
�
|��
z�|j��}
|j�|
�

z^|
IdH
W|j�|
�

Wd}z|��IdH
Wq�WqPt	j
y~


d}YqP0qP|r�t	j
�
dS|j�|
�

0Wd}z|��IdH
Wq�Wq�t	j
y�


d}Yq�0q�|r�t	j
�
nHd}z|��IdH
W�
qWq�t	j
�
y


d}Yq�0q�|�
r(t	j
�
0dS)Nzcannot wait on un-acquired lockFT)r+rIrr$rBr!rCrDrr	rE)rrHr:rrrrV
sJ








�




�




�





zCondition.waitc�s$|
�}|s |��IdH
|
�}q|Sr)
rV)r�	predicate�resultrrr�wait_for4
s




zCondition.wait_forrcCsJ|��st
d
�
�
d}|jD]*}||
kr*
qF|��s|d7}|�d�

qdS)Nz!cannot notify on un-acquired lockrrF)r+rIr!rNrO)r�
n�idxrHrrr�notifyA
s






zCondition.notifyc

Cs|�t
|j�
�

dSr)r_r4r!r
rrr�
notify_allY
szCondition.notify_all)
N)
r)
rrrr)r3rVr\r_r`rPrrr8rr�s
%
rcsLeZ
dZddd�
dd�Z�f
dd�Zdd	�Zd
d�Zdd
�Zdd�Z�Z	S)rrNrc
CsT|
d
krtd�
�
|
|_
t��|_|dur4t��|_n||_tj	dt
dd�
d|_dS)Nrz$Semaphore initial value must be >= 0rrrF)rWrQr@rAr!rr#r$r%r&r'�_wakeup_scheduled�r�valuerrrrr)q
s







�zSemaphore.__init__c
sVt��
�}
|��rd
n
d|j��}|jr<|�dt|j�
��}d|
dd��d|�d�S)	Nr+zunlocked, value:r-r.rr/r0r1)r2r3r+rQr!r4r5r8rrr3
s






zSemaphore.__repr__c
Cs2|jr.|j�
�}
|
��s|
�d�

d
|_dSqdSrJ)r!�popleftrNrOra)r�waiterrrr�
_wake_up_next�
s







zSemaphore._wake_up_nextc

Cs
|jd
kS)NrrSr
rrrr+�
szSemaphore.lockedc
�sn|js|j
d
k
r\|j��}
|j�|
�

z|
IdH
d|_WqtjyX


|��
�Yq0q|j
d8_
dS)NrFrT)	rarQr$rBr!rCr	rErfrGrrrr�
s












zSemaphore.acquirec

Cs|jd
7_|�
�
dS)Nr)rQrfr
rrrr�
s
zSemaphore.release)
r)
rrrr)r3rfr+rrrPrrr8rrb
srcs0eZ
dZddd�
�f
dd�Z�f
dd�Z�ZS)	rrNrc
s.|rtj
d
tdd�
|
|_t�j|
|d�
dS)Nrrrr)r%r&r'�_bound_valuer2r)rbr8rrr)�
s

�
zBoundedSemaphore.__init__c

s"|j|j
krtd
�
�
t���
dS)Nz(BoundedSemaphore released too many times)rQrgrWr2rr
r8rrr�
s


zBoundedSemaphore.release)
r)rrrr)rrPrrr8rr�
s	r)�__all__r@r%�rr	r
r
rrrrrrrr�<module>s

DzQ