| Server IP : 193.86.120.172 / Your IP : 216.73.216.67 Web Server : Apache/2.4.63 (Unix) System : Linux JServices 3.10.108 #86003 SMP Wed Oct 22 13:20:46 CST 2025 x86_64 User : kubec ( 1026) PHP Version : 8.2.28 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : OFF Directory : /proc/29145/cwd/lib/python3.8/multiprocessing/__pycache__/ |
Upload File : |
U
��p����� @ s d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZddl m
Z
ddddd gZ ej d
kp�e
ed �o�e
ed �o�e
ejd
�ZG dd� dej�ZejZd6dd �Zej d
k�re dddg7 Z d dlZd7dd�dd�Zdd� Zdd� Zdd� ZG dd� de�ZnHe ddd g7 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 d
k�r�d-d.� Z+d/d0� Z,eeje+� n d1d.� Z+d2d0� Z,eeje+� G d3d4� d4ed5�Z-dS )8� )�ABCMetaN� )�context� send_handle� recv_handle�ForkingPickler�register�dump�win32ZCMSG_LEN�
SCM_RIGHTS�sendmsgc sJ e Zd ZdZi ZejZ� fdd�Ze dd� �Z
e d dd��Z 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_table�copy�dispatch_table�update�_extra_reducers��self�args�� __class__� �D/tmp/_install_python3/usr/lib/python3.8/multiprocessing/reduction.pyr & s zForkingPickler.__init__c C s || j |< dS )z&Register a reduce function for a type.N)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__�__doc__r �copyregr r r � classmethodr r% �pickle�loads�
__classcell__r r r r r ! s
c C s t ||��| � dS )z3Replacement for pickle.dump() using ForkingPickler.N)r r )r" �filer# r r r r : s � DupHandle� duplicate� steal_handleF)�source_processc C s6 t �� }|dkr|}|dkr |}t �|| |d|t j�S )z<Duplicate a handle. (target_process is a handle not a pid!)Nr )�_winapi�GetCurrentProcess�DuplicateHandle�DUPLICATE_SAME_ACCESS)�handleZtarget_processZ inheritabler3 Zcurrent_processr r r r1 G s �c C sF t �t jd| �}z$t �||t �� ddt jt jB �W �S t �|� X dS )z5Steal a handle from process identified by source_pid.Fr N)r4 � OpenProcess�PROCESS_DUP_HANDLE� CloseHandler6 r5 r7 �DUPLICATE_CLOSE_SOURCE)Z
source_pidr8 Zsource_process_handler r r r2 S s �
�c C s t |tj|�}| �|� dS �z&Send a handle over a local connection.N)r0 r4 r7 �send)�connr8 �destination_pidZdhr r r r _ s c C s | � � �� S )�)Receive a handle over a local connection.)�recv�detach)r? r r r r d s c @ s" e Zd ZdZddd�Zdd� ZdS )r0 z Picklable wrapper for a handle.Nc C s\ |d krt �� }t�tjd|�}z t�t�� |||dd�| _W 5 t�|� X || _ || _
d S )NFr ) �os�getpidr4 r9 r: r; r6 r5 �_handle�_access�_pid)r r8 �access�pid�procr r r r j s �
zDupHandle.__init__c C sZ | j t�� kr| jS t�tjd| j �}z"t�|| jt� � | j
dtj �W �S t�|� X dS )z1Get the handle. This should only be called once.FN) rH rD rE rF r4 r9 r: r; r6 r5 rG r< )r rK r r r rC y s
� �zDupHandle.detach)N)r& r' r( r) r rC r r r r r0 h s
�DupFd�sendfds�recvfds�darwinc C sV t � d|�}tt|�d g�}| �|gtjtj|fg� trR| �d�dkrRt d��dS )z,Send an array of fds over an AF_UNIX socket.�i� r � Az%did not receive acknowledgement of fdN)
�array�bytes�lenr �socket�
SOL_SOCKETr � ACKNOWLEDGErB � RuntimeError)�sockZfds�msgr r r rM � s
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 tfk
r� Y nX t d��d S )
z/Receive an array of fds over an AF_UNIX socket.rP r rR z received %d items of ancdatar rQ z Len is {0:n} but msg[0] is {1!r}zInvalid data receivedN)rS �itemsizeZrecvmsgrV Z
CMSG_SPACE�EOFErrorrX r> rU rY rW r �
ValueErrorZ frombytes�AssertionError�format�list�
IndexError) rZ �size�aZ
bytes_sizer[ Zancdata�flagsZaddrZ
cmsg_levelZ cmsg_typeZ cmsg_datar r r rN � s<
�
�
��c C s2 t �| �� t jt j��}t||g� W 5 Q R X dS r= )rV �fromfd�fileno�AF_UNIX� SOCK_STREAMrM )r? r8 r@ �sr r r r � s c
C s< t �| �� t jt j�� }t|d�d W 5 Q R � S Q R X dS )rA r r N)rV rf rg rh ri rN )r? rj r r r r � s c C sF t �� }|dk r |�|�| ��S tr:ddlm} |�| �S td��dS )zReturn a wrapper for an fd.Nr )�resource_sharerz&SCM_RIGHTS appears not to be available)r Zget_spawning_popenrL Zduplicate_for_child�HAVE_SEND_HANDLE� rk r^ )�fdZ popen_objrk r r r rL � s
c C s2 | j d kr t| j| jjffS t| j | jjffS d S r
)�__self__�getattrr �__func__r& ��mr r r �_reduce_method� s
rt 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( rv r r r r ru � s ru c C s t | j| jffS r
)rp � __objclass__r& rr r r r �_reduce_method_descriptor� s rx 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| f|�|�S r
)� functools�partial)rz r r{ r r r ry � s ry c C s ddl m} t|| �ffS )Nr )� DupSocket)rk r� �_rebuild_socket)rj r� r r r �_reduce_socket� s r� c C s | � � S r
)rC )Zdsr r r r� � s r� c C s" t | �� �}t|| j| j| jffS r
)rL rg r� �familyr �proto)rj �dfr r r r� � s c C s | � � }tj||||d�S )N)rg )rC rV )r� r� r r� rn r r r r� � s c @ sd e Zd ZdZeZeZeZeZeZe j
dkr8e Z e Z e
Z
n eZeZeZeZeZeZeZeZdd� ZdS )�AbstractReducerz�Abstract 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� j�t� t ttj�t� t ttj �t� t t
j t � t t
j
t� d S r
)r r ru rv rt ra �appendrx �int�__add__r~ r r} rV r� r r r r r s
zAbstractReducer.__init__N)r& r' r( r) r r r r r �sys�platformr2 r1 r0 rM rN rL rt rx ry r� r� r r r r r r� � s&
r� )� metaclass)N)NF).�abcr r* r~ r rD r, rV r� rm r �__all__r� �hasattrrl ZPicklerr r r r4 r1 r2 r r �objectr0 rS rX rM rN rL rt ru r rv rx ra r� r� r� r} ry r r� r� r� r r r r �<module>
sj
�
�
� #