Ñò
§ÚêLc @ s8 d d d g Z d d k Z d d k Z d d k Z d d k Z d d k Z d d k Z d d k Z d d k l Z l
Z
d d k Z d d k l
Z
d d k l Z l Z l Z l Z d d k l Z l Z l Z l Z d d k l Z d e f d
„ ƒ YZ e ƒ Z d e f d „ ƒ YZ d e f d „ ƒ YZ d S(
t Queuet SimpleQueuet
JoinableQueueiÿÿÿÿN( t Emptyt Full( t Pipe( t Lockt BoundedSemaphoret Semaphoret Condition( t debugt infot Finalizet register_after_fork( t assert_spawningc B sË e Z d d „ Z d „ Z d „ Z d „ Z e d d „ Z e d d „ Z d „ Z
d „ Z d „ Z d
„ Z
d „ Z d „ Z d
„ Z d „ Z d „ Z e d „ ƒ Z e d „ ƒ Z e d „ ƒ Z RS( i c C sÆ | d j o t i i } n | | _ t d t ƒ \ | _ | _ t ƒ | _ t
i ƒ | _ t
i d j o
d | _ n
t ƒ | _ t | ƒ | _ | i ƒ t
i d j o t | t i ƒ n d S( Ni t duplext win32( t _multiprocessingt SemLockt
SEM_VALUE_MAXt _maxsizeR t Falset _readert _writerR t _rlockt ost getpidt _opidt syst platformt Nonet _wlockR t _semt _after_forkR
R ( t selft maxsize( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyt __init__ s
c C s8 t | ƒ | i | i | i | i | i | i | i f S( N( R R R R R R R R ( R" ( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyt __getstate__2 s
c C s> | \ | _ | _ | _ | _ | _ | _ | _ | i ƒ d S( N( R R R R R R R R! ( R" t state( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyt __setstate__7 s 0c C s t d ƒ t i t i ƒ ƒ | _ t i ƒ | _ d | _ d | _
t | _ t | _
d | _ | i i | _ | i i | _ | i i | _ d S( Ns Queue._after_fork()( R
t threadingR R t _notemptyt collectionst dequet _bufferR t _threadt _jointhreadR t _joincancelledt _closedt _closeR t sendt _sendR t recvt _recvt pollt _poll( R" ( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyR! < s
c C s | i i | | ƒ p
t ‚ n | i i ƒ z? | i d j o | i ƒ n | i i | ƒ | i i ƒ Wd | i i
ƒ Xd S( N( R t acquireR R) R- R t
_start_threadR, t appendt notifyt release( R" t objt blockt timeout( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyt putI s
c C sú | oP | d j oC | i i ƒ z! | i ƒ } | i i ƒ | SWd | i i ƒ Xn | o t i ƒ | } n | i i | | ƒ p
t ‚ n zS | i | o | t i ƒ p d ƒ p
t ‚ n | i ƒ } | i i ƒ | SWd | i i ƒ Xd S( Ng ( R R R8 R5 R R< t timeR R7 ( R" R> R? t rest deadline( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyt getW s$
(
c C s | i | i i i ƒ S( N( R R t _semlockt
_get_value( R" ( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyt qsizeo s c C s | i ƒ S( N( R7 ( R" ( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyt emptys s c C s | i i i ƒ S( N( R RE t _is_zero( R" ( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyt fullv s c C s
| i t ƒ S( N( RD R ( R" ( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyt
get_nowaity s c C s | i | t ƒ S( N( R@ R ( R" R= ( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyt
put_nowait| s c C s2 t | _ | i i ƒ | i o | i ƒ n d S( N( t TrueR0 R t closeR1 ( R" ( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyRN s
c C s& t d ƒ | i o | i ƒ n d S( Ns Queue.join_thread()( R
R. ( R" ( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyt join_thread… s
c C s> t d ƒ t | _ y | i i ƒ Wn t j
o n Xd S( Ns Queue.cancel_join_thread()( R
RM R/ R. t cancelt AttributeError( R" ( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyt cancel_join_thread‹ s
c C s t d ƒ | i i ƒ t i d t i d | i | i | i | i | i
i f d d ƒ | _ t
| i _ t d ƒ | i i ƒ t d ƒ | i t i ƒ j } | i o< | o4 t | i t i t i | i ƒ g d d ƒ| _ n t | t i | i | i g d d
ƒ| _ d S( Ns Queue._start_thread()t targett argst namet QueueFeederThreads doing self._thread.start()s ... done self._thread.start()t exitpriorityiûÿÿÿi
( R
R, t clearR( t ThreadR t _feedR) R3 R R RN R- RM t daemont startR R R R/ R t _finalize_joint weakreft refR. t _finalize_closeR1 ( R" t created_by_this_process( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyR9 “ s*
c C sF t d ƒ | ƒ } | d j o | i ƒ t d ƒ n t d ƒ d S( Ns joining queue threads ... queue thread joineds ... queue thread already dead( R
R t join( t twrt thread( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyR] ¹ s
c C sA t d ƒ | i ƒ z | i t ƒ | i ƒ Wd | i ƒ Xd S( Ns telling queue thread to quit( R
R8 R: t _sentinelR; R< ( t buffert notempty( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyR` Ã s
c C s t d ƒ d d k l } | i } | i } | i } | i } t }
t i d j o | i } | i } n d } y¹ x² | ƒ z | p | ƒ n Wd | ƒ Xyq xj | ƒ }
|
|
j o t d ƒ | ƒ d S| d j o | |
ƒ q¤ | ƒ z | |
ƒ Wd | ƒ Xq¤ Wqv t j
o qv Xqv Wn` t j
oT } y5 | ƒ o t
d | ƒ n d d k } | i ƒ WqŒt j
o qŒXn Xd S( Ns$ starting thread to feed data to pipei ( t
is_exitingR s% feeder thread got sentinel -- exitings error in queue thread: %siÿÿÿÿ( R
t utilRh R8 R< t waitt popleftRe R R R t
IndexErrort ExceptionR t tracebackt print_exc( Rf Rg R2 t writelockRN Rh t nacquiret nreleaset nwaitt bpopleftt sentinelt wacquiret wreleaseR= t eRn ( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyRZ Í sR
N( t __name__t
__module__R$ R% R' R! RM R R@ RD RG RH RJ RK RL RN RO RR R9 t staticmethodR] R` RZ ( ( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyR s$
&
c B sG e Z d d „ Z d „ Z d „ Z e d d „ Z d „ Z d „ Z RS( i c C s/ t i | | ƒ t d ƒ | _ t ƒ | _ d S( Ni ( R R$ R t _unfinished_tasksR t _cond( R" R# ( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyR$ s c C s t i | ƒ | i | i f S( N( R R% R} R| ( R" ( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyR% s c C s. t i | | d ƒ | d \ | _ | _ d S( Niþÿÿÿ( R R' R} R| ( R" R& ( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyR' s c C s¨ | i i | | ƒ p
t ‚ n | i i ƒ | i i ƒ zL | i d j o | i ƒ n | i i | ƒ | i
i ƒ | i i ƒ Wd | i i ƒ | i i ƒ Xd S( N(
R R8 R R) R} R- R R9 R, R: R| R< R; ( R" R= R> R? ( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyR@ s
c C sm | i i ƒ zK | i i t ƒ p t d ƒ ‚ n | i i i ƒ o | i i ƒ n Wd | i i ƒ Xd S( Ns! task_done() called too many times( R} R8 R| R t
ValueErrorRE RI t
notify_allR< ( R" ( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyt task_done. s
c C sJ | i i ƒ z( | i i i ƒ p | i i ƒ n Wd | i i ƒ Xd S( N( R} R8 R| RE RI Rj R< ( R" ( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyRb 8 s
N(
Ry Rz R$ R% R' RM R R@ R€ Rb ( ( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyR s
c B s5 e Z d „ Z d „ Z d „ Z d „ Z d „ Z RS( c C s^ t d t ƒ \ | _ | _ t ƒ | _ t i d j o
d | _ n
t ƒ | _ | i
ƒ d S( NR R ( R R R R R R R R R R t
_make_methods( R" ( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyR$ F s
c C s | i i ƒ S( N( R R6 ( R" ( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyRH O s c C s& t | ƒ | i | i | i | i f S( N( R R R R R ( R" ( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyR% R s
c C s, | \ | _ | _ | _ | _ | i ƒ d S( N( R R R R R ( R" R& ( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyR' V s c s | i i ‰ | i i | i i ‰ ‰ ‡ ‡ ‡ f d † } | | _ | i d j o | i i | _
nD | i i ‰ | i i | i i ‰ ‰ ‡ ‡ ‡ f d † } | | _
d S( Nc s! ˆ ƒ z ˆ ƒ SWd ˆ ƒ Xd S( N( ( ( t racquireR4 t rrelease( s. /usr/lib64/python2.6/multiprocessing/queues.pyRD ] s c s$ ˆ ƒ z ˆ | ƒ SWd ˆ ƒ Xd S( N( ( R= ( Rv Rw R2 ( s. /usr/lib64/python2.6/multiprocessing/queues.pyR@ k s ( R R4 R R8 R< RD R R R R2 R@ ( R" RD R@ ( ( Rv R‚ R2 Rw R4 Rƒ s. /usr/lib64/python2.6/multiprocessing/queues.pyR Z s ( Ry Rz R$ RH R% R' R ( ( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyR D s
( t __all__R R R( R* RA t atexitR^ R R R R t multiprocessingR t multiprocessing.synchronizeR R R R t multiprocessing.utilR
R R R
t multiprocessing.forkingR t objectRe R R ( ( ( s. /usr/lib64/python2.6/multiprocessing/queues.pyt s" ""ç
5