golden hour
/opt/saltstack/salt/lib/python3.10/site-packages/salt/ext/tornado/__pycache__
⬆️ Go Up
Upload
File/Folder
Size
Actions
__init__.cpython-310.pyc
378 B
Del
OK
_locale_data.cpython-310.pyc
3.23 KB
Del
OK
auth.cpython-310.pyc
39.18 KB
Del
OK
autoreload.cpython-310.pyc
7.02 KB
Del
OK
concurrent.cpython-310.pyc
17.24 KB
Del
OK
curl_httpclient.cpython-310.pyc
12.8 KB
Del
OK
escape.cpython-310.pyc
9.89 KB
Del
OK
gen.cpython-310.pyc
38.39 KB
Del
OK
http1connection.cpython-310.pyc
19.47 KB
Del
OK
httpclient.cpython-310.pyc
25.19 KB
Del
OK
httpserver.cpython-310.pyc
11.45 KB
Del
OK
httputil.cpython-310.pyc
29.84 KB
Del
OK
ioloop.cpython-310.pyc
33.19 KB
Del
OK
iostream.cpython-310.pyc
42.97 KB
Del
OK
locale.cpython-310.pyc
15.22 KB
Del
OK
locks.cpython-310.pyc
16.61 KB
Del
OK
log.cpython-310.pyc
8.07 KB
Del
OK
netutil.cpython-310.pyc
14.32 KB
Del
OK
options.cpython-310.pyc
19.63 KB
Del
OK
process.cpython-310.pyc
10.27 KB
Del
OK
queues.cpython-310.pyc
11.29 KB
Del
OK
routing.cpython-310.pyc
21.08 KB
Del
OK
simple_httpclient.cpython-310.pyc
16.08 KB
Del
OK
stack_context.cpython-310.pyc
10.65 KB
Del
OK
tcpclient.cpython-310.pyc
6.49 KB
Del
OK
tcpserver.cpython-310.pyc
10.06 KB
Del
OK
template.cpython-310.pyc
30.52 KB
Del
OK
testing.cpython-310.pyc
24.61 KB
Del
OK
util.cpython-310.pyc
13.72 KB
Del
OK
web.cpython-310.pyc
105.22 KB
Del
OK
websocket.cpython-310.pyc
39.08 KB
Del
OK
wsgi.cpython-310.pyc
11.5 KB
Del
OK
Edit: process.cpython-310.pyc
o �xe-2 � @ sD d Z ddlmZmZmZ ddlZddlZddlZddlZddl Z ddl Z ddl m Z ddl mZ ddlmZ ddlmZ ddlmZ dd lmZ dd lmZ dd lmZmZ zddlZW n e yg dZY nw erle Z zej Z W n e y� d ej!vr~� Y nw d d� Z"dd� Z#dd� Z$da%ddd�Z&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. � )�absolute_import�division�print_functionN)�hexlify)�Future)�ioloop)� PipeIOStream)�gen_log)�set_close_exec)� stack_context)�errno_from_exception�PY3ZAPPENGINE_RUNTIMEc 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 �L/opt/saltstack/salt/lib/python3.10/site-packages/salt/ext/tornado/process.pyr = 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 �longr r �urandomr �int�time�getpid�seed)r r# r r r �_reseed_randomM s �r$ c C s$ t �� \} }t| � t|� | |fS �N)r �piper )�r�wr r r � _pipe_cloexec[ s r) �d c sn t du sJ �| du s| dkrt� } tj�� rtd��t�d| � i � � fdd�}t| �D ]}||�}|dur:| S q,d}� r�zt � � \}}W n t ya } zt |�t jkr\W Y d}~q=� d}~ww |� vrgq=� �|�}t �|�r}t�d||t �|�� nt �|�dkr�t�d||t �|�� nt�d ||� q=|d 7 }||kr�td ��||�} | dur�| S � s?t�d� dS ) ae 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. Nr z�Cannot run in multiple processes: IOLoop instance has already been initialized. You cannot call IOLoop.instance() before calling start_processes()zStarting %d processesc s* t �� }|dkrt� | a| S | � |< d S �Nr )r �forkr$ �_task_id)�i�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- r r �IOLoopZ initialized� RuntimeErrorr �info�ranger �wait�OSErrorr �errnoZEINTR�pop� WIFSIGNALED�warning�WTERMSIG� WEXITSTATUSr �exit) Z num_processesZ max_restartsr2 r. �idZ num_restartsr/ �status�eZnew_idr r0 r �fork_processese sX � �� � �� rC 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 rD c @ sr e Zd ZdZe� ZdZi Zdd� Zdd� Z ddd �Z e dd d ��Z e d d� �Z e dd� �Ze dd� �Zdd� Zd S )� 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`. * A new keyword argument ``io_loop`` may be used to pass in an IOLoop. 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:: 4.1 The ``io_loop`` argument is deprecated. Fc O s~ |� dd �p tj�� | _g }g }|�d�tju r5t� \}}||d< |� ||f� |� |� t || jd�| _ |�d�tju rZt� \}}||d< |� ||f� |� |� t || jd�| _ |�d�tju rt� \} } | |d< |� | | f� |� | � t | | jd�| _z tj|i |��| _W n |D ]} t�| � q�� |D ]} t�| � q�dD ]} t| | �s�t| | t| j| �� q�d | _d | _d S )N�io_loop�stdin)rF �stdout�stderr)rG rH rI r/ )r: r r3 �currentrF �getrE �STREAMr) �extend�appendr rG rH rI � subprocess�Popen�procr �close�hasattr�setattr�getattr�_exit_callback� returncode) �self�args�kwargsZpipe_fds�to_closeZin_rZin_wZout_rZout_wZerr_rZerr_w�fd�attrr r r �__init__� sF � zSubprocess.__init__c C s4 t �|�| _t�| j� | 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 �wraprV rE � initializerF �_waitingr/ �_try_cleanup_process)rX �callbackr r r �set_exit_callback s z Subprocess.set_exit_callbackTc s" t � � � �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 c s. | dkr�r� � t| d �� d S � �| � d S r+ )Z set_exception�CalledProcessErrorZ set_result)�ret�Zfuture� raise_errorr r rc ( s z*Subprocess.wait_for_exit.<locals>.callback)r rd )rX rh rc r rg r � wait_for_exit s zSubprocess.wait_for_exitNc s@ � j rdS �du rtj�� �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:: 4.1 The ``io_loop`` argument is deprecated. Nc s �� � j�S r% )�add_callback_from_signal�_cleanup)�sig�frame��clsrF r r �<lambda>C s z'Subprocess.initialize.<locals>.<lambda>T)� _initializedr r3 rJ �signal�SIGCHLD� _old_sigchldrn r rn r r` 1 s � zSubprocess.initializec C s$ | j sdS t�tj| j� d| _ dS )z Removes the ``SIGCHLD`` handler.NF)rq rr rs rt )ro r r r � uninitializeF s zSubprocess.uninitializec C s" t | j�� �D ]}| �|� qd S r% )�listra �keysrb )ro r/ r r r rk N s �zSubprocess._cleanupc C s� z t �|t j�\}}W n ty+ } zt|�tjkr!W Y d }~d S W Y d }~nd }~ww |dkr2d S ||ks8J �| j�|�}|j � |j |� d S r+ ) r �waitpid�WNOHANGr8 r r9 ZECHILDra r: rF rj �_set_returncode)ro r/ Zret_pidrA rB Zsubprocr r r rb S s ��� �z Subprocess._try_cleanup_processc C sb t �|�r t �|� | _n t �|�sJ �t �|�| _| j| j_| jr/| j}d | _|| j� d S d S r% )r r; r= rW � WIFEXITEDr> rQ rV )rX rA rc r r r rz a s �zSubprocess._set_returncode)Tr% )�__name__� __module__� __qualname__�__doc__�objectrL rq ra r^ rd ri � classmethodr` ru rk rb rz r r r r rE � s" & rE )r* )*r Z __future__r r r r9 r rr rO r r! �binasciir Zsalt.ext.tornado.concurrentr Zsalt.ext.tornador Zsalt.ext.tornado.iostreamr Zsalt.ext.tornado.logr Z salt.ext.tornado.platform.autor r Zsalt.ext.tornado.utilr r r � ImportErrorr r re r �environr r$ r) r- rC rD r� rE r r r r �<module> sJ � �� U
Save