← Back
Editing: synchronize.cpython-33.pyc
� �� 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 � s t d � � | j j � | j j j � } x! t | � D] } | j j � qJ Wz | j j d | � SWd | j j � x! t | � D] } | j j � q� WXd S( Nu, must acquire() condition before using wait()T( u _locku _semlocku _is_mineu AssertionErroru _sleeping_countu releaseu _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 s� | j j j � s t d � � | j j d � s7 t � x4 | j j d � rm | j j d � } | s: t � q: W| j j d � r� | j j � | j j � | j j d � n d S( Nu lock is not ownedF( u _locku _semlocku _is_mineu AssertionErroru _wait_semaphoreu acquireu Falseu _woken_countu _sleeping_countu release( u selfu res( ( u@ /opt/alt/python33/lib64/python3.3/multiprocessing/synchronize.pyu notify� s u Condition.notifyc C s� | j j j � s t d � � | j j d � s7 t � x4 | j j d � rm | j j d � } | s: t � q: Wd } x- | j j d � r� | j j � | d 7} qw W| r� x! t | � D] } | j j � q� Wx | j j d � r� q� Wn d S( Nu lock is not ownedi i F( u _locku _semlocku _is_mineu AssertionErroru _wait_semaphoreu acquireu Falseu _woken_countu _sleeping_countu 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. $z3
Save File
Cancel