/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/queues.pyo (11857B)
ó ß[ bc@s>dddgZddlZddlZddlZddlZddlZddlZddlZddlm Z m Z ddl Z ddl m Z ddlmZmZmZmZdd lmZmZmZmZmZdd lmZdefd „ƒYZeƒZdefd „ƒYZdefd „ƒYZdS(tQueuet SimpleQueuet JoinableQueueiÿÿÿÿN(tEmptytFulli(tPipe(tLocktBoundedSemaphoret Semaphoret Condition(tdebugtinfotFinalizetregister_after_forkt is_exiting(tassert_spawningcBsËeZdd„Zd„Zd„Zd„Zedd„Zedd„Z d„Z d„Z d „Z d „Z d „Zd „Zd „Zd„Zd„Zed„ƒZed„ƒZed„ƒZRS(icCsÀ|dkrtjj}n||_tdtƒ\|_|_tƒ|_ t j ƒ|_ t jdkrud|_n tƒ|_t|ƒ|_|jƒt jdkr¼t|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      cCs8t|ƒ|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__Qs0cCstdƒtjtjƒƒ|_tjƒ|_d|_ d|_ t |_ t |_ d|_|jj|_|jj|_|jj|_dS(NsQueue._after_fork()(R t threadingR Rt _notemptyt collectionstdequet_bufferRt_threadt _jointhreadRt_joincancelledt_closedt_closeRtsendt_sendRtrecvt_recvtpollt_poll(R#((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyR"Vs      cCs}|jj||ƒst‚n|jjƒz=|jdkrJ|jƒn|jj|ƒ|jj ƒWd|jj ƒXdS(N( R!tacquireRR*R.Rt _start_threadR-tappendtnotifytrelease(R#tobjtblockttimeout((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pytputcs   cCs|rT|dkrT|jjƒz!|jƒ}|jjƒ|SWd|jjƒXn¯|rmtjƒ|}n|jj||ƒs‹t‚nzg|r¿|tjƒ}|j|ƒsÔt‚qÔn|jƒsÔt‚n|jƒ}|jjƒ|SWd|jjƒXdS(N( RRR9R6R!R=ttimeRR8(R#R?R@trestdeadline((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pytgetqs,         cCs|j|jjjƒS(N(RR!t_semlockt _get_value(R#((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pytqsizescCs |jƒ S(N(R8(R#((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pytempty‘scCs|jjjƒS(N(R!RFt_is_zero(R#((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pytfull”scCs |jtƒS(N(RER(R#((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyt get_nowait—scCs|j|tƒS(N(RAR(R#R>((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyt put_nowaitšscCsDt|_z|jjƒWd|j}|r?d|_|ƒnXdS(N(tTrueR1RtcloseR2R(R#RO((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyROs   cCs$tdƒ|jr |jƒndS(NsQueue.join_thread()(R R/(R#((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyt join_thread§s  cCs<tdƒt|_y|jjƒWntk r7nXdS(NsQueue.cancel_join_thread()(R RNR0R/tcanceltAttributeError(R#((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pytcancel_join_thread­s    c Csótdƒ|jjƒtjdtjd|j|j|j|j |j j fddƒ|_ t |j _tdƒ|j jƒtdƒ|jsÅt|j tjtj|j ƒgdd ƒ|_nt|tj|j|jgdd ƒ|_dS( NsQueue._start_thread()ttargettargstnametQueueFeederThreadsdoing self._thread.start()s... done self._thread.start()t exitpriorityiûÿÿÿi (R R-tclearR)tThreadRt_feedR*R4R RROR.RNtdaemontstartR0R t_finalize_jointweakreftrefR/t_finalize_closeR2(R#((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyR:µs(            cCsDtdƒ|ƒ}|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 R9R;t _sentinelR<R=(tbuffertnotempty((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyRaßs    cCs[tdƒ|j}|j}|j}|j}t} tjdkrX|j} |j} nd} xöy¬|ƒz|s~|ƒnWd|ƒXynxg|ƒ} | | krºtdƒ|ƒdS| dkrÓ|| ƒq| ƒz|| ƒWd| ƒXqWWnt k r nXWqat k rR} t ƒr9t d| ƒdSddl }|jƒqaXqaWdS(Ns$starting thread to feed data to pipeRs%feeder thread got sentinel -- exitingserror in queue thread: %siÿÿÿÿ(R R9R=twaittpopleftReRRRt IndexErrort ExceptionRR t tracebackt print_exc(RfRgR3t writelockROtnacquiretnreleasetnwaittbpoplefttsentineltwacquiretwreleaseR>teRl((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyR[ésL                N(t__name__t __module__R%R&R(R"RNRRARERHRIRKRLRMRORPRSR:t staticmethodR^RaR[(((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyR8s$              cBsGeZdd„Zd„Zd„Zedd„Zd„Zd„Z 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%)scCstj|ƒ|j|jfS(N(RR&R{Rz(R#((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyR&.scCs.tj||d ƒ|d\|_|_dS(Niþÿÿÿ(RR(R{Rz(R#R'((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyR(1scCs¤|jj||ƒst‚n|jjƒ|jjƒzJ|jdkrW|jƒn|jj |ƒ|j j ƒ|jj ƒWd|jj ƒ|jj ƒXdS(N( R!R9RR*R{R.RR:R-R;RzR=R<(R#R>R?R@((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyRA5s      cCsi|jjƒzG|jjtƒs1tdƒ‚n|jjjƒrS|jjƒnWd|jjƒXdS(Ns!task_done() called too many times( R{R9RzRt ValueErrorRFRJt notify_allR=(R#((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyt task_doneFs cCsH|jjƒz&|jjjƒs2|jjƒnWd|jjƒXdS(N(R{R9RzRFRJRhR=(R#((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyRbPs  N( RwRxR%R&R(RNRRAR~Rb(((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyR's     cBs5eZd„Zd„Zd„Zd„Zd„ZRS(cCs\tdtƒ\|_|_tƒ|_tjdkrBd|_ n tƒ|_ |j ƒdS(NRR( RRRRRRRRRR t _make_methods(R#((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyR%^s    cCs|jjƒ S(N(RR7(R#((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyRIgscCs&t|ƒ|j|j|j|jfS(N(RRRRR (R#((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyR&js cCs,|\|_|_|_|_|jƒdS(N(RRRR R(R#R'((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyR(nscs«|jj‰|jj|jj‰‰‡‡‡fd†}||_|jdkrd|jj |_ nC|jj ‰|jj|jj‰‰‡‡‡fd†}||_ dS(Ncs!ˆƒz ˆƒSWdˆƒXdS(N(((tracquireR5trrelease(s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyREus cs$ˆƒzˆ|ƒSWdˆƒXdS(N((R>(R3RtRu(s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyRAƒs( RR5RR9R=RER RRR3RA(R#RERA((R€R5RR3RtRus;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyRrs   (RwRxR%RIR&R(R(((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyR\s    (t__all__RRR)R+RBtatexitR_RRRRtRt synchronizeRRRR tutilR R R R RtforkingRtobjectReRR(((s;/opt/alt/python27/lib64/python2.7/multiprocessing/queues.pyt#s"        "(å 5