File "util.pyc"

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


V~gc@s
dd
lZdd
l
Z
dd
lZdd
lZdd
lZddlmZ
ddlmZm	Z	
dddddd	d
ddd
ddddgZ
dZdZdZ
dZdZdZdZd
aeadZdZdZdZdZd
d
ZdZejZe
jZ d Z!d!Z"iZ#e
jZ$d
e%f
d"YZ&d
d#
Z'd$Z(ea)eee'e	ed%Z*ej+e*

de%f
d&YZ,dej-f
d'YZ.d
S((iN(
t_args_from_interpreter_flags(tcurrent_processtactive_childrent	sub_debugtdebugtinfotsub_warningt
get_loggert
log_to_stderrtget_temp_dirtregister_after_forkt
is_exitingtFinalizetForkAwareThreadLocktForkAwareLocaltSUBDEBUGt
SUBWARNINGiii
iitmultiprocessings+[%(levelname)s/%(processName)s] %(message)sc
Gs trtj
t||

ndS(
N(t_loggertlogR(tmsgtargs((s9/opt/alt/python27/lib64/python2.7/multiprocessing/util.pyRDs

c
Gs trtj
t||

ndS(
N(RRtDEBUG(RR((s9/opt/alt/python27/lib64/python2.7/multiprocessing/util.pyRHs

c
Gs trtj
t||

ndS(
N(RRtINFO(RR((s9/opt/alt/python27/lib64/python2.7/multiprocessing/util.pyRLs

c
Gs trtj
t||

ndS(
N(RRR(RR((s9/opt/alt/python27/lib64/python2.7/multiprocessing/util.pyRPs

cCsd
dl}d
dl
}
|j
zts|jt
adt_|jtd
|jt	d
t
|
dr|
jt

|
j
t

q|
jjtdif

|
jjtdif

nWd|j
XtS(	s0
    Returns logger used by multiprocessing
    iNiRRt
unregister(((tloggingtatexitt_acquireLockRt	getLoggertLOGGER_NAMEt	propagatetaddLevelNameRRthasattrRt_exit_functiontregistert
_exithandlerstremovetappendt_releaseLock(RR((s9/opt/alt/python27/lib64/python2.7/multiprocessing/util.pyRTs



	





 c
Csjd
dl}
t
}|
jt
}|
j}|j|

|j|

|r`|j|

nta	t
S(sB
    Turn on logging and add a handler which prints to stderr
    iN(RRt	FormattertDEFAULT_LOGGING_FORMATt
StreamHandlertsetFormattert
addHandlertsetLeveltTruet_log_to_stderrR(tlevelRtloggert	formatterthandler((s9/opt/alt/python27/lib64/python2.7/multiprocessing/util.pyRqs	








cCstj
dkrwd
dl}d
dl}
|
jdd
}td|
td|jd|g
dd
|t_
ntj
S(Nitprefixspymp-screated temp directory %sRtexitpriorityi(	R
t_tempdirtNonetshutilttempfiletmkdtempRRtrmtree(R7R8ttempdir((s9/opt/alt/python27/lib64/python2.7/multiprocessing/util.pyR	s






cCsqtt
j
}|j
xN|D]F\\}
}}}y||

Wq#tk
rh
}
td
|
q#Xq#WdS(Ns after forker raised exception %s(tlistt_afterfork_registrytitemstsortt	ExceptionR(R>tindextidenttfunctobjt
e((s9/opt/alt/python27/lib64/python2.7/multiprocessing/util.pyt_run_after_forkerss







cCs#|tt
jt|
|
f<dS(
N(R=t_afterfork_countertnexttid(RDRC((s9/opt/alt/python27/lib64/python2.7/multiprocessing/util.pyR
s
cBsGeZ
dZdddd
Zdd
ZdZdZdZRS(sA
    Class which supports object finalization using weakrefs
    cCs|dks*t
|
ttfks*t
|
dk	rNtj|
||_n|dk	s`t
||_||_	|p{i|_
|tjf|_
tj|_|t|j
<dS(
N(R6ttypetinttlongtAssertionErrortweakreftreft_weakreft	_callbackt_argst_kwargst_finalizer_counterRHt_keytostgetpidt_pidt_finalizer_registry(tselfRDtcallbackRtkwargsR4((s9/opt/alt/python27/lib64/python2.7/multiprocessing/util.pyt__init__s
*
	
	


cCsyt|j
=Wntk
r+


td


nX|jtjkrTtd

d}n4td|j|j	|j

|j|j	|j
}d|_|_|_	|_
|_
|SdS(sQ
        Run the callback unless it has already been called or cancelled
        sfinalizer no longer registereds+finalizer ignored because different processs/finalizer calling %s with args %s and kwargs %sN(RYRUtKeyErrorRRXRVRWR6RQRRRSRP(RZtwrtres((s9/opt/alt/python27/lib64/python2.7/multiprocessing/util.pyt__call__s






	

%
c

CsKyt|j
=Wntk
r!


n&Xd
|_|_|_|_|_
d
S(s3
        Cancel finalization of the object
        N(RYRUR^R6RPRQRRRS(
RZ((s9/opt/alt/python27/lib64/python2.7/multiprocessing/util.pytcancels




c

Cs
|jt
kS(
sS
        Return whether this finalizer is still waiting to invoke callback
        (RURY(
RZ((s9/opt/alt/python27/lib64/python2.7/multiprocessing/util.pytstill_activesc
Csy|j}
Wnt
tfk
r/


d}
n
X|
dkr@d
Sdt|jd|j}|jr|dt|j
7}n|jr|dt|j
7}n|j	ddk	r|dt|j	d
7}n|dS(	Ns<Finalize object, dead>s<Finalize object, callback=%st__name__s, args=s	, kwargs=is, exitprority=t
>(
RPtAttributeErrort	TypeErrorR6tgetattrRQRRtstrRSRU(RZRDt
x((s9/opt/alt/python27/lib64/python2.7/multiprocessing/util.pyt__repr__s







	

	



(N(	Rdt
__module__t__doc__R6R]RaRbRcRk(((s9/opt/alt/python27/lib64/python2.7/multiprocessing/util.pyRs
		c
std
krd
Sd
kr(d}
nf
d}
gtjD]}|
|
rD|^qD}|jdt

xV|D]N\}}td|
y|
Wqytk
r


dd
l}|j
qyXqyWd
krtj	
nd
S(s
    Run all finalizers whose exit priority is not None and at least minpriority

    Finalizers with highest priority are called first; finalizers with
    the same priority will be called in reverse order of creation.
    Nc

Ss|d
d
dk	S(Ni(
R6(
t
p((s9/opt/alt/python27/lib64/python2.7/multiprocessing/util.pyt<lambda>
tc

s&|d
d
dk	o%|d
d
kS(Ni(
R6(
Rn(
tminpriority(s9/opt/alt/python27/lib64/python2.7/multiprocessing/util.pyRo

Rptreverses
calling %si(
RYR6R>R?R-RR@t	tracebackt	print_exctclear(Rqt
fRjR>tkeyt	finalizerRs((
Rqs9/opt/alt/python27/lib64/python2.7/multiprocessing/util.pyt_run_finalizerss 
+









cCstptd
kS(s6
    Returns true if the process is shutting down
    N(t_exitingR6(((s9/opt/alt/python27/lib64/python2.7/multiprocessing/util.pyR!
scCs|d


|
d

|d

|dk	rx:|D]/}|j
r7|d|j
|jj
q7q7Wx.|D] }|d|j
|j
qtWn|
d

|
dS(Nsprocess shutting downs2running all "atexit" finalizers with priority >= 0is!calling terminate() for daemon %sscalling join() for process %ss)running the remaining "atexit" finalizers(R6t	_daemonictnamet_popent	terminatetjoin(RRRyRR
Rn((s9/opt/alt/python27/lib64/python2.7/multiprocessing/util.pyR!)
s	





	





c
BseZ
dZd
ZRS(c

Cs|j
t
|tj
dS(
N(t_resetR
R
(
RZ((s9/opt/alt/python27/lib64/python2.7/multiprocessing/util.pyR]T
s


c

Cs1tj
|_|jj|_|jj|_dS(
N(t	threadingtLockt_locktacquiretrelease(
RZ((s9/opt/alt/python27/lib64/python2.7/multiprocessing/util.pyRX
s


(RdRlR]R(((s9/opt/alt/python27/lib64/python2.7/multiprocessing/util.pyR
S
s
	c
BseZ
dZd
ZRS(c

Cst|d

dS(Nc


Ss
|jj
S(
N(t__dict__Ru(
RD((s9/opt/alt/python27/lib64/python2.7/multiprocessing/util.pyRo_
Rp(
R
(
RZ((s9/opt/alt/python27/lib64/python2.7/multiprocessing/util.pyR]^
s
c

Cst|
d
fS(N((
RJ(
RZ((s9/opt/alt/python27/lib64/python2.7/multiprocessing/util.pyt
__reduce__`
s
(RdRlR]R(((s9/opt/alt/python27/lib64/python2.7/multiprocessing/util.pyR]
s
	(/RVt	itertoolsRNRRt
subprocessRtmultiprocessing.processR
Rt__all__tNOTSETRRRRRR(R6RtFalseR.RRRRRRR	tWeakValueDictionaryR=tcountRGRFR
RYRTtobjectRRyRRzR!R"R
tlocalR(((s9/opt/alt/python27/lib64/python2.7/multiprocessing/util.pyt<module>#sT




	







						
			
N'		

"