File "synchronize.cpython-33.pyc"

Full Path: /home/attunedd/public_html/byp/izo/con7ext_sym404/rintoar.txt/opt/alt/python33/lib64/python3.3/multiprocessing/__pycache__/synchronize.cpython-33.pyc
File size: 17.62 KB
MIME-type: text/x-bytecode.python
Charset: 8 bit


f)c@s
dd
ddddgZddl
Z
ddlZddlZddlmZ
dd	lmZmZ
dd
l	m
Z
mZ
ddlmZ

yddlmZ
Wn*ek
r


ed
ddd

Yn
Xeed

\ZZejjZGdddeZGdddeZGdddeZGdddeZGdd
d
eZGdddeZGdddeZGddde
jZdS(uLockuRLocku	SemaphoreuBoundedSemaphoreu	ConditionuEventiN(
ucurrent_process(uregister_after_forkudebug(uassert_spawninguPopen(
utime(
uSemLocku*This platform lacks a functioning sem_openu( implementation, therefore, the requiredu+ synchronization primitives needed will notu function, see issue 3770.ic

Bs\|EeZ
dZd
dZddZddZddZd	d
ZddZd
S(uSemLockcCsftj
|
||}|_td
|j

|j
tjdkrbdd}t||
ndS(Nucreated semlock with handle %suwin32c


Ss|jj

dS(
N(u_semlocku_after_fork(
uobj((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu_after_fork5s
u%SemLock.__init__.<locals>._after_fork(	u_multiprocessinguSemLocku_semlockudebuguhandleu
_make_methodsusysuplatformuregister_after_fork(uselfukinduvalueumaxvalueuslu_after_fork((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu__init__/s




uSemLock.__init__c

Cs"|jj
|_
|jj|_dS(
N(u_semlockuacquireurelease(
uself((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu
_make_methods9s

uSemLock._make_methodsc


Cs
|jj
S(
N(u_semlocku	__enter__(
uself((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu	__enter__=s
uSemLock.__enter__c
Gs|jj
|
S(
N(u_semlocku__exit__(uselfuargs((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu__exit__@s
uSemLock.__exit__c
Cs2t|

|j
}
tj|
j
|
j|
jfS(
N(uassert_spawningu_semlockuPopenuduplicate_for_childuhandleukindumaxvalue(uselfusl((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu__getstate__Cs


	
uSemLock.__getstate__cCs5tj
j|
|_td
|
d

|j
dS(Nu recreated blocker with handle %ri(u_multiprocessinguSemLocku_rebuildu_semlockudebugu
_make_methods(uselfustate((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu__setstate__Hs


uSemLock.__setstate__N(	u__name__u
__module__u__qualname__u__init__u
_make_methodsu	__enter__u__exit__u__getstate__u__setstate__(
u
__locals__((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyuSemLock-s
uSemLockc

Bs;|EeZ
dZd
dd
ZddZddZdS(	u	Semaphorei
cCstj
|t|
t
dS(
N(uSemLocku__init__u	SEMAPHOREu
SEM_VALUE_MAX(uselfuvalue((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu__init__Ss
uSemaphore.__init__c


Cs
|jj
S(
N(u_semlocku
_get_value(
uself((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu	get_valueVs
uSemaphore.get_valuec
Cs6y|jj
}
Wntk
r-


d
}
Yn
Xd|
S(Nuunknownu<Semaphore(value=%s)>(u_semlocku
_get_valueu	Exception(uselfuvalue((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu__repr__Ys






uSemaphore.__repr__N(u__name__u
__module__u__qualname__u__init__u	get_valueu__repr__(
u
__locals__((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu	SemaphoreQsc

Bs/|EeZ
dZd
dd
ZddZdS(uBoundedSemaphorei
cCstj
|t|
|

dS(
N(uSemLocku__init__u	SEMAPHORE(uselfuvalue((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu__init__fs
uBoundedSemaphore.__init__c
CsBy|jj
}
Wntk
r-


d
}
Yn
Xd|
|jjfS(Nuunknownu)<BoundedSemaphore(value=%s, maxvalue=%s)>(u_semlocku
_get_valueu	Exceptionumaxvalue(uselfuvalue((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu__repr__is






uBoundedSemaphore.__repr__N(u__name__u
__module__u__qualname__u__init__u__repr__(
u
__locals__((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyuBoundedSemaphoredsc

Bs,|EeZ
dZd
dZddZdS(uLockc

Cstj
|td
d

dS(Ni
(uSemLocku__init__u	SEMAPHORE(
uself((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu__init__ws
u
Lock.__init__c
Csy|jj
rPtj}
tjjd
kr|
dtjj7}
qnB|jjdkrnd}
n$|jjdkrd}
nd}
Wntk
r


d}
Yn
Xd	|
S(
Nu
MainThreadu
|i
uNoneiuSomeOtherThreaduSomeOtherProcessuunknownu<Lock(owner=%s)>(	u_semlocku_is_mineucurrent_processunameu	threadingucurrent_threadu
_get_valueu_countu	Exception(uselfuname((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu__repr__zs






	

	




u
Lock.__repr__N(u__name__u
__module__u__qualname__u__init__u__repr__(
u
__locals__((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyuLockusc

Bs,|EeZ
dZd
dZddZdS(uRLockc

Cstj
|td
d

dS(Ni
(uSemLocku__init__uRECURSIVE_MUTEX(
uself((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu__init__s
uRLock.__init__c
Csy|jj
r_tj}
tjjd
krM|
dtjj7}
n|jj}nT|jjdkrd\}
}n0|jjdkrd\}
}nd
\}
}Wntk
r


d\}
}Yn
Xd
|
|fS(Nu
MainThreadu
|i
uNoneiuSomeOtherThreadunonzerouSomeOtherProcessuunknownu<RLock(%s, %s)>(uNonei(uSomeOtherThreadunonzero(uSomeOtherProcessunonzero(uunknownuunknown(	u_semlocku_is_mineucurrent_processunameu	threadingucurrent_threadu_countu
_get_valueu	Exception(uselfunameucount((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu__repr__s













uRLock.__repr__N(u__name__u
__module__u__qualname__u__init__u__repr__(
u
__locals__((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyuRLocksc

Bs|EeZ
dZdd
d
ZddZddZddZd	d
ZddZ	d
dZ
ddd
ZddZddZ
ddd
ZdS(u	ConditioncCsM|
pt|_
td

|_td

|_td

|_|j
dS(Ni(uRLocku_locku	Semaphoreu_sleeping_countu_woken_countu_wait_semaphoreu
_make_methods(uselfulock((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu__init__s





uCondition.__init__c

Cs&t|

|j
|j|j|jfS(
N(uassert_spawningu_locku_sleeping_countu_woken_countu_wait_semaphore(
uself((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu__getstate__s



uCondition.__getstate__cCs,|
\|_|_
|_|_|j
dS(
N(u_locku_sleeping_countu_woken_countu_wait_semaphoreu
_make_methods(uselfustate((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu__setstate__s
uCondition.__setstate__c


Cs
|jj
S(
N(u_locku	__enter__(
uself((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu	__enter__s
uCondition.__enter__c
Gs|jj
|
S(
N(u_locku__exit__(uselfuargs((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu__exit__s
uCondition.__exit__c

Cs"|jj
|_
|jj|_dS(
N(u_lockuacquireurelease(
uself((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu
_make_methodss

uCondition._make_methodsc
CsRy&|jj
j|jj
j}
Wntk
r@


d
}
Yn
Xd|j|
fS(Nuunknownu<Condition(%s, %s)>(u_sleeping_countu_semlocku
_get_valueu_woken_countu	Exceptionu_lock(uselfunum_waiters((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu__repr__s






uCondition.__repr__cCs|jj
jstd


|jj
|jj
j}x!t|
D]}|jj
qJWz|jj	d|
SWd|jj
x!t|
D]}|jj	
qWXdS(Nu,must acquire() condition before using wait()T(u_locku_semlocku_is_mineuAssertionErroru_sleeping_countureleaseu_counturangeu_wait_semaphoreuacquireuTrueu_woken_count(uselfutimeoutucountu
i((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyuwaits

	




uCondition.waitc
Cs|jj
jstd


|jjd
s7t
x4|jjd
rm|jjd
}
|
s:t
q:W|jjd
r|jj	
|jj
|jjd

ndS(Nulock is not ownedF(
u_locku_semlocku_is_mineuAssertionErroru_wait_semaphoreuacquireuFalseu_woken_countu_sleeping_counturelease(uselfures((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyunotifys







uCondition.notifyc
Cs|jj
jstd


|jjd
s7t
x4|jjd
rm|jjd
}
|
s:t
q:Wd}x-|jjd
r|jj	
|d7}qwW|rx!t
|
D]}|jj
qWx|jjd
rqWndS(Nulock is not ownedii
F(u_locku_semlocku_is_mineuAssertionErroru_wait_semaphoreuacquireuFalseu_woken_countu_sleeping_countureleaseurange(uselfuresusleepersu
i((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu
notify_alls










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

|
}q>W|S(Ni(uNoneu_timeuwait(uselfu	predicateutimeouturesultuendtimeuwaittime((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyuwait_for
s
	





	









uCondition.wait_forN(u__name__u
__module__u__qualname__uNoneu__init__u__getstate__u__setstate__u	__enter__u__exit__u
_make_methodsu__repr__uwaitunotifyu
notify_alluwait_for(
u
__locals__((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu	Conditionsc

BsS|EeZ
dZd
dZddZddZddZdd	d

ZdS(uEventc

Cs%tt

|_td

|_dS(Ni(u	ConditionuLocku_condu	Semaphoreu_flag(
uself((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu__init__$
s

uEvent.__init__c


CsM|jj

z+|jj
d

r3|jj
dSd
SWd|jj
XdS(NFT(u_conduacquireu_flaguFalseureleaseuTrue(
uself((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyuis_set(
s







uEvent.is_setc


CsP|jj

z.|jj
d


|jj
|jj
Wd|jj
XdS(NF(u_conduacquireu_flaguFalseureleaseu
notify_all(
uself((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyuset2
s






u	Event.setc


Cs6|jj

z|jj
d


Wd|jj
XdS(NF(u_conduacquireu_flaguFalseurelease(
uself((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyuclear;
s



uEvent.clearc
Cs|jj

z]|jj
d

r2|jj
n|jj|


|jj
d

re|jj
dSd
SWd|jj
XdS(NFT(u_conduacquireu_flaguFalseureleaseuwaituTrue(uselfutimeout((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyuwaitB
s








u
Event.waitN(	u__name__u
__module__u__qualname__u__init__uis_setusetuclearuNoneuwait(
u
__locals__((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyuEvent"
s

	c

Bs|EeZ
dZd
d
d
dZddZddZedd
Zej	d	d
Zed
d
Z
e
j	dd
Z
d
S(uBarriercCspd
dl}d
dl
m}
||jd
d
}t}|j|
||||f

d
|_d
|_dS(Ni(
u
BufferWrapperu
ii(ustructumultiprocessing.heapu
BufferWrapperucalcsizeu	Conditionu__setstate__u_stateu_count(uselfupartiesuactionutimeoutustructu
BufferWrapperuwrapperucond((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu__init__W
s



	

	
uBarrier.__init__cCsC|
\|_|_
|_|_|_|jjjd

|_dS(Nu
i(u_partiesu_actionu_timeoutu_condu_wrapperucreate_memoryviewucastu_array(uselfustate((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu__setstate__`
s$
uBarrier.__setstate__c

Cs"|j|j
|j|j|jfS(
N(u_partiesu_actionu_timeoutu_condu_wrapper(
uself((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu__getstate__e
s

uBarrier.__getstate__c

Cs|jd
S(Ni(
u_array(
uself((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu_statei
suBarrier._statecCs|
|jd
<dS(Ni(
u_array(uselfuvalue((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu_statem
sc

Cs|jd
S(Ni
(
u_array(
uself((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu_countq
suBarrier._countcCs|
|jd
<dS(Ni
(
u_array(uselfuvalue((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu_countu
sN(u__name__u
__module__u__qualname__uNoneu__init__u__setstate__u__getstate__upropertyu_stateusetteru_count(
u
__locals__((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyuBarrierU
s	uBarrier(u__all__u	threadingusysu_multiprocessingumultiprocessing.processucurrent_processumultiprocessing.utiluregister_after_forkudebugumultiprocessing.forkinguassert_spawninguPopenutimeu_timeuSemLockuImportErrorulisturangeuRECURSIVE_MUTEXu	SEMAPHOREu
SEM_VALUE_MAXuobjectu	SemaphoreuBoundedSemaphoreuLockuRLocku	ConditionuEventuBarrier(((u@/opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu<module>s.










$z3