File "queues.pyc"

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


V~gc@s>
dd
dgZddl
Z
ddlZddlZddlZddlZddlZddlZddlm	Z	m
Z

ddlZddlm
Z

ddlmZmZmZmZ
dd	lmZmZmZmZmZ
dd
lmZ
def
dYZeZdef
dYZd
ef
d
YZdS(tQueuetSimpleQueuet
JoinableQueueiN(tEmptytFulli
(
tPipe(tLocktBoundedSemaphoret	Semaphoret	Condition(tdebugtinfotFinalizetregister_after_forkt
is_exiting(
tassert_spawningcBseZ
dd

ZdZdZdZeddZeddZ	dZ
dZd	Zd
Z
dZdZd
ZdZdZed
Zed
Zed
ZRS(icCs|
d
k
rtj
j}
n|
|_tdt
\|_|_t|_	t
j|_t
jdkrud|_nt|_t|

|_|j
t
jdkrt|tj
ndS(Nitduplextwin32(t_multiprocessingtSemLockt
SEM_VALUE_MAXt_maxsizeRtFalset_readert_writerRt_rlocktostgetpidt_opidtsystplatformtNonet_wlockRt_semt_after_forkR
R(tselftmaxsize((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyt__init__:s


	







c

Cs8t|

|j
|j|j|j|j|j|jfS(
N(RRRRRR R!R(
R#((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyt__getstate__Ls



cCs>|
\|_|_
|_|_|_|_|_|j
dS(
N(RRRRR R!RR"(R#tstate((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyt__setstate__Qs0
c

Cstd


t
jt
j
|_tj|_d|_	d|_
t|_t|_
d|_|jj|_|jj|_|jj|_dS(NsQueue._after_fork()(R
t	threadingR	Rt	_notemptytcollectionstdequet_bufferRt_threadt_jointhreadRt_joincancelledt_closedt_closeRtsendt_sendRtrecvt_recvtpollt_poll(
R#((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyR"Vs




	
	
	
	
	


cCs|jst

|jj||s.t
n|jj
z=|jdkrZ|j
n|j	j
|


|jj
Wd|jj
XdS(
N(
R1tAssertionErrorR!tacquireRR*R.Rt
_start_threadR-tappendtnotifytrelease(R#tobjtblockttimeout((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pytputcs


	






cCs
|
rT|dkrT|j
j
z!|j}|jj
|SWd|j
j
Xn|
rmtj|}n|j
j|
|st
nzg|
r|tj}|j|
st
qn|jst
n|j}|jj
|SWd|j
j
XdS(
N(	RRR:R6R!R>ttimeRR8(R#R@RAtrestdeadline((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pytgetqs,










	






	



c

Cs|j|j
jjS(
N(RR!t_semlockt
_get_value(
R#((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pytqsizesc


Cs|jS(
N(
R8(
R#((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pytemptys
c


Cs|jj
jS(
N(R!RGt_is_zero(
R#((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pytfulls
c

Cs
|jt

S(
N(RFR(
R#((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyt
get_nowaits
cCs|j|
t
S(
N(RBR(R#R?((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyt
put_nowaits
c
CsDt|_
z|jj
Wd|j}
|
r?d|_|

nXdS(
N(tTrueR1RtcloseR2R(R#RP((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyRPs
	

	

	
c

Cs3td


|j
st
|jr/|j
ndS(NsQueue.join_thread()(R
R1R9R/(
R#((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pytjoin_threads



	
c

Cs<td


t
|_y|jj
Wntk
r7


n
XdS(NsQueue.cancel_join_thread()(R
ROR0R/tcanceltAttributeError(
R#((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pytcancel_join_threads


	




c

	Cstd


|j
j
tjdtjd|j
|j|j|j	|j
jfdd|_t
|j_td

|jj
td

|jst|jtjtj|j
g
dd	
|_nt|tj|j
|jgdd

|_dS(NsQueue._start_thread()ttargettargstnametQueueFeederThreadsdoing self._thread.start()s... done self._thread.start()texitpriorityii
(R
R-tclearR)tThreadRt_feedR*R4R RRPR.ROtdaemontstartR0Rt_finalize_jointweakreftrefR/t_finalize_closeR2(
R#((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyR;s(



	
	







	




	

c
CsDtd


|}
|
dk	r6|
j
td

n
td

dS(Nsjoining queue threads... queue thread joineds... queue thread already dead(R
Rtjoin(ttwrtthread((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyR_s

	




cCsAtd


|
j

z|jt

|
j
Wd|
j
XdS(Nstelling queue thread to quit(R
R:R<t	_sentinelR=R>(tbuffertnotempty((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyRbs






cCs[
td


|
j
}|
j}|
j}|j}t}	tjdkrX|j
}
|j}nd}
xy|
z|s~|
nWd|
Xynxg|}||	krtd

|
dS|
dkr||

q|

z||

Wd|
XqWWnt	k
r



n
XWqat
k
rR

}

tr9
td|

dSddl
}|j
qaXqaWdS(Ns$starting thread to feed data to pipeRs%feeder thread got sentinel -- exitingserror in queue thread: %si(R
R:R>twaittpopleftRfRRRt
IndexErrort	ExceptionRRt	tracebackt	print_exc(RgRhR3t	writelockRPtnacquiretnreleasetnwaittbpoplefttsentineltwacquiretwreleaseR?t
eRm((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyR\sL

	
	
	
	


	








	












	



N(t__name__t
__module__R%R&R(R"RORRBRFRIRJRLRMRNRPRQRTR;tstaticmethodR_RbR\(((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyR8s$			
						
			 

cBsGeZ
dd

ZdZdZeddZdZdZ	RS(icCs/tj
||

td

|_t|_dS(Ni(RR%Rt_unfinished_tasksR	t_cond(R#R$((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyR%)
s


c

Cstj
|
|j|jfS(
N(RR&R|R{(
R#((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyR&.
s
cCs.tj
||
d
 
|
d
\|_|_dS(Ni(RR(R|R{(R#R'((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyR(1
s

cCs|jst

|jj||s.t
n|jj
|jj
zJ|jdkrg|j	
n|j
j|


|jj

|jj
Wd|jj

|jj

XdS(
N(R1R9R!R:RR*R|R.RR;R-R<R{R>R=(R#R?R@RA((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyRB5
s


	












c

Csi|jj

zG|jj
t
s1td


n|jjjrS|jj
nWd|jj
XdS(Ns!task_done() called too many times(	R|R:R{Rt
ValueErrorRGRKt
notify_allR>(
R#((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyt	task_doneF
s






c

CsH|jj

z&|jjjs2|jj
nWd|jj
XdS(
N(R|R:R{RGRKRiR>(
R#((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyRcP
s





N(
RxRyR%R&R(RORRBRRc(((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyR'
s			
c
Bs5eZ
dZd
ZdZdZdZRS(c

Cs\td
t

\|_|_t|_tjdkrBd|_	nt|_	|j

dS(NRR(RRRRRRRRRR t
_make_methods(
R#((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyR%^
s




c


Cs|jj
S(
N(RR7(
R#((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyRJg
s
c

Cs&t|

|j
|j|j|jfS(
N(RRRRR (
R#((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyR&j
s


cCs,|
\|_|_
|_|_|j
dS(
N(RRRR R(R#R'((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyR(n
s

c
s|jj

|jj|jj
fd
}
|
|_|jdkrd|jj	|_
nC|jj	|jj|jjfd}||_
dS(Ncs!
z
SWd
XdS(
N(((tracquireR5trrelease(s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyRFu
s


c

s$

z|
SWd
XdS(
N((
R?(R3RuRv(s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyRB
s


(RR5RR:R>RFR RRR3RB(R#RFRB((RR5RR3RuRvs;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyRr
s


	

(RxRyR%RJR&R(R(((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyR
\
s
					(t__all__RRR)R+RCtatexitR`RRRRtRtsynchronizeRRRR	tutilR
RRR
RtforkingRtobjectRfRR
(((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyt<module>#s"








"
(
	
5