File manager - Edit - /usr/local/CyberCP/lib/python3.10/site-packages/tornado/__pycache__/process.cpython-310.pyc
Back
o �h�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� 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)�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 �B/usr/local/CyberCP/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( �id� num_restartsr, �status�new_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 rA 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)rE rF rG )r �IOLoop�current�io_loop�getrB �STREAMr �pipe�extend�appendr rE rF rG � subprocess�Popen�proc�closer, �hasattr�setattr�getattr�_exit_callback� returncode) �selfrC rD �pipe_fds�to_close�in_r�in_w�out_r�out_w�err_r�err_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)rW rB � initialize�_waitingr, �_try_cleanup_process)rY re 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 )rk ��futurerj r r re ( s �z*Subprocess.wait_for_exit.<locals>.callback)r r ri )rY rj re r rn 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_loop�add_signal_handler�signal�SIGCHLD�_cleanup��cls�loopr r r rf 4 s zSubprocess.initializec C s( | j sdS t�� }|�tj� d| _ dS )z Removes the ``SIGCHLD`` handler.NF)rq rr rs �remove_signal_handlerru rv rx r r r � uninitializeI s zSubprocess.uninitializec C s" t | j�� �D ]}| �|� qd S �N)�listrg �keysrh )ry r, r r r rw 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�ChildProcessErrorrg r5 rJ � add_callback�_set_returncode)ry r, �ret_pidr> �subprocr r r rh 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 rX r r6 r8 � WIFEXITEDr9 rR rW )rY r> re r r r r� c s �zSubprocess._set_returncode)T�r N)�__name__� __module__� __qualname__�__doc__�objectrL rq rg r rd r r ri �boolrp � classmethodrf r| rw rh r� r r r r rB � s" ' rB r� r} )#r� rr r r ru rP r r �binasciir �tornado.concurrentr r r �tornador �tornado.iostreamr � tornado.logr �typingr r r � TYPE_CHECKINGr rm r r r# r+ r@ rA r� rB r r r r �<module> s> ��� �`
| ver. 1.4 |
Github
|
.
| PHP 8.2.28 | Generation time: 0.02 |
proxy
|
phpinfo
|
Settings