Name	Size	Mode	Actions
dummy/	-	0755	rm
connection.py	12663	0644	editdlrm
connection.pyc	14216	0644	editdlrm
connection.pyo	14066	0644	editdlrm
forking.py	14538	0644	editdlrm
forking.pyc	14248	0644	editdlrm
forking.pyo	14084	0644	editdlrm
heap.py	5748	0644	editdlrm
heap.pyc	6478	0644	editdlrm
heap.pyo	6097	0644	editdlrm
managers.py	34804	0644	editdlrm
managers.pyc	38244	0644	editdlrm
managers.pyo	37630	0644	editdlrm
pool.py	17699	0644	editdlrm
pool.pyc	18531	0644	editdlrm
pool.pyo	18072	0644	editdlrm
process.py	7904	0644	editdlrm
process.pyc	9482	0644	editdlrm
process.pyo	8728	0644	editdlrm
queues.py	11089	0644	editdlrm
queues.pyc	11626	0644	editdlrm
queues.pyo	11523	0644	editdlrm
reduction.py	5124	0644	editdlrm
reduction.pyc	6000	0644	editdlrm
reduction.pyo	6000	0644	editdlrm
sharedctypes.py	6145	0644	editdlrm
sharedctypes.pyc	8501	0644	editdlrm
sharedctypes.pyo	8421	0644	editdlrm
synchronize.py	8966	0644	editdlrm
synchronize.pyc	10436	0644	editdlrm
synchronize.pyo	10098	0644	editdlrm
util.py	7839	0644	editdlrm
util.pyc	9684	0644	editdlrm
util.pyo	9589	0644	editdlrm
__init__.py	7627	0644	editdlrm
__init__.pyc	8317	0644	editdlrm
__init__.pyo	8317	0644	editdlrm

�� �gc@s�
dd
ddddgZddk
Z
ddkZddkZddklZlZ
ddkZdd k l Z
dd klZl Z lZ
ddklZlZ
yddklZ
Wn+ej o



ed ddd�
�
n
Xed�
\ZZeiiZdef
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�ZRS(cCseti
|
||�}|_td
|i�

|i�
tidjo
d�}t||�
n

dS(Nscreated semlock with handle %stwin32c


Ss|ii
�
dS(
N(t_semlockt_after_fork(
tobj((s1/usr/lib/python2.6/multiprocessing/synchronize.pyR6s
( t_multiprocessingRRRthandlet _make_methodstsystplatformR (tselftkindtvaluetmaxvaluetslR((s1/usr/lib/python2.6/multiprocessing/synchronize.pyt__init__0s



c

Cs@|ii
|_
|ii|_|ii|_|ii|_dS(
N(Rtacquiretreleaset __enter__t__exit__(
R((s1/usr/lib/python2.6/multiprocessing/synchronize.pyR:s



c
Cs2t|�

|i
}
ti|
i�
|
i|
ifS(
N(RRR tduplicate_for_childRRR(RR((s1/usr/lib/python2.6/multiprocessing/synchronize.pyt__getstate__@s


cCs5ti
i|
�|_td
|
d�

|i�
dS(Ns recreated blocker with handle %ri(RRt_rebuildRRR(Rtstate((s1/usr/lib/python2.6/multiprocessing/synchronize.pyt__setstate__Es


(t__name__t __module__RRR#R&(((s1/usr/lib/python2.6/multiprocessing/synchronize.pyR.s  cBs&eZ
dd
�
Zd�Zd�ZRS(i
cCsti
|t|
t�
dS(
N(RRt SEMAPHOREt SEM_VALUE_MAX(RR((s1/usr/lib/python2.6/multiprocessing/synchronize.pyRPs
c


Cs |ii
�S(
N(Rt _get_value(
R((s1/usr/lib/python2.6/multiprocessing/synchronize.pyt get_valueSs
c
Cs7y|ii
�}
Wntj o



d
}
n
Xd|
S(Ntunknowns(RR+t Exception(RR((s1/usr/lib/python2.6/multiprocessing/synchronize.pyt__repr__Vs




(R'R(RR,R/(((s1/usr/lib/python2.6/multiprocessing/synchronize.pyRNs cBseZ
dd
�
Zd�ZRS(i
cCsti
|t|
|
�
dS(
N(RRR)(RR((s1/usr/lib/python2.6/multiprocessing/synchronize.pyRcs
c
CsCy|ii
�}
Wntj o



d
}
n
Xd|
|iifS(NR-s)(RR+R.R(RR((s1/usr/lib/python2.6/multiprocessing/synchronize.pyR/fs





(R'R(RR/(((s1/usr/lib/python2.6/multiprocessing/synchronize.pyRasc
BseZ
d�Zd
�ZRS(c

Csti
|td
d
�
dS(Ni
(RRR)(
R((s1/usr/lib/python2.6/multiprocessing/synchronize.pyRts
c
Cs�y�|ii
�oA
t�i}
ti�id
jo
|
dti�i7}
q�
nG
|ii�djo
d}
n'
|ii�djo
d}
n
d}
Wntj o



d}
n
Xd |
S( Nt MainThreadt
|i
tNoneitSomeOtherThreadtSomeOtherProcessR-s( Rt_is_mineRtnamet threadingtcurrent_threadR+t_countR.(RR6((s1/usr/lib/python2.6/multiprocessing/synchronize.pyR/ws











(R'R(RR/(((s1/usr/lib/python2.6/multiprocessing/synchronize.pyRrs c
BseZ
d�Zd
�ZRS(c

Csti
|td
d
�
dS(Ni
(RRtRECURSIVE_MUTEX(
R((s1/usr/lib/python2.6/multiprocessing/synchronize.pyR�s
c
Cs�y�|ii
�oP
t�i}
ti�id
jo
|
dti�i7}
n

|ii�}nY
|ii�djo
d\}
}n3
|ii�djo
d\}
}n
d \}
}Wntj o



d\}
}n
Xd |
|fS(NR0R1i
R2iR3tnonzeroR4R-s(sNonei(sSomeOtherThreadR;(sSomeOtherProcessR;(sunknownsunknown( RR5RR6R7R8R9R+R.(RR6tcount((s1/usr/lib/python2.6/multiprocessing/synchronize.pyR/�s












(R'R(RR/(((s1/usr/lib/python2.6/multiprocessing/synchronize.pyR
�s cBsVeZ
dd�
Zd
�Zd�Zd�Zd�Zdd�
Zd�Z d�Z RS( cCsN|
p
t�|_
td
�
|_td
�
|_td
�
|_|i�
dS(Ni(R
t_lockRt_sleeping_countt_woken_countt_wait_semaphoreR(Rtlock((s1/usr/lib/python2.6/multiprocessing/synchronize.pyR�s




c

Cs&t|�

|i
|i|i|ifS(
N(RR=R>R?R@(
R((s1/usr/lib/python2.6/multiprocessing/synchronize.pyR#�s


cCs,|
\|_|_
|_|_|i�
dS(
N(R=R>R?R@R(RR%((s1/usr/lib/python2.6/multiprocessing/synchronize.pyR&�s
c

Cs@|ii
|_
|ii|_|ii|_|ii|_dS(
N(R=RRR R!(
R((s1/usr/lib/python2.6/multiprocessing/synchronize.pyR�s



c
CsSy&|ii
i�|ii
i�}
Wntj o



d
}
n
Xd|i|
fS(Ntunkowns(R>RR+R?R.R=(Rtnum_waiters((s1/usr/lib/python2.6/multiprocessing/synchronize.pyR/�s





cCs�|ii
�
|iii�}x!t|�
D]}|ii
�
q,Wz|iit|
�
Wd|i i
�
x!t|�
D]}|ii�
qwWXdS(
N( R>RR=RR9txrangeR@RtTrueR?(RttimeoutR<t
i((s1/usr/lib/python2.6/multiprocessing/synchronize.pytwait�s 

  
c
Csrx*|ii
t�
o
|ii
t�
}
q
W|ii
t�
o.
|ii�
|ii
�
|ii
t�

n

dS(
N(R?RtFalseR>R@R(Rtres((s1/usr/lib/python2.6/multiprocessing/synchronize.pytnotify�s



c
Cs�x*|ii
t�
o
|ii
t�
}
q
Wd
}x/|ii
t�
o
|ii�
|d7}q6
W|oC
x!t|�
D]}|ii
�
qyWx|ii
t�
o
q�
Wn

dS(Nii
(R?RRIR>R@RRD(RRJtsleepersRG((s1/usr/lib/python2.6/multiprocessing/synchronize.pyt notify_all�s 







N(R'R(R2RR#R&RR/RHRKRM(((s1/usr/lib/python2.6/multiprocessing/synchronize.pyR�s     cBs8eZ
d�Zd
�Zd�Zd�Zdd�
ZRS(c

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

c

CsO|ii
�
z-|ii
t�
o
|ii�
tS
tSWd|ii�
XdS(
N(RNRRORIRRE(
R((s1/usr/lib/python2.6/multiprocessing/synchronize.pytis_set
s





c

CsP|ii
�
z.|ii
t�

|ii�
|ii�
Wd|ii�
XdS(
N(RNRRORIRRM(
R((s1/usr/lib/python2.6/multiprocessing/synchronize.pytset
s




c

Cs6|ii
�
z|ii
t�

Wd|ii�
XdS(
N(RNRRORIR(
R((s1/usr/lib/python2.6/multiprocessing/synchronize.pytclear"
s


cCsZ|ii
�
z8|ii
t�
o
|ii�
n
|ii|
�

Wd|ii�
XdS(
N(RNRRORIRRH(RRF((s1/usr/lib/python2.6/multiprocessing/synchronize.pyRH)
s



N(R'R(RRPRQRRR2RH(((s1/usr/lib/python2.6/multiprocessing/synchronize.pyR
s   (t__all__R7tosRRt_timeRt_sleepRtmultiprocessing.processRtmultiprocessing.utilR R Rtmultiprocessing.forkingRR RtImportErrortrangeR:R)R*tobjectRRRR
RR(((s1/usr/lib/python2.6/multiprocessing/synchronize.pyt s.









 d