Edit File: process.cpython-37.opt-2.pyc
B YI~d4) � @ s d ddgZ ddlZddlZddlZddlZddlZddlmZ yej� e� � �Z W n e k rj dZ Y nX dd� Z dd� Zdd � ZG d d � d e�ZG d d � d e�ZG d d� de�Ze� ae�d�ae� a[i Zx<eej � � �D ]*\Z Z e dd� dkr�de kr�e ee < q�W e� Z dS )� BaseProcess�current_process�active_children� N)�WeakSetc C s t S )N)�_current_process� r r �</opt/alt/python37/lib64/python3.7/multiprocessing/process.pyr $ s c C s t � tt�S )N)�_cleanup�list� _childrenr r r r r * s c C s. x(t t�D ] } | j�� d k r t�| � q W d S )N)r r �_popen�poll�discard)�pr r r r 5 s r c @ s� e Zd Zdd� Zddddi fdd�dd�Zdd � Zd d � Zd d � Zdd� Zdd� Z d+dd�Z dd� Z dd� Z e dd� �Zejdd� �Ze dd � �Zejd d � �Ze d d � �Zejd d � �Ze d!d"� �Ze d#d$� �ZeZe d%d&� �Zd'd(� Zd)d*� ZdS ),r c C s t �d S )N)�NotImplementedError)�selfr r r �_PopenE s zBaseProcess._PopenNr )�daemonc C s� t t�}tj|f | _tj�� | _t�� | _d | _ d| _ || _ t |�| _ t|�| _|pxt| �jd d�dd� | jD �� | _|d k r�|| _t�| � d S )NF�-�:c s s | ]}t |�V qd S )N)�str)�.0�ir r r � <genexpr>U s z'BaseProcess.__init__.<locals>.<genexpr>)�next�_process_counterr � _identity�_config�copy�os�getpid� _parent_pidr �_closed�_target�tuple�_args�dict�_kwargs�type�__name__�join�_namer � _dangling�add)r �group�target�name�args�kwargsr �countr r r �__init__H s zBaseProcess.__init__c C s | j rtd��d S )Nzprocess object is closed)r" � ValueError)r r r r � _check_closedZ s zBaseProcess._check_closedc C s | j r| j | j| j� d S )N)r# r% r' )r r r r �run^ s zBaseProcess.runc C s> | � � t� | �| �| _| jj| _| `| `| `t � | � d S )N) r6 r r r �sentinel� _sentinelr# r% r' r r- )r r r r �starte s zBaseProcess.startc C s | � � | j�� d S )N)r6 r � terminate)r r r r r; w s zBaseProcess.terminatec C s | � � | j�� d S )N)r6 r �kill)r r r r r< ~ s zBaseProcess.killc C s* | � � | j�|�}|d k r&t�| � d S )N)r6 r �waitr r )r ZtimeoutZresr r r r* � s zBaseProcess.joinc C sJ | � � | tkrdS | jd kr"dS | j�� }|d kr8dS t�| � dS d S )NTF)r6 r r r r r )r � returncoder r r �is_alive� s zBaseProcess.is_alivec C sH | j d k r>| j �� d kr td��| j �� d | _ | `t�| � d| _d S )Nz^Cannot close a process while it is still running. You should first call join() or terminate().T)r r r5 �closer9 r r r" )r r r r r@ � s zBaseProcess.closec C s | j S )N)r+ )r r r r r0 � s zBaseProcess.namec C s || _ d S )N)r+ )r r0 r r r r0 � s c C s | j �dd�S )Nr F)r �get)r r r r r � s zBaseProcess.daemonc C s || j d< d S )Nr )r )r Zdaemonicr r r r � s c C s | j d S )N�authkey)r )r r r r rB � s zBaseProcess.authkeyc C s t |�| jd< d S )NrB )�AuthenticationStringr )r rB r r r rB � s c C s" | � � | jd kr| jS | j�� S )N)r6 r r )r r r r �exitcode� s zBaseProcess.exitcodec C s* | � � | tkrt�� S | jo$| jjS d S )N)r6 r r r r �pid)r r r r �ident� s zBaseProcess.identc C s2 | � � y| jS tk r, td�d �Y nX d S )Nzprocess not started)r6 r9 �AttributeErrorr5 )r r r r r8 � s zBaseProcess.sentinelc C s� | t krd}nJ| jrd}n>| jt�� kr.d}n*| jd kr>d}n| j�� d k rT| j}nd}t|�t kr�|dkrrd}ndt � ||� }dt| �j | j || jr�d p�d f S ) NZstarted�closed�unknown�initialr Zstoppedz stopped[%s]z<%s(%s, %s%s)>z daemon� )r r" r! r r r r rD r( �int�_exitcode_to_namerA r) r+ r )r �statusr r r �__repr__� s" zBaseProcess.__repr__c C sR ddl m}m} �zy|| jd k r,|�| j� t�d�at� a |� � t }| a z|j � � |�� W d ~X |�d� z| �� d}W d |�� X W n� tk r� } zJ|js�d}n:t|jd t�r�|jd }n tj�t|jd �d � d}W d d }~X Y n2 d}dd l}tj�d| j � |� � Y nX W d t � � |�d| � |� � X |S )N� )�util�contextz child process calling self.run()r � z Process %s: z process exiting with exitcode %d) rK rQ rR Z _start_methodZ_force_start_method� itertoolsr3 r �setr Z _close_stdinr Z_finalizer_registry�clearZ_run_after_forkers�infor7 Z_exit_function� SystemExitr1 � isinstancerL �sys�stderr�writer � tracebackr0 � print_exc� threadingZ _shutdownZ_flush_std_streams)r rQ rR Z old_processrD �er] r r r � _bootstrap sD zBaseProcess._bootstrap)N)r) � __module__� __qualname__r r4 r6 r7 r: r; r< r* r? r@ �propertyr0 �setterr rB rD rF rE r8 rO ra r r r r r ? s. c @ s e Zd Zdd� ZdS )rC c C s, ddl m} |� d kr td��tt| �ffS )NrP )�get_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)rR rf � TypeErrorrC �bytes)r rf r r r � __reduce__F s z AuthenticationString.__reduce__N)r) rb rc ri r r r r rC E s rC c @ s e Zd Zdd� Zdd� ZdS )� _MainProcessc C s8 d| _ d| _d | _d | _d| _tt�d��dd�| _d S )Nr Z MainProcessF� z/mp)rB Z semprefix) r r+ r! r r" rC r �urandomr )r r r r r4 U s z_MainProcess.__init__c C s d S )Nr )r r r r r@ g s z_MainProcess.closeN)r) rb rc r4 r@ r r r r rj S s rj rP � ZSIG�_)!�__all__r rZ �signalrT r_ Z _weakrefsetr �path�abspath�getcwdZ ORIGINAL_DIR�OSErrorr r r �objectr rh rC rj r r3 r rU r rM r �__dict__�itemsr0 Zsignumr, r r r r �<module> s6
Back to File Manager