֦i/ g d Z ddlZddlZddlZddlZddlZddlmZ ddlmZ ddlm Z ddlm
Z
m Z e
ed \ ZZej j" Z G d
d e Z
G d d
e
Z G d de Z G d de
Z G d de
Z G d de Z G d de Z G d dej2 Zy# e $ r e d w xY w))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 r e Zd Z ej Zd Zed Zd Z d Z
d Z d Z d Z
ed Zy )
r
c | t j j }|j dk( | _ t
j dk( xs | j }t d D ]2 } t j |||| j | x}| _ n t d t j d|j z | j! t
j dk7 rd }t j" | | | j j$ `ddlm} | | j j$ d t j* | t j, | j j$ fd
y y # t $ r Y !w xY w) Nforkwin32d z cannot find name for semaphorez created semlock with handle %sc 8 | j j y N)_semlock _after_fork)objs 4/usr/lib64/python3.12/multiprocessing/synchronize.pyr z%SemLock.__init__.._after_forkG s ((* r )register semaphorer ) exitpriority)r
_default_context get_contextget_start_method _is_fork_ctxsysplatformrange_multiprocessingr
_make_namer FileExistsErrorr debughandle
_make_methodsregister_after_forknameresource_trackerr Finalize_cleanup)
selfkindvaluemaxvaluectx
unlink_nowislr r s
r __init__zSemLock.__init__2 sI ;**668C 0 0 2f <\\W,A0A0A
sA
%5%=%=%4??+< & T] ""BC C
3bii?@ <<7 "
+ $ $T; 7 == )
3 T]]'' 5 MM$ 0 04==3E3E2G'(
*
* #
s ).E:: FFc 8 ddl m} t | || d y )Nr )
unregisterr )r. r; r )r- r; s r r0 zSemLock._cleanupT s 044%r c p | j j | _ | j j | _ y r )r acquirereleaser1 s r r+ zSemLock._make_methodsZ s$ }},, }},, r c 6 | j j S r )r __enter__r? s r rA zSemLock.__enter__^ s }}&&((r c 4 | j j | S r )r __exit__r1 argss r rC zSemLock.__exit__a s %t}}%%t,,r c T t j | | j }t j dk( r.t j
j
|j }n#| j r t d |j }||j |j |j fS )Nr zA SemLock created in a fork context is being shared with a process in a spawn context. This is not supported. Please use the same context to create multiprocessing objects and Process.)
r
assert_spawningr r# r$ get_spawning_popenduplicate_for_childr* r" RuntimeErrorr2 r4 r- )r1 r8 hs r __getstate__zSemLock.__getstate__d s %
]] <<7 "**,@@KA " $J K K A277BKK11r c t j j | | _ t j
d|d z | j
d| _ y )Nz recreated blocker with handle %rr F)r& r
_rebuildr r r) r+ r" r1 states r __setstate__zSemLock.__setstate__r sD (00995A
5a@A !r c | t j j d dt t j
S )N semprefix-)r current_process_confignextr
_rand r r r' zSemLock._make_namey s/ !113;;KH w}}-/ /r N)__name__
__module__ __qualname__tempfile_RandomNameSequencerX r9 staticmethodr0 r+ rA rC rL rQ r' rY r r r
r
. sY (H ( ( *E *D & &
-)- 2 " / /r r
c e Zd ZddZd Zd Zy)r c H t j | t |t | y Nr5 )r
r9 SEMAPHORE
SEM_VALUE_MAXr1 r3 r5 s r r9 zSemaphore.__init__ s y% CHr c 6 | j j S r )r
_get_valuer? s r get_valuezSemaphore.get_value s }}''))r c | j j }d| j j d|dS # t $ r d}Y *w xY w)Nunknown<(value=)>)r rh Exception __class__rZ r1 r3 s r __repr__zSemaphore.__repr__ sG MM,,.E $(>>#:#:EBB E s 9 AANr )rZ r[ r\ r9 ri rr rY r r r r s I*Cr r c e Zd ZddZd Zy)r c @ t j | t ||| y rb r
r9 rd rf s r r9 zBoundedSemaphore.__init__ s y%C@r c | j j }d| j j d|d| j j
dS # t $ r d}Y Aw xY w)Nrk rl rm z , maxvalue=rn )r rh ro rp rZ r4 rq s r rr zBoundedSemaphore.__repr__ sY MM,,.E ''
0F0FH H E s A A A Nrs rZ r[ r\ r9 rr rY r r r r s AHr r c e Zd Zd Zd Zy)r c @ t j | t dd| y Nr rc rv r1 r5 s r r9 z
Lock.__init__ s y!QC8r c | j j rdt j j }t j j dk7 rd|dt j j z z
}n?| j j sd}n"| j j dkD rd}nd}d| j j d |d
S # t $ r d}Y *w xY w) N
MainThread|Noner SomeOtherThreadSomeOtherProcessrk rl z(owner=rn ) r _is_miner rU r- threadingcurrent_thread_is_zero_countro rp rZ )r1 r- s r rr z
Lock.__repr__ s }}%%' ..055 ++-22lBC)":":"<"A"A AAD]]++- %%'!+() $(>>#:#:DAA D s B=C C*)C*Nrx rY r r r r s
9Br r c e Zd Zd Zd Zy)r c @ t j | t dd| y r{ )r
r9 RECURSIVE_MUTEXr| s r r9 zRLock.__init__ s 1#>r c , | j j r~t j j }t j j dk7 r$|dt j j z z
}| j j }nH| j j sd\ }}n(| j j dkD rd\ }}nd\ }}d| j j d |d
|d S # t $ r d\ }}Y 0w xY w) Nr~ r )r r r )r nonzero)r r )rk rk rl (, rn ) r r r rU r- r r r r ro rp rZ )r1 r- counts r rr zRLock.__repr__ s
/}}%%' ..055 ++-22lBC)":":"<"A"A AAD
,,.]]++- ' e %%'!+ : e ; e "& !8!8$FF /.KD% /s C D DDNrx rY r r r r s
?Gr r c V e Zd Zd
dZd Zd Zd Zd Zd Zd Z d
d Z
dd
Z d Z d
d Z
y)r Nc |xs |j | _ |j d | _ |j d | _ |j d | _ | j
y Nr )r _lockr _sleeping_count _woken_count_wait_semaphorer+ )r1 lockr5 s r r9 zCondition.__init__ sS (SYY[
"}}Q / MM! , "}}Q / r c t j | | j | j | j | j
fS r )r
rG r r r r r? s r rL zCondition.__getstate__ s: %
D 0 0!!4#7#79 9r c Z |\ | _ | _ | _ | _ | j y r )r r r r r+ rO s r rQ zCondition.__setstate__ s* 49 2T)
D 0 r c 6 | j j S r )r rA r? s r rA zCondition.__enter__ s zz##%%r c 4 | j j | S r )r rC rD s r rC zCondition.__exit__ s "tzz""D))r c p | j j | _ | j j | _ y r )r r= r> r? s r r+ zCondition._make_methods s$ zz)) zz)) r c | j j j | j j j z
}d| j
j d| j d|dS # t $ r d}Y 7w xY w)Nrk rl r r rn )r r rh r ro rp rZ r )r1 num_waiterss r rr zCondition.__repr__ ss $ //88CCE ,,55@@B CK "& !8!8$**kRR $#K $s A A5 5 BBc & | j j | j j j }t | D ] }| j j | j j d| | j j t | D ] }| j j S # | j j t | D ] }| j j w xY w)NT) r r> r r r r% r r= r )r1 timeoutr r7 s r waitzCondition.wait s
$$&
##**,u A JJ %''//g>
% % ' 5\
""$ "
% % ' 5\
""$ "s
*C
ADc 8 | j j d r7| j j d }| j j d r7d}||k r[| j j d r@| j j |dz
}||k r | j j d r@|rdt | D ] }| j j | j j d r | j j d r y y y )NFr r )r r= r r r> r% )r1 nressleepersr7 s r notifyzCondition.notify s ''.&&..u5C ''.
lt 3 3 ; ;E B ( ( * MH lt 3 3 ; ;E B 8_!!))+ % &&..u5 &&..u5 r c D | j t j y )N)r )r r# maxsizer? s r
notify_allzCondition.notify_all/ s ckk "r c | }|r|S |t j |z }nd }d }|s<| |t j z
}|dk r |S | j | }|s<|S r )time monotonicr )r1 predicater resultendtimewaittimes r wait_forzCondition.wait_for2 s~ M nn&0GGH""T^^%55q=
IIh [F
r r rs )rZ r[ r\ r9 rL rQ rA rC r+ rr r r r r rY r r r r s: 9
&**S%.4#r r c 2 e Zd Zd Zd Zd Zd ZddZd Zy) r c x |j |j | _ |j d | _ y r )r r _condr _flagr| s r r9 zEvent.__init__J s( ]]388:.
]]1%
r c | j 5 | j j d r$| j j d d d y d d d y# 1 sw Y y xY wNFT)r r r= r> r? s r is_setz Event.is_setN sD
ZZzz!!%(
""$ Z ZZs 7A
AA c | j 5 | j j d | j j | j j d d d y # 1 sw Y y xY wNF)r r r= r> r r? s r setz Event.setU sE
ZZ JJ u % JJ JJ ! ! # ZZs AA&&A/c | | j 5 | j j d d d d y # 1 sw Y y xY wr )r r r= r? s r clearz Event.clear[ s%
ZZ JJ u % ZZs 2;Nc h | j 5 | j j d r| j j n| j j | | j j d r$| j j d d d y d d d y# 1 sw Y y xY wr )r r r= r> r )r1 r s r r z
Event.wait_ sv
ZZzz!!%(
""$
(zz!!%(
""$ Z ZZs BB( B((B1c | | j rdnd}dt | j dt | dd| dS )Nr unsetrl z at z#x >)r typer\ id)r1
set_statuss r rr zEvent.__repr__k s= "kkmU
4:**+44}Aj\KKr r ) rZ r[ r\ r9 r r r r rr rY r r r r H s! &$ &
Lr r c e Zd Zd dZd Zd Zed Zej d Zed Z e j d Z y)
BarrierNc dd l }ddlm} ||j d dz }|j }| j |||||f d| _ d| _ y )Nr r )
BufferWrapperr7 r )structheapr calcsizer rQ _stater ) r1 partiesactionr r5 r r wrapperconds r r9 zBarrier.__init__t sR ' 4q 89}} 7FGT7CD r c |\ | _ | _ | _ | _ | _ | j j j
d | _ y )Nr7 )_parties_action_timeoutr _wrappercreate_memoryviewcast_arrayrO s r rQ zBarrier.__setstate__} s> &+ $ dm
T]mm557<r s
44 "%(^ ((66
N/f N/h
C
C& Hy H"B7 B2GG G4i i^%LF %LT" i " k
4
3 4 44s B> >C