Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/billiard/__pycache__/process.cpython-39.pyc
Ðазад
a i�h/+ � @ s< d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ d dlm Z ze j � e � � �ZW n eyr dZY n0 g d�Zdd� Zdd� Zd d � Zd d � Zefd d�ZG dd� d�ZG dd� de�ZG dd� de�Ze� ae�d�a e � a [eZ i Z ej!�"� D ]0\Z#Z$e#dd� dk�r de#v�r e#e e$ < �q e� Z%dS )� N)�WeakSet��process)� BaseProcess�Process�current_process�active_childrenc C s t S )z@ Return process object representing the current process )�_current_process� r r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/billiard/process.pyr # s r c C s | a t_ d S �N)r �_mprocr r r r �_set_current_process* s r c C s* t t�D ] } | j�� d urt�| � qd S r )�list� _children�_popen�poll�discard)�pr r r �_cleanup/ s r c C s* z | � � W n tttfy$ Y n0 d S r )�flush�AttributeError�EnvironmentError�NotImplementedError)�fr r r � _maybe_flush6 s r c C s* z | � W n t y g Y S 0 tt�S )zN Return list of process objects corresponding to live child processes )� TypeErrorr r )r r r r r = s r c @ s2 e Zd ZdZdd� Zddddi dfdd�Zdd � Zd d � Zd d � Zdd� Z dd� Z d5dd�Z dd� Z dd� Z edd� �Zejdd� �Zedd � �Zejd d � �Zed d � �Zejd d � �Zed!d"� �Zed#d$� �ZeZed%d&� �Zed'd(� �Zed)d*� �Zed+d,� �Zed-d.� �Zed/d0� �Zd1d2� Z d3d4� Z dS )6r z� Process objects represent activity that is run in a separate process The class is analogous to `threading.Thread` c C s t � �d S r )r ��selfr r r �_PopenP s zBaseProcess._PopenNr c K s� |d u sJ d��t t�}tj|f | _tj�� | _t�� | _d | _ || _ t |�| _ t |�| _|p�t| �jd d�dd� | jD �� | _|d ur�|| _td ur�t�| � d| _d S )Nz#group argument must be None for now�-�:c s s | ]}t |�V qd S r )�str)�.0�ir r r � <genexpr>` � z'BaseProcess.__init__.<locals>.<genexpr>F)�next�_process_counterr � _identity�_config�copy�os�getpid� _parent_pidr �_target�tuple�_args�dict�_kwargs�type�__name__�join�_name�daemon� _dangling�add�_controlled_termination) r �group�target�name�args�kwargsr8 Z_kw�countr r r �__init__S s$ �� zBaseProcess.__init__c C s | j r| j | ji | j�� dS )zQ Method to be run in sub-process; can be overridden in sub-class N)r/ r1 r3 r r r r �runi s zBaseProcess.runc C sR | j du sJ d��| jt�� ks(J d��t� | �| �| _ | j j| _t� | � dS )z% Start child process Nz cannot start a process twicez:can only start a process object created by current process) r r. r, r- r r �sentinel� _sentinelr r: r r r r �startp s � zBaseProcess.startc C s | j d ur| j �� d S r )r �closer r r r rG | s zBaseProcess.closec C s | j �� dS )zT Terminate process; sends SIGTERM signal or uses TerminateProcess() N)r � terminater r r r rH � s zBaseProcess.terminatec C s d| _ | �� d S )NT)r; rH r r r r �terminate_controlled� s z BaseProcess.terminate_controlledc C sR | j t�� ksJ d��| jdus(J d��| j�|�}|durNt�| � | �� dS )z5 Wait until child process terminates z can only join a child processNz can only join a started process)r. r, r- r �waitr r rG )r �timeout�resr r r r6 � s zBaseProcess.joinc C sF | t u r dS | jt�� ks"J d��| jdu r0dS | j�� | jjdu S )z1 Return whether process is alive Tz can only test a child processNF)r r. r, r- r r � returncoder r r r �is_alive� s zBaseProcess.is_alivec C s | j d u rdS | j �� d u S )NF�r r r r r r � _is_alive� s zBaseProcess._is_alivec C s | j S r )r7 r r r r r> � s zBaseProcess.namec C s t |t�sJ d��|| _d S )Nzname must be a string)� isinstancer" r7 )r r> r r r r> � s c C s | j �dd�S )z4 Return whether process is a daemon r8 F�r* �getr r r r r8 � s zBaseProcess.daemonc C s | j du sJ d��|| jd< dS )z1 Set whether process is a daemon Nzprocess has already startedr8 )r r* )r �daemonicr r r r8 � s c C s | j d S )N�authkey)r* r r r r rU � s zBaseProcess.authkeyc C s t |�| jd< dS )z2 Set authorization key of process rU N)�AuthenticationStringr* )r rU r r r rU � s c C s | j du r| j S | j �� S )zM Return exit code of process or `None` if it has yet to stop NrO r r r r �exitcode� s zBaseProcess.exitcodec C s" | t u rt�� S | jo | jjS dS )zU Return identifier (PID) of process or `None` if it has yet to start N)r r, r- r �pidr r r r �ident� s zBaseProcess.identc C s( z| j W S ty" td��Y n0 dS )z{ Return a file descriptor (Unix) or handle (Windows) suitable for waiting for process termination. zprocess not startedN)rE r � ValueErrorr r r r rD � s zBaseProcess.sentinelc C s t S r )r( r r r r �_counter� s zBaseProcess._counterc C s t S r )r r r r r r � s zBaseProcess._childrenc C s | j S r )rU r r r r �_authkey� s zBaseProcess._authkeyc C s | j S r )r8 r r r r � _daemonic� s zBaseProcess._daemonicc C s | j �d�S )N�tempdirrR r r r r �_tempdir� s zBaseProcess._tempdirc C s� | t u rd}n>| jt�� kr"d}n*| jd u r2d}n| j�� d urH| j}nd}t|�tu rv|dkrfd}ndt � ||� }dt| �j | j || j r�dp�d f S ) N�started�unknown�initialr �stoppedz stopped[%s]z<%s(%s, %s%s)>z daemon� )r r. r, r- r r rW r4 �int�_exitcode_to_namerS r5 r7 r8 )r �statusr r r �__repr__ s �zBaseProcess.__repr__c C sd ddl m}m} �z&�z&| jd ur.|�| j� t�d�at� a t j d ur|zt j � � t tj�t _ W n tttfyz Y n0 t}t| � tjjj}t|�� �}|�d � |D ]2}|r�t || tj �s�t� |�j D ] }|� � q�q�t!�"� t_#z|j$�%� |�&� W ~n~0 |�'d| j(� z| �)� d}W |�*� n |�*� 0 W n� t+�y� } zv| j,�s\d}n\t | j,d t-��rz| j,d }n>t j.�/t0| j,d �d � t1t j.� t | j,d t0��r�dnd}W Y d } ~ nNd } ~ 0 d}|j2d| j3dd��s dd l4} t j.�/d | j3 � | �5� Y n0 W |�'d | j(|� t1t j6� t1t j.� n&|�'d | j(|� t1t j6� t1t j.� 0 |S ) N� )�util�contextz#child process %s calling self.run()r � z Process %sT)�exc_infoz Process %s: z#process %s exiting with exitcode %d)7rd rj rk Z _start_methodZ_force_start_method� itertoolsrA r( �setr �sys�stdinrG �openr, �devnullr �OSErrorrZ r r �logging�Logger�manager� loggerDictr �keys�appendrQ � PlaceHolder� getLogger�handlers� createLock� threading�RLock�_lockZ_finalizer_registry�clearZ_run_after_forkers�inforX rC Z_exit_function� SystemExitr? re �stderr�writer" r �errorr> � traceback� print_exc�stdout) r rj rk Z old_processrx Z logger_namesr> �handlerrW �excr� r r r � _bootstrap st � .� �� zBaseProcess._bootstrap)N) r5 � __module__� __qualname__�__doc__r rB rC rF rG rH rI r6 rN rP �propertyr> �setterr8 rU rW rY rX rD r[ r r\ r] r_ rh r� r r r r r I sX � r c @ s e Zd Zdd� ZdS )rV c C s, ddl m} |� d u r td��tt| �ffS )Nri )�get_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)rk r� r rV �bytes)r r� r r r � __reduce__e s �z AuthenticationString.__reduce__N)r5 r� r� r� r r r r rV c s rV c @ s e Zd Zdd� ZdS )� _MainProcessc C s2 d| _ d| _d | _d | _tt�d��dd�| _d S )Nr � MainProcess� z/mp)rU Z semprefix)r) r7 r. r rV r, �urandomr* r r r r rB u s �z_MainProcess.__init__N)r5 r� r� rB r r r r r� s s r� ri � ZSIG�_)&r, rp �signalrn ru r � _weakrefsetr �multiprocessingr r �path�abspath�getcwdZ ORIGINAL_DIRrt �__all__r r r r r r r� rV r� r rA r( ro r r rf �__dict__�itemsr> �signumr9 r r r r �<module> s@
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка