;ò Îvò8c@sFdfd„ƒYZdfd„ƒYZdfd„ƒYZd„ZdS(sfifocBsPtZd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Z RS( NcCs.ttf\|_|_d|_t|_dS(Ni(sNonesselfsheadstailslengths node_cache(sself((s=/mnt/gmirror/ports/devel/py-coro/work/coro_2001_02_02/fifo.pys__init__s cCs |iSdS(N(sselfslength(sself((s=/mnt/gmirror/ports/devel/py-coro/work/coro_2001_02_02/fifo.pys__len__ scCs\t|_|id|_|tg}|itjo ||_n||id<||_dS(Ni(sNonesselfs node_cacheslengthsvspsheadstail(sselfsvsp((s=/mnt/gmirror/ports/devel/py-coro/work/coro_2001_02_02/fifo.pyspushs    cCsst|_|i}|tjo td‚nD|id|_|\}}||_|tjo t|_ n|SdS(Nspop() from an empty queuei( sNonesselfs node_cachesheadspairs ValueErrorslengthsvaluesnextstail(sselfsvaluesnextspair((s=/mnt/gmirror/ports/devel/py-coro/work/coro_2001_02_02/fifo.pyspops        cCs,|itjo td‚n |idSdS(Nsfirst() of an empty queuei(sselfsheadsNones ValueError(sself((s=/mnt/gmirror/ports/devel/py-coro/work/coro_2001_02_02/fifo.pysfirst's cCsUt|_|id|_|i}||g}||_|tjo ||_ndS(Ni( sNonesselfs node_cacheslengthsheadsold_headsthingsnew_headstail(sselfsthingsold_headsnew_head((s=/mnt/gmirror/ports/devel/py-coro/work/coro_2001_02_02/fifo.pys push_front-s     cCsQ|}|i}x |o|d}|d}qW||df|_|dSdS(Nii(snsisselfsheadshs node_cache(sselfsnsish((s=/mnt/gmirror/ports/devel/py-coro/work/coro_2001_02_02/fifo.pys_nth6s  cCs›|djp ||ijo td‚nn|ioV|i\}}||djo%|d}||df|_|Sq—|i|ƒSn|i|ƒSdS(Nisindex out of rangei( sindexsselfslengths IndexErrors node_cachesjshsresults_nth(sselfsindexshsjsresult((s=/mnt/gmirror/ports/devel/py-coro/work/coro_2001_02_02/fifo.pys __getitem__?s   ( s__name__s __module__s__init__s__len__spushspopsfirsts push_fronts_nths __getitem__(((s=/mnt/gmirror/ports/devel/py-coro/work/coro_2001_02_02/fifo.pysfifos    sprotected_fifocBs;tZed„Zd„ZeZd„ZeZd„ZRS(NcCsE|tjodk}|iƒ|_n ||_tiƒ|_dS(N(slocksNonesthreads allocate_locksselfsfifo(sselfslocksthread((s=/mnt/gmirror/ports/devel/py-coro/work/coro_2001_02_02/fifo.pys__init__Qs    cCs6z!|iiƒ|ii|ƒWd|iiƒXdS(N(sselfslocksacquiresfifospushsitemsrelease(sselfsitem((s=/mnt/gmirror/ports/devel/py-coro/work/coro_2001_02_02/fifo.pyspushYs  cCs3z|iiƒ|iiƒSWd|iiƒXdS(N(sselfslocksacquiresfifospopsrelease(sself((s=/mnt/gmirror/ports/devel/py-coro/work/coro_2001_02_02/fifo.pyspopbs  cCs3z|iiƒt|iƒSWd|iiƒXdS(N(sselfslocksacquireslensqueuesrelease(sself((s=/mnt/gmirror/ports/devel/py-coro/work/coro_2001_02_02/fifo.pys__len__ks  ( s__name__s __module__sNones__init__spushsenqueuespopsdequeues__len__(((s=/mnt/gmirror/ports/devel/py-coro/work/coro_2001_02_02/fifo.pysprotected_fifoOs    s output_fifocBsktZdZdZdZd„Zd„Zd„Zd„Zd„Z d „Z d „Z d „Z d „Z RS( NsembeddedseofstriggercCstƒ|_t|_dS(N(sfifosselfsNones _embedded(sself((s=/mnt/gmirror/ports/devel/py-coro/work/coro_2001_02_02/fifo.pys__init__xs cCs&||_|ii|i|fƒdS(N(sselfsfifosparentspushsEMBEDDED(sselfsfifo((s=/mnt/gmirror/ports/devel/py-coro/work/coro_2001_02_02/fifo.pys push_embedded}s cCs|ii|itfƒdS(N(sselfsfifospushsEOFsNone(sself((s=/mnt/gmirror/ports/devel/py-coro/work/coro_2001_02_02/fifo.pyspush_eof‚scCs|ii|i|fƒdS(N(sselfsfifospushsTRIGGERsthunk(sselfsthunk((s=/mnt/gmirror/ports/devel/py-coro/work/coro_2001_02_02/fifo.pys push_trigger†scCs|ii|ƒdS(N(sselfsfifospushsitem(sselfsitem((s=/mnt/gmirror/ports/devel/py-coro/work/coro_2001_02_02/fifo.pyspush‰scCs2|itjot|iƒSnt|iƒSdS(N(sselfs _embeddedsNoneslensfifo(sself((s=/mnt/gmirror/ports/devel/py-coro/work/coro_2001_02_02/fifo.pys__len__scCst|ƒdjSdS(Ni(slensself(sself((s=/mnt/gmirror/ports/devel/py-coro/work/coro_2001_02_02/fifo.pysempty•scCs2|itjo|iiƒSn|iiƒSdS(N(sselfs _embeddedsNonesfifosfirst(sself((s=/mnt/gmirror/ports/devel/py-coro/work/coro_2001_02_02/fifo.pysfirst˜scCs|itj o|iiƒSnÝ|iiƒ}t|_t|iƒo°|iiƒ}t |ƒt fƒjo„|\}}||i jo ||_nK||i jo|i}t|_t|_n||ijo |ƒn|iiƒqùn|SdS(N(sselfs _embeddedsNonespopsfifosresultslensfirstsfrontstypeskindsvaluesEMBEDDEDsEOFsparentsTRIGGER(sselfsvaluesparentskindsresultsfront((s=/mnt/gmirror/ports/devel/py-coro/work/coro_2001_02_02/fifo.pyspopžs$       (s__name__s __module__sEMBEDDEDsEOFsTRIGGERs__init__s push_embeddedspush_eofs push_triggerspushs__len__semptysfirstspop(((s=/mnt/gmirror/ports/devel/py-coro/work/coro_2001_02_02/fifo.pys output_fifors        cCsÂtƒ}tƒ}tƒ}|idƒ|i|ƒ|idƒ|idƒ|idƒ|i|ƒ|iƒ|idƒ|iƒ|idƒ|idƒxno|iƒGHq®WdS( Nsonestwosthreesfoursfivessixsseveni(s output_fifosofsf2sf3spushs push_embeddedspush_eofspop(sofsf2sf3((s=/mnt/gmirror/ports/devel/py-coro/work/coro_2001_02_02/fifo.pys test_embedded»s"              N(sfifosprotected_fifos output_fifos test_embedded(s output_fifos test_embeddedsprotected_fifosfifo((s=/mnt/gmirror/ports/devel/py-coro/work/coro_2001_02_02/fifo.pys?sI#I