SvL>#p g d Z ddlZddlZddlZddlZddlZddlmZ ddlmZ ddlm Z ddlm
Z
m Z n# e $ r e d w xY w 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 dej ZdS ))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 | e Zd Z ej Zd Zed Zd Z d Z
d Z d Z d Z
ed Zd S )
r
c | t j }| dk | _ t
j dk p| j }t d D ]E} t j ||||
| x}| _ n # t $ r Y Bw xY wt d t j d|j z | t
j dk rd }t j | | | j j Kddlm} | | j j d t j | t j | j j fd
d S d S ) Nforkwin32d z cannot find name for semaphorez created semlock with handle %sc 8 | j d S N)_semlock _after_fork)objs B/opt/alt/python311/lib64/python3.11/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 s ;*6688C 0 0 2 2f <\W,A0A
s
D
DA
%5%=%4??+<+< & & T] #
""BCC C
3bi?@@@ <7 " "
+
+
+ $T; 7 7 7 = )
3 2 2 2 2 2 HT]' 5 5 5 M$ 04=3E2G'(
*
*
*
*
*
*
* )s '1B
B'&B'c H ddl m} t | || d d S )Nr )
unregisterr )r. r; r )r- r; s r r0 zSemLock._cleanupT s: 0000004
4%%%%%r c J | j j | _ | j j | _ d S r )r acquirereleaser1 s r r+ zSemLock._make_methodsZ s }, }, r c 4 | j S r )r __enter__r? s r rA zSemLock.__enter__^ s }&&(((r c | j j | S r )r __exit__r1 argss r rC zSemLock.__exit__a s %t}%t,,r c t j | | j }t j dk r,t j |j }n | j rt 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 " "*,,@@KKAA
K" $J K K K A27BK11r c t j j | | _ t j d|d z | d| _ d S )Nz recreated blocker with handle %rr F)r& r
_rebuildr r r) r+ r" r1 states r __setstate__zSemLock.__setstate__r sN (095A
5a@AAA !r c v t j j d dt t j S )N semprefix-)r current_process_confignextr
_rand r r r' zSemLock._make_namey s6 !133;KHHH w}---/ /r N)__name__
__module__ __qualname__tempfile_RandomNameSequencerX r9 staticmethodr0 r+ rA rC rL rQ r' rY r r r
r
. s (H ( * *E * * *D & & \&
- - -) ) )- - - 2 2 2 " " " / / \/ / /r r
c " e Zd ZddZd Zd ZdS )r r c L t j | t |t | d S Nr5 )r
r9 SEMAPHORE
SEM_VALUE_MAXr1 r3 r5 s r r9 zSemaphore.__init__ s$ y% CHHHHHHr c 4 | j S r )r
_get_valuer? s r get_valuezSemaphore.get_value s }'')))r c | j }n# t $ r d}Y nw xY wd| j j d|dS )Nunknown<(value=)>)r rh Exception __class__rZ r1 r3 s r __repr__zSemaphore.__repr__ s[ M,,..EE EEE #'>#:#:#:EEEBB ++Nr )rZ r[ r\ r9 ri rr rY r r r r sO I I I I* * *C C C C Cr r c e Zd ZddZd ZdS )r r c B t j | t ||| d S rb r
r9 rd rf s r r9 zBoundedSemaphore.__init__ s$ y%C@@@@@@r c | j }n# t $ r d}Y nw xY wd| j j d|d| j j dS )Nrk rl rm z , maxvalue=rn )r rh ro rp rZ r4 rq s r rr zBoundedSemaphore.__repr__ sp M,,..EE EEE '''
0F0F0FH Hrs Nrt rZ r[ r\ r9 rr rY r r r r s@ A A A AH H H H Hr r c e Zd Zd Zd ZdS )r c B t j | t dd| d S Nr rc rw r1 r5 s r r9 z
Lock.__init__ s$ y!QC888888r c | j rSt j j }t j j dk r |dt j j z z
}nB| j dk rd}n"| j dk rd}nd}n# t $ r d}Y nw xY wd | j
j d
|d S ) N
MainThread|r Noner SomeOtherThreadSomeOtherProcessrk rl z(owner=rn ) r _is_miner rU r- threadingcurrent_threadrh _countro rp rZ )r1 r- s r rr z
Lock.__repr__ s }%%''
* .005 +--2lBBC)":"<"<"A AAD ))++q00 %%''!++() DDD #'>#:#:#:DDDAAs B.B1 1 C ?C Nry rY r r r r s7 9 9 9B B B B Br r c e Zd Zd Zd ZdS )r c B t j | t dd| d S r| )r
r9 RECURSIVE_MUTEXr} s r r9 zRLock.__init__ s$ 1#>>>>>>r c | j rlt j j }t j j dk r |dt j j z z
}| j }nK| j dk rd\ }}n(| j dk rd\ }}nd\ }}n# t $ r d\ }}Y nw xY wd | j
j d
|d |d S )
Nr r r )r r r )r nonzero)r r )rk rk rl (, rn ) r r r rU r- r r r rh ro rp rZ )r1 r- counts r rr zRLock.__repr__ s
/}%%''
< .005 +--2lBBC)":"<"<"A AAD
,,.. ))++q00 ' ee %%''!++ : ee ; e / / /.KD%%% /!% !8!8!8$$$FFs CC C%$C%Nry rY r r r r s7 ? ? ?G G G G Gr r c X e Zd ZddZd Zd Zd Zd Zd Zd Z dd Z
dd Z d Z dd
Z
dS )r Nc |p| | _ | d | _ | d | _ | d | _ | d S Nr )r _lockr _sleeping_count _woken_count_wait_semaphorer+ )r1 lockr5 s r r9 zCondition.__init__ sj (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__ s2 %%%
D 0!4#79 9r c d |\ | _ | _ | _ | _ | d S r )r r r r r+ rO s r rQ zCondition.__setstate__ s6 49 2T)
D 0 r c 4 | j S r )r rA r? s r rA zCondition.__enter__ s z##%%%r c | j j | S r )r rC rD s r rC zCondition.__exit__ s "tz"D))r c J | j j | _ | j j | _ d S r )r r= r> r? s r r+ zCondition._make_methods s z) z) r c | j j | j j z
}n# t $ r d}Y nw xY wd| j j d| j d|dS )Nrk rl r r rn )r r rh r ro rp rZ r )r1 num_waiterss r rr zCondition.__repr__ s $ /8CCEE ,5@@BB CKK $ $ $#KKK $!% !8!8!8$***kkkRRs =A AAc | j | j j }t | D ]}| j | j d| | j t | D ]}| j S # | j t | D ]}| j w xY w)NT) r r> r r r r% r r= r )r1 timeoutr r7 s r waitzCondition.wait s
$$&&&
#**,,u ! !A J %'//g>>
% % ' ' ' 5\\
%
%
""$$$$
%
% % ' ' ' 5\\
%
%
""$$$$
%s
$C AD r c . | j d r4| j d }| j d 4d}||k rX| j d r>| j |dz
}||k r| j d >|rbt | D ]}| j | j d r | j d d S d S d S )NFr r )r r= r r r> r% )r1 nressleepersr7 s r notifyzCondition.notify s? ''.. 8&..u55C ''.. 8
llt 3 ; ;E B Bl ( ( * * * MH llt 3 ; ;E B Bl 8__
,
,!))++++ &..u55
&..u55
r c F | t j d S )N)r )r r# maxsizer? s r
notify_allzCondition.notify_all/ s ck """""r c | }|r|S |t j |z }nd }d }|s@| |t j z
}|dk rn!| | | }|@|S r )time monotonicr )r1 predicater resultendtimewaittimes r wait_forzCondition.wait_for2 s M n&&0GGGH !""T^%5%55q== IIh Y[[F
!
r r rt )rZ r[ r\ r9 rL rQ rA rC r+ rr r r r r rY r r r r s 9 9 9
& & &* * ** * *S S S% % % %. 4# # # r r c : e Zd Zd Zd Zd Zd Zd dZdefdZ dS )
r c | | | _ | d | _ d S r )r r _condr _flagr} s r r9 zEvent.__init__J s4 ]]388::..
]]1%%
r c | j 5 | j d r'| j d d d dS d d d dS # 1 swxY w Y d S NFT)r r r= r> r? s r is_setz Event.is_setN s
Z z!!%((
""$$$ s 5A
AA A c | j 5 | j d | j | j d d d d S # 1 swxY w Y d S NF)r r r= r> r r? s r setz Event.setU s
Z $ $ J u % % % J J ! ! # # # $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $s A
A""A&)A&c z | j 5 | j d d d d d S # 1 swxY w Y d S r )r r r= r? s r clearz Event.clear[ s
Z & & J u % % % & & & & & & & & & & & & & & & & & &s 044Nc f | j 5 | j d r| j n| j | | j d r'| j d d d dS d d d dS # 1 swxY w Y d S r )r r r= r> r )r1 r s r r z
Event.wait_ s
Z z!!%((
)
""$$$$
(((z!!%((
""$$$ s BB&B&&B*-B*returnc | rdnd}dt | j dt | dd| dS )Nr unsetrl z at z#x >)r typer\ id)r1
set_statuss r rr zEvent.__repr__k sK "kkmm8UU
K4::*KK4KKKjKKKKr r )
rZ r[ r\ r9 r r r r strrr rY r r r r H s & & & $ $ $ & & &
L# L L L L L Lr r c e Zd Zd dZd Zd Zed Zej d Zed Z e j d Z dS )
BarrierNc dd l }ddlm} || d dz }| }| |||||f d| _ d| _ d S )Nr r )
BufferWrapperr7 r )structheapr calcsizer rQ _stater ) r1 partiesactionr r5 r r wrapperconds r r9 zBarrier.__init__t s{
'''''' - 4 4q 899}} 7FGT7CDDD r c |\ | _ | _ | _ | _ | _ | j d | _ d S )Nr7 )_parties_action_timeoutr _wrappercreate_memoryviewcast_arrayrO s r rQ zBarrier.__setstate__} sF &+ $ dm
T]m5577<r s
4444444444 4 4 4
+ 3 4 4 44 "T%%((^^ (6
N/ N/ N/ N/ N/f N/ N/ N/h
C
C
C
C
C
C
C
C& H H H H Hy H H H"B B B B B7 B B B2G G G G GG G G G4i i i i i i i i^%L %L %L %L %LF %L %L %LT" " " " " i " " " " " s 5 A