�`^c@s�dd
ddddgZddl
Z
ddlZddlZddlmZmZ
ddlZdd	l	m
Z

dd
lmZm
Z
mZ
ddlmZmZ
yddlmZ
Wn)ek
r�


ed
ddd��n
Xed�\ZZejjZdef
d��YZdef
d��YZdef
d��YZdef
d��YZd
ef
d��YZdef
d��YZdef
d��YZdS(tLocktRLockt	SemaphoretBoundedSemaphoret	ConditiontEventi�N(ttimetsleep(
tcurrent_process(tFinalizetregister_after_forktdebug(tassert_spawningtPopen(
tSemLocks*This platform lacks a functioning sem_opens( implementation, therefore, the requireds+ synchronization primitives needed will nots function, see issue 3770.iRc
Bs>eZ
d�Zd
�Zd�Zd�Zd�Zd�ZRS(cCsctj
|
||�}|_td
|j�
|j�
tjdkr_d�}t||�
ndS(Nscreated semlock with handle %stwin32c


Ss|jj
�
dS(
N(t_semlockt_after_fork(
tobj((s1/sys/lib/python2.7/multiprocessing/synchronize.pyRPs
(	t_multiprocessingRRRthandlet
_make_methodstsystplatformR
(tselftkindtvaluetmaxvaluetslR((s1/sys/lib/python2.7/multiprocessing/synchronize.pyt__init__Js




	c

Cs"|jj
|_
|jj|_dS(
N(Rtacquiretrelease(
R((s1/sys/lib/python2.7/multiprocessing/synchronize.pyRTs

c


Cs
|jj
�S(
N(Rt	__enter__(
R((s1/sys/lib/python2.7/multiprocessing/synchronize.pyR Xs
c
Gs|jj
|
�S(
N(Rt__exit__(Rtargs((s1/sys/lib/python2.7/multiprocessing/synchronize.pyR![s
c
Cs2t|�
|j
}
tj|
j�|
j|
jfS(
N(RRR
tduplicate_for_childRRR(RR((s1/sys/lib/python2.7/multiprocessing/synchronize.pyt__getstate__^s


	
cCs5tj
j|
�|_td
|
d�
|j�
dS(Ns recreated blocker with handle %ri(RRt_rebuildRRR(Rtstate((s1/sys/lib/python2.7/multiprocessing/synchronize.pyt__setstate__cs


(t__name__t
__module__RRR R!R$R'(((s1/sys/lib/python2.7/multiprocessing/synchronize.pyRHs	
				cBs&eZ
dd
�Zd�Zd�ZRS(i
cCstj
|t|
t�
dS(
N(RRt	SEMAPHOREt
SEM_VALUE_MAX(RR((s1/sys/lib/python2.7/multiprocessing/synchronize.pyRns
c


Cs
|jj
�S(
N(Rt
_get_value(
R((s1/sys/lib/python2.7/multiprocessing/synchronize.pyt	get_valueqs
c
Cs5y|jj
�}
Wntk
r,


d
}
n
Xd|
S(Ntunknowns<Semaphore(value=%s)>(RR,t	Exception(RR((s1/sys/lib/python2.7/multiprocessing/synchronize.pyt__repr__ts







(R(R)RR-R0(((s1/sys/lib/python2.7/multiprocessing/synchronize.pyRls	cBseZ
dd
�Zd�ZRS(i
cCstj
|t|
|
�
dS(
N(RRR*(RR((s1/sys/lib/python2.7/multiprocessing/synchronize.pyR�s
c
CsAy|jj
�}
Wntk
r,


d
}
n
Xd|
|jjfS(NR.s)<BoundedSemaphore(value=%s, maxvalue=%s)>(RR,R/R(RR((s1/sys/lib/python2.7/multiprocessing/synchronize.pyR0�s







(R(R)RR0(((s1/sys/lib/python2.7/multiprocessing/synchronize.pyRsc
BseZ
d�Zd
�ZRS(c

Cstj
|td
d
�
dS(Ni
(RRR*(
R((s1/sys/lib/python2.7/multiprocessing/synchronize.pyR�s
c
Cs�y�|jj
�rPt�j}
tj�jd
kr�|
dtj�j7}
q�nB|jj�dkrnd}
n$|jj�dkr�d}
nd}
Wntk
r�


d}
n
Xd	|
S(
Nt
MainThreadt
|i
tNoneitSomeOtherThreadtSomeOtherProcessR.s<Lock(owner=%s)>(	Rt_is_mineRtnamet	threadingtcurrent_threadR,t_countR/(RR7((s1/sys/lib/python2.7/multiprocessing/synchronize.pyR0�s






	

	





(R(R)RR0(((s1/sys/lib/python2.7/multiprocessing/synchronize.pyR�s	c
BseZ
d�Zd
�ZRS(c

Cstj
|td
d
�
dS(Ni
(RRtRECURSIVE_MUTEX(
R((s1/sys/lib/python2.7/multiprocessing/synchronize.pyR�s
c
Cs�y�|jj
�r_t�j}
tj�jd
krM|
dtj�j7}
n|jj�}nT|jj�dkr�d\}
}n0|jj�dkr�d\}
}nd
\}
}Wntk
r�


d\}
}n
Xd
|
|fS(NR1R2i
R3iR4tnonzeroR5R.s<RLock(%s, %s)>(sNonei(sSomeOtherThreadR<(sSomeOtherProcessR<(sunknownsunknown(	RR6RR7R8R9R:R,R/(RR7tcount((s1/sys/lib/python2.7/multiprocessing/synchronize.pyR0�s













(R(R)RR0(((s1/sys/lib/python2.7/multiprocessing/synchronize.pyR
�s	cBsheZ
d
d�Zd
�Zd�Zd�Zd�Zd�Zd�Z	d
d�Z
d�Zd	�ZRS(cCsM|
pt�|_
td
�|_td
�|_td
�|_|j�
dS(Ni(R
t_lockRt_sleeping_countt_woken_countt_wait_semaphoreR(Rtlock((s1/sys/lib/python2.7/multiprocessing/synchronize.pyR�s





c

Cs&t|�
|j
|j|j|jfS(
N(RR>R?R@RA(
R((s1/sys/lib/python2.7/multiprocessing/synchronize.pyR$�s



cCs,|
\|_|_
|_|_|j�
dS(
N(R>R?R@RAR(RR&((s1/sys/lib/python2.7/multiprocessing/synchronize.pyR'�s
c


Cs
|jj
�S(
N(R>R (
R((s1/sys/lib/python2.7/multiprocessing/synchronize.pyR �s
c
Gs|jj
|
�S(
N(R>R!(RR"((s1/sys/lib/python2.7/multiprocessing/synchronize.pyR!�s
c

Cs"|jj
|_
|jj|_dS(
N(R>RR(
R((s1/sys/lib/python2.7/multiprocessing/synchronize.pyR�s

c
CsQy&|jj
j�|jj
j�}
Wntk
r?


d
}
n
Xd|j|
fS(NR.s<Condition(%s, %s)>(R?RR,R@R/R>(Rtnum_waiters((s1/sys/lib/python2.7/multiprocessing/synchronize.pyR0�s







cCs�|jj
j�std
��|jj�
|jj
j�}x!t|�D]}|jj�
qJWz|jj	t
|
�
Wd|jj�
x!t|�D]}|jj	�
q�WXdS(Ns,must acquire() condition before using wait()(R>RR6tAssertionErrorR?RR:txrangeRARtTrueR@(RttimeoutR=t
i((s1/sys/lib/python2.7/multiprocessing/synchronize.pytwait�s

	




c
Cs�|jj
j�std
��|jjt�s7t�x4|jjt�rm|jjt�}
|
s:t�q:W|jjt�r�|jj	�
|jj�
|jjt�
ndS(Nslock is not owned(
R>RR6RDRARtFalseR@R?R(Rtres((s1/sys/lib/python2.7/multiprocessing/synchronize.pytnotify�s







c
Cs�|jj
j�std
��|jjt�s7t�x4|jjt�rm|jjt�}
|
s:t�q:Wd}x-|jjt�r�|jj	�
|d7}qwW|r�!t
|�D]}|jj�
q�Wx|jjt�r��WndS(Nslock is not ownedii
(R>RR6RDRARRJR@R?RRE(RRKtsleepersRH((s1/sys/lib/python2.7/multiprocessing/synchronize.pyt
notify_all
s










N(
R(R)R3RR$R'R R!RR0RIRLRN(((s1/sys/lib/python2.7/multiprocessing/synchronize.pyR�s							cBs8eZ
d�Zd
�Zd�Zd�Zdd�ZRS(c

Cs%tt
��|_td
�|_dS(Ni(RRt_condRt_flag(
R((s1/sys/lib/python2.7/multiprocessing/synchronize.pyR-
s

c

CsM|jj
�
z+|jj
t�r3|jj�
tStSWd|jj�
XdS(
N(RORRPRJRRF(
R((s1/sys/lib/python2.7/multiprocessing/synchronize.pytis_set1
s







c

CsP|jj
�
z.|jj
t�
|jj�
|jj�
Wd|jj�
XdS(
N(RORRPRJRRN(
R((s1/sys/lib/python2.7/multiprocessing/synchronize.pytset;
s






c

Cs6|jj
�
z|jj
t�
Wd|jj�
XdS(
N(RORRPRJR(
R((s1/sys/lib/python2.7/multiprocessing/synchronize.pytclearD
s



cCs|jj
�
z]|jj
t�r2|jj�
n|jj|
�
|jj
t�re|jj�
tStSWd|jj�
XdS(
N(RORRPRJRRIRF(RRG((s1/sys/lib/python2.7/multiprocessing/synchronize.pyRIK
s








N(R(R)RRQRRRSR3RI(((s1/sys/lib/python2.7/multiprocessing/synchronize.pyR+
s
		
			(t__all__R8tosRRt_timeRt_sleepRtmultiprocessing.processRtmultiprocessing.utilR	R
Rtmultiprocessing.forkingRR
RtImportErrortrangeR;R*R+tobjectRRRR
RR(((s1/sys/lib/python2.7/multiprocessing/synchronize.pyt<module>$s.










$h