£Á°èZ¨Ä…–K§‚«“ô4“ÒÙ´dîfUÙÃÅ WKbyÊ¦•êŽ…È®FÒ¿ÊÎóCozá¬S@6{Í:›œêZÌ:Š•_%:¢¾¾~;‘Ã~èŠ©ÊÇí`ÔÑ©úë™µ'5I¿fš×WO%ø9¾«¾DK|€ùÍD”Ýs]nHÕ¶ê×Ó¼ãžªéUWŸÈË%DÒÕ¬ï‘]/Åcx  ‰ï2ß]ä6G[]S£ÔÏ¯rs{úëóµmÒï#UQxo·õÞCe]"±/aÙ&Eã4ú9Jé_ÞåëdãöKë)AÞ                  ¯¹ægƒÛowÐø^d™ý½ßB7áyMä9ÜÖUã
!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
<html>

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    6u   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
 rYqt Xqt Wn t k
 r} zr | rZt | d d  t j k rZd  Sy3 |   rvt 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   ii(   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.<locals>.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.<locals>.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   <module>
   s"   ""	
5