| Server IP : 127.0.0.1 / Your IP : 216.73.216.109 Web Server : Apache/2.4.54 (Win64) OpenSSL/1.1.1q PHP/8.1.10 System : Windows NT DESKTOP-E5T4RUN 10.0 build 19045 (Windows 10) AMD64 User : SERVERWEB ( 0) PHP Version : 8.1.10 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : OFF | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : C:/cygwin64/lib/python3.6/multiprocessing/__pycache__/ |
Upload File : |
3
�1�a
$ � @ s d dl mZmZ d dlZd dlZd dlZd dlZd dlZd dlZd dl Z ddl
m Z ddddd gZ e j
d
kp�eed �o�eed �o�eejd
�ZG dd� dej�ZejZd5dd �Ze j
d
k�re dddg7 Z d dlZd6dd�Zdd� Zdd� Zdd� ZG dd� de�ZnHe 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
k�r�d,d-� Z,d.d/� Z-eeje,� n d0d-� Z,d1d/� Z-eeje,� G d2d3� d3ed4�Z.dS )7� )�ABCMeta�abstractmethodN� )�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|� | jj� | _| jj| j� d S )N)�super�__init__�_copyreg_dispatch_table�copy�dispatch_table�update�_extra_reducers)�self�args)� __class__� � /usr/lib/python3.6/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 j� }| ||�j|� |j� S )N)�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 ||�j| � dS )z3Replacement for pickle.dump() using ForkingPickler.N)r r
)r �filer! r r r r
: s � DupHandle� duplicate� steal_handleFc C s* |dkrt j� }t jt j� | |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 inheritabler r r r/ G s
c C sB t jt jd| �}z t j||t j� ddt jt jB �S t j|� X dS )z5Steal a handle from process identified by source_pid.Fr N)r1 � OpenProcess�PROCESS_DUP_HANDLEr3 r2 r4 �DUPLICATE_CLOSE_SOURCE� CloseHandle)Z
source_pidr5 Zsource_process_handler r r r0 O s
c C s t |tj|�}| j|� dS )z&Send a handle over a local connection.N)r. r1 r4 �send)�connr5 �destination_pidZdhr r r r [ s c C s | j � j� S )z)Receive a handle over a local connection.)�recv�detach)r; r r r r ` s c @ s" e Zd ZdZddd�Zdd� ZdS )r. z Picklable wrapper for a handle.Nc
C s\ |d krt j� }tjtjd|�}z tjtj� |||dd�| _W d tj|� X || _ || _
d S )NFr ) �os�getpidr1 r6 r7 r3 r2 �_handler9 �_access�_pid)r r5 �access�pid�procr r r r f s zDupHandle.__init__c
C sV | j tj� kr| jS tjtjd| j �}z tj|| jtj� | j dtj
�S tj |� X dS )z1Get the handle. This should only be called once.FN) rC r? r@ rA r1 r6 r7 r3 r2 rB r8 r9 )r rF r r r r> u s
zDupHandle.detach)N)r$ r% r& r' r r> r r r r r. d s
�DupFd�sendfds�recvfds�darwinc C sV t j d|�}tt|�d g�}| j|gtjtj|fg� trR| jd�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 � ACKNOWLEDGEr= � RuntimeError)�sockZfds�msgr r r rH � s
c C s� t j d�}|j| }| jdtj|��\}}}}| r>| r>t�y�trN| jd� t|�dkrjt dt|� ��|d \}} }
|tj
kr�| tj kr�t|
�|j dkr�t �|j
|
� t|�d |d ks�t�t|�S W n t tfk
r� Y nX t d��dS ) z/Receive an array of fds over an AF_UNIX socket.rK r rM z received %d items of ancdatar rL zInvalid data receivedN)rN �itemsizeZrecvmsgrQ Z
CMSG_SPACE�EOFErrorrS r: rP rT rR r �
ValueErrorZ frombytes�AssertionError�list�
IndexError) rU �size�aZ
bytes_sizerV Zancdata�flagsZaddrZ
cmsg_levelZ cmsg_typeZ cmsg_datar r r rI � s,
c
C s2 t j| j� t jt j��}t||g� W dQ R X dS )z&Send a handle over a local connection.N)rQ �fromfd�fileno�AF_UNIX� SOCK_STREAMrH )r; r5 r< �sr r r r � s c
C s0 t j| j� t jt j��}t|d�d S Q R X dS )z)Receive a handle over a local connection.r r N)rQ r` ra rb rc rI )r; rd r r r r � s c C sF t j� }|dk r |j|j| ��S tr:ddlm} |j| �S td��dS )zReturn a wrapper for an fd.Nr )�resource_sharerz&SCM_RIGHTS appears not to be available)r Zget_spawning_popenrG Zduplicate_for_child�HAVE_SEND_HANDLE� re rY )�fdZ popen_objre r r r rG � 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
rm c @ s e Zd Zdd� ZdS )�_Cc C s d S )Nr )r r r r �f� s z_C.fN)r$ r% r& ro r r r r rn � s rn c C s t | j| jffS )N)rj � __objclass__r$ )rl r r r �_reduce_method_descriptor� s rq c C s t | j| j| jpi ffS )N)�_rebuild_partial�funcr �keywords)�pr r r �_reduce_partial� s rv c C s t j| f|�|�S )N)� functools�partial)rs r rt r r r rr � s rr c C s ddl m} t|| �ffS )Nr )� DupSocket)re ry �_rebuild_socket)rd ry r r r �_reduce_socket� s r{ c C s | j � S )N)r> )Zdsr r r rz � s rz c C s" t | j� �}t|| j| j| jffS )N)rG ra rz �familyr �proto)rd �dfr r r r{ � s c C s | j � }tj||||d�S )N)ra )r> rQ )r~ r| r r} rh r r r rz � 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 )N)r r rn ro rm r[ �appendrq �int�__add__rw rx rv rQ r{ )r r r r r r
s
zAbstractReducer.__init__N)r$ r% r& r' r r r
r r �sys�platformr0 r/ r. rH rI rG rm rq rr r{ rz r r r r r r � s&
r )� metaclass)N)NF)/�abcr r r( rw r r? r* rQ r� rg r �__all__r� �hasattrrf ZPicklerr r r
r1 r/ r0 r r �objectr. rN rS rH rI rG rm rn r ro rq r[ r� r� r� rv rr rx r{ rz r r r r r �<module>
sb
#