f(% H d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZddl m
Z
g dZ ej dk p( e
ed o e
ed o 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 j" e d Z# e e!e$j% e# e e!e&j' e# d! Z(d" Z) eej* e( ej dk rd# Z+d$ Z, eej e+ nd% Z+d& Z, eej e+ G d' d(e) Z-dS ), )ABCMetaN )context) send_handle recv_handleForkingPicklerregisterdumpwin32CMSG_LEN
SCM_RIGHTSsendmsgc p 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 d S N)super__init___copyreg_dispatch_tablecopydispatch_tableupdate_extra_reducers)selfargs __class__s @/opt/alt/python311/lib64/python3.11/multiprocessing/reduction.pyr zForkingPickler.__init__& sN $ " : ? ? A A ""4#788888 c || j |< dS )z&Register a reduce function for a type.N)r )clstypereduces r r zForkingPickler.register+ s %+D!!!r Nc t j } | || | | S r )ioBytesIOr
getbuffer)r objprotocolbufs r dumpszForkingPickler.dumps0 s; jll C $$$}} r r )__name__
__module__ __qualname____doc__r copyregr r r classmethodr r) pickleloads
__classcell__)r s @r r r ! s 33O % 49 9 9 9 9
+ + [+ [
LEEEEEr r c L t || | dS )z3Replacement for pickle.dump() using ForkingPickler.N)r r
)r& filer' s r r
r
: s& 4""'',,,,,r ) DupHandle duplicate steal_handleF)source_processc ~ t j }||}||}t j || |d|t j S )z<Duplicate a handle. (target_process is a handle not a pid!)Nr )_winapiGetCurrentProcessDuplicateHandleDUPLICATE_SAME_ACCESS)handletarget_process inheritabler8 current_processs r r6 r6 G sN "355 ! ,N ! ,N& FN
{G 9; ; ;r c t j t j d| } t j ||t j ddt j t j z t j | S # t j | w xY w)z5Steal a handle from process identified by source_pid.Fr )r: OpenProcessPROCESS_DUP_HANDLEr< r; r= DUPLICATE_CLOSE_SOURCE CloseHandle)
source_pidr> source_process_handles r r7 r7 S s ' 3 &z!; !; 7*%v)++Q-0NNP P
5 6 6 6 6G 5 6 6 6 6s A A7 7B
c f t |t j | }| | dS z&Send a handle over a local connection.N)r5 r: r= send)connr> destination_piddhs r r r _ s)
vw <o
N
N "
r c N | S ))Receive a handle over a local connection.)recvdetach)rL s r r r d s yy{{!!###r c e Zd ZdZddZd ZdS )r5 z Picklable wrapper for a handle.Nc H |t j }t j t j d| } t j t j |||dd | _ t j | n# t j | w xY w|| _ || _
d S )NFr ) osgetpidr: rC rD r< r; _handlerF _access_pid)r r> accesspidprocs r r zDupHandle.__init__j s { ikk&w'A5#NND
* & 6-//D&% 4 4 #D))))#D))))!DLDIIIs /A; ;Bc j | 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 yBIKK''|#&w'A5'+y2 2D
* .$,(A(C(CL%)GI I #D))))#D))))s
=B B2r )r* r+ r, r- r rR r r r5 r5 h s= --
* * * * *r r5 )DupFdsendfdsrecvfdsdarwinc 0 t j d| }t t | dz g }| |gt j t j |fg t r(| d dk rt d dS dS )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` s k#s##SXX^$%% cUf /1BC H IJJJ H499Q<<4// FGG G H H//r c " t j d }|j |z }| dt j | \ }}}}|s |st
t r| d t | dk r t dt | z |d \ }} }
|t j
k r| t j k rt |
|j z dk rt |
|
t | dz |d k r6t d t | |d t! | S n# t t" f$ r Y nw xY wt d ) 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 s K Z$&
$(LLF4Ej4Q4Q$R$R!WeT 7 N
$7||q "#A#&w<<$0 1 1 1/6qz ,J 9f ///V ...y>>AJ.!33$$ I&&&q66C<3q6))(:AA FFCF, ,- - - AwwJ' D 2333s DE+ +E?>E?c t j | t j t j 5 }t ||g ddd dS # 1 swxY w Y dS rJ )rj fromfdfilenoAF_UNIX SOCK_STREAMr` )rL r> rM ss r r r s
]4;;==&.&:L
M
M !QR Ax ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! !s A A #A c t j | t j t j 5 }t |d d cddd S # 1 swxY w Y dS )rP r r N)rj r r r r ra )rL r s r r r s
]4;;==&.&:L
M
M $QR1a==# $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $s A A$'A$c t j }|(| | | S t rddlm} | | S t d )zReturn a wrapper for an fd.Nr )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_ st .00 ??9#@#@#D#DEE E
G ) ) ) ) ) )"((,, , EFF Fr c x | j t | j | j j ffS t | j | j j ffS r )__self__getattrr __func__r* ms r _reduce_methodr s8 zaj&9:::QZ%8999r c e Zd Zd ZdS )_Cc d S 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^QZ0 00r c < t | j | j | j pi ffS r )_rebuild_partialfuncr keywords)ps r _reduce_partialr s afafaj.>B ? ??r c , t j | g|R i |S r ) functoolspartial)r r r s r r r s# T 5D 5 5 5H 5 55r c 4 ddl m} t || ffS )Nr ) DupSocket)r r _rebuild_socket)r r s r _reduce_socketr s) ...... 1 //r c * | S r )rR )dss r r r s yy{{r c | t | }t || j | j | j ffS r )r_ r r familyr proto)r dfs r r r s1
188::
QXqvqw ???r c Z | }t j |||| S )N)r )rR rj )r r r r r s r r r s(
YY[[}VT5<<<<r c p e Zd ZdZeZeZeZeZeZe j
dk re Z e Z e
Z
neZeZeZeZeZeZeZeZd ZdS )AbstractReducerzAbstract base class for use in implementing a Reduction class
suitable for use in replacing the standard reduction mechanism
used in multiprocessing.r c t t t j t t t t
j t t t t j t t t j t t t j
t d S r )r r r r r rz appendr int__add__r r r rj r )r r s r r zAbstractReducer.__init__ s bddf ~...dk""$=>>>ck""$=>>>"O444 /////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 s $NH D K K
|w # #N 9 '#N%O0 0 0 0 0r 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 <module>r s
N
N
N LG+ 8 WVZ00 7 WV\227 WV]I66 V^ . "- - - - <7 9999GNNN
;$(
;
;
;
;
;
7
7
7
$ $ $ * * * * *F * * * *F ....GLLL ,(*KH H H4 4 48! ! !
$ $ $
G G G : : :
bbddf ~ & & &1 1 1 dk 5 6 6 6 ck 5 6 6 6@ @ @6 6 6 O , , , <70 0 0 HV]N++++@ @ @= = =
HV]N+++ 0 0 0 0 0 0 0 0 0 0 0r