403Webshell
Server IP : 54.37.205.81  /  Your IP : 216.73.216.76
Web Server : nginx/1.22.1
System : Linux vps-249481fa 6.1.0-50-cloud-amd64 #1 SMP PREEMPT_DYNAMIC Debian 6.1.176-1 (2026-07-02) x86_64
User : debian ( 1000)
PHP Version : 8.2.32
Disable Function : NONE
MySQL : OFF  |  cURL : ON  |  WGET : ON  |  Perl : ON  |  Python : OFF  |  Sudo : ON  |  Pkexec : OFF
Directory :  /lib/python3/dist-packages/tornado/test/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Command :


[ Back ]     

Current File : /lib/python3/dist-packages/tornado/test/__pycache__/process_test.cpython-311.pyc
�

��b,,��0�ddlZddlZddlZddlZddlZddlZddlZddlZddlm	Z	m
Z
ddlmZddl
mZddlmZddlmZmZmZddlmZddlmZmZmZmZdd	lmZdd
lmZm Z eGd�dej!����Z"eGd
�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�*��eZdZd�Z�fd�Zd�Z�xZS)�ProcessTestc�L�Gd�dt��}td|fg��S)Nc��eZdZd�ZdS)�+ProcessTest.get_app.<locals>.ProcessHandlerc��|�dd��r4tjt|�d������|�dd��rFtjtj��t|�d������|�ttj������dS)N�exit�signal)�get_argument�os�_exit�int�kill�getpid�write�str)�selfs �;/usr/lib/python3/dist-packages/tornado/test/process_test.py�getz/ProcessTest.get_app.<locals>.ProcessHandler.gets����$�$�V�T�2�2�=��H�S��!2�!2�6�!:�!:�;�;�<�<�<��$�$�X�t�4�4�K��G�B�I�K�K��T�->�->�x�-H�-H�)I�)I�J�J�J��
�
�3�r�y�{�{�+�+�,�,�,�,�,�N)�__name__�
__module__�__qualname__r&�r'r%�ProcessHandlerrs#������
-�
-�
-�
-�
-r'r,�/r)r$r,s  r%�get_appzProcessTest.get_appsD��	-�	-�	-�	-�	-�^�	-�	-�	-��S�.�1�2�3�3�3r'c���t���;tjd��tj��t	jd��t
jd��t���	��dS)Nz$aborting child process from tearDown�r)
r	�logging�error�shutdownrrr�alarm�super�tearDown)r$�	__class__s �r%r6zProcessTest.tearDown%se����9�9� �
�M�@�A�A�A�������H�Q�K�K�K���Q����
���������r'c�>����	�
�ttd��5t��\�
�	�	fd��tjd��	tdd���}��|du��tjd��nu#t$rh}��|j	d����t��du���
���Yd}~ddd��dSd}~wwxYw	|dvrF��|t������
fd�}tj
|�����n|d	k�r��|t�����
���tt���d��fd�	}|dd
���|dd
���t!|d��j��|dd
���t!|d��j��}|dd
���t!|d��j��}��||��|dd
���t'jd��n&#t*$rt-jd|d
����wxYwddd��dS#1swxYwYdS)Nz:(Starting .* processes|child .* exited|uncaught exception)c���d�|fzS)Nzhttp://127.0.0.1:%d%sr+)�path�ports �r%�get_urlz/ProcessTest.test_multi_process.<locals>.get_url>s���.�$���=�=r'��)�max_restartsr)rr0c����K�t������}|��g��tj������d{V��dS�N)rr.�add_sockets�asyncio�Event�wait)�serverr$�socks ��r%�fz)ProcessTest.test_multi_process.<locals>.fRsb�����!+�D�L�L�N�N�!;�!;���*�*�D�6�2�2�2�%�m�o�o�2�2�4�4�4�4�4�4�4�4�4�4�4r'�Fc���	���|����S#t$r}|r|jdks�Yd}~dSd}~wwxYw)NiW)�fetchr�code)�url�fail_ok�e�clientr<s   ��r%rKz-ProcessTest.test_multi_process.<locals>.fetchase���&�#)�<�<������#=�#=�=��(�&�&�&�$+�&���#�
�
� %�1>�
�
�
�
�
�����&���s�!�
A�?�Az/?exit=2T)rNz/?exit=3r-z/?exit=0z/?exit=4zexception in child process %d)�exc_info)F)r
rrrr4r�
assertTrue�
SystemExit�assertEqualrLr	�closerC�runrrr�body�assertNotEqualrr�	Exceptionr1r2)r$�idrOrHrK�pid�pid2rPr<r;rGs`      @@@@r%�test_multi_processzProcessTest.test_multi_process4s|�������
��Q�
�
�L	�L	�*�+�+�J�D�$�
>�
>�
>�
>�
>�
�L��O�O�O�

�#�A�A�6�6�6������$��/�/�/���Q�������
�
�
�� � ����+�+�+�����	�	�T� 1�2�2�2��
�
��������)L	�L	�L	�L	�L	�L	�L	�L	�����
����7
���<�<��$�$�R����3�3�3�5�5�5�5�5�5�
�K�����$�$�$�$��1�W�W��$�$�R����3�3�3��J�J�L�L�L�
(�(=�>�>�F�&�&�&�&�&�&�&��E�*�d�3�3�3�3��E�*�d�3�3�3�3����c�
�
��(�(�(��E�*�d�3�3�3�3��e�e�C�j�j�o�.�.�C��E�*�d�3�3�3�3��u�u�S�z�z��/�/�D��'�'��T�2�2�2��E�*�d�3�3�3�3��H�Q�K�K�K����
�
�
��
�=�r�D�Q�Q�Q�Q��
����UL	�L	�L	�L	�L	�L	�L	�L	�L	�L	�L	�L	����L	�L	�L	�L	�L	�L	sU�+J�<B�J�
C6�AC1� J�1C6�6J�:E$I�J�#J�J�J�J)r(r)r*r.r6r]�
__classcell__)r7s@r%rrs]�������4�4�4�
�
�
�
�
�Q�Q�Q�Q�Q�Q�Qr'rc��eZdZd�Zed���Zed���Zed���Zd�Zed���Z	d�Z
ed���Zed	���Zd
S)�SubprocessTestc�j�|j���|j���dSrA)�proc�	terminaterE�r$�subprocs  r%�
term_and_waitzSubprocessTest.term_and_wait�s0������ � � ���������r'c#�T��K�tj��j�d��rt	jd���t
tjddgtj	tj	tj��������fd������j
j�����jj���j
�d��V��j�d���j
�d	��V�}��|d
���j
�d��V��j�d���j
���V�}��|d��dS)
N�LayeredTwistedIOLoopz9Subprocess tests not compatible with LayeredTwistedIOLoop�-u�-i��stdin�stdout�stderrc�.�������SrA�rfrds��r%�<lambda>z0SubprocessTest.test_subprocess.<locals>.<lambda>������ 2� 2�7� ;� ;�r'�>>> sprint('hello')
�
�hello
sraise SystemExit
r')r�configured_classr(�endswith�unittest�SkipTestr
�sys�
executable�STREAM�
subprocess�STDOUT�
addCleanuprmrUrl�
read_untilr"rT�read_until_close�r$�datares` @r%�test_subprocesszSubprocessTest.test_subprocess�s��������"�$�$�-�6�6�7M�N�N�	��#�N���
��
�^�T�4�(��#��$��$�	
�
�
��	
���;�;�;�;�;�<�<�<������,�-�-�-�����
�+�,�,�,��n�'�'��0�0�0�0�0��
���/�0�0�0��^�.�.�u�5�5�5�5������z�*�*�*��n�'�'��0�0�0�0�0��
���1�2�2�2��^�4�4�6�6�6�6������s�#�#�#�#�#r'c#���K�ttjddgtjtjtj��������fd����j�d��V��j	�
���j���V�}��|d��dS)Nrirjrkc�.�������SrArprds��r%rqz1SubprocessTest.test_close_stdin.<locals>.<lambda>�rrr'rsrt)
r
rzr{r|r}r~rrmr�rlrUr�rTr�s` @r%�test_close_stdinzSubprocessTest.test_close_stdin�s��������
�^�T�4�(��#��$��$�	
�
�
��	
���;�;�;�;�;�<�<�<��n�'�'��0�0�0�0�0��
�������^�4�4�6�6�6�6������u�%�%�%�%�%r'c#�(��K�ttjdddgtj��������fd����j�d��V�}��|d���j���dS)Nri�-cz'import sys; sys.stderr.write('hello\n'))rnc�.�������SrArprds��r%rqz,SubprocessTest.test_stderr.<locals>.<lambda>�rrr'rtru)	r
rzr{r|rrnr�rTrUr�s` @r%�test_stderrzSubprocessTest.test_stderr�s��������
�^�T�4�)S�T��$�
�
�
��	
���;�;�;�;�;�<�<�<��^�.�.�u�5�5�5�5������z�*�*�*���������r'c�`�tj��|�tj��ttjddg��}|�|j��|���}|�	|d��|�	|j
|��dS�Nr��passr)r
�
initializer�uninitializerzr{�set_exit_callback�stoprErT�
returncode�r$re�rets   r%�
test_sigchildzSubprocessTest.test_sigchild�s�����������
�/�0�0�0��c�n�d�F�;�<�<���!�!�$�)�,�,�,��i�i�k�k������a� � � �����+�S�1�1�1�1�1r'c#�4K�tj��|�tj��ttjddg��}|���V�}|�|d��|�|j|��dSr�)	r
r�rr�rzr{�
wait_for_exitrTr�r�s   r%�test_sigchild_futurez#SubprocessTest.test_sigchild_future�s�������������
�/�0�0�0��c�n�d�F�;�<�<���)�)�+�+�+�+������a� � � �����+�S�1�1�1�1�1r'c�B��tj����tj��ttjddgtj���}��|jj��|�	�j
��tjd��tj|jt j��	����}n�#t&$rs|j���}|��fd���	����t'd���#t&$rt'd���wxYwwxYw��|j|����|t j��dS)Nr�zimport time; time.sleep(30))rmg�������?c�,������SrA)r�)rHr$s �r%rqz5SubprocessTest.test_sigchild_signal.<locals>.<lambda>�s���D�I�I�K�K�r'z=subprocess closed stdout but failed to get termination signalzsubprocess failed to terminate)r
r�rr�rzr{r|rmrUr�r��time�sleeprr r[r�SIGTERMrE�AssertionErrorr��add_done_callbackrTr�)r$rer��futs`   r%�test_sigchild_signalz#SubprocessTest.test_sigchild_signal�s������������
�/�0�0�0��
�^�T�#@�A��$�
�
�
��	
�����,�-�-�-��!�!�$�)�,�,�,�	
�
�3����
����V�^�,�,�,�	��)�)�+�+�C�C���	�	�	��.�1�1�3�3�C��!�!�"7�"7�"7�"7�8�8�8�
��	�	����%�V�����"�
G�
G�
G�$�%E�F�F�F�
G����	����"	
����+�S�1�1�1�����v�~�o�.�.�.�.�.s$�C#�#;E �E�3E �E�E c#�K�tj��|�tj��ttjddg��}|�tj��5}|�	��V�ddd��n#1swxYwY|�
|jjd��dS)Nr��import sys; sys.exit(1)r0)
r
r�rr�rzr{�assertRaisesr}�CalledProcessErrorr�rT�	exceptionr�)r$re�cms   r%�test_wait_for_exit_raisez'SubprocessTest.test_wait_for_exit_raises�������������
�/�0�0�0��c�n�d�4M�N�O�O��
�
�
�z�<�
=�
=�	*���'�'�)�)�)�)�)�	*�	*�	*�	*�	*�	*�	*�	*�	*�	*�	*����	*�	*�	*�	*������0�!�4�4�4�4�4s�0B�B�Bc#�K�tj��|�tj��ttjddg��}|�d���V�}|�|d��dS)Nr�r�F)�raise_errorr0)r
r�rr�rzr{r�rTr�s   r%�!test_wait_for_exit_raise_disabledz0SubprocessTest.test_wait_for_exit_raise_disabledsy������������
�/�0�0�0��c�n�d�4M�N�O�O���)�)�e�)�<�<�<�<������a� � � � � r'N)
r(r)r*rfrr�r�r�r�r�r�r�r�r+r'r%r`r`�s�����������$�$��X�$�:�&�&��X�&�����X��2�2�2��2�2��X�2�&/�&/�&/�P�5�5��X�5��!�!��X�!�!�!r'r`)$rCr1rrr}rzr�rx�tornado.httpclientrr�tornado.httpserverr�tornado.ioloopr�tornado.logr�tornado.processrr	r
�tornado.simple_httpclientr�tornado.testingrr
rr�tornado.test.utilr�tornado.webrr�TestCaserr`r+r'r%�<module>r�s�����������	�	�	�	�
�
�
�
�����
�
�
�
���������4�4�4�4�4�4�4�4�)�)�)�)�)�)�!�!�!�!�!�!�������?�?�?�?�?�?�?�?�?�?�;�;�;�;�;�;�P�P�P�P�P�P�P�P�P�P�P�P�+�+�+�+�+�+�3�3�3�3�3�3�3�3��n�n�n�n�n�(�#�n�n���n�b�I!�I!�I!�I!�I!�]�I!�I!���I!�I!�I!r'

Youez - 2016 - github.com/yon3zu
LinuXploit