File manager

�
e f�/�@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

CsT
|dkrtj
j�}n|j�}tjd
kpB|dk}xbtd�
D]H}y,tj|
|||j	�|�}|_
Wntk
r�


YqRXPqRWtd�
�
tj
d|j�

|j�
tjd
kr�dd�}	tj||	�
n|j
jdk	rP
dd	lm}

|
|j
j�

tj|tj|j
jf
d
d�

ndS)N�win32�fork�dzcannot find name for semaphorezcreated semlock with handle %sc


Ss|jj
�
dS)
N)�_semlock�_after_fork)
�obj�r�@/opt/alt/python34/lib64/python3.4/multiprocessing/synchronize.pyrHs
z%SemLock.__init__.<locals>._after_forkr	)
�registerZexitpriorityr)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__3s.

















zSemLock.__init__c
Cs(d
dlm
}

t|�

|
|�

dS)Nr	)
�
unregister)r#r-r)r"r-rrrr$Us


zSemLock._cleanupc

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

zSemLock._make_methodsc


Cs
|jj
�S)
N)r�	__enter__)
r%rrrr0_s
zSemLock.__enter__c
Gs|jj
|
�S)
N)r�__exit__)r%�argsrrrr1bs
zSemLock.__exit__c
Csbtj
|�

|j}
tjd
kr@tj�j|
j�
}n	|
j}||
j|
j	|
j
fS)Nr)r
�assert_spawningrrrZget_spawning_popenZduplicate_for_childr r&r(r")r%r+�
hrrr�__getstate__es


	

	
zSemLock.__getstate__cCs8tj
j|
�|_tjd
|
d�

|j�
dS)Nz recreated blocker with handle %rr)rr
Z_rebuildrrrr!)r%�staterrr�__setstate__ns


zSemLock.__setstate__cCs$d
tj
�jdttj�
fS)Nz%s-%sZ	semprefix)r�current_processZ_config�nextr
�_randrrrrrss
zSemLock._make_nameN)�__name__�
__module__�__qualname__�tempfileZ_RandomNameSequencer:r,�staticmethodr$r!r0r1r5r7rrrrrr
/s"	r
c@s7eZ
dZd
dd�
Zdd�Zdd�ZdS)	rr	c
Cs tj
|t|
td
|�

dS)Nr))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
Cs6y|jj
�}
Wntk
r-


d
}
Yn
Xd|
S)N�unknownz<Semaphore(value=%s)>)rrB�	Exception)r%r'rrr�__repr__�s






zSemaphore.__repr__N)r;r<r=r,rCrFrrrrr|sc@s+eZ
dZd
dd�
Zdd�ZdS)rr	c
Cs tj
|t|
|
d
|�

dS)Nr))r
r,r@)r%r'r)rrrr,�s
zBoundedSemaphore.__init__c
CsBy|jj
�}
Wntk
r-


d
}
Yn
Xd|
|jjfS)NrDz)<BoundedSemaphore(value=%s, maxvalue=%s)>)rrBrEr()r%r'rrrrF�s






zBoundedSemaphore.__repr__N)r;r<r=r,rFrrrrr�sc@s(eZ
dZd
d�Zdd�ZdS)r
c

Cs tj
|td
d
d|
�

dS)Nr	r))r
r,r@)r%r)rrrr,�s
z
Lock.__init__c
Cs�y�|jj
�rStj�j}
tj�jd
kr�|
dtj�j7}
q�nB|jj�dkrqd}
n$|jj�dkr�d}
nd}
Wnt	k
r�


d}
Yn
Xd	|
S)
N�
MainThread�
|r	�Noner�SomeOtherThread�SomeOtherProcessrDz<Lock(owner=%s)>)
r�_is_minerr8r"�	threading�current_threadrB�_countrE)r%r"rrrrF�s






	

	




z
Lock.__repr__N)r;r<r=r,rFrrrrr
�sc@s(eZ
dZd
d�Zdd�ZdS)rc

Cs tj
|td
d
d|
�

dS)Nr	r))r
r,�RECURSIVE_MUTEX)r%r)rrrr,�s
zRLock.__init__c
Cs�y�|jj
�rbtj�j}
tj�jd
krP|
dtj�j7}
n|jj�}nT|jj�dkr�d\}
}n0|jj�dkr�d\}
}nd
\}
}Wnt	k
r�


d\}
}Yn
Xd
|
|fS)NrGrHr	rIrrJ�nonzerorKrDz<RLock(%s, %s)>)zNoner)zSomeOtherThreadrQ)zSomeOtherProcessrQ)�unknownrR)
rrLrr8r"rMrNrOrBrE)r%r"�countrrrrF�s













zRLock.__repr__N)r;r<r=r,rFrrrrr�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)rrrr,�s





zCondition.__init__c

Cs)tj
|�

|j|j|j|jfS)
N)r
r3rTrUrVrW)
r%rrrr5�s



zCondition.__getstate__cCs,|
\|_|_
|_|_|j�
dS)
N)rTrUrVrWr!)r%r6rrrr7�s
zCondition.__setstate__c


Cs
|jj
�S)
N)rTr0)
r%rrrr0�s
zCondition.__enter__c
Gs|jj
|
�S)
N)rTr1)r%r2rrrr1�s
zCondition.__exit__c

Cs"|jj
|_
|jj|_dS)
N)rTr.r/)
r%rrrr!�s

zCondition._make_methodsc
CsRy&|jj
j�|jj
j�}
Wntk
r@


d
}
Yn
Xd|j|
fS)NrDz<Condition(%s, %s)>)rUrrBrVrErT)r%Znum_waitersrrrrF�s






zCondition.__repr__cCs�|jj
�
|jjj�}x!t|�
D]}|jj
�
q,Wz|jjd
|
�SWd|jj
�
x!t|�
D]}|jj�
qwWXdS)NT)	rUr/rTrrOrrWr.rV)r%�timeoutrSr*rrr�wait�s




zCondition.waitc
Csnx(|jj
d
�
r*|jj
d
�
}
qW|jj
d
�
rj|jj�
|jj
�
|jj
d
�

ndS)NF)rVr.rUrWr/)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�WndS)NFrr	)rVr.rUrWr/r)r%r[Zsleepersr*rrr�
notify_all 
s








zCondition.notify_allcCs�|
�}|r|S|dk	r/t�|}nd}d}xL|s�|dk	rp|t�}|d
k
rpPqpn|j
|�

|
�}q>W|S)Nr)�_timerZ)r%Z	predicaterY�resultZendtimeZwaittimerrr�wait_for7
s
	





	









zCondition.wait_for)r;r<r=r,r5r7r0r1r!rFrZr\r]r`rrrrr�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)rrrr,O
s

zEvent.__init__c


CsM|jj
�
z+|jj
d
�
r3|jj�
dSd
SWd|jj�
XdS)NFT)rar.rbr/)
r%rrr�is_setS
s







zEvent.is_setc


CsP|jj
�
z.|jj
d
�

|jj�
|jj�
Wd|jj�
XdS)NF)rar.rbr/r])
r%rrr�set]
s






z	Event.setc


Cs6|jj
�
z|jj
d
�

Wd|jj�
XdS)NF)rar.rbr/)
r%rrr�clearf
s



zEvent.clearNc
Cs|jj
�
z]|jj
d
�
r2|jj�
n|jj|
�

|jj
d
�
re|jj�
dSd
SWd|jj�
XdS)NFT)rar.rbr/rZ)r%rYrrrrZm
s








z
Event.wait)r;r<r=r,rcrdrerZrrrrrM
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	)
�
BufferWrapperr*r)�struct�heaprgZcalcsizerr7�_staterO)	r%Zparties�actionrYr)rhrg�wrapperZcondrrrr,�
s





	
zBarrier.__init__cCsC|
\|_|_
|_|_|_|jj�jd
�
|_dS)Nr*)�_parties�_action�_timeoutra�_wrapperZcreate_memoryview�cast�_array)r%r6rrrr7�
s$
zBarrier.__setstate__c

Cs"|j|j
|j|j|jfS)
N)rmrnrorarp)
r%rrrr5�
s

zBarrier.__getstate__c

Cs|jd
S)Nr)
rr)
r%rrrrj�
szBarrier._statecCs|
|jd
<dS)Nr)
rr)r%r'rrrrj�
sc

Cs|jd
S)Nr	)
rr)
r%rrrrO�
szBarrier._countcCs|
|jd
<dS)Nr	)
rr)r%r'rrrrO�
s)
r;r<r=r,r7r5�propertyrj�setterrOrrrrrf�
s	rf)�__all__rMrr>rrr^�r
rrr
r�ImportError�listrrPr@rA�objectrrr
rrrrfrrrr�<module>s0










Mz3