$58 GRAYBYTE WORDPRESS FILE MANAGER $31



���]�:�@s�dd
dddgZddl
Z
ddlmZ
dd	lmZ
dd
lmZ
ddlmZ
Gdd
�d
�ZGdd�d�Z	Gdd�de	�Z
Gdd
�d
�ZGdd�de	�ZGdd�de	�Z
Gdd�de
�ZdS)�Lock�Event�	Condition�	Semaphore�BoundedSemaphore�N�
)
�compat)
�events)
�futures)
�	coroutinec@s4eZ
dZd
d�Zdd�Zdd�ZdS)�_ContextManagercCs
|
|_dS)
N)
�_lock)�self�lock�r�*/opt/alt/python35/lib64/python3.5/locks.py�__init__s
z_ContextManager.__init__c


CsdS)
Nr)
rrrr�	__enter__sz_ContextManager.__enter__c
Gs"z|jj
�
Wdd|_XdS)
N)r
�release)r�argsrrr�__exit__$s

z_ContextManager.__exit__N)�__name__�
__module__�__qualname__rrrrrrrr
src@sseZ
dZd
d�Zdd�Zedd��
Zejrodd�Z	ed	d
��
Z
edd��
Zd
S)�_ContextManagerMixinc

Cstd
�
�
dS)Nz9"yield from" should be used as context manager expression)
�RuntimeError)
rrrrr,s

z_ContextManagerMixin.__enter__c

GsdS)
Nr)rrrrrr0sz_ContextManagerMixin.__exit__c

cs|j�EdH
t
|�
S)
N)�acquirer)
rrrr�__iter__5s
z_ContextManagerMixin.__iter__c

cs|j�EdH
t
|�
S)
N)rr)
rrrr�	__await__Hs
z_ContextManagerMixin.__await__c

cs|j�EdH
dS)
N)
r)
rrrr�
__aenter__Msz_ContextManagerMixin.__aenter__c
Cs|j�
dS)
N)
r)r�exc_type�exc�tbrrr�	__aexit__Tsz_ContextManagerMixin.__aexit__N)rrrrrrrrZPY35rrr#rrrrr+s
	rcsjeZ
dZd
ddd�
Z�f
dd�Zdd�Zed	d
��
Zdd�Zd
d�Z	�S)r
�loopNc

CsCtj
�|_d
|_|
dk	r0|
|_ntj�|_dS)NF)�collections�deque�_waiters�_locked�_loopr	�get_event_loop)rr$rrrr�s


	

z
Lock.__init__c
sbt�j
�}
|jrd
nd}|jrHdj|t|j�
�}dj|
dd�|�S)N�locked�unlockedz
{},waiters:{}z	<{} [{}]>r���)�super�__repr__r(r'�format�len)r�res�extra)
�	__class__rrr/�s



	

z
Lock.__repr__c


Cs|jS)
N)
r()
rrrrr+�szLock.lockedc
cs�|jr3t
d
d�|jD�
�
r3d|_dS|jj�}
|jj|
�

zLy|
EdH
d|_dSWn+tjk
r�


|js�|j�
�Yn
XWd|jj	|
�

XdS)Nc
ss|]}
|
j�V
qdS)
N)
�	cancelled)�.0�
wrrr�	<genexpr>�szLock.acquire.<locals>.<genexpr>T)
r(�allr'r)�
create_future�appendr
�CancelledError�_wake_up_first�remove)r�futrrrr�s&
	



	
	


	


zLock.acquirec

Cs/|jrd
|_|j
�
ntd�
�
dS)NFzLock is not acquired.)r(r=r)
rrrrr�s	
	

zLock.releasec
Cs2x+|jD] }
|
j
�s
|
jd
�

Pq
WdS)NT)r'�done�
set_result)rr?rrrr=�s



zLock._wake_up_first)
rrrrr/r+rrrr=rr)
r4rr
Ys6csjeZ
dZd
ddd�
Z�f
dd�Zdd�Zd	d
�Zdd�Zed
d��
Z	�S)rr$Nc

CsCtj
�|_d
|_|
dk	r0|
|_ntj�|_dS)NF)r%r&r'�_valuer)r	r*)rr$rrrr�s


	

zEvent.__init__c
sbt�j
�}
|jrd
nd}|jrHdj|t|j�
�}dj|
dd�|�S)N�setZunsetz
{},waiters:{}z	<{} [{}]>rr-)r.r/rBr'r0r1)rr2r3)
r4rrr/�s



	

zEvent.__repr__c


Cs|jS)
N)
rB)
rrrr�is_set�szEvent.is_setc
CsC|js?d
|_x*|j
D]}
|
j�s|
jd
�

qWdS)NT)rBr'r@rA)rr?rrrrC�s
	
	

z	Event.setc

Cs
d
|_dS)NF)
rB)
rrrr�clear�szEvent.clearc
csU|jr
d
S|j
j�}
|jj|
�

z|
EdH
d
SWd|jj|
�

XdS)NT)rBr)r:r'r;r>)rr?rrr�wait

s	



	
z
Event.wait)
rrrrr/rDrCrErrFrr)
r4rr�s	csveZ
dZd
dd
dd�

Z�f
dd�Zedd��
Zed	d
��
Zddd
�
Zdd�Z	�S)rNr$c
Cs�|dk	r||_nt
j�|_|
dkrHtd
|j�
}
n|
j|jk	rftd�
�
|
|_|
j|_|
j|_|
j|_t	j
�|_dS)Nr$z"loop argument must agree with lock)r)r	r*r
�
ValueErrorr
r+rrr%r&r')rrr$rrrr
s




	

zCondition.__init__c
set�j
�}
|j�r!d
nd}|jrKdj|t|j�
�}dj|
dd�|�S)Nr+r,z
{},waiters:{}z	<{} [{}]>rr-)r.r/r+r'r0r1)rr2r3)
r4rrr/2
s



	

zCondition.__repr__c
cs�|j�st
d
�
�
|j�
zH|jj�}
|jj|
�

z|
EdH
dSWd|jj|
�

XWdx0y|j�EdH
PWqpt	j
k
r�


YqpXqpWXdS)Nzcannot wait on un-acquired lockT)r+rrr)r:r'r;r>rr
r<)rr?rrrrF9
s 






	





zCondition.waitccs2|
�}x"|s-|j�EdH
|
�}qW|S)
N)
rF)r�	predicate�resultrrr�wait_for[
s
	
	



zCondition.wait_forrcCsf|j�st
d
�
�
d}xA|jD]6}||
kr;P|j�s(|d7}|jd�

q(WdS)Nz!cannot notify on un-acquired lockrrF)r+rr'r@rA)r�
n�idxr?rrr�notifyi
s







zCondition.notifyc

Cs|jt
|j�
�

dS)
N)rMr1r')
rrrr�
notify_all�
szCondition.notify_all)
rrrrr/rrFrJrMrNrr)
r4rr
s
"csmeZ
dZd
dddd�

Z�f
dd�Zdd	�Zd
d�Zedd
��
Zdd�Z	�S)rrr$Nc
Cs[|
d
krtd�
�
|
|_
tj�|_|dk	rH||_ntj�|_dS)Nrz$Semaphore initial value must be >= 0)rGrBr%r&r'r)r	r*)r�valuer$rrrr�
s


	


zSemaphore.__init__c
sqt�j
�}
|j�r!d
ndj|j�
}|jrWdj|t|j�
�}dj|
dd�|�S)Nr+zunlocked,value:{}z
{},waiters:{}z	<{} [{}]>rr-)r.r/r+r0rBr'r1)rr2r3)
r4rrr/�
s



	

zSemaphore.__repr__c
Cs@x9|jr;|jj
�}
|
j�s|
jd�

dSqWdS)
N)r'�popleftr@rA)r�waiterrrr�
_wake_up_next�
s






zSemaphore._wake_up_nextc

Cs
|jd
kS)Nr)
rB)
rrrrr+�
szSemaphore.lockedc
	cs�x}|jd
k
r|j
j�}
|jj|
�

y
|
EdH
Wq


|
j�
|jd
krt|
j�rt|j�
�YqXqW|jd8_dS)NrrT)rBr)r:r'r;�cancelr5rR)rr?rrrr�
s













zSemaphore.acquirec

Cs|jd
7_|j
�
dS)Nr)rBrR)
rrrrr�
s
zSemaphore.release)
rrrrr/rRr+rrrrr)
r4rr�
s
cs=eZ
dZd
dd�f
dd�

Z�f
dd�Z�S)rrr$Nc
s#|
|_t
�j|
d
|�


dS)Nr$)�_bound_valuer.r)rrOr$)
r4rrr�
s
	
zBoundedSemaphore.__init__c

s/|j|j
krtd
�
�
t�j�
dS)Nz(BoundedSemaphore released too many times)rBrTrGr.r)
r)
r4rrr�
s


zBoundedSemaphore.release)rrrrrrr)
r4rr�
s)�__all__r%�rr	r
Z
coroutinesrrrr
rrrrrrrr�<module>s


.zBuM