JFIF $
d d 7
Viewing File: /usr/lib64/python3.9/multiprocessing/__pycache__/reduction.cpython-39.opt-2.pyc
a
�i(% � @ s d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZddl m
Z
g d�Z ej dkp�e
ed�o�e
ed�o�e
ejd �ZG d
d � d ej�ZejZd8d d
�Zej dk� r�e g d�7 Z d dlZd9dd�dd�Zdd� Zdd� Zdd� ZG dd� de�ZnFe g d�7 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 dk�r�d/d0� Z+d1d2� Z,eeje+� n d3d0� Z+d4d2� Z,eeje+� G d5d6� d6ed7�Z-dS ):� )�ABCMetaN� )�context)� send_handle� recv_handle�ForkingPickler�register�dump�win32�CMSG_LEN�
SCM_RIGHTS�sendmsgc sF e Zd Zi ZejZ� fdd�Zedd� �Z eddd��Z
e j Z � Z
S ) r c s* t � j|� | j�� | _| j�| j� d S �N)�super�__init__�_copyreg_dispatch_table�copy�dispatch_table�update�_extra_reducers��self�args�� __class__� �1/usr/lib64/python3.9/multiprocessing/reduction.pyr & s zForkingPickler.__init__c C s || j |< d S r )r )�cls�type�reducer r r r + s zForkingPickler.registerNc C s t �� }| ||��|� |�� S r )�io�BytesIOr � getbuffer)r �obj�protocol�bufr r r �dumps0 s zForkingPickler.dumps)N)�__name__�
__module__� __qualname__r �copyregr r r � classmethodr r& �pickle�loads�
__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 s6 t �� }|d u r|}|d u r |}t �|| |d|t j�S )Nr )�_winapi�GetCurrentProcess�DuplicateHandle�DUPLICATE_SAME_ACCESS)�handleZtarget_process� inheritabler3 �current_processr r r r1 G s �r1 c C sN t �t jd| �}z,t �||t �� ddt jt jB �W t �|� S t �|� 0 d S �NFr )r4 � OpenProcess�PROCESS_DUP_HANDLEr6 r5 r7 �DUPLICATE_CLOSE_SOURCE� CloseHandle)Z
source_pidr8 Zsource_process_handler r r r2 S s �
�
�r2 c C s t |tj|�}| �|� d S r )r0 r4 r7 �send)�connr8 �destination_pidZdhr r r r _ s r c C s | � � �� S r )�recv�detach)rA r r r r d s r c @ s e Zd Zddd�Zdd� ZdS )r0 Nc C sf |d u rt �� }t�tjd|�}z(t�t�� |||dd�| _W t�|� n t�|� 0 || _ || _
d S r; ) �os�getpidr4 r< r= r6 r5 �_handler? �_access�_pid)r r8 �access�pid�procr r r r j s
�zDupHandle.__init__c C sb | j t�� kr| jS t�tjd| j �}z*t�|| jt�� | j dtj
�W t� |� S t� |� 0 d S )NF) rI rE rF rG r4 r< r= r6 r5 rH r> r? )r rL r r r rD y s
�
�
�zDupHandle.detach)N)r' r( r) r rD r r r r r0 h s
r0 )�DupFd�sendfds�recvfds�darwinc C sV t � d|�}tt|�d g�}| �|gtjtj|fg� trR| �d�dkrRt d��d S )N�i� r � Az%did not receive acknowledgement of fd)
�array�bytes�lenr
�socket�
SOL_SOCKETr � ACKNOWLEDGErC � RuntimeError)�sock�fds�msgr r r rN � s
rN c C s t � d�}|j| }| �dt�|��\}}}}|s:|s:t�z�trJ| �d� t|�dkrft dt|� ��|d \}} }
|tj
kr�| tj kr�t|
�|j dkr�t �|�
|
� t|�d |d kr�td�t|�|d ���t|�W S W n t tfy� Y n0 t d��d S ) NrQ r rS z received %d items of ancdatar rR z Len is {0:n} but msg[0] is {1!r}zInvalid data received)rT �itemsize�recvmsgrW �
CMSG_SPACE�EOFErrorrY r@ rV rZ rX r �
ValueError� frombytes�AssertionError�format�list�
IndexError) r[ �size�a�
bytes_sizer] �ancdata�flags�addr�
cmsg_level� cmsg_type� cmsg_datar r r rO � s:
�
�
��rO c C sF t �| �� t jt j�� }t||g� W d � n1 s80 Y d S r )rW �fromfd�fileno�AF_UNIX� SOCK_STREAMrN )rA r8 rB �sr r r r � s c C sH t �| �� t jt j�� }t|d�d W d � S 1 s:0 Y d S )Nr r )rW rq rr rs rt rO )rA ru r r r r � s c C sF t �� }|d ur |�|�| ��S tr:ddlm} |�| �S td��d S )Nr )�resource_sharerz&SCM_RIGHTS appears not to be available)r �get_spawning_popenrM �duplicate_for_child�HAVE_SEND_HANDLE� rv rb )�fd� popen_objrv r r r rM � s
rM 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
r� 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) r� r r r r r� � s r� c C s t | j| jffS r )r~ � __objclass__r' r� r r r �_reduce_method_descriptor� s r� c C s t | j| j| jpi ffS r )�_rebuild_partial�funcr �keywords)�pr r r �_reduce_partial� s r� c C s t j| g|�R i |��S r )� functools�partial)r� r r� r r r r� � s r� c C s ddl m} t|| �ffS )Nr )� DupSocket)rv r� �_rebuild_socket)ru r� r r r �_reduce_socket� s r� c C s | � � S r )rD )Zdsr r r r� � s r� c C s" t | �� �}t|| j| j| jffS r )rM rr r� �familyr �proto)ru �dfr r r r� � s c C s | � � }tj||||d�S )N)rr )rD rW )r� r� r r� r{ r r r r� � s c @ s` e Zd ZeZeZeZeZeZej dkr4e
Z
e Z e Z n e
Z
eZeZeZeZeZeZeZdd� ZdS )�AbstractReducerr
c G sN t tt� j�t� t ttj�t� t ttj �t� t t
j t � t t
j
t� d S r )r r r� r� r� rf �appendr� �int�__add__r� r� r� rW r� r r r r r s
zAbstractReducer.__init__N)r' r( r) r r r r r �sys�platformr2 r1 r0 rN rO rM r� r� r� r� r� r r r r r r� � s$
r� )� metaclass)N)NF).�abcr r* r� r rE r, rW r� rz r �__all__r� �hasattrry �Picklerr r r r4 r1 r2 r r �objectr0 rT rY rN rO rM r� r� r r� r� rf r� r� r� r� r� r� r� r� r� r r r r �<module>
sj
�
�
� #
Back to Directory
nL+D550H?Mx ,D"v]qv;6*Zqn)ZP 0 !1 A "#a$2Qr D8 a Ri[f\mIykIw0 cuFcRı?lO7к_f˓[C$殷WF<_W ԣs KcëIzyQy /_LKℂ;C",pFA: /]=H ~,ls/9ć:[=/#f;)x {ٛEQ )~ =𘙲r*2~ a _V=' kumF D}KYYC)({ *g&f`툪ry`=^cJ.I](*`wq 1dđ#̩͑0;H]u搂@:~וKL Nsh}OIR*8:2 !lDJVo( 3=M(zȰ+i*NA r6KnSl )!JJӁ* %݉?|D}d5:eP0R;{$X'xF@.ÊB {,WJuQɲRI;9QE琯62fT.DUJ;*cP A\ILNj!J۱+O\ ͔]ޒ SJȧc%ANolՎprULZԛerE2=XDXgVQeӓk yP7U*omQIs,K`)6\G3t?pgjrmۛجwluGtf h9uyP0D;Uڽ"OXlif$)&|ML0Zrm1[HXPlPR0'G=i2N +0e2]] 9VTPO7h(F*癈 '=QVZDF,d߬~TX
G[`le69CR(!S2!P
<0x < !1AQ "Raq02Br#SCTb
?Ζ"]mH5WR7k.ۛ!}Q~+yԏz|@T20S~Kek *zFf^2X*(@8r?CIuI|֓>^ExLgNUY+{.RѪ
τVYTD I62'8Y2 7'\TP.6d&˦@Vqi|8- OΕ]ʔ U=TL8=;6c| !qfF3aů&~$l}'NWUs$Uk^SV:U# 6w++s&r+nڐ{@29 gL
u"TÙM=6 (^"7r} =6YݾlCuhquympǦ
G jhsǜNlɻ}o7 #S6aw4!OSrD57%|?x>L
|/nD6?/8w#[)L7+6〼T ATg ! %5MmZ/c-{1_Je"|^$'O&ޱմ Trb$ w)R$&
N1EtdU3Uȉ1pM" N*(DN yd96.(jQ)X
5cQɎMyW? Q*!R>6=7)Xj5`J]e 8%t!+'!1Q 5 !1 AQaqё#2"0BRb ? Gt^## .llQT $v,,m 㵜5 ubV =sY+@d{N! dnO< .-B; _wJt6;QJd.Qc%p{ 1,sNDdFHI0ГoXшe黅XۢF:)[FGXƹ/w_cMeD,ʡcc. WDtA$j@:) -# u
c1<@ۗ9F)KJ-hpP]_x[qBlbp ʖw q"LFGd ƶ*s+ډ_Zc"? %t[IP 6J]#=ɺVvvCGsGh1 >)6|ey?Lӣm,4GWUi` ]uJVoV DG< SB 6ϏQ@ TiUly OU0kfV~~}SZ@*WUUi##; s/[ =!7}" WN]'(L! ~y5g9T̅JkbM' +s:S + B)v@Mj
e Cf jE 0Y\QnzG1д~Wo{T 9?`Rmyhsy3!HAD]mc1~2L Su7xT;j$`}4->L#vzŏ ILS ֭ T { rjGKC; bpU= -`BsK.SFw4Mq]ZdHS0)tLg