/opt/alt/python27/lib64/python2.7/multiprocessing/
/opt/alt/python27/lib64/python2.7/multiprocessing
NameSizeModeActions
dummy/-0755rm
connection.py150070644editdlrm
connection.pyc151340644editdlrm
connection.pyo149870644editdlrm
forking.py171570644editdlrm
forking.pyc149030644editdlrm
forking.pyo147440644editdlrm
heap.py85810644editdlrm
heap.pyc71690644editdlrm
heap.pyo67990644editdlrm
managers.py367150644editdlrm
managers.pyc397900644editdlrm
managers.pyo391890644editdlrm
pool.py242010644editdlrm
pool.pyc233460644editdlrm
pool.pyo228300644editdlrm
process.py96840644editdlrm
process.pyc99420644editdlrm
process.pyo91890644editdlrm
queues.py122960644editdlrm
queues.pyc119540644editdlrm
queues.pyo118570644editdlrm
reduction.py65820644editdlrm
reduction.pyc62350644editdlrm
reduction.pyo62350644editdlrm
sharedctypes.py77560644editdlrm
sharedctypes.pyc89700644editdlrm
sharedctypes.pyo88890644editdlrm
synchronize.py106540644editdlrm
synchronize.pyc115320644editdlrm
synchronize.pyo111990644editdlrm
util.py110060644editdlrm
util.pyc105090644editdlrm
util.pyo104040644editdlrm
__init__.py78050644editdlrm
__init__.pyc88030644editdlrm
__init__.pyo88030644editdlrm
Edit: /opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyc (11532B)
ó ß[ bc@sœddddddgZddlZddlZddlZddlmZmZddlZdd l m Z dd l m Z m Z mZdd lmZmZydd lmZWn)ek rßed dddƒ‚nXedƒ\ZZejjZdefd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdS(tLocktRLockt SemaphoretBoundedSemaphoret ConditiontEventiÿÿÿÿN(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.iRcBs>eZd„Zd„Zd„Zd„Zd„Zd„ZRS(cCsctj|||ƒ}|_td|jƒ|jƒtjdkr_d„}t||ƒndS(Nscreated semlock with handle %stwin32cSs|jjƒdS(N(t_semlockt _after_fork(tobj((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyRPs( t_multiprocessingRRR thandlet _make_methodstsystplatformR (tselftkindtvaluetmaxvaluetslR((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyt__init__Js   cCs"|jj|_|jj|_dS(N(Rtacquiretrelease(R((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyRTscCs |jjƒS(N(Rt __enter__(R((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyR XscGs|jj|ŒS(N(Rt__exit__(Rtargs((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyR![scCs2t|ƒ|j}tj|jƒ|j|jfS(N(R RR tduplicate_for_childRRR(RR((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyt __getstate__^s  cCs5tjj|Œ|_td|dƒ|jƒdS(Ns recreated blocker with handle %ri(RRt_rebuildRR R(Rtstate((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyt __setstate__cs(t__name__t __module__RRR R!R$R'(((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyRHs     cBs&eZdd„Zd„Zd„ZRS(icCstj|t|tƒdS(N(RRt SEMAPHOREt SEM_VALUE_MAX(RR((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyRnscCs |jjƒS(N(Rt _get_value(R((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyt get_valueqscCs5y|jjƒ}Wntk r,d}nXd|S(Ntunknowns(RR,t Exception(RR((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyt__repr__ts   (R(R)RR-R0(((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyRls  cBseZdd„Zd„ZRS(icCstj|t||ƒdS(N(RRR*(RR((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyRscCsAy|jjƒ}Wntk r,d}nXd||jjfS(NR.s)(RR,R/R(RR((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyR0„s   (R(R)RR0(((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyRs cBseZd„Zd„ZRS(cCstj|tddƒdS(Ni(RRR*(R((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyR’scCsµy“|jjƒrPtƒj}tjƒjdkr’|dtjƒj7}q’nB|jjƒdkrnd}n$|jjƒdkrŒd}nd}Wntk r¬d}nXd |S( Nt MainThreadt|itNoneitSomeOtherThreadtSomeOtherProcessR.s( Rt_is_mineRtnamet threadingtcurrent_threadR,t_countR/(RR7((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyR0•s      (R(R)RR0(((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyRs cBseZd„Zd„ZRS(cCstj|tddƒdS(Ni(RRtRECURSIVE_MUTEX(R((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyR«scCsây´|jjƒr_tƒj}tjƒjdkrM|dtjƒj7}n|jjƒ}nT|jjƒdkrƒd \}}n0|jjƒdkr§d \}}n d \}}Wntk rÓd\}}nXd ||fS(NR1R2iR3iR4tnonzeroR5R.s(R3i(R4R<(R5R<(R.R.( RR6RR7R8R9R:R,R/(RR7tcount((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyR0®s  (R(R)RR0(((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyR©s cBsheZd d„Zd„Zd„Zd„Zd„Zd„Zd„Z d d„Z d„Z d „Z RS( cCsM|p tƒ|_tdƒ|_tdƒ|_tdƒ|_|jƒdS(Ni(Rt_lockRt_sleeping_countt _woken_countt_wait_semaphoreR(Rtlock((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyRÅs cCs&t|ƒ|j|j|j|jfS(N(R R>R?R@RA(R((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyR$Ìs  cCs,|\|_|_|_|_|jƒdS(N(R>R?R@RAR(RR&((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyR'ÑscCs |jjƒS(N(R>R (R((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyR ÖscGs|jj|ŒS(N(R>R!(RR"((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyR!ÙscCs"|jj|_|jj|_dS(N(R>RR(R((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyRÜscCsQy&|jjjƒ|jjjƒ}Wntk r?d}nXd|j|fS(NR.s(R?RR,R@R/R>(Rt num_waiters((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyR0às   cCs±|jjjƒstdƒ‚|jjƒ|jjjƒ}x!t|ƒD]}|jjƒqJWz|jj t |ƒWd|j jƒx!t|ƒD]}|jj ƒq•WXdS(Ns,must acquire() condition before using wait()( R>RR6tAssertionErrorR?RR:txrangeRARtTrueR@(RttimeoutR=ti((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pytwaitès   cCs±|jjjƒstdƒ‚|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((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pytnotifyÿs  cCsî|jjjƒstdƒ‚|jjtƒ s7t‚x4|jjtƒrm|jjtƒ}|s:t‚q:Wd}x-|jjtƒr£|jj ƒ|d7}qwW|rêx!t |ƒD]}|jjƒq·Wx|jjtƒræqÑWndS(Nslock is not ownedii( R>RR6RDRARRJR@R?RRE(RRKtsleepersRH((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyt notify_alls N( R(R)R3RR$R'R R!RR0RIRLRN(((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyRÃs         cBs8eZd„Zd„Zd„Zd„Zdd„ZRS(cCs%ttƒƒ|_tdƒ|_dS(Ni(RRt_condRt_flag(R((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyR-scCsM|jjƒz+|jjtƒr3|jjƒtStSWd|jjƒXdS(N(RORRPRJRRF(R((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pytis_set1s  cCsP|jjƒz.|jjtƒ|jjƒ|jjƒWd|jjƒXdS(N(RORRPRJRRN(R((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pytset;s   cCs6|jjƒz|jjtƒWd|jjƒXdS(N(RORRPRJR(R((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pytclearDs cCs|jjƒz]|jjtƒr2|jjƒn|jj|ƒ|jjtƒre|jjƒtStSWd|jjƒXdS(N(RORRPRJRRIRF(RRG((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyRIKs  N(R(R)RRQRRRSR3RI(((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyR+s   (t__all__R8tosRRt_timeRt_sleepRtmultiprocessing.processRtmultiprocessing.utilR R R tmultiprocessing.forkingR R Rt ImportErrortrangeR;R*R+tobjectRRRRRR(((s@/opt/alt/python27/lib64/python2.7/multiprocessing/synchronize.pyt$s.       $h