python (3.11.7)
e 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 ZdS ) N )process) reduction)utilstopwin32 DupSocketc e Zd ZdZd Zd ZdS )r z Picklable wrapper for a socket.c | fd}t |j | _ d S )Nc \ | }| | d S N)share
send_bytes)connpidr new_socks S/BuggyBox/python/3.11.7/bootstrap/lib/python3.11/multiprocessing/resource_sharer.pysendz DupSocket.__init__.<locals>.send s, s++&&&&& )dup_resource_sharerregisterclose_id)selfsockr r s @r __init__zDupSocket.__init__ sH xxzzH
'
'
'
'
' (00x~FFDHHHr c t | j 5 }| }t j | cddd S # 1 swxY w Y dS )z1Get the socket. This should only be called once.N)r get_connectionr
recv_bytessocket fromshare)r r r s r detachzDupSocket.detach$ s !00::
/d )) '..
/
/
/
/
/
/
/
/
/
/
/
/
/
/
/
/
/
/s (AA AN__name__
__module__ __qualname____doc__r r# r r r r s; -- G G G / / / / /r DupFdc e Zd ZdZd Zd ZdS )r* z-Wrapper for fd which can be used at any time.c t j | fd}fd}t || | _ d S )Nc 4 t j | | d S r
)r send_handle)r r new_fds r r z DupFd.__init__.<locals>.send1 s %dFC88888r c 0 t j d S r
)osr )r/ s r r z DupFd.__init__.<locals>.close3 s r )r1 r r r r )r fdr r r/ s @r r zDupFd.__init__/ s] VBZZF
9
9
9
9
9
!
!
!
!
!'00u==DHHHr c t | j 5 }t j | cddd S # 1 swxY w Y dS )z-Get the fd. This should only be called once.N)r r r r recv_handle)r r s r r# z DupFd.detach7 s !00::
3d ,T22
3
3
3
3
3
3
3
3
3
3
3
3
3
3
3
3
3
3s AAANr$ r) r r r* r* - s8 ;; > > > 3 3 3 3 3r c N e Zd ZdZd Zd Zed Zd
dZd Z d Z
d Z dS ) _ResourceSharerz.Manager for resources using background thread.c d| _ i | _ t j | _ d | _ d | _ d | _ t j | t j d S )Nr ) _key_cache threadingLock_lock _listener_address_threadr register_after_forkr6
_afterfork)r s r r z_ResourceSharer.__init__? sP ^%%
'ABBBBBr c | j 5 | j | | xj dz
c_ ||f| j | j < | j | j fcddd S # 1 swxY w Y dS )z+Register resource, returning an identifier.Nr )r< r> _startr8 r9 )r r r s r r z_ResourceSharer.registerH s
Z . .}$
IINII&*E]DK "M49- . . . . . . . . . . . . . . . . . .s A
A A#&A#c ddl m} | \ }} ||t j j }| |t
j f |S )z<Return connection from which to receive identified resource.r Clientauthkey)
connectionrF r current_processrH r r1 getpid)identrF addresskeycs r r z _ResourceSharer.get_connectionQ sa '&&&&& F7G$;$=$=$E F F F RY[[!"""r Nc x ddl m} | j 5 | j || j t j j }| d | | j
| | j rt j
d | j d| _ d| _ d| _ | j D ]\ }\ }} | | j ddd dS # 1 swxY w Y dS )z:Stop the background thread and clear registered resources.r rE NrG z._ResourceSharer thread did not stop when asked)rI rF r< r> r rJ rH r r r? joinis_aliver sub_warningr= r9 itemsclear)r timeoutrF rO rN r r s r r z_ResourceSharer.stopZ s &&&&&&
Z $ $}(F4=#*#:#<#<#DF F Ft !!'***<((** <$ &; < < <$$&&& # $
!%*.+*;*;*=*= &C $EGGGG !!###! $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $s DD//D36D3c , | j D ]\ }\ }} | | j | j | j | j d | _ d | _ d | _ d S r
) r9 rT rU r< _at_fork_reinitr= r r> r? )r rN r r s r rA z_ResourceSharer._afterforko s "&+"3"3"5"5 C $ EGGGG
""$$$ > % N " " "
r c " ddl m} t j d |t j j | _ | j j | _ t j | j }d|_
| || _ d S )Nr )Listenerz0starting listener and thread for sending handlesrG )targetT)rI rZ r debugr rJ rH r= rM r> r: Thread_servedaemonstartr? )r rZ ts r rC z_ResourceSharer._startz s ((((((
EFFF!'*A*C*C*KLLL .
DK 0 0 0 r c D t t d r0t j t j t j | j 5 }| }| d d d d S |\ }}| j | \ }} ||| | n# | w xY w d d d n # 1 swxY w Y n9# t j s t j
t j Y nxY w)Npthread_sigmask)hasattrsignalrc SIG_BLOCK
valid_signalsr= acceptrecvr9 popr
is_exitingsys
excepthookexc_info)r r msgrN destination_pidr r s r r^ z_ResourceSharer._serve so 6, - - M "6#3V5I5K5K L L L 4
4^**,, ))++C{ ,/(C "&+//#"6"6KD% T?333
4(( 4NCLNN33 4sT C( !C 9 C( "C ) C 5 C C C C( C C( #C $C( (4D r
) r% r& r' r( r r staticmethodr r rA rC r^ r) r r r6 r6 = s 88C C C. . . \$ $ $ $* 4 4 4 4 4r r6 )r1 re r! rl r: r contextr r __all__platformobjectr r* r6 r r r) r r <module>rw sE
( <7 } G
/
/
/
/
/F
/
/
/
/ yG
3
3
3
3
3
3
3
3 Y4 Y4 Y4 Y4 Y4f Y4 Y4 Y4x #?$$ r 
Browse
Usage
Versions