£Á°è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               @   s  d  d d d d d g Z  d d l Z d d l Z d d l Z d d l m Z d d	 l m Z m Z d d
 l	 m
 Z
 m Z d d l m Z y d d l m Z Wn* e k
 r e d d d d   Yn Xe e d   \ Z Z e j j Z Gd d   d e  Z Gd d   d e  Z Gd d   d e  Z Gd d    d  e  Z Gd d   d e  Z Gd d   d e  Z Gd d   d e  Z Gd d   d e j  Z d S(   u   Locku   RLocku	   Semaphoreu   BoundedSemaphoreu	   Conditionu   Eventi    N(   u   current_process(   u   register_after_forku   debug(   u   assert_spawningu   Popen(   u   time(   u   SemLocku*   This platform lacks a functioning sem_openu(    implementation, therefore, the requiredu+    synchronization primitives needed will notu    function, see issue 3770.i   c             B   s\   |  Ee  Z d  Z d d   Z d d   Z d d   Z d d   Z d	 d
   Z d d   Z d S(   u   SemLockc             C   sf   t  j | | |  } |  _ t d | j  |  j   t j d k rb d d   } t |  |  n  d  S(   Nu   created semlock with handle %su   win32c             S   s   |  j  j   d  S(   N(   u   _semlocku   _after_fork(   u   obj(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   _after_fork5   s    u%   SemLock.__init__.<locals>._after_fork(	   u   _multiprocessingu   SemLocku   _semlocku   debugu   handleu   _make_methodsu   sysu   platformu   register_after_fork(   u   selfu   kindu   valueu   maxvalueu   slu   _after_fork(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   __init__/   s    
u   SemLock.__init__c             C   s"   |  j  j |  _ |  j  j |  _ d  S(   N(   u   _semlocku   acquireu   release(   u   self(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   _make_methods9   s    u   SemLock._make_methodsc             C   s   |  j  j   S(   N(   u   _semlocku	   __enter__(   u   self(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu	   __enter__=   s    u   SemLock.__enter__c             G   s   |  j  j |   S(   N(   u   _semlocku   __exit__(   u   selfu   args(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   __exit__@   s    u   SemLock.__exit__c             C   s2   t  |   |  j } t j | j  | j | j f S(   N(   u   assert_spawningu   _semlocku   Popenu   duplicate_for_childu   handleu   kindu   maxvalue(   u   selfu   sl(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   __getstate__C   s    
	u   SemLock.__getstate__c             C   s5   t  j j |   |  _ t d | d  |  j   d  S(   Nu    recreated blocker with handle %ri    (   u   _multiprocessingu   SemLocku   _rebuildu   _semlocku   debugu   _make_methods(   u   selfu   state(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   __setstate__H   s    u   SemLock.__setstate__N(	   u   __name__u
   __module__u   __qualname__u   __init__u   _make_methodsu	   __enter__u   __exit__u   __getstate__u   __setstate__(   u
   __locals__(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   SemLock-   s   
u   SemLockc             B   s;   |  Ee  Z d  Z d d d  Z d d   Z d d   Z d S(	   u	   Semaphorei   c             C   s   t  j |  t | t  d  S(   N(   u   SemLocku   __init__u	   SEMAPHOREu   SEM_VALUE_MAX(   u   selfu   value(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   __init__S   s    u   Semaphore.__init__c             C   s   |  j  j   S(   N(   u   _semlocku
   _get_value(   u   self(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu	   get_valueV   s    u   Semaphore.get_valuec             C   s6   y |  j  j   } Wn t k
 r- d } Yn Xd | S(   Nu   unknownu   <Semaphore(value=%s)>(   u   _semlocku
   _get_valueu	   Exception(   u   selfu   value(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   __repr__Y   s
    u   Semaphore.__repr__N(   u   __name__u
   __module__u   __qualname__u   __init__u	   get_valueu   __repr__(   u
   __locals__(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu	   SemaphoreQ   s   c             B   s/   |  Ee  Z d  Z d d d  Z d d   Z d S(   u   BoundedSemaphorei   c             C   s   t  j |  t | |  d  S(   N(   u   SemLocku   __init__u	   SEMAPHORE(   u   selfu   value(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   __init__f   s    u   BoundedSemaphore.__init__c             C   sB   y |  j  j   } Wn t k
 r- d } Yn Xd | |  j  j f S(   Nu   unknownu)   <BoundedSemaphore(value=%s, maxvalue=%s)>(   u   _semlocku
   _get_valueu	   Exceptionu   maxvalue(   u   selfu   value(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   __repr__i   s    u   BoundedSemaphore.__repr__N(   u   __name__u
   __module__u   __qualname__u   __init__u   __repr__(   u
   __locals__(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   BoundedSemaphored   s   c             B   s,   |  Ee  Z d  Z d d   Z d d   Z d S(   u   Lockc             C   s   t  j |  t d d  d  S(   Ni   (   u   SemLocku   __init__u	   SEMAPHORE(   u   self(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   __init__w   s    u   Lock.__init__c             C   s   y |  j  j   rP t   j } t j   j d k r | d t j   j 7} q nB |  j  j   d k rn d } n$ |  j  j   d k r d } n d } Wn t k
 r d } Yn Xd	 | S(
   Nu
   MainThreadu   |i   u   Nonei    u   SomeOtherThreadu   SomeOtherProcessu   unknownu   <Lock(owner=%s)>(	   u   _semlocku   _is_mineu   current_processu   nameu	   threadingu   current_threadu
   _get_valueu   _countu	   Exception(   u   selfu   name(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   __repr__z   s    		
u   Lock.__repr__N(   u   __name__u
   __module__u   __qualname__u   __init__u   __repr__(   u
   __locals__(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   Locku   s   c             B   s,   |  Ee  Z d  Z d d   Z d d   Z d S(   u   RLockc             C   s   t  j |  t d d  d  S(   Ni   (   u   SemLocku   __init__u   RECURSIVE_MUTEX(   u   self(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   __init__   s    u   RLock.__init__c             C   s   y |  j  j   r_ t   j } t j   j d k rM | d t j   j 7} n  |  j  j   } nT |  j  j   d k r d \ } } n0 |  j  j   d k r d \ } } n d \ } } Wn t k
 r d \ } } Yn Xd
 | | f S(   Nu
   MainThreadu   |i   u   Nonei    u   SomeOtherThreadu   nonzerou   SomeOtherProcessu   unknownu   <RLock(%s, %s)>(   u   Nonei    (   u   SomeOtherThreadu   nonzero(   u   SomeOtherProcessu   nonzero(   u   unknownu   unknown(	   u   _semlocku   _is_mineu   current_processu   nameu	   threadingu   current_threadu   _countu
   _get_valueu	   Exception(   u   selfu   nameu   count(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   __repr__   s    u   RLock.__repr__N(   u   __name__u
   __module__u   __qualname__u   __init__u   __repr__(   u
   __locals__(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   RLock   s   c             B   s   |  Ee  Z d  Z d d d  Z d d   Z d d   Z d d   Z d	 d
   Z d d   Z	 d d   Z
 d d d  Z d d   Z d d   Z d d d  Z d S(   u	   Conditionc             C   sM   | p t    |  _ t d  |  _ t d  |  _ t d  |  _ |  j   d  S(   Ni    (   u   RLocku   _locku	   Semaphoreu   _sleeping_countu   _woken_countu   _wait_semaphoreu   _make_methods(   u   selfu   lock(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   __init__   s
    u   Condition.__init__c             C   s&   t  |   |  j |  j |  j |  j f S(   N(   u   assert_spawningu   _locku   _sleeping_countu   _woken_countu   _wait_semaphore(   u   self(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   __getstate__   s    
u   Condition.__getstate__c             C   s,   | \ |  _  |  _ |  _ |  _ |  j   d  S(   N(   u   _locku   _sleeping_countu   _woken_countu   _wait_semaphoreu   _make_methods(   u   selfu   state(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   __setstate__   s    u   Condition.__setstate__c             C   s   |  j  j   S(   N(   u   _locku	   __enter__(   u   self(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu	   __enter__   s    u   Condition.__enter__c             G   s   |  j  j |   S(   N(   u   _locku   __exit__(   u   selfu   args(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   __exit__   s    u   Condition.__exit__c             C   s"   |  j  j |  _ |  j  j |  _ d  S(   N(   u   _locku   acquireu   release(   u   self(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   _make_methods   s    u   Condition._make_methodsc             C   sR   y& |  j  j j   |  j j j   } Wn t k
 r@ d } Yn Xd |  j | f S(   Nu   unknownu   <Condition(%s, %s)>(   u   _sleeping_countu   _semlocku
   _get_valueu   _woken_countu	   Exceptionu   _lock(   u   selfu   num_waiters(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   __repr__   s    u   Condition.__repr__c             C   s   |  j  j   |  j j j   } x! t |  D] } |  j j   q, Wz |  j j d |  SWd  |  j	 j   x! t |  D] } |  j j   qw WXd  S(   NT(
   u   _sleeping_countu   releaseu   _locku   _semlocku   _countu   rangeu   _wait_semaphoreu   acquireu   Trueu   _woken_count(   u   selfu   timeoutu   countu   i(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   wait   s    u   Condition.waitc             C   sn   x( |  j  j d  r* |  j j d  } q W|  j j d  rj |  j j   |  j  j   |  j j d  n  d  S(   NF(   u   _woken_countu   acquireu   Falseu   _sleeping_countu   _wait_semaphoreu   release(   u   selfu   res(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   notify   s    u   Condition.notifyc             C   s   x( |  j  j d  r* |  j j d  } q Wd } x- |  j j d  r` |  j j   | d 7} q4 W| r x! t |  D] } |  j  j   qt Wx |  j j d  r q Wn  d  S(   Ni    i   F(   u   _woken_countu   acquireu   Falseu   _sleeping_countu   _wait_semaphoreu   releaseu   range(   u   selfu   resu   sleepersu   i(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu
   notify_all   s    u   Condition.notify_allc             C   s   |   } | r | S| d  k	 r/ t   | } n d  } d  } xL | s | d  k	 rp | t   } | d k rp Pqp n  |  j |  |   } q> W| S(   Ni    (   u   Noneu   _timeu   wait(   u   selfu	   predicateu   timeoutu   resultu   endtimeu   waittime(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   wait_for  s    		u   Condition.wait_forN(   u   __name__u
   __module__u   __qualname__u   Noneu   __init__u   __getstate__u   __setstate__u	   __enter__u   __exit__u   _make_methodsu   __repr__u   waitu   notifyu
   notify_allu   wait_for(   u
   __locals__(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu	   Condition   s   c             B   sS   |  Ee  Z d  Z d d   Z d d   Z d d   Z d d   Z d d	 d
  Z d S(   u   Eventc             C   s%   t  t    |  _ t d  |  _ d  S(   Ni    (   u	   Conditionu   Locku   _condu	   Semaphoreu   _flag(   u   self(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   __init__$  s    u   Event.__init__c          
   C   sM   |  j  j   z+ |  j j d  r3 |  j j   d Sd SWd  |  j  j   Xd  S(   NFT(   u   _condu   acquireu   _flagu   Falseu   releaseu   True(   u   self(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   is_set(  s    u   Event.is_setc          
   C   sP   |  j  j   z. |  j j d  |  j j   |  j  j   Wd  |  j  j   Xd  S(   NF(   u   _condu   acquireu   _flagu   Falseu   releaseu
   notify_all(   u   self(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   set2  s    u	   Event.setc          
   C   s6   |  j  j   z |  j j d  Wd  |  j  j   Xd  S(   NF(   u   _condu   acquireu   _flagu   Falseu   release(   u   self(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   clear;  s    u   Event.clearc          
   C   s   |  j  j   z] |  j j d  r2 |  j j   n |  j  j |  |  j j d  re |  j j   d Sd SWd  |  j  j   Xd  S(   NFT(   u   _condu   acquireu   _flagu   Falseu   releaseu   waitu   True(   u   selfu   timeout(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   waitB  s    u
   Event.waitN(	   u   __name__u
   __module__u   __qualname__u   __init__u   is_setu   setu   clearu   Noneu   wait(   u
   __locals__(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   Event"  s
   
	c             B   s   |  Ee  Z d  Z d d d d  Z d d   Z d d   Z e d d    Z e j	 d	 d    Z e d
 d    Z
 e
 j	 d d    Z
 d S(   u   Barrierc             C   sp   d d  l  } d d l m } | | j d  d  } t   } |  j | | | | | f  d |  _ d |  _ d  S(   Ni    (   u   BufferWrapperu   ii   (   u   structu   multiprocessing.heapu   BufferWrapperu   calcsizeu	   Conditionu   __setstate__u   _stateu   _count(   u   selfu   partiesu   actionu   timeoutu   structu   BufferWrapperu   wrapperu   cond(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   __init__W  s    		u   Barrier.__init__c             C   sC   | \ |  _  |  _ |  _ |  _ |  _ |  j j   j d  |  _ d  S(   Nu   i(   u   _partiesu   _actionu   _timeoutu   _condu   _wrapperu   create_memoryviewu   castu   _array(   u   selfu   state(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   __setstate__`  s    $u   Barrier.__setstate__c             C   s"   |  j  |  j |  j |  j |  j f S(   N(   u   _partiesu   _actionu   _timeoutu   _condu   _wrapper(   u   self(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   __getstate__e  s    u   Barrier.__getstate__c             C   s   |  j  d S(   Ni    (   u   _array(   u   self(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   _statei  s    u   Barrier._statec             C   s   | |  j  d <d  S(   Ni    (   u   _array(   u   selfu   value(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   _statem  s    c             C   s   |  j  d S(   Ni   (   u   _array(   u   self(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   _countq  s    u   Barrier._countc             C   s   | |  j  d <d  S(   Ni   (   u   _array(   u   selfu   value(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   _countu  s    N(   u   __name__u
   __module__u   __qualname__u   Noneu   __init__u   __setstate__u   __getstate__u   propertyu   _stateu   setteru   _count(   u
   __locals__(    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   BarrierU  s   	u   Barrier(   u   __all__u	   threadingu   sysu   _multiprocessingu   multiprocessing.processu   current_processu   multiprocessing.utilu   register_after_forku   debugu   multiprocessing.forkingu   assert_spawningu   Popenu   timeu   _timeu   SemLocku   ImportErroru   listu   rangeu   RECURSIVE_MUTEXu	   SEMAPHOREu   SEM_VALUE_MAXu   objectu	   Semaphoreu   BoundedSemaphoreu   Locku   RLocku	   Conditionu   Eventu   Barrier(    (    (    u@   /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu   <module>   s.   $z3