__  __    __   __  _____      _            _          _____ _          _ _ 
 |  \/  |   \ \ / / |  __ \    (_)          | |        / ____| |        | | |
 | \  / |_ __\ V /  | |__) | __ ___   ____ _| |_ ___  | (___ | |__   ___| | |
 | |\/| | '__|> <   |  ___/ '__| \ \ / / _` | __/ _ \  \___ \| '_ \ / _ \ | |
 | |  | | |_ / . \  | |   | |  | |\ V / (_| | ||  __/  ____) | | | |  __/ | |
 |_|  |_|_(_)_/ \_\ |_|   |_|  |_| \_/ \__,_|\__\___| |_____/|_| |_|\___V 2.1
 if you need WebShell for Seo everyday contact me on Telegram
 Telegram Address : @jackleet
        
        
For_More_Tools: Telegram: @jackleet | Bulk Smtp support mail sender | Business Mail Collector | Mail Bouncer All Mail | Bulk Office Mail Validator | Html Letter private



Upload:

Command:

[email protected]: ~ $
�

*�_i6Y���SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK	r	SSK
r
SSKrSSKrSSK
JrJrJr SSKJr SSKJrJr SSKJr SSKJrJr SSKJr SS	KJrJrJ r J!r! SS
K"J#r# SSK$J%r%J&r&J'r'J(r(J)r)J*r*J+r+ SSK,J-r-J.r. \(aSSK/r/SSK0r0S
r1\1\#:�deSr2\2\1:�deS
r3Sr4"SS5r5\Rl"SSS9"SS55r7"SS5r8\9r:\;\S\74\;\S\:4-r<\<\8-r="SS\>5r?"SS\>5r@SrA"SS\
R�5rCS \D\CS!\9S-4S"jrE"S#S$5rFg)%�N)�Any�Literal�TextIO)�support)�	os_helper�
MS_WINDOWS�)�Logger)�
TestResult�State)�TestResults)�RunTests�WorkerRunTests�JsonFile�JsonFileType)�PROGRESS_MIN_TIME)�StrPath�TestName�format_duration�
print_warning�count�plural�get_signal_name)�create_worker_process�USE_PROCESS_GROUPg>@g�r@gN@c�0�\rSrSrSrSrSrSrSrSr	g)	�MultiprocessIterator�4z8A thread-safe iterator over tests for multiprocess mode.c�D�[R"5UlXlg�N)�	threading�Lock�lock�
tests_iter)�selfr$s  �3/usr/lib/python3.13/test/libregrtest/run_workers.py�__init__�MultiprocessIterator.__init__8s���N�N�$��	�$��c��U$r ��r%s r&�__iter__�MultiprocessIterator.__iter__<s���r)c��UR URc[e[UR5sSSS5 $!,(df   g=fr )r#r$�
StopIteration�nextr,s r&�__next__�MultiprocessIterator.__next__?s/��
�Y�Y����&�#�#�����(��Y�Y�s	�(?�
A
c�^�UR SUlSSS5 g!,(df   g=fr �r#r$r,s r&�stop�MultiprocessIterator.stopEs��
�Y�Y�"�D�O��Y�Y�s��
,r5N)
�__name__�
__module__�__qualname__�__firstlineno__�__doc__r'r-r2r6�__static_attributes__r+r)r&rr4s��B�%��)�#r)rT)�slots�frozenc�H�\rSrSr%\\S'Sr\S-\S'Sr\S-\S'Sr	g)�MultiprocessResult�J�resultN�
worker_stdout�err_msgr+)
r8r9r:r;r�__annotations__rD�strrEr=r+r)r&rArAJs$���� $�M�3��:�$��G�S�4�Z�r)rAc��\rSrSrSrSrg)�WorkerThreadExited�Rz)Indicates that a worker thread has exitedr+N)r8r9r:r;r<r=r+r)r&rIrIRs��3r)rIFc��\rSrSrSrg)�
ExitThread�Zr+N)r8r9r:r;r=r+r)r&rLrLZs��r)rLc�H^�\rSrSrS\S\S-S\S-S\4U4SjjrSrU=r$)	�WorkerError�^�	test_namerEN�stdout�statec�V>�[XS9n[XSU5Ul[TU]5 g)N�rS)rrA�	mp_result�superr')r%rQrErRrSrC�	__class__s      �r&r'�WorkerError.__init___s(���
�I�3��+�F�G�D���
���r))rV)	r8r9r:r;rrGr'r=�
__classcell__�rXs@r&rOrO^s9����$����*���t����	�r)rOz
<not running>c
�^�\rSrSrS\SSSS4U4SjjrS\4SjrS#S	jrS#S
jr	S$S\
S\S
\S-S\S-4SjjrS\
RS\4SjrS\
RS\\\S-44SjrS\S\S\
4SjrS\
S\S\\S-\\44SjrS\S\4SjrS\S\S-S\S\\\44SjrS\S\4SjrS#SjrS#SjrS \SS4S!jr S"r!U=r"$)%�WorkerThread�l�	worker_id�runner�
RunWorkers�returnNc�L>�[TU]5 XlURUlURUlUR
UlURUlURUl[Ul
[R"5Ul
SUlSUlSUlg)NF)rWr'r_�runtests�pending�output�worker_timeout�timeout�log�_NOT_RUNNINGrQ�time�	monotonic�
start_time�_popen�_killed�_stopped)r%r_r`rXs   �r&r'�WorkerThread.__init__msv���
����"������
��~�~����m�m����,�,����:�:���%����.�.�*���48��������
r)c���SUR3/nUR5(aURS5 OURS5 URnU(aURSU35 URnUbN[
R"5UR-
nURSUR3S[U5345 SSRU5-$)	NzWorkerThread #�running�stoppedztest=zpid=ztime=z<%s>� )r_�is_alive�appendrQrnrkrlrm�extend�pidr�join)r%�info�test�popen�dts     r&�__repr__�WorkerThread.__repr__{s��� ���� 0�1�2���=�=�?�?��K�K�	�"��K�K�	�"��~�~����K�K�%��v��'����������!�D�O�O�3�B��K�K�4��	�	�{�+� ���!4� 5�6�8�
9�������&�&r)c��URnUcgUR(agSUl[(aUS3nOUS3n[SU3[R
SS9 [(a0[R"UR[R5 gUR5 g![a g[an[SUSU<35 SnAgSnAff=f)NTz process groupz processzKill )�file�flushzFailed to kill z: )rnror�print�sys�stderr�os�killpgry�signal�SIGKILL�kill�ProcessLookupError�OSErrorr)r%r}�what�excs    r&�_kill�WorkerThread._kill�s��������=���<�<��������V�>�*�D��V�8�$�D�
��d�V�n�3�:�:�T�:�	=� � ��	�	�%�)�)�V�^�^�4��
�
���!�	�
��	=��O�D�6��C�7�;�<�<��	=�s$�:B)�B)�)
C�5	C�>C�Cc�2�SUlUR5 g)NT)rpr�r,s r&r6�WorkerThread.stop�s����
��
�
�r)rd�	output_fd�tmp_dirc�R�[XU5nX@lSUlUR(aUR	5 [
eUR
URS9nUceUUR5 SUl$![Ra, UR(a[
eUR	5 SnO%[a UR(a[
eef=fUR5 SUlg! UR	5 e=f!UR5 SUlf=f)NF�rh)rrnrorpr�rL�waitrh�_wait_completed�
subprocess�TimeoutExpiredr�)r%rdr�r�r}�retcodes      r&�_run_process�WorkerThread._run_process�s	��%�h�7�C�������'	��}�}��
�
�� � �
��*�*�T�\�\�*�:���*�*�*��4
� � �"��D�K��5�,�,�

��=�=�%�$��
�
�����
��=�=�%�$��
���

� � �"��D�K��	��J�J�L���� � �"��D�K�s5�'C7�A:�:=C�7C7�9"C�C7�7D
�
D
�
D&�stackc���[(a[R"5nO[RR
n[R"SUSS9nURU5 U$)z/Create stdout temporary file (file descriptor).�w+�backslashreplace)�encoding�errors)	r�locale�getencodingr�rRr��tempfile�
TemporaryFile�
enter_context)r%r�r��stdout_files    r&�
create_stdout�WorkerThread.create_stdout�sY���:��)�)�+�H��z�z�*�*�H��,�,�T�6>�4F�H��	���K�(��r)c��URR5nU(a[S[R5nSnX44$[
R"SSS9nURU5 UR5n[(a3[R"U5n[U[R5nX44$[U[R5nX44$)zCreate JSON file.Nr��utf8�r�)rd�json_file_use_stdoutrr�STDOUTr�r�r��filenor�msvcrt�
get_osfhandle�WINDOWS_HANDLE�UNIX_FD)r%r�r��	json_file�json_tmpfile�json_fd�json_handles       r&�create_json_file�WorkerThread.create_json_file�s��� $�}�}�A�A�C��� ��|�':�':�;�I��L��(�(�$�1�1�$��H�L�����-�"�)�)�+�G��z�$*�#7�#7��#@��$�[�%1�%@�%@�B�	��(�(�%�W�l�.B�.B�C�	��(�(r)rQr�c�L�U4nURR(aURRU5nOSn0nU(aUVs/sHofS4PM snUS'URR(a
SUS'SUS'URR"SUUS.UD6$s snf)NT�match_tests�verboseF�output_on_failure)�testsr�r+)rd�rerun�get_match_testsr��create_worker_runtests)r%rQr�r�r��kwargsr|s       r&r��#WorkerThread.create_worker_runtestss�������=�=����-�-�7�7�	�B�K��K�!#���>I�$J�k�d�D�\�k�$J�F�=�!��=�=�*�*� $�F�9��*/�F�&�'��}�}�3�3�������	��	%Ks�

B!�worker_runtests�	stdout_fdc��[R(du[R"SS9n[R
R
U5nURUX#5n[R"U5n[R"U5 XE4$URX5n/nXE4$![R"U5n[R"U5 f=f)N�test_python_)�prefix)r�is_wasir��mkdtempr��path�abspathr��listdirr�rmtree)r%r�r�r�r��	tmp_filess      r&�
run_tmp_files�WorkerThread.run_tmp_filess���
����&�&�n�=�G��g�g�o�o�g�.�G�
*��+�+�O�,5�@���J�J�w�/�	�� � ��)�
�#�#��'�'��C�G��I��#�#��
�J�J�w�/�	�� � ��)�s�
B!�!.Cr�c���URS5 UR5R5$![a,n[	UR
SU3S[RS9eSnAff=f)NrzCannot read process stdout: )rRrS)�seek�read�strip�	ExceptionrOrQr�
WORKER_BUG)r%r�r�s   r&�read_stdout�WorkerThread.read_stdout0sh�������	6��#�#�%�+�+�-�-���	6��d�n�n� <�S�E�B�%)�$)�$4�$4�6�
6��	6�s�1�
A'�'A"�"A'r�rRc��Ub"URS5 UR5nOkUR[R:Xa%URS5up5nUR
5nO(URSS9nUR5nSSS5 W(d$[URSU[RS9e[R"U5n	X�4$!,(df   NS=f![a-nSU3n[URX�[RS9eSnAff=f![a-nSU3n[URX�[RS9eSnAff=f)	Nr�
r�r�z$Failed to read worker process JSON: rUz
empty JSONz%Failed to parse worker process JSON: )r�r��	file_typerr��
rpartition�rstrip�openr�rOrQrr�r�	from_json)
r%r�r�rR�worker_json�_�json_fpr�rErCs
          r&�	read_json�WorkerThread.read_json<sC��	6��'��!�!�!�$�*�/�/�1���$�$��(;�(;�;�)/�):�):�4�)@�&��;�������^�^�V�^�4��")�,�,�.�K�5���d�n�n�l�F�$)�$4�$4�6�
6�	6��)�)�+�6�F����-5�4���	6�=�S�E�B�G��d�n�n�g�$)�$4�$4�6�
6��		6���	6�>�c�U�C�G��d�n�n�g�$)�$4�$4�6�
6��		6�sY�$C(�AC(�*C(�9C�
C(�>D"�
C%�!C(�%C(�(
D�2(D�D�"
E�,(E�Ec
���[R"5nURU5nURU5upEUR	X5nURUUR
55upxURU5n	Uc$[URU	S[RS9eUS:waA[U5n
U
(aUSU
S3n[URSU3U	[RS9eURXEU	5up�SSS5 W(aASUS[U5S	S
R![#U553nW	U-
n	WR%5 ['WW	5$!,(df   Nb=f)N)rRrErSr� (�)z
Exit code rUz

Warning -- z leaked temporary files (�): �, )�
contextlib�	ExitStackr�r�r�r�r�r�rOrQr�TIMEOUTr�
WORKER_FAILEDr��lenrz�sorted�set_env_changedrA)
r%rQr�r�r�r�r�r�r�rR�namerC�msgs
             r&�_runtest�WorkerThread._runtest^sm��
�
!�
!�
#�u��,�,�U�3�K�&*�&;�&;�E�&B�#�I�"�9�9�)�O�O�"&�!3�!3�O�4?�4F�4F�4H�"J��G��%�%�k�2�F���!�$�.�.��*.�(-�
�
�7�7��!�|�&�w�/���!(�	��D�6��3�G�!�$�.�.�J�w�i�2H�&�(-�(;�(;�=�=�"�^�^�I�V�L�N�F�-$�0�!�!*��,��9�~�&�c�$�)�)�F�9�4E�*F�)G�I�C�
�c�M�F��"�"�$�!�&�&�1�1�?$�
#�s�C+E�
E+c���URRnURRnUR(d�[	UR
5n[R"5Ul	X0l
URU5n[Ul
[R"5UR-
URlUR"R%SU45 URR'X5(aOUR(dM�UR"R%[155 g![a M1f=f![anURnSnAN�SnAff=f![Ul
f=f![(a Nt[*a3 UR"R%S[,R."545 N�f=f!UR"R%[155 f=f)NFT)rd�	fail_fast�fail_env_changedrpr1rer0rkrlrmrQr�rOrVrjrC�durationrf�put�	must_stoprL�
BaseException�	traceback�
format_excrI)r%r�r�rQrVr�s      r&�run�WorkerThread.run�sg���M�M�+�+�	��=�=�9�9��	2��m�m�� $�T�\�\� 2�I�#'�.�.�"2���!*��2� $�
�
�i� 8�I�&2�D�N�,0�N�N�,<�t���,N�	� � �)�������	� 2�3��#�#�-�-�i�J�J��%�m�m�m�0
�K�K�O�O�.�0�1��+%�����#�.� #�
�
�I��.��&2�D�N���	���	<��K�K�O�O�T�9�#7�#7�#9�:�;�	<��
�K�K�O�O�.�0�1�s��E<�D8� E<�6E	�A9E<�G�E<�8
E�E<�G�E�E<�	
E)�E$�E,�$E)�)E,�,
E9�9E<�<
G�G�9G�G�G�G�%G,c	��URnUc[S5eUR[5 g![R
[4a,n[SUS[[5SU<35 SnAgSnAff=f)Nz5Should never access `._popen` before calling `.run()`zFailed to wait for z completion (timeout=r�)	rn�
ValueErrorr��WAIT_COMPLETED_TIMEOUTr�r�r�rr)r%r}r�s   r&r��WorkerThread._wait_completed�sz�������=��T�U�U�	&��J�J�-�.���)�)�7�3�	&��/��v�6&�&5�6L�&M�%N�c� �G�%�
&�
&��	&�s�2�A8�"A3�3A8rmc��URS5 UR5(dg[R"5U-
nUR	SUS[U535 U[:�a[SUS[U535 gM�)Ng�?zWaiting for z thread for zFailed to join z in )rzrvrkrlrir�WAIT_KILLED_TIMEOUTr)r%rmr~s   r&�wait_stopped�WorkerThread.wait_stopped�s|����I�I�c�N��=�=�?�?�����!�J�.�B��H�H�|�D�6��o�b�6I�5J�K�L��'�'����v�T�/�"�:M�9N�O�P��r))rornrprirfrerdrmrQrhr_�rbNr )#r8r9r:r;�intr'rGrr�r6rrr�r�r�rr��tuplerr�rr��listr�r�rr�rAr�rr��floatr
r=rZr[s@r&r]r]lsi����#��|����'�#�'� =�8�04�-�^�-��-�%��n�-�8;�d�
�-�^�:�#7�#7��F��,)�j�&:�&:�)�u�X�v�X\�}�E\�?]�)�,���X��R`��$$�^�$�!$�$�).�s�T�z�4��=�/H�)I�$�.
6�v�
6�#�
6�  �8�  �6�D�=�  ��  �"'�
�C��"8�  �D 2�(� 2�/A� 2�D2�<&��u����r)r]�workersrbc�8�/nUHknURnU[:XaM[R"5UR-
nU[
:�dMIUS[
U5S3nURU5 Mm U(dgS[U5SSRU53$)Nr�r�z	running (r�r�)
rQrjrkrlrmrrrwr�rz)rrs�workerrQr~�texts      r&�get_runningr�s����G����$�$�	���$��
�^�^�
�� 1� 1�
1��
�"�"��[��?�2�#6�"7�q�9�D��N�N�4� ����
�s�7�|�n�C��	�	�'�(:�';�<�<r)c
��\rSrSrS\S\S\S\SS4
SjrSS	jr	SS
jr
S\S-4SjrS\
SS4S
jrS\S\4SjrSSjrSrg)rai��num_workersrd�logger�resultsrbNc��XlX lURUlURUlX@lSUl[R"5UlUR5n[U5UlURUlURb,[URS-URS-5UlOSUl/UlURR!5nUb[URU5Ulgg)Nrg�?i,)rrdri�display_progressr�live_worker_count�queue�Queuerf�
iter_testsrrerh�minrgr�get_jobs)r%rrdrrr$�jobss       r&r'�RunWorkers.__init__�s���&�� �
��:�:��� &� 7� 7���$+��!"���16�������(�(�*�
�+�J�7����'�'����<�<�#�14�D�L�L�3�4F����W]�H]�0^�D��"&�D��+-����}�}�%�%�'���� #�4�#3�#3�T�:�D��r)c�f�[SURS-5Vs/sHn[X5PM snUlURR5nUb
[
US5nOSn[UR5n[USS5nSUSUSU3nUR(aAURb4US	[UR5<S
[UR5<S3-
nURU5 URH(nUR5 U=RS-
slM* gs snf)Nr	r|r��process�	processeszRun z in parallel using z worker z (timeout: z, worker timeout: r�)�rangerr]rrdr!rr�rrhrgrri�startr)r%�indexr"r��nworkersr&r�rs        r&�
start_workers�RunWorkers.start_workers�s��%*�1�d�.>�.>��.B�%C�E�%C�E�%�U�1�%C�E����}�}�%�%�'�����$��'�E��E��t�|�|�$���8�Y��<�	��e�W�/���8�I�;�0���<�<�D�/�/�;��&�t�|�|�4�&�t�':�':�;�=�
>�C�	
����
��l�l�F��L�L�N��"�"�a�'�"�#��!Es�D.c��[R"5nURHnUR5 M URHnUR	U5 M gr )rkrlrr6r
)r%rmrs   r&�stop_workers�RunWorkers.stop_workerssA���^�^�%�
��l�l�F��K�K�M�#��l�l�F����
�+�#r)c��URRnURSLnURS:�alU(a[R
"[SS9 URR[S9n[U[5(aU=RS-slMzU$g![Ra Of=fU(d-[UR5nU(aUR!U5 URS:�aM�Nb)NrT)�exitr�r	)rd�pgorhr�faulthandler�dump_traceback_later�MAIN_PROCESS_TIMEOUTrf�get�PROGRESS_UPDATE�
isinstancerIr�Emptyrrri)r%r2�use_faulthandlerrCrss     r&�_get_result�RunWorkers._get_result
s����m�m���� �L�L��4���$�$�q�(���1�1�2F�7;�=�
��������A���f�&8�9�9��*�*�a�/�*���
����;�;�
��
���%�d�l�l�3����H�H�W�%�'�$�$�q�(s�AB"�B"�"B9�8B9rVc���URnURRn[U5nUR(aUSUR--
nOGUR
(a6UR
[:�a"U(dUS[UR
5--
nU(d$[UR5nU(aUSU3-
nURURU5 g)Nz (%s)z -- )rCrdr2rGrEr�rrrrr�
test_index)r%rVrCr2rrss      r&�display_result�RunWorkers.display_result&s����!�!���m�m�����6�{������G�i�/�/�/�/�D��o�o�&�/�/�5F�"F�s��G�o�f�o�o�>�>�>�D��!�$�,�,�/�G���$�w�i�(�(�����d�o�o�t�4r)�itemc�4�US(aRUSn[SU35 [S[RS9nURRX0R5 U$U=RS-
slUSnURnURRX0R5 URU5 URR(dSnOUR[R:gnU(aURnU(a
[USS9 U$)z&Returns True if test runner must stop.rr	zregrtest worker thread failed: z<regrtest worker>rUT)r�)rrrr�r�accumulate_resultrdr>rCr?r�rS�PASSEDrDr�)r%rArrCrV�show_stdoutrRs       r&�_process_result�RunWorkers._process_result6s�����7��a��J��;�J�<�H�I�� 3�5�;K�;K�L�F��L�L�*�*�6�=�=�A��M����1�����G�	��!�!�����&�&�v�}�}�=����I�&��}�}�.�.��K�"�<�<�5�<�<�7�K���,�,�F���f�D�)��
r)c��URRnURRnUR5 SUlUR5nUcO*UR
U5nURX5(aOM>URb[R"5 URR!5 UR#5 g![a [5 SURlNtf=f!URb[R"5 URR!5 UR#5 f=f)NrT)rdr�r�r+r>r;rFr��KeyboardInterruptr�r�interruptedrhr3�cancel_dump_traceback_laterrer6r.)r%r�r�rArCs     r&r�RunWorkers.runSs
���M�M�+�+�	��=�=�9�9���������	 ���'�'�)���<���-�-�d�3���#�#�I�@�@����|�|�'��8�8�:�
�L�L���������!�	,��G�'+�D�L�L�$�	,���|�|�'��8�8�:�
�L�L��������s=�C�C<�'C�C<�C�%C9�6C<�8C9�9C<�<AE
)rrrirrfrerrdr>rhrgrr)r8r9r:r;r
rr
r
r'r+r.�QueueOutputr;rAr?rrFrr=r+r)r&rara�st��;�C�;�8�;��;�*5�;�:>�;�8(�*,��[�4�/��85�(:�5�t�5� �K��J��: r)ra)Gr��dataclassesr3�os.pathr�rr�r�r�r�r!rkr�typingrrrr|r�test.supportrrrr
rCrrrr
rdrrrr�singler�utilsrrrrrrrrrrr�r�r7r5rr	r�	dataclassrArIrG�ExcStrrrM�QueueContentr�rLrOrj�Threadr]rrrar+r)r&�<module>rXsr�������
��
�����'�'��.��%� �F�F�%�D�D�D�=�
���
���+�+�+�+�
 ����.�.�.�����#�#�,
���T�$�/���0��4�4�

���G�E�N�$6�6�7�%���
�v�@U�:V�V���/�/��	��	��)����S�9�#�#�S�l
=��l�+�=��d�
�=�\ �\ r)

Filemanager

Name Type Size Permission Actions
__init__.cpython-313.pyc File 145 B 0644
cmdline.cpython-313.pyc File 24.28 KB 0644
filter.cpython-313.pyc File 2.46 KB 0644
findtests.cpython-313.pyc File 4.79 KB 0644
logger.cpython-313.pyc File 4.31 KB 0644
main.cpython-313.pyc File 32.74 KB 0644
pgo.cpython-313.pyc File 1010 B 0644
refleak.cpython-313.pyc File 10.9 KB 0644
result.cpython-313.pyc File 11.14 KB 0644
results.cpython-313.pyc File 14.6 KB 0644
run_workers.cpython-313.pyc File 26.94 KB 0644
runtests.cpython-313.pyc File 11.2 KB 0644
save_env.cpython-313.pyc File 21.47 KB 0644
setup.cpython-313.pyc File 5.85 KB 0644
single.cpython-313.pyc File 13.12 KB 0644
testresult.cpython-313.pyc File 11.72 KB 0644
tsan.cpython-313.pyc File 716 B 0644
utils.cpython-313.pyc File 29.34 KB 0644
win_utils.cpython-313.pyc File 4.19 KB 0644
worker.cpython-313.pyc File 4.99 KB 0644
Filemanager