File "util.cpython-33.pyc"

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

 
Open Edit   Advanced Editor   Back 

f&c@sddlZddlZddlZddlZddlZddlZddlZddlmZddl	m
Z
mZdddddd	d
ddd
ddddgZdZ
dZdZdZdZdZdZdad*addZddZddZddZddZddd	Zdd
ZejZ ej!Z"dd Z#d!dZ$iZ%ej!Z&Gd"d
d
e'Z(dd#d$Z)d%dZ*d*a+eee)ee
d&d'Z,ej-e,Gd(dde'Z.Gd)ddej/Z0dS(+iN(u_args_from_interpreter_flags(ucurrent_processuactive_childrenu	sub_debugudebuguinfousub_warningu
get_loggeru
log_to_stderruget_temp_diruregister_after_forku
is_exitinguFinalizeuForkAwareThreadLockuForkAwareLocaluSUBDEBUGu
SUBWARNINGii
iiumultiprocessingu+[%(levelname)s/%(processName)s] %(message)scGs trtjt||ndS(N(u_loggeruloguSUBDEBUG(umsguargs((u9/opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu	sub_debug-scGs trtjt||ndS(N(u_loggeruloguDEBUG(umsguargs((u9/opt/alt/python33/lib64/python3.3/multiprocessing/util.pyudebug1scGs trtjt||ndS(N(u_loggeruloguINFO(umsguargs((u9/opt/alt/python33/lib64/python3.3/multiprocessing/util.pyuinfo5scGs trtjt||ndS(N(u_loggerulogu
SUBWARNING(umsguargs((u9/opt/alt/python33/lib64/python3.3/multiprocessing/util.pyusub_warning9sc
Csddl}|jzts|jtadt_|jtd|jtdt	t
drt
jtt
j
tqt
jjtfift
jjtfifnWd|jXtS(u0
    Returns logger used by multiprocessing
    iNuSUBDEBUGu
SUBWARNINGu
unregister(uloggingu_acquireLocku_loggeru	getLoggeruLOGGER_NAMEu	propagateuaddLevelNameuSUBDEBUGu
SUBWARNINGuhasattruatexitu
unregisteru_exit_functionuregisteru
_exithandlersuremoveuappendu_releaseLock(ulogging((u9/opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu
get_logger=s
	
 cCsjddl}t}|jt}|j}|j||j||r`|j|nda	t
S(uB
    Turn on logging and add a handler which prints to stderr
    iNT(uloggingu
get_loggeru	FormatteruDEFAULT_LOGGING_FORMATu
StreamHandlerusetFormatteru
addHandlerusetLeveluTrueu_log_to_stderru_logger(ulevelulogginguloggeru	formatteruhandler((u9/opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu
log_to_stderrZs	

cCstjdkrwddl}ddl}|jdd}td|td|jd|gdd|t_ntjS(	Niuprefixupymp-ucreated temp directory %suargsuexitpriorityidi(	ucurrent_processu_tempdiruNoneushutilutempfileumkdtempuinfouFinalizeurmtree(ushutilutempfileutempdir((u9/opt/alt/python33/lib64/python3.3/multiprocessing/util.pyuget_temp_dirps
cCsttj}|jx`|D]X\\}}}}y||Wq#tk
rz}ztd|WYdd}~Xq#Xq#WdS(Nu after forker raised exception %s(ulistu_afterfork_registryuitemsusortu	Exceptionuinfo(uitemsuindexuidentufuncuobjue((u9/opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu_run_after_forkerss
u_run_after_forkerscCs#|tttt||f<dS(N(u_afterfork_registryunextu_afterfork_counteruid(uobjufunc((u9/opt/alt/python33/lib64/python3.3/multiprocessing/util.pyuregister_after_forkscBsn|EeZdZdZfddddZdeeej	ddZ
ddZdd	Zd
dZ
dS(
uFinalizeuA
    Class which supports object finalization using weakrefs
    cCs|dks$t|tks$t|dk	rHtj|||_n|dk	sZt||_||_|pui|_	|t
tf|_t
j|_|t|j<dS(N(uNoneutypeuintuAssertionErroruweakrefurefu_weakrefu	_callbacku_argsu_kwargsunextu_finalizer_counteru_keyuosugetpidu_pidu_finalizer_registry(uselfuobjucallbackuargsukwargsuexitpriority((u9/opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu__init__s$		uFinalize.__init__c
Csy||j=Wntk
r,|dYnX|j|krR|dd}n4|d|j|j|j|j|j|j}d|_|_|_|_|_|SdS(uQ
        Run the callback unless it has already been called or cancelled
        ufinalizer no longer registeredu+finalizer ignored because different processu/finalizer calling %s with args %s and kwargs %sN(u_keyuKeyErroru_piduNoneu	_callbacku_argsu_kwargsu_weakref(uselfuwru_finalizer_registryu	sub_debugugetpidures((u9/opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu__call__s

	%uFinalize.__call__cCsLyt|j=Wntk
r"Yn&Xd|_|_|_|_|_dS(u3
        Cancel finalization of the object
        N(u_finalizer_registryu_keyuKeyErroruNoneu_weakrefu	_callbacku_argsu_kwargs(uself((u9/opt/alt/python33/lib64/python3.3/multiprocessing/util.pyucancels

uFinalize.cancelcCs
|jtkS(uS
        Return whether this finalizer is still waiting to invoke callback
        (u_keyu_finalizer_registry(uself((u9/opt/alt/python33/lib64/python3.3/multiprocessing/util.pyustill_activesuFinalize.still_activec
Csy|j}Wnttfk
r0d}YnX|dkrAdSdt|jd|j}|jr|dt|j7}n|jr|dt|j7}n|j	ddk	r|dt|j	d7}n|dS(	Nu<Finalize object, dead>u<Finalize object, callback=%su__name__u, args=u	, kwargs=iu, exitprority=u>(
u_weakrefuAttributeErroru	TypeErroruNoneugetattru	_callbacku_argsustru_kwargsu_key(uselfuobjux((u9/opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu__repr__s		uFinalize.__repr__N(u__name__u
__module__u__qualname__u__doc__uNoneu__init__u_finalizer_registryu	sub_debuguosugetpidu__call__ucancelustill_activeu__repr__(u
__locals__((u9/opt/alt/python33/lib64/python3.3/multiprocessing/util.pyuFinalizescstdkrdSdkr+ddnfddfddttjD}|jdd
xW|D]O\}}td|y|Wqytk
rd	dl}|j	YqyXqyWdkrtj
ndS(u
    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.
    NcSs|dddk	S(Ni(uNone(up((u9/opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu<lambda>su!_run_finalizers.<locals>.<lambda>cs&|dddk	o%|ddkS(Ni(uNone(up(uminpriority(u9/opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu<lambda>scs"g|]}|r|qS(((u.0ux(uf(u9/opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu
<listcomp>s	u#_run_finalizers.<locals>.<listcomp>ureverseu
calling %siT(u_finalizer_registryuNoneulistuitemsusortuTrueu	sub_debugu	Exceptionu	tracebacku	print_excuclear(uminpriorityuitemsukeyu	finalizeru	traceback((ufuminpriorityu9/opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu_run_finalizerss %

u_run_finalizerscCstptdkS(u6
    Returns true if the process is shutting down
    N(u_exitinguNone(((u9/opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu
is_exitingscCstsda|d|d|d|dk	rx:|D]/}|jrC|d|j|jjqCqCWx.|D] }|d|j|jqWn|d|ndS(Nuprocess shutting downu2running all "atexit" finalizers with priority >= 0iu!calling terminate() for daemon %sucalling join() for process %su)running the remaining "atexit" finalizersT(u_exitinguTrueuNoneu	_daemonicunameu_popenu	terminateujoin(uinfoudebugu_run_finalizersuactive_childrenucurrent_processup((u9/opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu_exit_functions	


	
u_exit_functioncBs,|EeZdZddZddZdS(uForkAwareThreadLockcCs|jt|tjdS(N(u_reseturegister_after_forkuForkAwareThreadLock(uself((u9/opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu__init__Ds
uForkAwareThreadLock.__init__cCs1tj|_|jj|_|jj|_dS(N(u	threadinguLocku_lockuacquireurelease(uself((u9/opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu_resetHsuForkAwareThreadLock._resetN(u__name__u
__module__u__qualname__u__init__u_reset(u
__locals__((u9/opt/alt/python33/lib64/python3.3/multiprocessing/util.pyuForkAwareThreadLockCscBs,|EeZdZddZddZdS(uForkAwareLocalcCst|dddS(NcSs
|jjS(N(u__dict__uclear(uobj((u9/opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu<lambda>Osu)ForkAwareLocal.__init__.<locals>.<lambda>(uregister_after_fork(uself((u9/opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu__init__NsuForkAwareLocal.__init__cCst|ffS(N(utype(uself((u9/opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu
__reduce__PsuForkAwareLocal.__reduce__N(u__name__u
__module__u__qualname__u__init__u
__reduce__(u
__locals__((u9/opt/alt/python33/lib64/python3.3/multiprocessing/util.pyuForkAwareLocalMsF(1usysu	functoolsuosu	itertoolsuweakrefuatexitu	threadingu
subprocessu_args_from_interpreter_flagsumultiprocessing.processucurrent_processuactive_childrenu__all__uNOTSETuSUBDEBUGuDEBUGuINFOu
SUBWARNINGuLOGGER_NAMEuDEFAULT_LOGGING_FORMATuNoneu_loggeruFalseu_log_to_stderru	sub_debugudebuguinfousub_warningu
get_loggeru
log_to_stderruget_temp_diruWeakValueDictionaryu_afterfork_registryucountu_afterfork_counteru_run_after_forkersuregister_after_forku_finalizer_registryu_finalizer_counteruobjectuFinalizeu_run_finalizersu
is_exitingu_exitingu_exit_functionuregisteruForkAwareThreadLockulocaluForkAwareLocal(((u9/opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu<module>
sX		R$	(