Team Ai
Datasetpublic

codekingpro/portable-devtools

sourceHugging Faceupdated 5mo agoView on Hugging Face
1likes15kdownloads
process_test.cpython-313.pyc77 linesDownload Raw Back to __pycache__
1�

2��j�*���SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKJ	r	J3r4 SSKJr SSK
Jr SSKJrJrJr SSKJr SSKJrJrJrJr SSKJr SS	KJrJr \"S5S\R>55r \"SS
\55r!g)�N)�6HTTPClient�	HTTPError)�7HTTPServer)�gen_log)�fork_processes�task_id�8Subprocess)�SimpleAsyncHTTPClient)�bind_unused_port�	ExpectLog�
AsyncTestCase�gen_test)�
skipIfNonUnix��RequestHandler�Applicationc�4^�\rSrSrSrU4SjrSrSrU=r$)�ProcessTest�c�<�"SS[5n[SU4/5$)Nc��\rSrSrSrSrg)�+ProcessTest.get_app.<locals>.ProcessHandler�c��URSS5(a.[R"[URS555 URSS5(aB[R"[R9"5[URS555 UR
[[R10"555 g)N�exit�signal)�get_argument�os�_exit�int�kill�getpid�write�str)�selfs �_D:\code\apps\devtools\python\user_packages\Python313\site-packages\tornado/test/process_test.py�get�/ProcessTest.get_app.<locals>.ProcessHandler.gets����$�$�V�T�2�2��H�H�S��!2�!2�6�!:�;�<��$�$�X�t�4�4��G�G�B�I�I�K��T�->�->�x�-H�)I�J��11�12�3�r�y�y�{�+�,��N)�__name__�13__module__�__qualname__�__firstlineno__r'�__static_attributes__r*r)r&�ProcessHandlerrs��
-r)r0�/r)r%r0s  r&�get_app�ProcessTest.get_apps#��	-�^�	-��S�.�1�2�3�3r)c��>�[5bA[R"S5 [R"5 [R14"S5 [R"S5 [TU]%5 g)Nz$aborting child process from tearDown�r)15r�logging�error�shutdownrrr�alarm�super�tearDown)r%�	__class__s �r&r;�ProcessTest.tearDown$sG����9� �
�M�M�@�A������H�H�Q�K����Q��
���r)c�x^^^^	^16�[[S5 [5um17m	U	4Sjm[R"S5 [SSS9nTR
U5 [R"S5 US;a=TRU[55 UU184Sjn[R"U"55 O�US	:Xa�TRU[55 T19R5 [[ 5mSUU4S20jjnU"SSS
9 U"SSS
9 [#U"S5R$5 U"SSS
9 [#U"S5R$5nU"SSS
9 [#U"S5R$5nTR'XV5 U"SSS
9 [(R*"S5 SSS5 g![aWnTRURS5 TR[55 T21R5 SnASSS5 gSnAff=f![,a [.R0"SUSS9 ef=f!,(df   g=f)Nz:(Starting .* processes|child .* exited|uncaught exception)c�>�STU4-$)Nzhttp://127.0.0.1:%d%sr*)�path�ports �r&�get_url�/ProcessTest.test_multi_process.<locals>.get_url=s���.�$���=�=r)��)�max_restartsr)rr5c��># �[TR55nURT/5 [R"5R5IShv�N gN7f�N)rr2�add_sockets�asyncio�Event�wait)�serverr%�socks ��r&�f�)ProcessTest.test_multi_process.<locals>.fQs>����!+�D�L�L�N�!;���*�*�D�6�2�%�m�m�o�2�2�4�4�4�s�AA�A�A�c�>�TRT"U55$![a"nU(aURS:XdeSnAgSnAff=f)NiW)�fetchr�code)�url�fail_ok�e�clientrBs   ��r&rS�-ProcessTest.test_multi_process.<locals>.fetch`s@���&�#)�<�<����#=�=��(�&�$+����#�
� %�1>��&�s��22A�A�Az/?exit=2T)rVz/?exit=3r1z/?exit=0z/?exit=4zexception in child process %d)�exc_info)F)rrrrr9r�assertIsNotNone�23SystemExit�assertEqualrT�assertIsNoner�closerJ�runrr24r �body�assertNotEqualrr�	Exceptionr6r7)r%�idrWrOrS�pid�pid2rXrBrArNs`      @@@@r&�test_multi_process�ProcessTest.test_multi_process3s����25��Q�26�*�+�J�D�$�
>�
�L�L��O�27
�#�A�A�6���$�$�R�(����Q��7
���<��$�$�R���3�5�28�K�K���$��1�W��$�$�R���3��J�J�L�29(�(=�>�F�&�&��*�d�3��*�d�3���c�30���(��*�d�3��e�C�j�o�o�.�C��*�d�3��u�S�z���/�D��'�'��2��*�d�3��H�H�Q�K�S31�32���
�� � �����+��!�!�'�)�,��33�34���)35�36��
��x�
��
�
�=�r�D�Q��
��U37�38�sP�*H+�1F"�3AH�5H+�6C#H�"39H�,AG>�1H+�>H�H+�"H(�(H+�+40H9r*)	r+r,r-r.r2r;rgr/�
__classcell__)r<s@r&rrs���4�
�Q�Qr)rc��\rSrSrSr\S5r\S5r\S5rSr	\S5r41Sr\S	5r\S425r
Srg)
�SubprocessTest�c�l�URR5 URR5 grH)�proc�	terminaterL�r%�subprocs  r&�
term_and_wait�SubprocessTest.term_and_wait�s"������� ������r)c#��^^# �[[RSSS/[R[R[R43S9mTR
UU4Sj5 TR
TRR5 TR
TRR5 TRRS5v� TRRS5 TRRS5v�nTRUS	5 TRRS5v� TRRS445 TRR5v�nTRUS5 g7f)N�-u�-i�-I��stdin�stdout�stderrc�&>�TRT5$rH�rrrps��r&�<lambda>�0SubprocessTest.test_subprocess.<locals>.<lambda>������ 2� 2�7� ;r)�>>> sprint('hello')45�46�hello47sraise SystemExit48r))r	�sys�49executable�STREAM�50subprocess�STDOUT�51addCleanuprzr_ry�52read_untilr#r]�read_until_close�r%�datarqs` @r&�test_subprocess�SubprocessTest.test_subprocess�s�����
�^�^�T�4��.��#�#��$�$��$�$�	53��	
���;�<�������,�,�-�����
�
�+�+�,��n�n�'�'��0�0��
�
���/�0��^�^�.�.�u�5�5������z�*��n�n�'�'��0�0��
�
���1�2��^�^�4�4�6�6������s�#�s�E7E;c#�^^# �[[RSSS/[R[R[R54S9mTR
UU4Sj5 TRRS5v� TRR5 TRR5v�nTRUS5 g7f)Nrurvrwrxc�&>�TRT5$rHr}rps��r&r~�1SubprocessTest.test_close_stdin.<locals>.<lambda>�r�r)r�r�)
r	r�r�r�r�r�r�rzr�ryr_r�r]r�s` @r&�test_close_stdin�SubprocessTest.test_close_stdin�s������
�^�^�T�4��.��#�#��$�$��$�$�	55��	
���;�<��n�n�'�'��0�0��
�
�����^�^�4�4�6�6������u�%�s�CC	c#�"^^# �[[RSSS/[RS9mTR	UU4Sj5 TR56R
S5v�nTRUS5 TR57R5 g7f)Nru�-cz'import sys; sys.stderr.write('hello\n'))r{c�&>�TRT5$rHr}rps��r&r~�,SubprocessTest.test_stderr.<locals>.<lambda>�r�r)r�r�)	r	r�r�r�r�r{r�r]r_r�s` @r&�test_stderr�SubprocessTest.test_stderr�sr�����
�^�^�T�4�)S�T��$�$�58��	
���;�<��^�^�.�.�u�5�5������z�*�������s�BBc�V�[R"5 UR[R5 [[R59SS/5nUR
UR5 UR5nURUS5 URURU5 g�Nr��passr)r	�60initializer��uninitializer�r��set_exit_callback�stoprLr]�61returncode�r%rq�rets   r&�
test_sigchild�SubprocessTest.test_sigchild�sx���������62�/�/�0��c�n�n�d�F�;�<���!�!�$�)�)�,��i�i�k������a� �����+�+�S�1r)c#�,# �[R"5 UR[R5 [[R63SS/5nUR
5v�nURUS5 URURU5 g7fr�)	r	r�r�r�r�r��
wait_for_exitr]r�r�s   r&�test_sigchild_future�#SubprocessTest.test_sigchild_future�so����������64�/�/�0��c�n�n�d�F�;�<���)�)�+�+������a� �����+�+�S�1�s�BBc�J^�[R"5 TR[R5 [[R65SS/[RS9nTRURR5 URTR5 [R"S5 [R"UR[ R"5 TR%5nTR-UR.U5 TR-U[ R"*5 g![&ae URR)5nUR+U4Sj5 TR%5 ['S5e![&a ['S5ef=ff=f)Nr�zimport time; time.sleep(30))rzg�������?c�$>�TR5$rH)r�)rOr%s �r&r~�5SubprocessTest.test_sigchild_signal.<locals>.<lambda>�s���D�I�I�Kr)z=subprocess closed stdout but failed to get termination signalzsubprocess failed to terminate)r	r�r�r�r�r�r�rzr_r�r��time�sleeprr!rer�SIGTERMrL�AssertionErrorr��add_done_callbackr]r�)r%rqr��futs`   r&�test_sigchild_signal�#SubprocessTest.test_sigchild_signal�sA����������66�/�/�0��
�^�^�T�#@�A��$�$�67��	
������,�,�-��!�!�$�)�)�,�	
�68�69�3��70������V�^�^�,�	��)�)�+�C�$	
����+�+�S�1�����v�~�~�o�.��%�	��.�.�1�1�3�C��!�!�"7�8�
��	�	��%�V����"�
G�$�%E�F�F�
G��	�s$�%D3�39F"�-F�=F"�F�F"c#�# �[R"5 UR[R5 [[R71SS/5nUR
[R5nUR5v� SSS5 URWRRS5 g!,(df   N5=f7f)Nr��import sys; sys.exit(1)r5)
r	r�r�r�r�r��assertRaisesr��CalledProcessErrorr�r]�	exceptionr�)r%rq�cms   r&�test_wait_for_exit_raise�'SubprocessTest.test_wait_for_exit_raise�s�����������72�/�/�0��c�n�n�d�4M�N�O��
�
�
�z�<�<�
=���'�'�)�)�>�������0�0�!�4�>�
=�s�A0C�2B4�/C�473C�>Cc#��# �[R"5 UR[R5 [[R74SS/5nUR
SS9v�nURUS5 g7f)Nr�r�F)�raise_errorr5)r	r�r�r�r�r�r�r]r�s   r&�!test_wait_for_exit_raise_disabled�0SubprocessTest.test_wait_for_exit_raise_disableds_����������75�/�/�0��c�n�n�d�4M�N�O���)�)�e�)�<�<������a� �s�A5A7r*N)r+r,r-r.rrrr�r�r�r�r�r�r�r�r/r*r)r&rkrk�s�����$��$�(�&��&�����2��2��2�&/�P�5��5��!��!r)rk)"rJr6rrr�r�r��unittest�tornado.httpclientrr�tornado.httpserverr�tornado.logr�tornado.processrrr	�tornado.simple_httpclientr76�tornado.testingrrr
r�tornado.test.utilr�tornado.webrr�TestCaserrkr*r)r&�<module>r�s~����	�
��77���4�)��?�?�;�P�P�+�3��n�(�#�#�n��n�b�@!�]�@!��@!r)
codekingpro/portable-devtools · Team Ai