|
Server : LiteSpeed System : Linux server51.dnsbootclub.com 4.18.0-553.62.1.lve.el8.x86_64 #1 SMP Mon Jul 21 17:50:35 UTC 2025 x86_64 User : nandedex ( 1060) PHP Version : 8.1.33 Disable Function : NONE Directory : /opt/cppython/lib/python3.8/multiprocessing/__pycache__/ |
U
@��g�0 � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZddl m
Z
ddl m Z ddl m
Z
ddl mZ ddl mZ ddl mZ d d
d d gZd
Ze�d�ZG dd� de�Zddd�Zdd� Zdd� Zdd� Ze� Zej Z ej Z ej Z ej Z dS )� N� )�
connection)�process)� reduction)�resource_tracker)�spawn)�util�ensure_running�get_inherited_fds�connect_to_new_process�set_forkserver_preload� �qc @ sD e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dS )�
ForkServerc C s. d | _ d | _d | _d | _t�� | _dg| _d S )N�__main__)�_forkserver_address�_forkserver_alive_fd�_forkserver_pid�_inherited_fds� threading�Lock�_lock�_preload_modules��self� r �9/opt/cppython/lib/python3.8/multiprocessing/forkserver.py�__init__" s
zForkServer.__init__c C s | j � | �� W 5 Q R X d S �N)r �_stop_unlockedr r r r �_stop* s zForkServer._stopc C sV | j d krd S t�| j� d | _t�| j d� d | _ t�| j�sLt�| j� d | _d S )Nr ) r �os�closer �waitpidr � is_abstract_socket_namespacer �unlinkr r r r r / s
zForkServer._stop_unlockedc C s& t dd� | jD ��s td��|| _dS )z>Set list of module names to try to load in forkserver process.c s s | ]}t |�tkV qd S r )�type�str)�.0�modr r r � <genexpr>@ s z4ForkServer.set_forkserver_preload.<locals>.<genexpr>z&module_names must be a list of stringsN)�allr � TypeError)r Z
modules_namesr r r r > s z!ForkServer.set_forkserver_preloadc C s | j S )z�Return list of fds inherited from parent process.
This returns None if the current process was not started by fork
server.
)r r r r r r
D s z ForkServer.get_inherited_fdsc
C s� | � � t|�d tkr td��t�tj���}|�| j� t� � \}}t� � \}}||| j
t � � g}||7 }zNz&t�||� ||fW W �4W 5 Q R � S t�
|� t�
|� � Y nX W 5 t�
|� t�
|� X W 5 Q R X dS )a; Request forkserver to create a child process.
Returns a pair of fds (status_r, data_w). The calling process can read
the child process's pid and (eventually) its returncode from status_r.
The calling process should write to data_w the pickled preparation and
process data.
� z too many fdsN)r �len�MAXFDS_TO_SEND�
ValueError�socket�AF_UNIX�connectr r! �piper r Zgetfdr" r �sendfds)r �fds�client�parent_r�child_w�child_r�parent_wZallfdsr r r r L s( �
z!ForkServer.connect_to_new_processc s� | j ��~ t�� | jdk r`t�| jtj�\}}|sBW 5 Q R � dS t�| j� d| _ d| _d| _d}| j
r�ddh� t � d�}� fdd�|�
� D �}ni }t�tj���}t�d�}|�|� t�|�s�t�|d � |�� t�� \}}ztzV|�� |g} ||�� || j
|f; }t �� }
|
gt�� } | d
|g7 } t�|
| | �}W n t�|� � Y nX W 5 t�|� X || _ || _|| _W 5 Q R X W 5 Q R X dS ) z�Make sure that a fork server is running.
This can be called from any process. Note that usually a child
process will just reuse the forkserver started by its parent, so
ensure_running() will do nothing.
NzCfrom multiprocessing.forkserver import main; main(%d, %d, %r, **%r)� main_path�sys_path�ignorec s i | ]\}}|� kr||�qS r r )r( �x�y�Z desired_keysr r �
<dictcomp>� s z-ForkServer.ensure_running.<locals>.<dictcomp>r2 i� z-c) r r r r r! r# �WNOHANGr" r r r r Zget_preparation_data�itemsr1 r2 r �arbitrary_address�bindr r$ �chmod�listenr4 �filenoZget_executable� _args_from_interpreter_flags�spawnv_passfds) r �pid�status�cmd�data�listener�address�alive_rZalive_wZ fds_to_passZexe�argsr rA r r i sN
�
zForkServer.ensure_runningN)
�__name__�
__module__� __qualname__r r r r r
r r r r r r r s r c C s� |rdd|kr8|dk r8dt �� _zt�|� W 5 t �� `X |D ]&}z t|� W q< tk
r` Y q<X q<t�� t �
� \}}t � |d� t � |d� dd� }t j
|t jt ji} dd� | �� D �}
t �|� i } tjtj| d ���} t�� ���}
| �� t_|
�| tj� |
�|tj� |
�|tj� �z�d
d � |
�� D �}|�r"�qB�q"||k�rjt � |d �d
k�sft d��t �||k�r\t � |d� zt � dt j �\}}W n t!k
�r� Y �q\Y nX |dk�rq\| �"|d�}|dk �rJt �#|��r�t �$|� }n&t �%|��st d�&||���t �'|�}zt(||� W n t)k
�r< Y nX t �*|� nt+�,d| � �q�| |k�r�| �-� d ��,}t.�/|t0d �}t1|�t0k�r�t2d�&t1|����|^}}}|�*� t �3� }|dk�rNd }zpz<| �*� |
�*� ||||g}|�5| �6� � t7||||
�}W n. t8k
�r: t9j:t9�;� � t9j<�=� Y nX W 5 t �4|� X nNzt(||� W n t)k
�rr Y nX || |< t �*|� |D ]}t �*|� �q�W 5 Q R X W n4 t>k
�r� } z|j?t?j@k�r̂ W 5 d}~X Y nX �q W 5 Q R X W 5 Q R X dS )zRun forkserver.r NTFc W s d S r r )Z_unusedr r r �sigchld_handler� s z main.<locals>.sigchld_handlerc S s i | ]\}}|t � ||��qS r )�signal)r( �sig�valr r r rB � s � zmain.<locals>.<dictcomp>)rI c S s g | ]\}}|j �qS r )�fileobj)r( �key�eventsr r r �
<listcomp>� s zmain.<locals>.<listcomp>r � z Not at EOF?i ���r zChild {0:n} status is {1:n}z.forkserver: waitpid returned unexpected pid %dz Too many ({0:n}) fds to send)Ar �current_processZ _inheritingr Zimport_main_path�
__import__� ImportErrorr � _close_stdinr! r4 � set_blockingrX �SIGCHLD�SIGINT�SIG_IGNrD �
set_wakeup_fdr1 r2 � selectors�DefaultSelector� getsockname� _forkserverr �register�
EVENT_READ�select�read�AssertionError�
SystemExitr# rC �ChildProcessError�pop� WIFSIGNALED�WTERMSIG� WIFEXITED�format� WEXITSTATUS� write_signed�BrokenPipeErrorr" �warnings�warn�acceptr �recvfdsr/ r. � RuntimeError�fork�_exit�extend�values�
_serve_one� Exception�sys�
excepthook�exc_info�stderr�flush�OSError�errnoZ ECONNABORTED)Z listener_fdrR Zpreloadr< r= �modnameZsig_rZsig_wrW �handlersZ old_handlersZ pid_to_fdrP �selectorZrfdsrL �stsr9 �
returncode�sr6 r: �code�
unused_fds�fd�er r r �main� s�
��
�
��
�
��
�
r� c C sh t �d� |�� D ]\}}t � ||� q|D ]}t�|� q,|^t_tj_ t_
t� | �}t �
| |�}|S )Nr` )rX ri rD r! r" rm r r �_resource_trackerZ_fdr �dupr Z_main) r: r6 r� r� rY rZ r� �parent_sentinelr� r r r r� 1 s
�
r� c C sN d}t j}t|�|k r@t�| |t|� �}|s6td��||7 }q
t �|�d S )Nr_ zunexpected EOFr )�
SIGNED_STRUCT�sizer. r! rq �EOFError�unpack)r� rO �lengthr� r r r � read_signedH s
r� c C s< t �|�}|r8t�| |�}|dkr*td��||d � }q
d S )Nr zshould not get here)r� �packr! �writer� )r� �n�msg�nbytesr r r r{ R s
r{ )NN) r� r! rj rX r1 �structr� r r} � r r �contextr r r r �__all__r/ �Structr� �objectr r� r� r� r{ rm r r
r r r r r r �<module> s> �