ž
¨ÿ f- c @ s8 d d d g Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z m
Z
d d l Z d d l m
Z
d d l m Z m Z m Z m Z d d l m Z m Z m Z m Z d d l m Z Gd
d „ d e ƒ Z e ƒ Z Gd d „ d e ƒ Z Gd d „ d e ƒ Z d S(
u Queueu SimpleQueueu
JoinableQueuei N( u Emptyu Full( u Pipe( u Locku BoundedSemaphoreu Semaphoreu Condition( u debugu infou Finalizeu register_after_fork( u assert_spawningc B s
| Ee Z d Z d d d „ Z d d „ Z d d „ Z d d „ Z d' d& d
d „ Z d' d& d d
„ Z
d d „ Z d d „ Z d d „ Z
d d „ Z d d „ Z d d „ Z d d „ Z d d „ Z d d „ Z e d d! „ ƒ Z e d" d# „ ƒ Z e d$ d% „ ƒ Z d& S(( u Queuei c C sÉ | d k r t j j } n | | _ t d d ƒ \ | _ | _ t ƒ | _ t
j ƒ | _ t
j d k ru d | _ n t ƒ | _ t | ƒ | _ d | _ | j ƒ t
j d k rÅ t | t j ƒ n d S( Ni u duplexu win32F( u _multiprocessingu SemLocku
SEM_VALUE_MAXu _maxsizeu Pipeu Falseu _readeru _writeru Locku _rlocku osu getpidu _opidu sysu platformu Noneu _wlocku BoundedSemaphoreu _semu
_ignore_epipeu _after_forku register_after_forku Queue( u selfu maxsize( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu __init__! s
u Queue.__init__c C s> t | ƒ | j | j | j | j | j | j | j | j f S( N( u assert_spawningu
_ignore_epipeu _maxsizeu _readeru _writeru _rlocku _wlocku _semu _opid( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu __getstate__5 s
u Queue.__getstate__c C sD | \ | _ | _ | _ | _ | _ | _ | _ | _ | j ƒ d S( N( u
_ignore_epipeu _maxsizeu _readeru _writeru _rlocku _wlocku _semu _opidu _after_fork( u selfu state( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu __setstate__: s 6u Queue.__setstate__c C s t d ƒ t j t j ƒ ƒ | _ t j ƒ | _ d | _ d | _
d | _ d | _
d | _ | j j | _ | j j | _ | j j | _ d S( Nu Queue._after_fork()F( u debugu threadingu Conditionu Locku _notemptyu collectionsu dequeu _bufferu Noneu _threadu _jointhreadu Falseu _joincancelledu _closedu _closeu _writeru sendu _sendu _readeru recvu _recvu pollu _poll( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu _after_fork? s
u Queue._after_forkc
C s} | j j | | ƒ s t ‚ n | j j ƒ z= | j d k rJ | j ƒ n | j j | ƒ | j j ƒ Wd | j j
ƒ Xd S( N( u _semu acquireu Fullu _notemptyu _threadu Noneu
_start_threadu _bufferu appendu notifyu release( u selfu obju blocku timeout( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu putL s
u Queue.putc C s | rT | d k rT | j j ƒ z! | j ƒ } | j j ƒ | SWd | j j ƒ Xn¼ | rm t j ƒ | } n | j j | | ƒ s‹ t ‚ n zt | rÌ | t j ƒ } | d k sÀ | j | ƒ rá t ‚ qá n | j ƒ sá t ‚ n | j ƒ } | j j ƒ | SWd | j j ƒ Xd S( Ni ( u Noneu _rlocku acquireu _recvu _semu releaseu timeu Emptyu _poll( u selfu blocku timeoutu resu deadline( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu getZ s,
u Queue.getc C s | j | j j j ƒ S( N( u _maxsizeu _semu _semlocku
_get_value( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu qsizev s u Queue.qsizec C s | j ƒ S( N( u _poll( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu emptyz s u Queue.emptyc C s | j j j ƒ S( N( u _semu _semlocku _is_zero( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu full} s u
Queue.fullc C s
| j d ƒ S( NF( u getu False( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu
get_nowait€ s u Queue.get_nowaitc C s | j | d ƒ S( NF( u putu False( u selfu obj( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu
put_nowaitƒ s u Queue.put_nowaitc C s0 d | _ | j j ƒ | j r, | j ƒ n d S( NT( u Trueu _closedu _readeru closeu _close( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu close† s
u Queue.closec C s$ t d ƒ | j r | j ƒ n d S( Nu Queue.join_thread()( u debugu _jointhread( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu join_threadŒ s
u Queue.join_threadc C s= t d ƒ d | _ y | j j ƒ Wn t k
r8 Yn Xd S( Nu Queue.cancel_join_thread()T( u debugu Trueu _joincancelledu _jointhreadu cancelu AttributeError( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu cancel_join_thread’ s
u Queue.cancel_join_threadc
C s t d ƒ | j j ƒ t j d t j d | j | j | j | j | j
j | j f d d ƒ | _
d | j
_ t d ƒ | j
j ƒ t d ƒ | j t j ƒ k } | j rè | rè t | j
t j t j | j
ƒ g d d ƒ| _ n t | t j | j | j g d d
ƒ| _ d S(
Nu Queue._start_thread()u targetu argsu nameu QueueFeederThreadu doing self._thread.start()u ... done self._thread.start()u exitpriorityi i
Tiûÿÿÿ( u debugu _bufferu clearu threadingu Threadu Queueu _feedu _notemptyu _sendu _wlocku _writeru closeu
_ignore_epipeu _threadu Trueu daemonu startu _opidu osu getpidu _joincancelledu Finalizeu _finalize_joinu weakrefu refu _jointhreadu _finalize_closeu _close( u selfu created_by_this_process( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu
_start_threadš s*
u Queue._start_threadc C sD t d ƒ | ƒ } | d k r6 | j ƒ t d ƒ n
t d ƒ d S( Nu joining queue threadu ... queue thread joinedu ... queue thread already dead( u debugu Noneu join( u twru thread( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu _finalize_joinÀ s
u Queue._finalize_joinc
C sA t d ƒ | j ƒ z | j t ƒ | j ƒ Wd | j ƒ Xd S( Nu telling queue thread to quit( u debugu acquireu appendu _sentinelu notifyu release( u bufferu notempty( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu _finalize_closeÊ s
u Queue._finalize_closec C s¹ t d ƒ d d l m } | j } | j } | j } | j }
t } t j d k rh | j } | j }
n d } y² x« | ƒ z | sŽ | ƒ n Wd | ƒ Xym xf |
ƒ } | | k rÊ t d ƒ | ƒ d S| d k rã | | ƒ q | ƒ z | | ƒ Wd |
ƒ Xq Wqt t k
rYqt Xqt Wn’ t k
r´} zr | rZt
| d d ƒ t j k rZd Sy3 | ƒ rvt d | ƒ n d d l } | j ƒ Wn t k
r¡Yn XWYd d } ~ Xn Xd S( Nu$ starting thread to feed data to pipei ( u
is_exitingu win32u% feeder thread got sentinel -- exitingu errnoi u error in queue thread: %s( u debugu utilu
is_exitingu acquireu releaseu waitu popleftu _sentinelu sysu platformu Noneu
IndexErroru Exceptionu getattru errnou EPIPEu infou tracebacku print_exc( u bufferu notemptyu sendu writelocku closeu ignore_epipeu
is_exitingu nacquireu nreleaseu nwaitu bpopleftu sentinelu wacquireu wreleaseu obju eu traceback( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu _feedÔ sV
!
u Queue._feedNT( u __name__u
__module__u __qualname__u __init__u __getstate__u __setstate__u _after_forku Trueu Noneu putu getu qsizeu emptyu fullu
get_nowaitu
put_nowaitu closeu join_threadu cancel_join_threadu
_start_threadu staticmethodu _finalize_joinu _finalize_closeu _feed( u
__locals__( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu Queue s$
&
c B se | Ee Z d Z d d d „ Z d d „ Z d d „ Z d d d d „ Z d
d „ Z d d
„ Z
d S( u
JoinableQueuei c C s/ t j | | ƒ t d ƒ | _ t ƒ | _ d S( Ni ( u Queueu __init__u Semaphoreu _unfinished_tasksu Conditionu _cond( u selfu maxsize( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu __init__ s u JoinableQueue.__init__c C s t j | ƒ | j | j f S( N( u Queueu __getstate__u _condu _unfinished_tasks( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu __getstate__ s u JoinableQueue.__getstate__c C s: t j | | d d … ƒ | d d … \ | _ | _ d S( Ni iþÿÿÿiþÿÿÿ( u Queueu __setstate__u _condu _unfinished_tasks( u selfu state( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu __setstate__" s u JoinableQueue.__setstate__c
C s¤ | j j | | ƒ s t ‚ n | j j ƒ | j j ƒ zJ | j d k rW | j ƒ n | j j | ƒ | j
j ƒ | j j ƒ Wd | j j ƒ | j j ƒ Xd S( N(
u _semu acquireu Fullu _notemptyu _condu _threadu Noneu
_start_threadu _bufferu appendu _unfinished_tasksu releaseu notify( u selfu obju blocku timeout( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu put& s
u JoinableQueue.putc
C si | j j ƒ zG | j j d ƒ s1 t d ƒ ‚ n | j j j ƒ rS | j j ƒ n Wd | j j ƒ Xd S( Nu! task_done() called too many timesF( u _condu acquireu _unfinished_tasksu Falseu
ValueErroru _semlocku _is_zerou
notify_allu release( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu task_done7 s
u JoinableQueue.task_donec
C sH | j j ƒ z& | j j j ƒ s2 | j j ƒ n Wd | j j ƒ Xd S( N( u _condu acquireu _unfinished_tasksu _semlocku _is_zerou waitu release( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu joinA s
u JoinableQueue.joinNT( u __name__u
__module__u __qualname__u __init__u __getstate__u __setstate__u Trueu Noneu putu task_doneu join( u
__locals__( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu
JoinableQueue s
c B sP | Ee Z d Z d d „ Z d d „ Z d d „ Z d d „ Z d d
„ Z d S( u SimpleQueuec C sk t d d ƒ \ | _ | _ t ƒ | _ | j j | _ t j d k rQ d | _ n t ƒ | _ | j ƒ d S( Nu duplexu win32F(
u Pipeu Falseu _readeru _writeru Locku _rlocku pollu _pollu sysu platformu Noneu _wlocku
_make_methods( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu __init__O s u SimpleQueue.__init__c C s | j ƒ S( N( u _poll( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu emptyY s u SimpleQueue.emptyc C s& t | ƒ | j | j | j | j f S( N( u assert_spawningu _readeru _writeru _rlocku _wlock( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu __getstate__\ s
u SimpleQueue.__getstate__c C s, | \ | _ | _ | _ | _ | j ƒ d S( N( u _readeru _writeru _rlocku _wlocku
_make_methods( u selfu state( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu __setstate__` s u SimpleQueue.__setstate__c s± | j j ‰ | j j | j j ‰ ‰ ‡ ‡ ‡ f d d † } | | _ | j d k rg | j j | _
nF | j j ‰ | j j | j j ‰ ‰ ‡ ‡ ‡ f d d † } | | _
d S( Nc
s! ˆ ƒ z ˆ ƒ SWd ˆ ƒ Xd S( N( ( ( u racquireu recvu rrelease( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu getg s u& SimpleQueue._make_methods..getc
s$ ˆ ƒ z ˆ | ƒ SWd ˆ ƒ Xd S( N( ( u obj( u sendu wacquireu wrelease( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu putu s u& SimpleQueue._make_methods..put( u _readeru recvu _rlocku acquireu releaseu getu _wlocku Noneu _writeru sendu put( u selfu getu put( ( u racquireu recvu rreleaseu sendu wacquireu wreleaseu; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu
_make_methodsd s u SimpleQueue._make_methodsN( u __name__u
__module__u __qualname__u __init__u emptyu __getstate__u __setstate__u
_make_methods( u
__locals__( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu SimpleQueueM s
( u __all__u sysu osu threadingu collectionsu timeu weakrefu errnou queueu Emptyu Fullu _multiprocessingu multiprocessing.connectionu Pipeu multiprocessing.synchronizeu Locku BoundedSemaphoreu Semaphoreu Conditionu multiprocessing.utilu debugu infou Finalizeu register_after_forku multiprocessing.forkingu assert_spawningu objectu Queueu _sentinelu
JoinableQueueu SimpleQueue( ( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu
s" ""ï
5