$43 GRAYBYTE WORDPRESS FILE MANAGER $51

B

YI~d)>�@s�dZd
dl
Z
d
dlZddlmZ
ddlmZ
ddlmZ
Gdd�d�ZGd	d
�d
�Z	Gdd�de	�Z
Gd
d�d�ZGdd�de	�ZGdd�de	�Z
Gdd�de
�ZdS))�Lock�Event�	Condition�	Semaphore�BoundedSemaphore�N�
)
�events)
�futures)
�	coroutinec@s$eZ
dZd
d�Zdd�Zdd�ZdS)�_ContextManagercCs
|
|_dS)
N)
�_lock)�self�lock�r�2/opt/alt/python37/lib64/python3.7/asyncio/locks.py�__init__ s
z_ContextManager.__init__c


CsdS)
Nr)
r
rrr�	__enter__#sz_ContextManager.__enter__c
Gsz|j�
�
Wdd|_XdS)
N)r�release)r
�argsrrr�__exit__(s

z_ContextManager.__exit__N)�__name__�
__module__�__qualname__rrrrrrrr
src@sHeZ
dZd
d�Zdd�Zedd��
Zdd�Zd	d
�Zdd�Z	d
d�Z
dS)�_ContextManagerMixinc

Cstd
�
�
dS)Nz9"yield from" should be used as context manager expression)
�RuntimeError)
r
rrrr0s

z_ContextManagerMixin.__enter__c

GsdS)
Nr)r
rrrrr4sz_ContextManagerMixin.__exit__c

cs&tj
d
tdd�
|��EdH
t|�
S)NzD'with (yield from lock)' is deprecated use 'async with lock' instead�)
�
stacklevel)�warnings�warn�DeprecationWarning�acquirer)
r
rrr�__iter__9s


z_ContextManagerMixin.__iter__c

�s|��IdH
t
|�
S)
N)r r)
r
rrrZ
__acquire_ctxPs

z"_ContextManagerMixin.__acquire_ctxc

Cstj
d
tdd�
|����S)Nz='with await lock' is deprecated use 'async with lock' insteadr)
r)rrr�!_ContextManagerMixin__acquire_ctx�	__await__)
r
rrrr#Ts

z_ContextManagerMixin.__await__c

�s|��IdH
dS)
N)
r )
r
rrr�
__aenter__[s
z_ContextManagerMixin.__aenter__c�s|��
dS)
N)
r)r
�exc_type�exc�tbrrr�	__aexit__as
z_ContextManagerMixin.__aexit__N)rrrrrr
r!r"r#r$r(rrrrr/s
rcsJeZ
dZd
d�
dd�Z�f
dd�Zdd�Zd	d
�Zdd�Zd
d�Z�Z	S)r
N)
�loopc

Cs.t�
�|_d
|_|
dk	r |
|_n
t��|_dS)NF)�collections�deque�_waiters�_locked�_loopr�get_event_loop)r
r)rrrr�s





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






z
Lock.__repr__c


Cs|jS)
N)
r-)
r
rrrr0�szLock.lockedc
	�s�|js$t
d
d�|jD�
�
r$d|_dS|j��}
|j�|
�

y"z|
IdH
Wd|j�|
�

XWn&tjk
r�


|js||�	�
�YnXd|_dS)Nc
ss|]}
|
��V
qdS)
N)
�	cancelled)�.0�
wrrr�	<genexpr>�szLock.acquire.<locals>.<genexpr>T)
r-�allr,r.�
create_future�append�remover	�CancelledError�_wake_up_first)r
�futrrrr �s










zLock.acquirec

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


zLock.releasec
Cs>ytt
|j�
�
}
Wntk
r&


dSX|
��s:|
�d
�

dS)NT)�next�iterr,�
StopIteration�done�
set_result)r
rDrrrrC�s



zLock._wake_up_first)
rrrrr5r0r rrC�
__classcell__rr)
r9rr
es6r
csJeZ
dZd
d�
dd�Z�f
dd�Zdd�Zd	d
�Zdd�Zd
d�Z�Z	S)rN)
r)c

Cs.t�
�|_d
|_|
dk	r |
|_n
t��|_dS)NF)r*r+r,�_valuer.rr/)r
r)rrrr�s





zEvent.__init__c
sLt��
�}
|jrd
nd}|jr2|�dt|j�
��}d|
dd��d|�d�S)	N�setZunsetz
, waiters:r2rr3z [z]>)r4r5rKr,r6)r
r7r8)
r9rrr5�s






zEvent.__repr__c


Cs|jS)
N)
rK)
r
rrr�is_set
szEvent.is_setc
Cs2|js.d
|_x |j
D]}
|
��s|
�d
�

qWdS)NT)rKr,rHrI)r
rDrrrrL
s



z	Event.setc

Cs
d
|_dS)NF)
rK)
r
rrr�clear
szEvent.clearc
	�sB|jr
d
S|j
��}
|j�|
�

z|
IdH
d
S|j�|
�

XdS)NT)rKr.r?r,r@rA)r
rDrrr�wait
s






z
Event.wait)
rrrrr5rMrLrNrOrJrr)
r9rr�s	rcsNeZ
dZdd
d�
dd�Z�f
dd�Zdd�Zd	d
�Zddd
�
Zdd�Z�Z	S)rN)
r)c
Csp|dk	r||_n
t
��|_|
dkr0t|jd
�
}
n|
j|jk	rDtd�
�
|
|_|
j|_|
j|_|
j|_t	�
�|_dS)N)
r)z"loop argument must agree with lock)r.rr/r
�
ValueErrorrr0r rr*r+r,)r
rr)rrrr5
s







zCondition.__init__c
sNt��
�}
|��rd
nd}|jr4|�dt|j�
��}d|
dd��d|�d�S)	Nr0r1z
, waiters:r2rr3z [z]>)r4r5r0r,r6)r
r7r8)
r9rrr5H
s






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

z|
IdH
dS|j�|
�

XWdd}x4y|��IdH
PWqXt	j
k
r�


d}YqXXqXW|r�t	j
�
XdS)Nzcannot wait on un-acquired lockTF)r0rrr.r?r,r@rAr r	rB)r
rDr:rrrrOO
s&















zCondition.waitc�s(|
�}x|s"|��IdH
|
�}qW|S)
N)
rO)r
Z	predicate�resultrrr�wait_fort
s





zCondition.wait_forrcCsL|��st
d
�
�
d}x2|jD](}||
kr*P|��s|d7}|�d�

qWdS)Nz!cannot notify on un-acquired lockrrF)r0rr,rHrI)r
�
n�idxrDrrr�notify�
s





zCondition.notifyc

Cs|�t
|j�
�

dS)
N)rUr6r,)
r
rrr�
notify_all�
szCondition.notify_all)
N)
r)
rrrrr5rOrRrUrVrJrr)
r9rr+
s
%
rcsLeZ
dZddd�
dd�Z�f
dd�Zdd	�Zd
d�Zdd
�Zdd�Z�Z	S)rrN)
r)c
Cs>|
d
krtd�
�
|
|_
t��|_|dk	r0||_n
t��|_dS)Nrz$Semaphore initial value must be >= 0)rPrKr*r+r,r.rr/)r
�valuer)rrrr�
s






zSemaphore.__init__c
sVt��
�}
|��rd
n
d|j��}|jr<|�dt|j�
��}d|
dd��d|�d�S)	Nr0zunlocked, value:z
, waiters:r2rr3z [z]>)r4r5r0rKr,r6)r
r7r8)
r9rrr5�
s






zSemaphore.__repr__c
Cs0x*|jr*|j�
�}
|
��s|
�d�

dSqWdS)
N)r,�popleftrHrI)r
Zwaiterrrr�
_wake_up_next�
s







zSemaphore._wake_up_nextc

Cs
|jd
kS)Nr)
rK)
r
rrrr0�
szSemaphore.lockedc
�sxxd|jd
k
rd|j
��}
|j�|
�

y|
IdH
Wq


|
��
|jd
krZ|
��sZ|��
�YqXqW|jd8_dS)NrrT)rKr.r?r,r@Zcancelr:rY)r
rDrrrr �
s	










zSemaphore.acquirec

Cs|jd
7_|�
�
dS)Nr)rKrY)
r
rrrr�
s
zSemaphore.release)
r)
rrrrr5rYr0r rrJrr)
r9rr�
s
rcs0eZ
dZddd�
�f
dd�Z�f
dd�Z�ZS)	rrN)
r)c
s|
|_t
�j|
|d
�
dS)N)
r))�_bound_valuer4r)r
rWr))
r9rrr�
s

zBoundedSemaphore.__init__c

s"|j|j
krtd
�
�
t���
dS)Nz(BoundedSemaphore released too many times)rKrZrPr4r)
r
)
r9rrr�
s


zBoundedSemaphore.release)
r)rrrrrrJrr)
r9rr�
sr)�__all__r*r�rr	Z
coroutinesr
rrr
rrrrrrrr�<module>s


"6AwK