!A?h(% 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 n e Zd Z i Zej Z fdZed Z edd Z
e j Z xZ
S )r c t j | | j | _ | j | j d S N)super__init___copyreg_dispatch_tablecopydispatch_tableupdate_extra_reducers)selfargs __class__s F/opt/alt/python-internal/lib64/python3.11/multiprocessing/reduction.pyr zForkingPickler.__init__& sN $ " : ? ? A A ""4#788888 c || j |< d S r )r )clstypereduces r r zForkingPickler.register+ s 4$*D!!!r Nc t j } | || | | S r )ioBytesIOr
getbuffer)r objprotocolbufs r dumpszForkingPickler.dumps0 s; jll C $$$}} r r )__name__
__module__ __qualname__r copyregr r r classmethodr r) pickleloads
__classcell__)r s @r r r ! s 3O % 49 9 9 9 9
+ + [+ [
LEEEEEr r c N t || | d S r )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 )Nr )_winapiGetCurrentProcessDuplicateHandleDUPLICATE_SAME_ACCESS)handletarget_process inheritabler7 current_processs r r5 r5 G sO J!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 wNFr )r9 OpenProcessPROCESS_DUP_HANDLEr; r: r< DUPLICATE_CLOSE_SOURCE CloseHandle)
source_pidr= source_process_handles r r6 r6 S s C ' 3 &z!; !; 7*%v)++Q-0NNP P
5 6 6 6 6G 5 6 6 6 6s A A8 8Bc h t |t j | }| | d S r )r4 r9 r< send)connr= destination_piddhs r r r _ s, 4
vw >AJ.!33$$ I&&&q66C<3q6))(:AA FFCF, ,- - - AwwJ' D 2333s DE, ,F ?F c t j | t j t j 5 }t ||g d d d d S # 1 swxY w Y d S r )ri fromfdfilenoAF_UNIX SOCK_STREAMr_ )rK r= rL ss r r r s 4
]4;;==&.&:L
M
M !QR Ax ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! !s A A!$A!c t j | t j t j 5 }t |d d cd d d S # 1 swxY w Y d S )Nr r )ri r r r r r` )rK r s r r r s 7
]4;;==&.&:L
M
M $QR1a==# $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $s A!!A%(A%c t j }|(| | | S t rddlm} | | S t d )Nr )resource_sharerz&SCM_RIGHTS appears not to be available)r get_spawning_popenr^ duplicate_for_childHAVE_SEND_HANDLE r ru )fd popen_objr s r r^ r^ sw ).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 )rP )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 )rP ri )r r r r r s r r r s(
YY[[}VT5<<<>>ck""$=>>>"O444 /////r N)r* r+ r, r r r
r r sysplatformr6 r5 r4 r_ r` 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 r\ ).abcr r- r r# rS r/ ri r r r __all__r hasattrr Picklerr r r
r9 r5 r6 r r objectr4 rf rk r_ r` r^ r r r r r ry r r r r r r r r r r] r r 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