B
´Šý`¿;Mã @ s, d dddddgZ ddlZddlZddlZddlZddlZdd lmZ dd
lmZ dd lm Z ydd lm
Z
m Z W n e k
rΠe d
ƒ‚Y nX e
edƒƒ\ZZej
jZG dd„ deƒZ
G dd„ de
ƒZG dd„ deƒZG dd „ d e
ƒZG dd„ de
ƒZG dd„ deƒZG dd„ deƒZG dd„ dejƒZdS )ÚLockÚRLockÚ SemaphoreÚBoundedSemaphoreÚ ConditionÚEventé Né )Úcontext)Úprocess)Úutil)ÚSemLockÚ
sem_unlinkz—This platform lacks a functioning sem_open implementation, therefore, the required synchronization primitives needed will not function, see issue 3770.é c @ s\ e Zd Ze ¡ Zdd„ Zedd„ ƒZdd„ Z dd„ Z
d d
„ Z d d „ Z d
d„ Z
edd„ ƒZdS )r c C sö |d krt j ¡ }| ¡ }tjdkp*|dk}xPtdƒD ]<}y t |||| ¡ |¡ }| _
W n t k
rn Y q6X P q6W t dƒ‚t
d|j ¡ | ¡ tjdkr´dd„ } t | | ¡ | j
jd k ròdd lm}
|
| j
jƒ t j| tj| j
jfd
d d S ) NÚwin32Úforkéd z cannot find name for semaphorez created semlock with handle %sc S s | j ¡ d S )N)Ú_semlockÚ _after_fork)Úobj© r ú@/opt/alt/python37/lib64/python3.7/multiprocessing/synchronize.pyr G s z%SemLock.__init__.._after_forkr )Úregisterr )Z exitpriority)r Z_default_contextZ get_contextZget_start_methodÚsysÚplatformÚrangeÚ_multiprocessingr Ú
_make_namer ÚFileExistsErrorr ÚdebugÚhandleÚ
_make_methodsZregister_after_forkÚnameÚsemaphore_trackerr ZFinalizeÚ_cleanup) ÚselfÚkindÚvalueÚmaxvalueÚctxr! Z
unlink_nowÚiÚslr r r r r Ú__init__2 s.
zSemLock.__init__c C s ddl m} t| ƒ || ƒ d S )Nr )Ú
unregister)r" r, r
)r! r, r r r r# T s zSemLock._cleanupc C s | j j| _| j j| _d S )N)r ÚacquireÚrelease)r$ r r r r Z s
zSemLock._make_methodsc C s
| j ¡ S )N)r Ú __enter__)r$ r r r r/ ^ s zSemLock.__enter__c G s | j j|Ž S )N)r Ú__exit__)r$ Úargsr r r r0 a s zSemLock.__exit__c C sD t | ¡ | j}tjdkr,t ¡ |j¡}n|j}||j|j |j
fS )Nr ) r Úassert_spawningr r r Zget_spawning_popenZduplicate_for_childr r% r' r! )r$ r* Úhr r r Ú __getstate__d s
zSemLock.__getstate__c C s, t jj|Ž | _t d|d ¡ | ¡ d S )Nz recreated blocker with handle %rr )r r Z_rebuildr r r r )r$ Ústater r r Ú __setstate__m s zSemLock.__setstate__c C s dt ¡ jd ttjƒf S )Nz%s-%sZ semprefix)r
Úcurrent_processZ_configÚnextr Ú_randr r r r r r s zSemLock._make_nameN)Ú__name__Ú
__module__Ú __qualname__ÚtempfileZ_RandomNameSequencer9 r+ Ú staticmethodr# r r/ r0 r4 r6 r r r r r r . s " r c @ s& e Zd Zd dd„Zdd„ Zdd„ ZdS )
r r c C s t j| t|t|d d S )N)r( )r r+ Ú SEMAPHOREÚ
SEM_VALUE_MAX)r$ r& r( r r r r+ } s zSemaphore.__init__c C s
| j ¡ S )N)r Ú
_get_value)r$ r r r Ú get_value€ s zSemaphore.get_valuec C s8 y| j ¡ }W n tk
r& d}Y nX d| jj|f S )NÚunknownz<%s(value=%s)>)r rA Ú ExceptionÚ __class__r: )r$ r& r r r Ú__repr__ƒ s
zSemaphore.__repr__N)r )r: r; r< r+ rB rF r r r r r { s
c @ s e Zd Zddd„Zdd„ ZdS )r r c C s t j| t|||d d S )N)r( )r r+ r? )r$ r& r( r r r r+ s zBoundedSemaphore.__init__c C s> y| j ¡ }W n tk
r& d}Y nX d| jj|| j jf S )NrC z<%s(value=%s, maxvalue=%s)>)r rA rD rE r: r' )r$ r& r r r rF “ s
zBoundedSemaphore.__repr__N)r )r: r; r< r+ rF r r r r r Ž s
c @ s e Zd Zdd„ Zdd„ ZdS )r c C s t j| tdd|d d S )Nr )r( )r r+ r? )r$ r( r r r r+ ¡ s z
Lock.__init__c C s yf| j ¡ r8t ¡ j}t ¡ jdkrd|dt ¡ j 7 }n,| j ¡ dkrLd}n| j ¡ dkr`d}nd}W n t k
r~ d}Y nX d | j
j |f S )
NÚ
MainThreadú|r ÚNoner ÚSomeOtherThreadÚSomeOtherProcessrC z<%s(owner=%s)>) r Ú_is_miner
r7 r! Ú threadingÚcurrent_threadrA Ú_countrD rE r: )r$ r! r r r rF ¤ s
z
Lock.__repr__N)r: r; r< r+ rF r r r r r Ÿ s c @ s e Zd Zdd„ Zdd„ ZdS )r c C s t j| tdd|d d S )Nr )r( )r r+ ÚRECURSIVE_MUTEX)r$ r( r r r r+ º s zRLock.__init__c C s¬ y|| j ¡ rBt ¡ j}t ¡ jdkr6|dt ¡ j 7 }| j ¡ }n8| j ¡ dkrZd\}}n | j ¡ dkrrd\}}nd\}}W n t k
r˜ d\}}Y nX d | j
j ||f S )
NrG rH r )rI r r )rJ Únonzero)rK rQ )rC rC z <%s(%s, %s)>) r rL r
r7 r! rM rN rO rA rD rE r: )r$ r! Úcountr r r rF ½ s
zRLock.__repr__N)r: r; r< r+ rF r r r r r ¸ s c @ sl e Zd Zddd„Zdd„ Zdd„ Zdd „ Zd
d „ Zd d
„ Zdd„ Z ddd„Z
ddd„Z dd„ Z d dd„Z
dS ) r Nc C s> |p
| ¡ | _| d¡| _| d¡| _| d¡| _| ¡ d S )Nr )r Ú_lockr Ú_sleeping_countÚ _woken_countÚ_wait_semaphorer )r$ Úlockr( r r r r+ Ô s
zCondition.__init__c C s t | ¡ | j| j| j| jfS )N)r r2 rS rT rU rV )r$ r r r r4 Û s
zCondition.__getstate__c C s |\| _ | _| _| _| ¡ d S )N)rS rT rU rV r )r$ r5 r r r r6 à s zCondition.__setstate__c C s
| j ¡ S )N)rS r/ )r$ r r r r/ å s zCondition.__enter__c G s | j j|Ž S )N)rS r0 )r$ r1 r r r r0 è s zCondition.__exit__c C s | j j| _| j j| _d S )N)rS r- r. )r$ r r r r ë s
zCondition._make_methodsc C sJ y | j j ¡ | jj ¡ }W n tk
r4 d}Y nX d| jj| j|f S )NrC z <%s(%s, %s)>)rT r rA rU rD rE r: rS )r$ Z num_waitersr r r rF ï s
zCondition.__repr__c C s‚ | j j ¡ stdƒ‚| j ¡ | j j ¡ }xt|ƒD ]}| j ¡ q4W z| j d|¡S | j
¡ xt|ƒD ]}| j ¡ qjW X d S )Nz,must acquire() condition before using wait()T) rS r rL ÚAssertionErrorrT r. rO r rV r- rU )r$ ÚtimeoutrR r) r r r Úwait÷ s
zCondition.waitr c C s¸ | j j ¡ stdƒ‚| j d¡r(tdƒ‚x(| j d¡rP| j d¡}|s*tdƒ‚q*W d}x*||k r€| j d¡r€| j ¡ |d7 }qXW |r´xt |ƒD ]}| j ¡ qW x| j d¡r²q¤W d S )Nzlock is not ownedFz;notify: Should not have been able to acquire_wait_semaphorez>notify: Bug in sleeping_count.acquire- res should not be Falser r )
rS r rL rX rV r- rU rT r. r )r$ ÚnZresZsleepersr) r r r Únotify s
zCondition.notifyc C s | j tjd d S )N)r[ )r\ r Úmaxsize)r$ r r r Ú
notify_all( s zCondition.notify_allc C sh |ƒ }|r|S |d k r$t ¡ | }nd }d }x6|sb|d k rP|t ¡ }|dkrPP | |¡ |ƒ }q.W |S )Nr )ÚtimeZ monotonicrZ )r$ Z predicaterY ÚresultZendtimeZwaittimer r r Úwait_for+ s
zCondition.wait_for)N)N)r )N)r: r; r< r+ r4 r6 r/ r0 r rF rZ r\ r^ ra r r r r r Ò s
c @ s6 e Zd Zdd„ Zdd„ Zdd„ Zdd„ Zd d
d „Zd S )
r c C s | | ¡ ¡| _| d¡| _d S )Nr )r r Ú_condr Ú_flag)r$ r( r r r r+ C s zEvent.__init__c C s0 | j | j d¡r"| j ¡ dS dS Q R X d S )NFT)rb rc r- r. )r$ r r r Úis_setG s
z Event.is_setc C s6 | j & | j d¡ | j ¡ | j ¡ W d Q R X d S )NF)rb rc r- r. r^ )r$ r r r ÚsetN s
z Event.setc C s" | j | j d¡ W d Q R X d S )NF)rb rc r- )r$ r r r ÚclearT s z Event.clearNc C sT | j D | j d¡r | j ¡ n | j |¡ | j d¡rF| j ¡ dS dS Q R X d S )NFT)rb rc r- r. rZ )r$ rY r r r rZ X s
z
Event.wait)N)r: r; r< r+ rd re rf rZ r r r r r A s
c @ sZ e Zd Zddd„Zdd„ Zdd„ Zedd „ ƒZejd
d „ ƒZed d „ ƒZ e jd
d „ ƒZ dS )ÚBarrierNc C sR dd l }ddlm} || d¡d ƒ}| ¡ }| |||||f¡ d| _d| _d S )Nr r )Ú
BufferWrapperr) r )ÚstructÚheaprh Zcalcsizer r6 Ú_staterO ) r$ ZpartiesÚactionrY r( ri rh ÚwrapperZcondr r r r+ j s zBarrier.__init__c C s. |\| _ | _| _| _| _| j ¡ d¡| _d S )Nr) )Ú_partiesÚ_actionÚ_timeoutrb Ú_wrapperZcreate_memoryviewÚcastÚ_array)r$ r5 r r r r6 s s zBarrier.__setstate__c C s | j | j| j| j| jfS )N)rn ro rp rb rq )r$ r r r r4 x s zBarrier.__getstate__c C s
| j d S )Nr )rs )r$ r r r rk | s zBarrier._statec C s || j d< d S )Nr )rs )r$ r& r r r rk € s c C s
| j d S )Nr )rs )r$ r r r rO „ s zBarrier._countc C s || j d< d S )Nr )rs )r$ r& r r r rO ˆ s )NN)
r: r; r< r+ r6 r4 Úpropertyrk ÚsetterrO r r r r rg h s
rg )Ú__all__rM r r= r r_ Ú r r
r r r
Ú ImportErrorÚlistr rP r? r@ Úobjectr r r r r r rg r r r r Ú s. Mo'