/opt/alt/python39/lib64/python3.9/multiprocessing/__pycache__
Edit: /opt/alt/python39/lib64/python3.9/multiprocessing/__pycache__/reduction.cpython-39.pyc (8298B)
a
XC?h(% @ s d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZddl m
Z
g dZ ej dkpe
edoe
edoe
ejd ZG d
d d ejZejZd8d d
Zej dk re g d7 Z d dlZd9ddddZdd Zdd Zdd ZG dd deZnFe 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+ n d3d0 Z+d4d2 Z,eeje+ G d5d6 d6ed7Z-dS ): )ABCMetaN )context) send_handle recv_handleForkingPicklerregisterdumpwin32ZCMSG_LEN
SCM_RIGHTSsendmsgc sJ e Zd ZdZi ZejZ fddZe dd Z
e d ddZ e j
Z
ZS )
r z)Pickler subclass used by multiprocessing.c s* t j| | j | _| j| j d S N)super__init___copyreg_dispatch_tablecopydispatch_tableupdate_extra_reducersselfargs __class__ >/opt/alt/python39/lib64/python3.9/multiprocessing/reduction.pyr & s zForkingPickler.__init__c C s || j |< dS )z&Register a reduce function for a type.N)r )clstypereducer r r r + s zForkingPickler.registerNc C s t }| ||| | S r
)ioBytesIOr getbuffer)r objprotocolZbufr r r dumps0 s zForkingPickler.dumps)N)__name__
__module__ __qualname____doc__r copyregr r r classmethodr r$ pickleloads
__classcell__r r r r r ! s
r c C s t ||| dS )z3Replacement for pickle.dump() using ForkingPickler.N)r r )r" filer# r r r r : s r ) DupHandle duplicate steal_handleF)source_processc C s6 t }|du r|}|du r |}t || |d|t jS )z
r r r r d s r c @ s" e Zd ZdZdddZdd ZdS )r/ z Picklable wrapper for a handle.Nc C sf |d u rt }ttjd|}z(tt |||dd| _W t| n t| 0 || _ || _
d S )NFr ) osgetpidr3 r8 r9 r5 r4 _handler; _access_pid)r r7 accesspidprocr r r r j s
zDupHandle.__init__c C sb | j t kr| jS ttjd| j }z*t|| jt | j dtj
W t | S t | 0 dS )z1Get the handle. This should only be called once.FN) rG rC rD rE r3 r8 r9 r5 r4 rF r: r; )r rJ r r r rB y s
zDupHandle.detach)N)r% r& r' r( r rB r r r r r/ h s
r/ )DupFdsendfdsrecvfdsdarwinc C sV t d|}tt|d g}| |gtjtj|fg trR| ddkrRt ddS )z,Send an array of fds over an AF_UNIX socket.i r Az%did not receive acknowledgement of fdN)
arraybyteslenr socket
SOL_SOCKETr ACKNOWLEDGErA RuntimeError)sockZfdsmsgr r r rL s
rL c C s t d}|j| }| dt|\}}}}|s:|s:tztrJ| d t|dkrft dt| |d \}} }
|tj
kr| tj krt|
|j dkrt |
|
t|d |d krtdt||d t|W S W n t tfy Y n0 t dd S )
z/Receive an array of fds over an AF_UNIX socket.rO r rQ z received %d items of ancdatar rP z Len is {0:n} but msg[0] is {1!r}zInvalid data receivedN)rR itemsizeZrecvmsgrU Z
CMSG_SPACEEOFErrorrW r= rT rX rV r
ValueErrorZ frombytesAssertionErrorformatlist
IndexError) rY sizeaZ
bytes_sizerZ ZancdataflagsZaddrZ
cmsg_levelZ cmsg_typeZ cmsg_datar r r rM s:
rM c C sF t | t jt j }t||g W d n1 s80 Y dS r< )rU fromfdfilenoAF_UNIX SOCK_STREAMrL )r> r7 r? sr r r r s c C sH t | t jt j }t|dd W d S 1 s:0 Y dS )r@ r r N)rU re rf rg rh rM )r> ri r r r r s c C sF t }|dur ||| S tr:ddlm} || S tddS )zReturn a wrapper for an fd.Nr )resource_sharerz&SCM_RIGHTS appears not to be available)r Zget_spawning_popenrK Zduplicate_for_childHAVE_SEND_HANDLE rj r] )fdZ popen_objrj r r r rK s
rK c C s2 | j d u r t| j| jjffS t| j | jjffS d S r
)__self__getattrr __func__r% mr r r _reduce_method s
rs 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' ru r r r r rt s rt c C s t | j| jffS r
)ro __objclass__r% rq r r r _reduce_method_descriptor s rw c C s t | j| j| jpi ffS r
)_rebuild_partialfuncr keywords)pr r r _reduce_partial s r| c C s t j| g|R i |S r
) functoolspartial)ry r rz r r r rx s rx c C s ddl m} t|| ffS )Nr ) DupSocket)rj r _rebuild_socket)ri r r r r _reduce_socket s r c C s | S r
)rB )Zdsr r r r s r c C s" t | }t|| j| j| jffS r
)rK rf r familyr proto)ri dfr r r r s c C s | }tj||||dS )N)rf )rB rU )r r r r rm r r r r s c @ sd e Zd ZdZeZeZeZeZeZe j
dkr8e Z e Z e
Z
n eZeZeZeZeZeZeZeZdd 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 G sN t tt jt t ttjt t ttj t t t
j t t t
j
t d S r
)r r rt ru rs r` appendrw int__add__r} r~ r| rU r r r r r r s
zAbstractReducer.__init__N)r% r& r' r( r r r r r sysplatformr1 r0 r/ rL rM rK rs rw rx r r r r r r r r s&
r ) metaclass)N)NF).abcr r) r} r rC r+ rU r rl r __all__r hasattrrk ZPicklerr r r r3 r0 r1 r r objectr/ rR rW rL rM rK rs rt r ru rw r` r r r r| rx r~ r r r r r r r
sj
#