3
\
$ @ s d dl mZmZ d dlZd dlZd dlZd dlZd dlZd dlZd dl Z ddl
m Z ddddd gZ e j
d
kpeed oeed oeejd
ZG dd dejZejZd5dd Ze j
d
kre dddg7 Z d dlZd6ddZdd Zdd Zdd ZG dd deZnHe dddg7 Z d dlZe j
d kZ d 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) e j
d
krd,d- Z,d.d/ Z-eeje, n d0d- Z,d1d/ Z-eeje, G d2d3 d3ed4Z.dS )7 )ABCMetaabstractmethodN )context send_handle recv_handleForkingPicklerregisterdumpwin32ZCMSG_LEN
SCM_RIGHTSsendmsgc sF e Zd Zi ZejZ fddZedd Z edddZ
e j Z Z
S ) r c s* t j| | jj | _| jj| j d S )N)super__init___copyreg_dispatch_tablecopydispatch_tableupdate_extra_reducers)selfargs) __class__ 1/usr/lib64/python3.6/multiprocessing/reduction.pyr & s zForkingPickler.__init__c C s || j |< d S )N)r )clstypereducer r r r + s zForkingPickler.registerNc C s t j }| ||j| |j S )N)ioBytesIOr
getbuffer)r objprotocolZbufr r r dumps0 s zForkingPickler.dumps)N)__name__
__module__ __qualname__r copyregr r r classmethodr r" pickleloads
__classcell__r r )r r r ! s c C s t ||j| d S )N)r r
)r filer! r r r r
: s DupHandle duplicate steal_handleFc C s* |d krt j }t jt j | |d|t jS )Nr )_winapiGetCurrentProcessDuplicateHandleDUPLICATE_SAME_ACCESS)handleZtarget_processZ inheritabler r r r- G s
c C sB t jt jd| }z t j||t j ddt jt jB S t j| X d S )NFr )r/ OpenProcessPROCESS_DUP_HANDLEr1 r0 r2 DUPLICATE_CLOSE_SOURCE CloseHandle)Z
source_pidr3 Zsource_process_handler r r r. O s
c C s t |tj|}| j| d S )N)r, r/ r2 send)connr3 destination_pidZdhr r r r [ s c C s | j j S )N)recvdetach)r9 r r r r ` s c @ s e Zd ZdddZdd ZdS )r, Nc
C s\ |d krt j }tjtjd|}z tjtj |||dd| _W d tj| X || _ || _
d S )NFr ) osgetpidr/ r4 r5 r1 r0 _handler7 _access_pid)r r3 accesspidprocr r r r f s zDupHandle.__init__c
C sV | j tj kr| jS tjtjd| j }z tj|| jtj | j dtj
S tj | X d S )NF) rA r= r> r? r/ r4 r5 r1 r0 r@ r6 r7 )r rD r r r r< u s
zDupHandle.detach)N)r# r$ r% r r< r r r r r, d s
DupFdsendfdsrecvfdsdarwinc C sV t j d|}tt|d g}| j|gtjtj|fg trR| jddkrRt dd S )Ni r Az%did not receive acknowledgement of fd)
arraybyteslenr
socket
SOL_SOCKETr ACKNOWLEDGEr; RuntimeError)sockZfdsmsgr r r rF s
c C s t j d}|j| }| jdtj|\}}}}| r>| r>tyxtrN| jd t|dkrjt dt| |d \}} }
|tj
kr| tj krt|
|j dkrt |j
|
t|S W n t tfk
r Y nX t dd S )NrI r rK z received %d items of ancdatar zInvalid data received)rL itemsizeZrecvmsgrO Z
CMSG_SPACEEOFErrorrQ r8 rN rR rP r
ValueErrorZ frombyteslist
IndexError) rS sizeaZ
bytes_sizerT ZancdataflagsZaddrZ
cmsg_levelZ cmsg_typeZ cmsg_datar r r rG s*
c
C s2 t j| j t jt j}t||g W d Q R X d S )N)rO fromfdfilenoAF_UNIX SOCK_STREAMrF )r9 r3 r: sr r r r s c
C s0 t j| j t jt j}t|dd S Q R X d S )Nr r )rO r] r^ r_ r` rG )r9 ra r r r r s c C sF t j }|d k r |j|j| S tr:ddlm} |j| S tdd S )Nr )resource_sharerz&SCM_RIGHTS appears not to be available)r Zget_spawning_popenrE Zduplicate_for_childHAVE_SEND_HANDLE rb rW )fdZ popen_objrb r r r rE s
c C s2 | j d kr t| j| jjffS t| j | jjffS d S )N)__self__getattrr __func__r# )mr r r _reduce_method s
rj c @ s e Zd Zdd ZdS )_Cc C s d S )Nr )r r r r f s z_C.fN)r# r$ r% rl r r r r rk s rk c C s t | j| jffS )N)rg __objclass__r# )ri r r r _reduce_method_descriptor s rn c C s t | j| j| jpi ffS )N)_rebuild_partialfuncr keywords)pr r r _reduce_partial s rs c C s t j| f||S )N) functoolspartial)rp r rq r r r ro s ro c C s ddl m} t|| ffS )Nr ) DupSocket)rb rv _rebuild_socket)ra rv r r r _reduce_socket s rx c C s | j S )N)r< )Zdsr r r rw s rw c C s" t | j }t|| j| j| jffS )N)rE r^ rw familyr proto)ra dfr r r rx s c C s | j }tj||||dS )N)r^ )r< rO )r{ ry r rz re r r r rw s c @ s` e Zd ZeZeZeZeZeZej dkr4e
Z
e Z e Z n e
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 )N)r r rk rl rj rX appendrn int__add__rt ru rs rO rx )r r r r r r
s
zAbstractReducer.__init__N)r# r$ r% r r r
r r sysplatformr. r- r, rF rG rE rj rn ro rx rw r r r r r r| s$
r| ) metaclass)N)NF)/abcr r r& rt r r= r( rO r rd r __all__r hasattrrc ZPicklerr r r
r/ r- r. r r objectr, rL rQ rF rG rE rj rk r rl rn rX r} r~ r rs ro ru rx rw r| r r r r
sb
#