ž
¨ÿ 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__.._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 ( 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) ( 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 ( 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 ( 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 ( 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 s.
$z3