o
0iZ- @ s g d Z ddlZddlZddlZddlZddlZddlmZ ddlmZ ddlm Z z
ddlm
Z
m Z W n e y? e dw e
ed \ZZej
jZG d
d d eZ
G d d
d
e
ZG dd deZG dd de
ZG dd de
ZG dd deZG dd deZG dd dejZdS ))LockRLock SemaphoreBoundedSemaphore ConditionEvent N )context)process)util)SemLock
sem_unlinkzThis 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 u r t j }| }tjdkp|dk}tdD ] }zt|||| | }| _
W n t y5 Y qw nt dt
d|j | tjdkrWdd } t | | | j
jd urydd lm}
|
| j
jd
t j| tj| j
jfd d d S d S )
Nwin32forkd z cannot find name for semaphorez created semlock with handle %sc S s | j d S N)_semlock _after_fork)obj r B/opt/alt/python310/lib64/python3.10/multiprocessing/synchronize.pyr G s z%SemLock.__init__.._after_forkr )register semaphorer )Z exitpriority)r Z_default_contextZ get_contextZget_start_methodsysplatformrange_multiprocessingr
_make_namer FileExistsErrorr debughandle
_make_methodsZregister_after_forknameresource_trackerr ZFinalize_cleanup) selfkindvaluemaxvaluectxr# Z
unlink_nowislr r r r r __init__2 s6
zSemLock.__init__c C s" ddl m} t| || d d S )Nr )
unregisterr )r$ r. r
)r# r. r r r r% T s zSemLock._cleanupc C | j j| _| j j| _d S r )r acquirereleaser& r r r r" Z
zSemLock._make_methodsc C
| j S r )r __enter__r2 r r r r5 ^
zSemLock.__enter__c G | j j| S r )r __exit__r& argsr r r r8 a zSemLock.__exit__c C sD t | | j}tjdkrt |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| | _td|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 ttjf S )Nz%s-%sZ semprefix)r
current_processZ_confignextr _randr r r r r r s zSemLock._make_nameN)__name__
__module__ __qualname__tempfileZ_RandomNameSequencerD r- staticmethodr% r" r5 r8 r> rA r r r r r r . s "
r c @ s& e Zd Zd ddZdd Zdd ZdS )
r r c C s t j| t|t|d d S Nr* )r r- SEMAPHORE
SEM_VALUE_MAXr& r( r* r r r r- } zSemaphore.__init__c C r4 r )r
_get_valuer2 r r r get_value r6 zSemaphore.get_valuec C s6 z| j }W n ty d}Y nw d| jj|f S )Nunknownz<%s(value=%s)>)r rP Exception __class__rE r& r( r r r __repr__ s zSemaphore.__repr__Nr )rE rF rG r- rQ rV r r r r r { s
r c @ s e Zd ZdddZdd ZdS )r r c C s t j| t|||d d S rJ r r- rL rN r r r r- rO zBoundedSemaphore.__init__c C s< z| j }W n ty d}Y nw d| jj|| j jf S )NrR z<%s(value=%s, maxvalue=%s)>)r rP rS rT rE r) rU r r r rV s zBoundedSemaphore.__repr__NrW rE rF rG r- rV r r r r r s
r c @ e Zd Zdd Zdd ZdS )r c C t j| tdd|d d S Nr rK rX r& r* r r r r- rO z
Lock.__init__c C s z3| j r t j}t jdkr|dt j 7 }n| j dkr&d}n | j dkr0d}nd}W n t y> d}Y nw d | j
j |f S )
N
MainThread|r Noner SomeOtherThreadSomeOtherProcessrR z<%s(owner=%s)>) r _is_miner
rB r# threadingcurrent_threadrP _countrS rT rE )r& r# r r r rV s
z
Lock.__repr__NrY r r r r r r c @ rZ )r c C r[ r\ )r r- RECURSIVE_MUTEXr] r r r r- rO zRLock.__init__c C s z>| j r!t j}t jdkr|dt j 7 }| j }n | j dkr-d\}}n| j dkr9d\}}nd\}}W n
t yK d\}}Y nw d | j
j ||f S )
Nr^ r_ r )r` r r )ra nonzero)rb ri )rR rR <%s(%s, %s)>) r rc r
rB r# rd re rf rP rS rT rE )r& r# countr r r rV s
zRLock.__repr__NrY r r r r r rg r c @ sl e Zd ZdddZdd Zdd Zdd Zd
d Zd d
Zdd Z dddZ
dddZ dd Z dddZ
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 r )r r< rm rn ro rp r2 r r r r> s
zCondition.__getstate__c C s |\| _ | _| _| _| d S r )rm rn ro rp r" r? r r r rA s
zCondition.__setstate__c C r4 r )rm r5 r2 r r r r5 r6 zCondition.__enter__c G r7 r )rm r8 r9 r r r r8 r; zCondition.__exit__c C r/ r )rm r0 r1 r2 r r r r" r3 zCondition._make_methodsc C sH z| j j | jj }W n ty d}Y nw d| jj| j|f S )NrR rj )rn r rP ro rS rT rE rm )r& Z num_waitersr r r rV s
zCondition.__repr__c C s | j | jj }t|D ]}| j qz| jd|W | j t|D ]}| j q(S | j t|D ]}| j q:w )NT) rn r1 rm r rf r rp r0 ro )r& timeoutrk r+ r r r wait s
zCondition.waitr c C s | j dr| jd}| j dsd}||k r1| jdr1| j |d7 }||k r1| jds |rNt|D ]}| j q7| jdrP | jdsEd S d S d S )NFr r )ro r0 rn rp r1 r )r& nresZsleepersr+ r r r notify s
zCondition.notifyc C s | j tjd d S )N)rt )rv r maxsizer2 r r r
notify_all( s zCondition.notify_allc C sj | }|r|S |d urt | }nd }d }|s3|d ur)|t }|dkr) |S | | | }|r|S rl )time monotonicrs )r& Z predicaterr resultZendtimeZwaittimer r r wait_for+ s"
zCondition.wait_forr rW )rE rF rG r- r> rA r5 r8 r" rV rs rv rx r| r r r r r s
r c @ s6 e Zd Zdd Zdd Zdd Zdd Zd d
d Zd S )
r c C s | | | _|d| _d S rl )r r _condr _flagr] r r r r- C s zEvent.__init__c C sV | j | jdr| j W d dS W d dS 1 s$w Y d S NFT)r} r~ r0 r1 r2 r r r is_setG s
$z Event.is_setc C sL | j | jd | j | j W d d S 1 s w Y d S NF)r} r~ r0 r1 rx r2 r r r setN s
"z Event.setc C s8 | j | jd W d d S 1 sw Y d S r )r} r~ r0 r2 r r r clearT s "z Event.clearNc C sz | j 0 | jdr| j n| j | | jdr*| j W d dS W d dS 1 s6w Y d S r )r} r~ r0 r1 rs )r& rr r r r rs X s
$z
Event.waitr )rE rF rG r- r r r rs r r r r r A s r c @ sZ e Zd ZdddZdd Zdd Zedd Zejd
d Zed d Z e jd
d Z dS )BarrierNc C sR dd l }ddlm} ||dd }| }| |||||f d| _d| _d S )Nr r )
BufferWrapperr+ r )structZheapr Zcalcsizer rA _staterf ) r& Zpartiesactionrr r* r r wrapperZcondr r r r- j s
zBarrier.__init__c C s. |\| _ | _| _| _| _| j d| _d S )Nr+ )_parties_action_timeoutr} _wrapperZcreate_memoryviewcast_arrayr? r r r rA s s zBarrier.__setstate__c C s | j | j| j| j| jfS r )r r r r} r r2 r r r r> x s zBarrier.__getstate__c C
| j d S rl r r2 r r r r |
zBarrier._statec C || j d< d S rl r rU r r r r c C r Nr r r2 r r r rf r zBarrier._countc C r r r rU r r r rf r )NN)
rE rF rG r- rA r> propertyr setterrf r r r r r h s
r )__all__rd r rH r ry r r
r r r
ImportErrorlistr rh rL rM objectr r r r r r r r r r r s0
Mo'