| Server IP : 198.38.94.13 / Your IP : 216.73.217.33 Web Server : Apache System : Linux d4744.dxb1.stableserver.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64 User : revivere ( 1140) PHP Version : 8.2.33 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /opt/saltstack/salt/lib/python3.10/site-packages/tornado/__pycache__/ |
Upload File : |
o
;j�1 � @ s d Z ddlZddlZddlZddlZddlZddlZddlZddlm Z ddl
m Z m Z m
Z
ddlmZ ddlmZ ddlmZ ddlZddlmZmZmZ ejrWdd lmZ ejZd
efd d �Z dd
d�Z da ddee dee d
efdd�Z d
ee fdd�Z G dd� d�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)�Optional�Any�Callable)�List�returnc C s\ t du rdS zt �� W S ty Y nw zt�d�W S ttfy& Y nw 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 �C/opt/saltstack/salt/lib/python3.10/site-packages/tornado/process.pyr 1 s
� �
r c C sh dt jvrd S dd l} z ttt�d��d�}W n ty, tt�� d �t� � A }Y nw | �
|� d S )N�randomr � i� ) �sys�modulesr �intr r �urandomr �time�getpid�seed)r r" r r r �_reseed_randomA s
�r# �
num_processes� max_restartsc sN t jdkr td��|du rd}tdu sJ �| du s | dkr t� } t�d| � i � dtdtt f� fd d
� }t | �D ]}||�}|durG| S q9d}� r�t
� � \}}|� vrWqJ� � |�}t
�
|�rmt�d ||t
�|�� nt
�|�dkr�t�d ||t
�|�� nt�d
||� qJ|d7 }||kr�td��||�}|dur�|S � sLt �d� dS )aq 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`` calls ``sys.exit(0)`` after all child
processes have exited normally.
max_restarts defaults to 100.
Availability: Unix
�win32z fork not available on windowsN�d r zStarting %d processes�ir
c s* t �� }|dkrt� | a| S | � |< d S �Nr )r �forkr# �_task_id)r( �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)r �platform� Exceptionr+ r r �infor r �ranger �wait�pop� WIFSIGNALED�warning�WTERMSIG� WEXITSTATUS� RuntimeError�exit) r$ r% r/ r( �idZ num_restartsr, �statusZnew_idr r- r �fork_processesS sZ
�
��� r> c C s t S )zpReturns the current task id, if any.
Returns None if this process was not created by `fork_processes`.
)r+ r r r r �task_id� s r? c @ s� e Zd ZdZe� ZdZi Zdededdfdd�Z d e
e gdf ddfd
d �Z d d
e
ddfdd�Zed dd��Zed dd��Zed dd��Zede ddfdd��Zde ddfdd �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.
F�args�kwargsr
Nc
O sp t j�� | _g }g }|�d�tju r-t�� \}}||d< |� ||f� |�
|� t |�| _ |�d�tju rPt�� \}}||d< |� ||f� |�
|� t |�| _
|�d�tju rst�� \} }
|
|d< |� | |
f� |�
|
� t | �| _z tj|i |��| _W n |D ]} t�| � q�� |D ]} t�| � q�| jj| _dD ]} t| | �s�t| | t| j| �� q�d | _d | _d S )N�stdin�stdout�stderr)rC rD rE )r ZIOLoop�current�io_loop�getr@ �STREAMr �pipe�extend�appendr rC rD rE �
subprocess�Popen�proc�closer, �hasattr�setattr�getattr�_exit_callback�
returncode)
�selfrA rB Zpipe_fds�to_closeZin_rZin_wZout_rZout_wZerr_rZerr_w�fd�attrr r r �__init__� sH
�
zSubprocess.__init__�callbackc 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.
Availability: Unix
N)rT r@ �
initialize�_waitingr, �_try_cleanup_process)rV r[ r r r �set_exit_callback� s z Subprocess.set_exit_callbackT� raise_errorz Future[int]c s, t � � dtddf� �fdd� }| �|� � S )a2 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
Availability: Unix
�retr
Nc s. | dkr�rt � t| d�� d S t� | � d S )Nr �unknown)r �CalledProcessErrorr )ra �Zfuturer` r r r[ ( s
�z*Subprocess.wait_for_exit.<locals>.callback)r r r_ )rV r` r[ r rd r �
wait_for_exit s
zSubprocess.wait_for_exitc C s, | j rdS t�� }|�tj| j� 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.
Availability: Unix
NT)� _initialized�asyncio�get_event_loopZadd_signal_handler�signal�SIGCHLD�_cleanup��clsZloopr r r r\ 4 s
zSubprocess.initializec C s( | j sdS t�� }|�tj� d| _ dS )z Removes the ``SIGCHLD`` handler.NF)rf rg rh Zremove_signal_handlerri rj rl r r r � uninitializeI s
zSubprocess.uninitializec C s" t | j�� �D ]}| �|� qd S �N)�listr] �keysr^ )rm r, r r r rk R s �zSubprocess._cleanupr, c C sd z t �|t j�\}}W n
ty Y d S w |dkr d S ||ks"J �| j�|�}|j�|j|� d S r) ) r �waitpid�WNOHANG�ChildProcessErrorr] r5 rG Z add_callback�_set_returncode)rm r, Zret_pidr= Zsubprocr r r r^ W s � z Subprocess._try_cleanup_processr= c C st t jdkr d| _nt�|�rt�|� | _n
t�|�s J �t�|�| _| j| j_| j r8| j }d | _ || j� d S d S )Nr& ���)
r r0 rU r r6 r8 � WIFEXITEDr9 rO rT )rV r= r[ r r r ru c s
�zSubprocess._set_returncode)T�r
N)�__name__�
__module__� __qualname__�__doc__�objectrI rf r] r
rZ r r r_ �boolre � classmethodr\ rn rk r^ ru r r r r r@ � s" ' r@ rx ro )"r| rg r r ri rM r r �binasciir Ztornado.concurrentr r r Ztornador Ztornado.iostreamr Z tornado.logr �typingr r
r �
TYPE_CHECKINGr rc r r r# r+ r> r? r@ r r r r �<module> s>
���
�`