cj(% f d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZddl m
Z
g dZ ej dk( xs) e
ed xr e
ed xr e
ej d Z G d
d ej Zej" Zd)d Zej dk( r'e g d
z
Z d dlZd*dddZd Zd Zd Z G d de Zn)e g dz
Z d dlZej dk( Zd Z d Z d Zd Zd Z d Z G d d Z e e! e jD e d Z# e e!e$jJ e# e e!e&jN e# d Z(d! Z) eejT e( ej dk( rd" Z+d# Z, eej e+ nd$ Z+d% Z, eej e+ G d& d'e( Z-y)+ )ABCMetaN )context) send_handle recv_handleForkingPicklerregisterdumpwin32CMSG_LEN
SCM_RIGHTSsendmsgc x e Zd ZdZi Zej Z fdZe d Z
e dd Z e j Z
xZS )r z)Pickler subclass used by multiprocessing.c t | | | j j | _ | j j | j y N)super__init___copyreg_dispatch_tablecopydispatch_tableupdate_extra_reducers)selfargs __class__s 2/usr/lib64/python3.12/multiprocessing/reduction.pyr zForkingPickler.__init__& sA
$ " : : ? ? A ""4#7#78 c " || j |< y)z&Register a reduce function for a type.N)r )clstypereduces r r zForkingPickler.register+ s %+D!r c z t j } | || j | |j S r )ioBytesIOr
getbuffer)r objprotocolbufs r dumpszForkingPickler.dumps0 s. jjl C $}} r r )__name__
__module__ __qualname____doc__r copyregr r r classmethodr r) pickleloads
__classcell__)r s @r r r ! sO 3O % 4 49
+ +
LLEr r c : t || j | y)z3Replacement for pickle.dump() using ForkingPickler.N)r r
)r& filer' s r r
r
: s 4"'',r ) DupHandle duplicate steal_handle)source_processc t j }||}||}t j || |d|t j S )z source_process_handles r r7 r7 S s~ ' 3 3 & &z!; 7**%v))+Q--0N0NNP
5 6G 5 6s A
B B c \ t |t j | }| j | yz&Send a handle over a local connection.N)r5 r: r= send)connr> destination_piddhs r r r _ s!
vw < | j j S ))Receive a handle over a local connection.)recvdetach)rL s r r r d s yy{!!##r c e Zd ZdZddZd Zy)r5 z Picklable wrapper for a handle.Nc X |t j }t j t j d| } t j
t j |||dd | _ t j | || _ || _
y # t j | w xY w)NFr ) osgetpidr: rC rD r< r; _handlerF _access_pid)r r> accesspidprocs r r zDupHandle.__init__j s { iik&&w'A'A5#ND
* & 6 6--/D&% 4 ##D)!DLDI ##D)s 1B B)c | j t j k( r | j S t j
t j d| j } t j || j t j | j dt j t j | S # t j | w xY w)z1Get the handle. This should only be called once.F) rY rU rV rW r: rC rD r< r; rX rE rF )r r\ s r rR zDupHandle.detachy s yyBIIK'||#&&w'A'A5'+yy2D
* ..$,,(A(A(CLL%)G)GI ##D)##D)s
A
C Cr )r* r+ r, r- r rR r r r5 r5 h s -
*r r5 )DupFdsendfdsrecvfdsdarwinc t j d| }t t | dz g }| j |gt j
t j |fg t r | j d dk7 r t d yy)z,Send an array of fds over an AF_UNIX socket.i r Az%did not receive acknowledgement of fdN)
arraybyteslenr socket
SOL_SOCKETr
ACKNOWLEDGErQ RuntimeError)sockfdsmsgs r r` r` sr kk#s#SX^$% cUf / /1B1BC H IJ 499Q<4/ FG G 0;r c t j d }|j |z }| j dt j | \ }}}}|s|st
t r| j d t | dk7 rt dt | z |d \ }} }
|t j k( r| t j k( rxt |
|j z dk7 rt |j |
t | dz |d k7 r't dj t | |d t! | S t d # t t" f$ r
Y t d w xY w) z/Receive an array of fds over an AF_UNIX socket.rd r rf z received %d items of ancdatar re z Len is {0:n} but msg[0] is {1!r}zInvalid data received)rg itemsizerecvmsgrj
CMSG_SPACEEOFErrorrl rK ri rm rk r
ValueError frombytesAssertionErrorformatlist
IndexError) rn sizea
bytes_sizerp ancdataflagsaddr
cmsg_level cmsg_type cmsg_datas r ra ra sT KK ZZ$&
$(LLF4E4Ej4Q$R!WeT7N $7|q "#A#&w<$0 1 1/6qz ,J 9f / //V . ..y>AJJ.!3$$ I&q6C<3q6)(:AA FCF,- - Aw 233 J' 233 s C"E E$#E$c t j | j t j t j 5 }t ||g ddd y# 1 sw Y yxY wrJ )rj fromfdfilenoAF_UNIX SOCK_STREAMr` )rL r> rM ss r r r s>
]]4;;=&..&:L:L
MQR Ax N
M
Ms AA"c t j | j t j t j 5 }t |d d cddd S # 1 sw Y yxY w)rP r r N)rj r r r r ra )rL r s r r r s@
]]4;;=&..&:L:L
MQR1a=# N
M
Ms AA$c t j }| |j |j | S t rddlm} |j | S t d )zReturn a wrapper for an fd.r )resource_sharerz&SCM_RIGHTS appears not to be available)r get_spawning_popenr_ duplicate_for_childHAVE_SEND_HANDLE r rv )fd popen_objr s r r_ r_ sS ..0 ??9#@#@#DE E
)"((, , EF Fr c | j (t | j | j j ffS t | j | j j ffS r )__self__getattrr __func__r* ms r _reduce_methodr sH zzajj&9&9:::QZZ%8%8999r c e Zd Zd Zy)_Cc y r r^ )r s r fz_C.f s r N)r* r+ r, r r^ r r r r s
r r c > t | j | j ffS r )r __objclass__r* r s r _reduce_method_descriptorr s Q^^QZZ0 00r c \ t | j | j | j xs i ffS r )_rebuild_partialfuncr keywords)ps r _reduce_partialr s% affaffajj.>B ? ??r c 4 t j | g|i |S r ) functoolspartial)r r r s r r r s T 5D 5H 55r c , ddl m} t || ffS )Nr ) DupSocket)r r _rebuild_socket)r r s r _reduce_socketr s . 1 //r c " | j S r )rR )dss r r r s yy{r c t | j }t || j | j | j
ffS r )r_ r r familyr proto)r dfs r r r s2
188:
QXXqvvqww ???r c T | j }t j |||| S )N)r )rR rj )r r r r r s r r r s"
YY[}}VT5<ckk"$=>""O4 /r N)r* r+ r, r- r r r
r r sysplatformr7 r6 r5 r` ra r_ r r r r r r r^ r r r r sl $NH D K K
||w # #N 9 '#N%O0r r ) metaclassr )NF).abcr r. r r# rU r0 rj r r r __all__r hasattrr Picklerr r r
r: r6 r7 r r objectr5 rg rl r` ra r_ r r r r r rz r r r r r r r r r r^ r r r s
N LLG+ 8 VZ0 7 V\27 V]]I6 V^^ . " "- <<7 99G
;$(
;
7
$ *F *F ..G ,,(*KH48!
$
G :
bdff ~ &1 dkk 5 6 ckk 5 6@6 O , <<70 V]]N+@=
V]]N+ 0 0r