/opt/imh/python3.13/lib/python3.13/multiprocessing/__pycache__
Edit: /opt/imh/python3.13/lib/python3.13/multiprocessing/__pycache__/synchronize.cpython-313.pyc (21482B)
e/ / S Qr SSKrSSKrSSKrSSKrSSKrSSKJr SSKJr SSKJ r SSKJ
r
J r \
" \" S 5 5 u rr\R R" r " S
S \5 r
" S S
\
5 r " S S\5 r " S S\
5 r " S S\
5 r " S S\5 r " S S\5 r " S S\R2 5 rg! \ a \ " S5 ef = f))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 z \ rS rSr\R
" 5 rS r\S 5 r S r
S r S r S r
S r\S 5 rS
rg ) r
. c $ Uc [ R R 5 nUR 5 S:H U l [
R S:H =( d U R n[ S5 H0 n [ R " XX0R 5 U5 =opl O
[ S5 e[ R " SUR - 5 U R! 5 [
R S:w a S n[ R" " X5 U R R$ b^ SSKJn U " U R R$ S 5 [ R* " U [ R, U R R$ 4S
S 9 g g ! [ a GM# f = f) Nforkwin32d z cannot find name for semaphorez created semlock with handle %sc 8 U R R 5 g N)_semlock _after_fork)objs A/opt/imh/python3.13/lib/python3.13/multiprocessing/synchronize.pyr %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__SemLock.__init__2 sA ;**668C 0 0 2f <\\W,A0A0A
sA
%5%=%=??+< & ] ""BC C
3bii?@ <<7 "
+ $ $T 7 == )
3 T]]'' 5 MM$ 0 04==3E3E2G'(
*
* #
s /,F
FFc 8 SSK Jn [ U 5 U" U S5 g )Nr )
unregisterr )r0 r> r )r/ r> s r r2 SemLock._cleanupT s 044%r c p U R R U l U R R U l g r )r acquirereleaser3 s r r- SemLock._make_methodsZ s$ }},, }},, r c 6 U R R 5 $ r )r __enter__rC s r rF SemLock.__enter__^ s }}&&((r c 4 U R R " U6 $ r )r __exit__r3 argss r rI SemLock.__exit__a s }}%%t,,r c b [ R " U 5 U R n[ R S:X a/ [ R
" 5 R
UR 5 nO(U R ( a [ S5 eUR nX!R UR UR 4$ )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$ RuntimeErrorr4 r6 r/ )r3 r: hs r __getstate__SemLock.__getstate__d s %
]] <<7 "**,@@KA " $J K K A77BKK11r c [ R R " U6 U l [ R
" SUS - 5 U R
5 SU l g )Nz recreated blocker with handle %rr F)r( r
_rebuildr r r+ r- r$ r3 states r __setstate__SemLock.__setstate__r sD (00995A
5a@A !r c [ R " 5 R S < S[ [ R
5 < 3$ )N semprefix-)r current_process_confignextr
_rand r r r) SemLock._make_namey s/ !113;;KH w}}-/ /r )r$ r rA rB N)__name__
__module__ __qualname____firstlineno__tempfile_RandomNameSequencera r; staticmethodr2 r- rF rI rS rY r) __static_attributes__rb r r r
r
. sW ( ( *E *D & &
-)- 2 " / /r r
c * \ rS rSrSS jrS rS rSrg)r c D [ R " U [ U[ US9 g Nr7 )r
r; SEMAPHORE
SEM_VALUE_MAXr3 r5 r7 s r r; Semaphore.__init__ s y% CHr c 6 U R R 5 $ r )r
_get_valuerC s r get_valueSemaphore.get_value s }}''))r c U R R 5 nSU R R < SU< S3$ ! [ a Sn N-f = f)Nunknown<(value=)>)r rv Exception __class__rd r3 r5 s r __repr__Semaphore.__repr__ sG MM,,.E $(>>#:#:EBB E s ; A
A
rb Nr )rd re rf rg r; rw r rk rb r r r r s I*Cr r c $ \ rS rSrSS jrS rSrg)r c : [ R " U [ XUS9 g ro r
r; rq rs s r r; BoundedSemaphore.__init__ s y%C@r c U R R 5 nSU R R < SU< SU R R
< S3$ ! [ a Sn NEf = f)Nrz r{ r| z , maxvalue=r} )r rv r~ r rd r6 r s r r BoundedSemaphore.__repr__ sY MM,,.E ''
0F0FH H E s A A"!A"rb Nr rd re rf rg r; r rk rb r r r r s AHr r c \ rS rSrS rS rSrg)r c < [ R " U [ SSUS9 g Nr rp r r3 r7 s r r;
Lock.__init__ s y!QC8r c U R R 5 ( ah [ R " 5 R n[
R " 5 R S:w a% US[
R " 5 R - -
nOFU R R 5 ( d SnO$U R R 5 S: a SnOSn SU R R < S U< S
3$ ! [ a Sn N-f = f) N
MainThread|Noner SomeOtherThreadSomeOtherProcessrz r{ z(owner=r} ) r _is_miner r^ r/ threadingcurrent_thread_is_zero_countr~ r rd )r3 r/ s r r
Lock.__repr__ s }}%%'' ..055 ++-22lBC)":":"<"A"A AAD]]++-- %%'!+() $(>>#:#:DAA D s$ BC. !C. + C. C. . C=<C=rb Nr rb r r r r s
9Br r c \ rS rSrS rS rSrg)r c < [ R " U [ SSUS9 g r )r
r; RECURSIVE_MUTEXr s r r; RLock.__init__ s 1#>r c L U R R 5 ( a [ R " 5 R n[
R " 5 R S:w a% US[
R " 5 R - -
nU R R 5 nOLU R R 5 ( d Su pO(U R R 5 S: a Su pOSu p SU R R < S U< S
U< S 3$ ! [ a Su p N3f = f) Nr r )r r r )r nonzero)r r )rz rz r{ (, r} ) r r r r^ r/ r r r r r~ r rd )r3 r/ counts r r RLock.__repr__ s
/}}%%'' ..055 ++-22lBC)":":"<"A"A AAD
,,.]]++-- ' e %%'!+ : e ; e "& !8!8$FF /.KD% /s$ B D ##D "D *D D#"D#rb Nr rb r r r r s
?Gr r c f \ rS rSrSS jrS rS rS rS rS r S r
SS
jr SS jr S r
SS
jrSrg)r Nc U=( d UR 5 U l UR S5 U l UR S5 U l UR S5 U l U R
5 g Nr )r _lockr _sleeping_count _woken_count_wait_semaphorer- )r3 lockr7 s r r; Condition.__init__ sS (SYY[
"}}Q / MM! , "}}Q / r c [ R " U 5 U R U R U R U R
4$ r )r
rN r r r r rC s r rS Condition.__getstate__ s: %
D 0 0!!4#7#79 9r c Z Uu U l U l U l U l U R 5 g r )r r r r r- rW s r rY Condition.__setstate__ s* 49 2T)
D 0 r c 6 U R R 5 $ r )r rF rC s r rF Condition.__enter__ s zz##%%r c 4 U R R " U6 $ r )r rI rJ s r rI Condition.__exit__ s zz""D))r c p U R R U l U R R U l g r )r rA rB rC s r r- Condition._make_methods s$ zz)) zz)) r c U R R R 5 U R R R 5 -
nSU R
R < SU R < SU< S3$ ! [ a Sn N;f = f)Nrz r{ r r r} )r r rv r r~ r rd r )r3 num_waiterss r r Condition.__repr__ ss $ //88CCE ,,55@@B CK "& !8!8$**kRR $#K $s A A8 8 BBc U R R R 5 ( d S5 eU R R 5 U R R R 5 n[
U5 H nU R R 5 M U R R SU5 U R R 5 [
U5 H nU R R 5 M $ ! U R R 5 [
U5 H nU R R 5 M f = f)Nz,must acquire() condition before using wait()T)
r r r r rB r r' r rA r )r3 timeoutr r9 s r waitCondition.wait s zz""++-- >= >-
$$&
##**,u A JJ %''//g>
% % ' 5\
""$ "
% % ' 5\
""$ "s
C> >AEc R U R R R 5 ( d S5 eU R R S5 ( a S5 eU R
R S5 ( aK U R R S5 nU( d S5 eU R
R S5 ( a MK SnX1: af U R R S5 ( aF U R R 5 US-
nX1: a" U R R S5 ( a MF U( aq [ U5 H nU R
R 5 M U R R S5 ( a$ U R R S5 ( a M# g g g )Nzlock is not ownedFznotify: Bug in sleeping_count.acquire- res should not be Falser r ) r r r r rA r r rB r' )r3 nressleepersr9 s r notifyCondition.notify sl zz""++--B/BB-''// *) * ''..&&..u5C
8 7
83 ''..
lt 3 3 ; ;E B B ( ( * MH lt 3 3 ; ;E B B 8_!!))+ % &&..u55 &&..u55 r c > U R [ R S9 g )N)r )r r% maxsizerC s r
notify_allCondition.notify_all/ s ckk "r c U" 5 nU( a U$ Ub [ R " 5 U- nOS nS nU( dE Ub! U[ R " 5 -
nUS:: a U$ U R W5 U" 5 nU( d ME U$ r )time monotonicr )r3 predicater resultendtimewaittimes r wait_forCondition.wait_for2 s M nn&0GGH""T^^%55q=
IIh [F
&
r )r r r r rA rB r r )rd re rf rg r; rS rY rF rI r- r r r r r rk rb r r r r s: 9
&**S%.4#r r c < \ rS rSrS rS rS rS rS
S jrS r S r
g) r iH c x UR UR 5 5 U l UR S5 U l g r )r r _condr _flagr s r r; Event.__init__J s( ]]388:.
]]1%
r c U R U R R S5 ( a$ U R R 5 S S S 5 g S S S 5 g! , ( d f g = fNFT)r r rA rB rC s r is_set Event.is_setN sG
ZZzz!!%((
""$ Z ZZs )r typerf id)r3
set_statuss r r Event.__repr__k s? "kkmmU
4:**+44}Aj\KKr )r r r ) rd re rf rg r; r r r r r rk rb r r r r H s! &$ &
Lr r c \ rS rSrS S jrS rS r\S 5 r\R S 5 r\S 5 r
\
R S 5 r
S
r g) Barrierir Nc SS K nSSKJn U" UR S5 S- 5 nUR 5 nU R XX8U45 SU l SU l g )Nr r )
BufferWrapperr9 r )structheapr calcsizer rY _stater ) r3 partiesactionr r7 r r wrapperconds r r; Barrier.__init__t sN ' 4q 89}} 7G7CD r c Uu U l U l U l U l U l U R R 5 R
S5 U l g )Nr9 )_parties_action_timeoutr _wrappercreate_memoryviewcast_arrayrW s r rY Barrier.__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