File "synchronize.pyc"

Full Path: /home/attunedd/public_html/byp/izo/con7ext_sym404/rintoar.txt/lib64/python2.7/multiprocessing/synchronize.pyc
File size: 10.77 KB
MIME-type: text/x-bytecode.python
Charset: 8 bit


{fc@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
dYZdef
dYZdef
dYZdef
dYZd
ef
dYZdef
dYZdef
dYZdS(tLocktRLockt	SemaphoretBoundedSemaphoret	ConditiontEventiN(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
dZd
ZdZdZdZdZRS(cCsctj
|
||}|_td
|j

|j
tjdkr_d}t||
ndS(Nscreated semlock with handle %stwin32c


Ss|jj

dS(
N(t_semlockt_after_fork(
tobj((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyRPs
(	t_multiprocessingRRRthandlet
_make_methodstsystplatformR
(tselftkindtvaluetmaxvaluetslR((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyt__init__Js




	c

Cs"|jj
|_
|jj|_dS(
N(Rtacquiretrelease(
R((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyRTs

c


Cs
|jj
S(
N(Rt	__enter__(
R((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyR Xs
c
Gs|jj
|
S(
N(Rt__exit__(Rtargs((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyR![s
c
Cs2t|

|j
}
tj|
j
|
j|
jfS(
N(RRR
tduplicate_for_childRRR(RR((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyt__getstate__^s


	
cCs5tj
j|
|_td
|
d

|j
dS(Ns recreated blocker with handle %ri(RRt_rebuildRRR(Rtstate((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyt__setstate__cs


(t__name__t
__module__RRR R!R$R'(((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyRHs	
				cBs&eZ
dd

ZdZdZRS(i
cCstj
|t|
t
dS(
N(RRt	SEMAPHOREt
SEM_VALUE_MAX(RR((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyRns
c


Cs
|jj
S(
N(Rt
_get_value(
R((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyt	get_valueqs
c
Cs5y|jj
}
Wntk
r,


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







(R(R)RR-R0(((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyRls	cBseZ
dd

ZdZRS(i
cCstj
|t|
|

dS(
N(RRR*(RR((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyRs
c
CsAy|jj
}
Wntk
r,


d
}
n
Xd|
|jjfS(NR.s)<BoundedSemaphore(value=%s, maxvalue=%s)>(RR,R/R(RR((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyR0s







(R(R)RR0(((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyRsc
BseZ
dZd
ZRS(c

Cstj
|td
d

dS(Ni
(RRR*(
R((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyRs
c
Csy|jj
rPtj}
tjjd
kr|
dtjj7}
qnB|jjdkrnd}
n$|jjdkrd}
nd}
Wntk
r


d}
n
Xd	|
S(
Nt
MainThreadt
|i
tNoneitSomeOtherThreadtSomeOtherProcessR.s<Lock(owner=%s)>(	Rt_is_mineRtnamet	threadingtcurrent_threadR,t_countR/(RR7((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyR0s






	

	





(R(R)RR0(((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyRs	c
BseZ
dZd
ZRS(c

Cstj
|td
d

dS(Ni
(RRtRECURSIVE_MUTEX(
R((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyRs
c
Csy|jj
r_tj}
tjjd
krM|
dtjj7}
n|jj}nT|jjdkrd\}
}n0|jjdkrd\}
}nd
\}
}Wntk
r


d\}
}n
Xd
|
|fS(NR1R2i
R3iR4tnonzeroR5R.s<RLock(%s, %s)>(R3i(R4R<(R5R<(R.R.(	RR6RR7R8R9R:R,R/(RR7tcount((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyR0s













(R(R)RR0(((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyR
s	cBsheZ
d
d
Zd
ZdZdZdZdZdZ	d
d
Z
dZd	ZRS(cCsM|
pt|_
td

|_td

|_td

|_|j
dS(Ni(R
t_lockRt_sleeping_countt_woken_countt_wait_semaphoreR(Rtlock((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyRs





c

Cs&t|

|j
|j|j|jfS(
N(RR>R?R@RA(
R((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyR$s



cCs,|
\|_|_
|_|_|j
dS(
N(R>R?R@RAR(RR&((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyR's
c


Cs
|jj
S(
N(R>R (
R((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyR s
c
Gs|jj
|
S(
N(R>R!(RR"((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyR!s
c

Cs"|jj
|_
|jj|_dS(
N(R>RR(
R((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyRs

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((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyR0s







cCs|jj
jstd


|jj
|jj
j}x!t|
D]}|jj
qJWz|jj	t
|

Wd|jj
x!t|
D]}|jj	
qWXdS(Ns,must acquire() condition before using wait()(R>RR6tAssertionErrorR?RR:txrangeRARtTrueR@(RttimeoutR=t
i((s3/usr/lib64/python2.7/multiprocessing/synchronize.pytwaits

	




c
Cs|jj
jstd


|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((s3/usr/lib64/python2.7/multiprocessing/synchronize.pytnotifys







c
Cs|jj
jstd


|jjt
s7t
x4|jjt
rm|jjt
}
|
s:t
q:Wd}x-|jjt
r|jj	
|d7}qwW|rx!t
|
D]}|jj
qWx|jjt
rqWndS(Nslock is not ownedii
(R>RR6RDRARRJR@R?RRE(RRKtsleepersRH((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyt
notify_all
s










N(
R(R)R3RR$R'R R!RR0RIRLRN(((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyRs							cBs8eZ
dZd
ZdZdZdd
ZRS(c

Cs%tt

|_td

|_dS(Ni(RRt_condRt_flag(
R((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyR-
s

c

CsM|jj

z+|jj
t
r3|jj
tStSWd|jj
XdS(
N(RORRPRJRRF(
R((s3/usr/lib64/python2.7/multiprocessing/synchronize.pytis_set1
s







c

CsP|jj

z.|jj
t

|jj
|jj
Wd|jj
XdS(
N(RORRPRJRRN(
R((s3/usr/lib64/python2.7/multiprocessing/synchronize.pytset;
s






c

Cs6|jj

z|jj
t

Wd|jj
XdS(
N(RORRPRJR(
R((s3/usr/lib64/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((s3/usr/lib64/python2.7/multiprocessing/synchronize.pyRIK
s








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








$h