*j S SK r S SKrS SKrS SKrS SKrSSKJr SSKJr SSKJ r S/r
\R S:X a \
S/-
r
" S S\ 5 r
O\
S
/-
r
" S S
\ 5 r " S S
\ 5 r\" 5 r\R" rg) N )process) reduction)utilstopwin32 DupSocketc \ rS rSrS rS rSrg)r c | ^ UR 5 mU4S jn[ R UTR 5 U l g )Nc J > TR U5 nU R U5 g N)share
send_bytes)connpidr new_socks F/opt/alt/python313/lib64/python3.13/multiprocessing/resource_sharer.pysend DupSocket.__init__..send s s+& )dup_resource_sharerregisterclose_id)selfsockr r s @r __init__DupSocket.__init__ s- xxzH
' (00x~~FDHr c [ R U R 5 nUR 5 n[ R
" U5 sS S S 5 $ ! , ( d f g = fr )r get_connectionr
recv_bytessocket fromshare)r r r s r detachDupSocket.detach$ s< !00:d ) ''. ;::s &A
A r N__name__
__module__ __qualname____firstlineno__r r& __static_attributes__ r r r r s
G /r DupFdc \ rS rSrS rS rSrg)r0 - c ~ ^ [ R " U5 mU4S jnU4S jn[ R X#5 U l g )Nc 6 > [ R " U TU5 g r )r send_handle)r r new_fds r r DupFd.__init__..send1 s %%dFC8r c 2 > [ R " T 5 g r )osr )r6 s r r DupFd.__init__..close3 s r )r9 r r r r )r fdr r r6 s @r r DupFd.__init__/ s, VVBZF
9
!'00=DHr c [ R U R 5 n[ R " U5 sS S S 5 $ ! , ( d f g = fr )r r" r r recv_handle)r r s r r& DupFd.detach7 s0 !00:d ,,T2 ;::s A
Ar( Nr) r/ r r r0 r0 - s > 3r c L \ rS rSrS rS r\S 5 rS S jrS r S r
S r S
r g) _ResourceSharer= c SU l 0 U l [ R " 5 U l S U l S U l S U l [ R " U [ R 5 g )Nr ) _key_cache threadingLock_lock _listener_address_threadr register_after_forkrA
_afterfork)r s r r _ResourceSharer.__init__? sI ^^%
'A'ABr c U R U R c U R 5 U =R S-
sl X4U R U R ' U R U R 4sS S S 5 $ ! , ( d f g = f)Nr )rH rJ _startrD rE )r r r s r r _ResourceSharer.registerH sW
ZZ}}$
IINI&*]DKK "MM499- ZZs A$A;;
B c SSK Jn U u p#U" U[ R " 5 R S9nUR U[ R " 5 45 U$ )Nr Clientauthkey)
connectionrT r current_processrV r r9 getpid)identrT addresskeycs r r" _ResourceSharer.get_connectionQ sE ' 7G$;$;$=$E$E F RYY[!"r Nc SSK Jn U R U R Gb U" U R [ R
" 5 R S9nUR S 5 UR 5 U R R U5 U R R 5 ( a [ R " S5 U R R 5 S U l S U l S U l U R R! 5 H u nu pVU" 5 M U R R# 5 S S S 5 g ! , ( d f g = f)Nr rS rU z._ResourceSharer thread did not stop when asked)rW rT rH rJ r rX rV r r rK joinis_aliver sub_warningrI rE itemsclear)r timeoutrT r] r\ r r s r r _ResourceSharer.stopZ s &
ZZ}}(4==#*#:#:#<#D#DFt !!'*<<((**$$ &; <$$& # $
!%*.++*;*;*=&C $G +> !!#! ZZs D$E
Ec > U R R 5 H u nu p#U" 5 M U R R 5 U R R 5 U R
b U R
R
5 S U l S U l S U l g r ) rE rc rd rH _at_fork_reinitrI r rJ rK )r r\ r r s r rM _ResourceSharer._afterforko st "&++"3"3"5 C $ G #6
""$ >> % NN "
r c : SSK Jn [ R " S5 U" [ R
" 5 R SS9U l U R R U l [ R " U R S9nSUl
UR 5 X l g )Nr )Listenerz0starting listener and thread for sending handles )rV backlog)targetT)rW rk r debugr rX rV rI r[ rJ rF Thread_servedaemonstartrK )r rk ts r rP _ResourceSharer._startz sj (
EF!'*A*A*C*K*KUXY ..
DKK 0 r c P [ [ S5 ( a8 [ R " [ R [ R " 5 5 U R
R
5 nUR 5 nUc
S S S 5 g Uu p4U R R U5 u pV U" X5 U" 5 S S S 5 Mu ! U" 5 f = f! , ( d f N = f! [ R " 5 ( d& [ R " [ R " 5 6 Nc= f)Npthread_sigmask)hasattrsignalrw SIG_BLOCK
valid_signalsrI acceptrecvrE popr
is_exitingsys
excepthookexc_info)r r msgr\ destination_pidr r s r rq _ResourceSharer._serve s 6, - - " "6#3#3V5I5I5K L
4^^**, ))+C{ -, ,/(C"&++//#"6KD T3 - -,
4((NNCLLN3sO C! *C?C! !C*C2C:C! C
C
C C! C! !AD%)rJ rE rD rI rH rK r )
r* r+ r, r- r r staticmethodr" r rM rP rq r. r/ r r rA rA = s5 C. $* 4r rA )r9 ry r$ r rF r contextr r __all__platformobjectr r0 rA r r r/ r r r s
( <<7 } G
/F
/ yG
3
3 Y4f Y4x #$ r