Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/tornado/__pycache__/process.cpython-39.pyc
Ðазад
a _�h�3 � @ sD d Z ddlZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z m Z m Z ddlmZ ddlmZ ddlmZ ddlmZ dd lmZ ddlZdd lmZmZmZm Z ej r�dd lm Z ej Z e d �d d�Z!dd �dd�Z"ee e f d �dd�Z#da$dee e e d�dd�Z%ee d �dd�Z&G dd� de'�Z(dS )z�Utilities for working with multiple processes, including both forking the server into multiple processes and managing subprocesses. � N)�hexlify)�Future�"future_set_result_unless_cancelled�%future_set_exception_unless_cancelled)�ioloop)� PipeIOStream)�gen_log)�set_close_exec)�errno_from_exception)�Tuple�Optional�Any�Callable)�List��returnc C s\ t du r dS z t �� W S ty( Y n0 z t�d�W S ttfyL Y n0 t�d� dS )z1Returns the number of processors on this machine.N� �SC_NPROCESSORS_CONFz1Could not detect number of processors; assuming 1) �multiprocessing� cpu_count�NotImplementedError�os�sysconf�AttributeError� ValueErrorr �error� r r �/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/tornado/process.pyr 3 s r c C sh dt jvrd S dd l} zttt�d��d�}W n* tyX tt�� d �t� � A }Y n0 | � |� d S )N�randomr � i� ) �sys�modulesr �intr r �urandomr �time�getpid�seed)r r& r r r �_reseed_randomC s r' c C s$ t �� \} }t| � t|� | |fS �N)r �piper )�r�wr r r � _pipe_cloexecR s r, )� num_processes� max_restartsr c s� |du r d}t du sJ �| du s(| dkr.t� } t�d| � i � ttt d�� fdd� }t| �D ] }||�}|dur^| S q^d}� �rxzt�� \}}W n@ t y� } z(t |�t j kr�W Y d}~q�� W Y d}~n d}~0 0 |� vr�q�� � |�}t�|��rt�d||t�|�� n8t�|�dk�r8t�d ||t�|�� nt�d ||� q�|d 7 }||k�rbtd ��||�} | dur�| S q�t�d� dS ) a� Starts multiple worker processes. If ``num_processes`` is None or <= 0, we detect the number of cores available on this machine and fork that number of child processes. If ``num_processes`` is given and > 0, we fork that specific number of sub-processes. Since we use processes and not threads, there is no shared memory between any server code. Note that multiple processes are not compatible with the autoreload module (or the ``autoreload=True`` option to `tornado.web.Application` which defaults to True when ``debug=True``). When using multiple processes, no IOLoops can be created or referenced until after the call to ``fork_processes``. In each child process, ``fork_processes`` returns its *task id*, a number between 0 and ``num_processes``. Processes that exit abnormally (due to a signal or non-zero exit status) are restarted with the same id (up to ``max_restarts`` times). In the parent process, ``fork_processes`` returns None if all child processes have exited normally, but will otherwise only exit by throwing an exception. max_restarts defaults to 100. N�d r zStarting %d processes)�ir c s. t �� }|dkr t� | a| S | � |< d S d S �Nr )r �forkr' �_task_id)r0 �pid��childrenr r � start_child� s z#fork_processes.<locals>.start_childz1child %d (pid %d) killed by signal %d, restartingz3child %d (pid %d) exited with status %d, restartingz!child %d (pid %d) exited normallyr z"Too many child restarts, giving up)r3 r r �infor" r �ranger �wait�OSErrorr �errnoZEINTR�pop� WIFSIGNALED�warning�WTERMSIG� WEXITSTATUS� RuntimeErrorr �exit) r- r. r7 r0 �idZ num_restartsr4 �status�eZnew_idr r5 r �fork_processes\ s\ �� rG c C s t S )zpReturns the current task id, if any. Returns None if this process was not created by `fork_processes`. )r3 r r r r �task_id� s rH c @ s� e Zd ZdZe� ZdZi ZdZe e dd�dd�Z e e gdf dd�dd �Z d ed d �d d�Zedd�dd��Zedd�dd��Zedd�dd��Zee dd�dd��Ze dd�dd�ZdS ) � Subprocessa Wraps ``subprocess.Popen`` with IOStream support. The constructor is the same as ``subprocess.Popen`` with the following additions: * ``stdin``, ``stdout``, and ``stderr`` may have the value ``tornado.process.Subprocess.STREAM``, which will make the corresponding attribute of the resulting Subprocess a `.PipeIOStream`. If this option is used, the caller is responsible for closing the streams when done with them. The ``Subprocess.STREAM`` option and the ``set_exit_callback`` and ``wait_for_exit`` methods do not work on Windows. There is therefore no reason to use this class instead of ``subprocess.Popen`` on that platform. .. versionchanged:: 5.0 The ``io_loop`` argument (deprecated since version 4.1) has been removed. FN)�args�kwargsr c O sx t j�� | _g }g }|�d�tju rXt� \}}||d< |�||f� |� |� t |�| _ |�d�tju r�t� \}}||d< |�||f� |� |� t |�| _ |�d�tju r�t� \} } | |d< |�| | f� |� | � t | �| _ ztj|i |��| _W n$ |D ]} t�| � �q� Y n0 |D ]} t�| � �q | jj| _dD ]&} t| | ��s@t| | t| j| �� �q@d | _d | _d S )N�stdin�stdout�stderr)rL rM rN )r �IOLoop�current�io_loop�getrI �STREAMr, �extend�appendr rL rM rN � subprocess�Popen�procr �closer4 �hasattr�setattr�getattr�_exit_callback� returncode) �selfrJ rK Zpipe_fds�to_closeZin_rZin_wZout_rZout_wZerr_rZerr_w�fd�attrr r r �__init__� sF zSubprocess.__init__)�callbackr c C s* || _ t�� | tj| j< t�| j� dS )a� Runs ``callback`` when this process exits. The callback takes one argument, the return code of the process. This method uses a ``SIGCHLD`` handler, which is a global setting and may conflict if you have other libraries trying to handle the same signal. If you are using more than one ``IOLoop`` it may be necessary to call `Subprocess.initialize` first to designate one ``IOLoop`` to run the signal handlers. In many cases a close callback on the stdout or stderr streams can be used as an alternative to an exit callback if the signal handler is causing a problem. N)r] rI � initialize�_waitingr4 �_try_cleanup_process)r_ rd r r r �set_exit_callback s z Subprocess.set_exit_callbackTz Future[int])� raise_errorr c s* t � � tdd�� �fdd� }| �|� � S )a Returns a `.Future` which resolves when the process exits. Usage:: ret = yield proc.wait_for_exit() This is a coroutine-friendly alternative to `set_exit_callback` (and a replacement for the blocking `subprocess.Popen.wait`). By default, raises `subprocess.CalledProcessError` if the process has a non-zero exit status. Use ``wait_for_exit(raise_error=False)`` to suppress this behavior and return the exit status without raising. .. versionadded:: 4.2 N)�retr c s, | dkr �r t � t| d�� n t� | � d S )Nr �unknown)r �CalledProcessErrorr )rj ��futureri r r rd , s �z*Subprocess.wait_for_exit.<locals>.callback)r r" rh )r_ ri rd r rm r � wait_for_exit s zSubprocess.wait_for_exitr c s8 � j r dS tj�� �t�tj� �fdd��� _d� _ dS )a� Initializes the ``SIGCHLD`` handler. The signal handler is run on an `.IOLoop` to avoid locking issues. Note that the `.IOLoop` used for signal handling need not be the same one used by individual Subprocess objects (as long as the ``IOLoops`` are each running in separate threads). .. versionchanged:: 5.0 The ``io_loop`` argument (deprecated since version 4.1) has been removed. Nc s �� � j�S r( )�add_callback_from_signal�_cleanup)�sig�frame��clsrQ r r �<lambda>J � z'Subprocess.initialize.<locals>.<lambda>T)� _initializedr rO rP �signal�SIGCHLD� _old_sigchld�ru r rt r re 8 s �zSubprocess.initializec C s$ | j s dS t�tj| j� d| _ dS )z Removes the ``SIGCHLD`` handler.NF)rx ry rz r{ r| r r r � uninitializeN s zSubprocess.uninitializec C s" t | j�� �D ]}| �|� qd S r( )�listrf �keysrg )ru r4 r r r rq V s zSubprocess._cleanup)r4 r c C s� zt �|t j�\}}W n@ tyV } z(t|�tjkrBW Y d }~d S W Y d }~n d }~0 0 |dkrdd S ||kspJ �| j�|�}|j � |j |� d S r1 ) r �waitpid�WNOHANGr; r r< ZECHILDrf r= rQ rp �_set_returncode)ru r4 Zret_pidrE rF Zsubprocr r r rg [ s $ z Subprocess._try_cleanup_process)rE r c C s^ t �|�rt �|� | _nt �|�s(J �t �|�| _| j| j_| jrZ| j}d | _|| j� d S r( )r r> r@ r^ � WIFEXITEDrA rX r] )r_ rE rd r r r r� h s zSubprocess._set_returncode)T)�__name__� __module__� __qualname__�__doc__�objectrS rx rf r{ r rc r r" rh �boolro � classmethodre r} rq rg r� r r r r rI � s" ' rI )N))r� r< r r ry rV r r$ �binasciir Ztornado.concurrentr r r �tornador Ztornado.iostreamr Z tornado.logr Ztornado.platform.autor Z tornado.utilr �typingr r r r � TYPE_CHECKINGr rl r" r r' r, r3 rG rH r� rI r r r r �<module> s4 ^
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка