֦i d dl Z d dlZd dlZd dlZd dlZddlmZ ddlmZ ddlm Z dgZ
ej dk( re
dgz
Z
G d de Z
ne
d
gz
Z
G d d
e Z G d d
e Z e Zej" Zy) N )process) reduction)utilstopwin32 DupSocketc e Zd Z d Zd Zy)r c z |j fd}t j |j | _ y )Nc J j | }| j | y N)share
send_bytes)connpidr new_socks 8/usr/lib64/python3.12/multiprocessing/resource_sharer.pysendz DupSocket.__init__..send s s+& )dup_resource_sharerregisterclose_id)selfsockr r s @r __init__zDupSocket.__init__ s- xxzH
' (00x~~FDHr c t j | j 5 }|j }t j
| cd d d S # 1 sw Y y xY wr
)r get_connectionr
recv_bytessocket fromshare)r r r s r detachzDupSocket.detach$ s? C!00:d ) ''. ;::s %AAN__name__
__module__ __qualname__r r# r r r r s - G /r DupFdc e Zd Z d Zd Zy)r) c z t j | fd}fd}t j || | _ y )Nc 4 t j | | y r
)r send_handle)r r new_fds r r z DupFd.__init__..send1 s %%dFC8r c 0 t j y r
)osr )r. s r r z DupFd.__init__..close3 s r )r0 r r r r )r fdr r r. s @r r zDupFd.__init__/ s. VVBZF
9
!'00u=DHr c t j | j 5 }t j | cd d d S # 1 sw Y y xY wr
)r r r r recv_handle)r r s r r# z DupFd.detach7 s3 ?!00:d ,,T2 ;::s A A Nr$ r( r r r) r) - s ; > 3r c D e Zd Z d Zd Zed Zd dZd Zd Z d Z
y)
_ResourceSharerc d| _ i | _ t j | _ d | _ d | _ d | _ t j | t j y )Nr ) _key_cache threadingLock_lock _listener_address_threadr register_after_forkr5
_afterfork)r s r r z_ResourceSharer.__init__? sI ^^%
'A'ABr c | j 5 | j | j | xj dz
c_ ||f| j | j < | j | j fcd d d S # 1 sw Y y xY w)Nr )r; r= _startr7 r8 )r r r s r r z_ResourceSharer.registerH s\ 9
ZZ}}$
IINI&*E]DKK "MM499- ZZs A$A<<Bc ddl m} | \ }} ||t j j }|j |t
j f |S )Nr Clientauthkey)
connectionrE r current_processrG r r0 getpid)identrE addresskeycs r r z _ResourceSharer.get_connectionQ sH J& 7G$;$;$=$E$E F RYY[!"r Nc ddl m} | j 5 | j || j t j
j }|j d |j | j j | | j j rt j d | j j d | _ d | _ d | _ | j j! D ] \ }\ }} | | j j# d d d y # 1 sw Y y xY w)Nr rD rF z._ResourceSharer thread did not stop when asked)rH rE r; r= r rI rG r r r> joinis_aliver sub_warningr< r8 itemsclear)r timeoutrE rN rM r r s r r z_ResourceSharer.stopZ s H&
ZZ}}(4==#*#:#:#<#D#DFt !!'*<<((*$$ &; <$$& # $
!%*.++*;*;*=&C $G +> !!#! ZZs D D;;Ec : | j j D ] \ }\ }} | | j j | j j | j
| j
j
d | _ d | _ d | _ y r
) r8 rS rT r; _at_fork_reinitr< r r= r> )r rM r r s r r@ z_ResourceSharer._afterforko sv "&++"3"3"5 C $ G #6
""$ >> % NN "
r c B ddl m} t j d |t j
j d | _ | j j | _ t j | j }d|_
|j || _ y )Nr )Listenerz0starting listener and thread for sending handles )rG backlog)targetT)rH rY r debugr rI rG r< rL r= r9 Thread_servedaemonstartr> )r rY ts r rB z_ResourceSharer._startz sl (
EF!'*A*A*C*K*KUXY ..
DKK 0 r c * t t d r6t j t j t j | j
j
5 }|j }|
d d d y |\ }}| j j | \ }} ||| | d d d v# | w xY w# 1 sw Y xY w# t j s$t j t j Y UxY w)Npthread_sigmask)hasattrsignalrd SIG_BLOCK
valid_signalsr< acceptrecvr8 popr
is_exitingsys
excepthookexc_info)r r msgrM destination_pidr r s r r_ z_ResourceSharer._serve s 6, - " "6#3#3V5I5I5K L
4^^**, ))+C{ -, ,/(C "&++//#"6KD% T?3 - -,
4(NNCLLN3sH C #C
7C #C
$ B>-C
5C > CC
CC :Dr
) r% r& r' r r staticmethodr r r@ rB r_ r( r r r5 r5 = s8 8C. $* 4r r5 )r0 rf r! rm r9 r contextr r __all__platformobjectr r) r5 r r r( r r rx s
( <<7 } G
/F
/ yG
3
3 Y4f Y4x #$ r