o
0i(% @ s d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZddl m
Z
g dZ ej dkp@e
edo@e
edo@e
ejd ZG d
d d ejZejZd8d d
Zej dkr~e g d7 Z d dlZd9ddddZdd Zdd Zdd ZG dd deZn#e g d7 Z d dlZej d kZd d Z d d Z d!d Zd"d Zd#d$ Z d%d& Z G d'd( d(Z ee!e j"e d)d* Z#ee!e$j%e# ee!e&j'e# d+d, Z(d-d. Z)eej*e( ej dkrd/d0 Z+d1d2 Z,eeje+ nd3d0 Z+d4d2 Z,eeje+ G d5d6 d6ed7Z-dS ): )ABCMetaN )context) send_handle recv_handleForkingPicklerregisterdumpwin32ZCMSG_LEN
SCM_RIGHTSsendmsgc sH e Zd Z i ZejZ fddZedd Z edddZ
e j Z Z
S ) r c s* t j| | j | _| j| j d S N)super__init___copyreg_dispatch_tablecopydispatch_tableupdate_extra_reducersselfargs __class__ @/opt/alt/python310/lib64/python3.10/multiprocessing/reduction.pyr & s zForkingPickler.__init__c C s || j |< d S r
)r )clstypereducer r r r + s zForkingPickler.registerNc C s t }| ||| | S r
)ioBytesIOr getbuffer)r objprotocolZbufr r r dumps0 s zForkingPickler.dumpsr
)__name__
__module__ __qualname__r copyregr r r classmethodr r$ pickleloads
__classcell__r r r r r ! s
r c C s t ||| d S r
)r r )r" filer# r r r r : s r ) DupHandle duplicate steal_handleF)source_processc C s8 t }|d u r |}|d u r|}t || |d|t jS )Nr )_winapiGetCurrentProcessDuplicateHandleDUPLICATE_SAME_ACCESS)handleZtarget_processZ inheritabler1 Zcurrent_processr r r r/ G s r/ c C sL t t jd| }zt ||t ddt jt jB W t | S t | w NFr )r2 OpenProcessPROCESS_DUP_HANDLEr4 r3 r5 DUPLICATE_CLOSE_SOURCE CloseHandle)Z
source_pidr6 Zsource_process_handler r r r0 S s
r0 c C s t |tj|}| | d S r
)r. r2 r5 send)connr6 destination_pidZdhr r r r _ s r c C s | S r
)recvdetach)r= r r r r d s r c @ s e Zd Z dddZdd ZdS )r. Nc C sf |d u rt }ttjd|}ztt |||dd| _W t| nt| w || _ || _
d S r7 ) osgetpidr2 r8 r9 r4 r3 _handler; _access_pid)r r6 accesspidprocr r r r j s
zDupHandle.__init__c C s` | j t kr | jS ttjd| j }zt|| jt | j dtj
W t | S t | w NF) rE rA rB rC r2 r8 r9 r4 r3 rD r: r; )r rH r r r r@ y s
zDupHandle.detachr
)r% r& r' r r@ r r r r r. h s
r. )DupFdsendfdsrecvfdsdarwinc C s\ t d|}tt|d g}| |gtjtj|fg tr*| ddkr,t dd S d S )Ni r Az%did not receive acknowledgement of fd)
arraybyteslenr socket
SOL_SOCKETr ACKNOWLEDGEr? RuntimeError)sockZfdsmsgr r r rK s rK c C s t d}|j| }| dt|\}}}}|s |s tz[tr&| d t|dkr4t dt| |d \}} }
|tj
krp| tj krut|
|j dkrPt |
|
t|d |d krktdt||d t|W S W t dW t d t tfy Y t dw ) NrN r rP z received %d items of ancdatar rO z Len is {0:n} but msg[0] is {1!r}zInvalid data received)rQ itemsizeZrecvmsgrT Z
CMSG_SPACEEOFErrorrV r< rS rW rU r
ValueErrorZ frombytesAssertionErrorformatlist
IndexError) rX sizeaZ
bytes_sizerY ZancdataflagsZaddrZ
cmsg_levelZ cmsg_typeZ cmsg_datar r r rL sD
rL c C sJ t | t jt j}t||g W d d S 1 s w Y d S r
)rT fromfdfilenoAF_UNIX SOCK_STREAMrK )r= r6 r> sr r r r s "c C sJ t | t jt j}t|dd W d S 1 s w Y d S )Nr r )rT rd re rf rg rL )r= rh r r r r s $c C sD t }|d ur||| S tr ddlm} || S td)Nr )resource_sharerz&SCM_RIGHTS appears not to be available)r Zget_spawning_popenrJ Zduplicate_for_childHAVE_SEND_HANDLE ri r\ )fdZ popen_objri r r r rJ s
rJ c C s. | j d u rt| j| jjffS t| j | jjffS r
)__self__getattrr __func__r% mr r r _reduce_method s
rr c @ s e Zd Zdd ZdS )_Cc C s d S r
r )r r r r f s z_C.fN)r% r& r' rt r r r r rs s rs c C s t | j| jffS r
)rn __objclass__r% rp r r r _reduce_method_descriptor s rv c C s t | j| j| jp i ffS r
)_rebuild_partialfuncr keywords)pr r r _reduce_partial r{ c C s t j| g|R i |S r
) functoolspartial)rx r ry r r r rw r| rw c C s ddl m} t|| ffS )Nr ) DupSocket)ri r _rebuild_socket)rh r r r r _reduce_socket s r c C s | S r
)r@ )Zdsr r r r s r c C s" t | }t|| j| j| jffS r
)rJ re r familyr proto)rh dfr r r r s c C s | }tj||||dS )N)re )r@ rT )r r r r rl r r r r s c @ sb e Zd Z eZeZeZeZeZej dkre
Z
e Z e Z ne
Z
eZeZeZeZeZeZeZdd ZdS )AbstractReducerr
c G sN t tt jt t ttjt t ttj t t t
j t t t
j
t d S r
)r r rs rt rr r_ appendrv int__add__r} r~ r{ rT r r r r r r s
zAbstractReducer.__init__N)r% r& r' r r r r r sysplatformr0 r/ r. rK rL rJ rr rv rw r r r r r r r r s(
r ) metaclassr
rI ).abcr r( r} r rA r* rT r rk r __all__r hasattrrj ZPicklerr r r r2 r/ r0 r r objectr. rQ rV rK rL rJ rr rs r rt rv r_ r r r r{ rw r~ r r r r r r r sl
#