Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/tornado/test/__pycache__/process_test.cpython-39.pyc
Ðазад
a _�h�, � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZm Z d dl m Z d dl m Z d dlmZ d dlmZmZmZ d dlmZ d dlmZmZmZmZ d d lm Z d d l m Z m Z e G d d � d ej ��Z!e G d d� de��Z"dS )� N)� HTTPClient� HTTPError)� HTTPServer)�IOLoop)�gen_log)�fork_processes�task_id� Subprocess)�SimpleAsyncHTTPClient)�bind_unused_port� ExpectLog� AsyncTestCase�gen_test)� skipIfNonUnix��RequestHandler� Applicationc s, e Zd Zdd� Z� fdd�Zdd� Z� ZS )� ProcessTestc C s G dd� dt �}td|fg�S )Nc @ s e Zd Zdd� ZdS )z+ProcessTest.get_app.<locals>.ProcessHandlerc S s\ | � dd �r t�t| � d��� | � dd �rFt�t�� t| � d��� | �tt�� �� d S )N�exit�signal)Z get_argument�os�_exit�int�kill�getpid�write�str��self� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/tornado/test/process_test.py�get s z/ProcessTest.get_app.<locals>.ProcessHandler.getN)�__name__� __module__� __qualname__r! r r r r �ProcessHandler s r% �/r )r r% r r r �get_app s zProcessTest.get_appc sB t � d ur&t�d� t�� t�d� t�d� tt | �� � d S )Nz$aborting child process from tearDown� r ) r �logging�error�shutdownr r r �alarm�superr �tearDownr �� __class__r r r. $ s zProcessTest.tearDownc s t td���� t� \}��fdd��t�d� z(tddd�}| �|d u� t�d� W nX ty� } z@| �|j d� | �t � d u � |� � W Y d }~W d � d S d }~0 0 �z t d ur�t � t �� � |dv �r| �|t � � t| �� �}|�|g� t�� �� n�|d k�r�| �|t � � |� � tt�� d� �fd d � }|d dd� |ddd� t|d�j� |ddd� t|d�j�}|ddd� t|d�j�}| �||� |ddd� t�d� W n& t �y� t j d|dd� � Y n0 W d � n1 �s�0 Y d S )Nz:(Starting .* processes|child .* exited|uncaught exception)c s d� | f S )Nzhttp://127.0.0.1:%d%sr )�path)�portr r �get_url= s z/ProcessTest.test_multi_process.<locals>.get_url� � )Z max_restartsr )r r( � Fc sJ z� � �| ��W S tyD } z |r.|jdks0� W Y d }~n d }~0 0 d S )NiW )�fetchr �code)�url�fail_ok�e)�clientr3 r r r7 ` s z-ProcessTest.test_multi_process.<locals>.fetchz/?exit=2T)r: z/?exit=3r& z/?exit=0z/?exit=4z exception in child process %d)�exc_info)F) r r r r r, r Z assertTrue� SystemExit� assertEqualr8 r �close�asyncioZset_event_loopZnew_event_loopr r' Z add_socketsr �current�startr r r �bodyZassertNotEqualr r � Exceptionr) r* )r �sock�idr; �serverr7 �pidZpid2r )r< r3 r2 r �test_multi_process3 sR � $ z ProcessTest.test_multi_process)r" r# r$ r' r. rJ � __classcell__r r r/ r r s r c @ sl e Zd Zdd� Zedd� �Zedd� �Zedd� �Zd d � Zed d � �Z d d� Z edd� �Z edd� �Z dS )�SubprocessTestc C s |j �� |j �� d S �N)�proc� terminate�wait�r �subprocr r r � term_and_wait� s z SubprocessTest.term_and_waitc # s� t �� j�d�rt�d��ttjddgtj tj t j d��� � � �fdd�� � � �j j� � � �jj� �j �d�V �j�d � �j �d �V }� �|d � �j �d�V �j�d � �j �� V }� �|d � d S )NZLayeredTwistedIOLoopz9Subprocess tests not compatible with LayeredTwistedIOLoop�-u�-i��stdin�stdout�stderrc s � � ��S rM �rS r rQ r r �<lambda>� � z0SubprocessTest.test_subprocess.<locals>.<lambda>� >>> s print('hello') � � hello s raise SystemExit r\ )r Zconfigured_classr" �endswith�unittestZSkipTestr �sys� executable�STREAM� subprocess�STDOUT� addCleanuprX r@ rW � read_untilr r? �read_until_close�r �datar rQ r �test_subprocess� s* � � z SubprocessTest.test_subprocessc # sf t tjddgt jt jtjd��� �� �fdd�� �j�d�V �j � � �j� � V }� � |d� d S )NrT rU rV c s � � ��S rM rZ r rQ r r r[ � r\ z1SubprocessTest.test_close_stdin.<locals>.<lambda>r] r^ ) r rb rc rd re rf rg rX rh rW r@ ri r? rj r rQ r �test_close_stdin� s � z SubprocessTest.test_close_stdinc # sT t tjdddgt jd��� �� �fdd�� �j�d�V }� �|d� �j�� d S ) NrT �-cz'import sys; sys.stderr.write('hello\n'))rY c s � � ��S rM rZ r rQ r r r[ � r\ z,SubprocessTest.test_stderr.<locals>.<lambda>r^ r_ ) r rb rc rd rg rY rh r? r@ rj r rQ r � test_stderr� s � zSubprocessTest.test_stderrc C sV t �� | �t j� t tjddg�}|�| j� | �� }| � |d� | � |j |� d S �Nrn �passr ) r � initializerg � uninitializerb rc �set_exit_callback�stoprP r? � returncode�r rR �retr r r � test_sigchild� s z SubprocessTest.test_sigchildc c sL t �� | �t j� t tjddg�}|�� V }| �|d� | �|j|� d S rp ) r rr rg rs rb rc � wait_for_exitr? rv rw r r r �test_sigchild_future� s z#SubprocessTest.test_sigchild_futurec s� t �� � �t j� t tjddgt jd�}� �|jj� |� � j � t � |j tj� z� jdd�}W nb ty� |j�� }|�� fdd�� z� jdd� W n ty� td��Y n 0 td ��Y n0 � �|j|� � �|tj � d S ) Nrn zimport time; time.sleep(30))rX g �?)�timeoutc s � � � S rM )ru )�fr r r r[ � r\ z5SubprocessTest.test_sigchild_signal.<locals>.<lambda>z subprocess failed to terminatez=subprocess closed stdout but failed to get termination signal)r rr rg rs rb rc rd rX r@ rt ru r r rI r �SIGTERMrP �AssertionErrorri Zadd_done_callbackr? rv )r rR rx Zfutr r r �test_sigchild_signal� s. � � z#SubprocessTest.test_sigchild_signalc c sn t �� | �t j� t tjddg�}| �tj��}|� � V W d � n1 sP0 Y | � |j j d� d S )Nrn �import sys; sys.exit(1)r( ) r rr rg rs rb rc Z assertRaisesre �CalledProcessErrorrz r? � exceptionrv )r rR �cmr r r �test_wait_for_exit_raise� s (z'SubprocessTest.test_wait_for_exit_raisec c sB t �� | �t j� t tjddg�}|jdd�V }| �|d� d S )Nrn r� F)Z raise_errorr( )r rr rg rs rb rc rz r? rw r r r �!test_wait_for_exit_raise_disabled s z0SubprocessTest.test_wait_for_exit_raise_disabledN) r" r# r$ rS r rl rm ro ry r{ r� r� r� r r r r rL � s rL )#rA r) r r re rb ra Ztornado.httpclientr r Ztornado.httpserverr Ztornado.ioloopr Z tornado.logr Ztornado.processr r r Ztornado.simple_httpclientr Ztornado.testingr r r r Ztornado.test.utilr Z tornado.webr r ZTestCaser rL r r r r �<module> s& q
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка