⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.144
Server IP:
157.245.143.252
Server:
Linux www 6.11.0-9-generic #9-Ubuntu SMP PREEMPT_DYNAMIC Mon Oct 14 13:19:59 UTC 2024 x86_64
Server Software:
nginx/1.26.0
PHP Version:
8.3.11
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
python3.12
/
test
/
libregrtest
/
__pycache__
/
View File Name :
run_workers.cpython-312.pyc
CRh\W ^ d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl Z d dl Z d dl Z d dl mZmZmZ d dlmZ d dlmZmZ ddlmZ ddlmZmZ ddlm Z dd l m Z m Z m Z m!Z! dd l"m#Z# dd l$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+ dd l,m-Z-m.Z. erd dl/Z/d dl0Z0d Z1e1e#k\ sJ dZ2e2e1k\ sJ d Z3dZ4 G d d Z5 ejl dd G d d Z7e8Z9e:ed e7f e:ed e9f z Z; G d de< Z= G d de< Z> G d d e j~ Z@d eAe@ d e8dz fd ZB G d d! ZCy)" N)AnyLiteralTextIO)support) os_helper MS_WINDOWS )Logger) TestResultState) TestResults)RunTestsWorkerRunTestsJsonFile JsonFileType)PROGRESS_MIN_TIME)StrPathTestNameformat_duration print_warningcountpluralget_signal_name)create_worker_processUSE_PROCESS_GROUPg >@g r@g N@c ( e Zd ZdZd Zd Zd Zd Zy)MultiprocessIteratorz8A thread-safe iterator over tests for multiprocess mode.c D t j | _ || _ y N) threadingLocklock tests_iter)selfr# s 3/usr/lib/python3.12/test/libregrtest/run_workers.py__init__z MultiprocessIterator.__init__8 s NN$ $ c | S r r$ s r% __iter__z MultiprocessIterator.__iter__< s r' c | j 5 | j t t | j cd d d S # 1 sw Y y xY wr )r" r# StopIterationnextr* s r% __next__z MultiprocessIterator.__next__? s/ YY&##( YYs '>Ac T | j 5 d | _ d d d y # 1 sw Y y xY wr )r" r# r* s r% stopzMultiprocessIterator.stopE s YY "DO YYs 'N)__name__ __module__ __qualname____doc__r& r+ r/ r1 r) r' r% r r 4 s B%) #r' r T)slotsfrozenc @ e Zd ZU eed< dZedz ed< dZedz ed< y)MultiprocessResultresultN worker_stdouterr_msg)r2 r3 r4 r __annotations__r; strr< r) r' r% r9 r9 J s$ $M3:$ GS4Z r' r9 Fc e Zd Zy) ExitThreadN)r2 r3 r4 r) r' r% r@ r@ V s r' r@ c < e Zd Zdededz dedz def fd Z xZS ) WorkerError test_namer< Nstdoutstatec ` t || }t ||| | _ t | y )NrE )r r9 mp_resultsuperr& )r$ rC r< rD rE r: __class__s r% r& zWorkerError.__init__[ s, IU3+FFGD r' )r2 r3 r4 r r> r& __classcell__rJ s @r% rB rB Z s9 $ * t r' rB c n e Zd Zdeddddf fd ZdefdZd!dZd!d Z d"d e d ed e dz dedz fd Z de j defdZde j deeedz f fdZdedede fdZde dedeedz ee f fdZdedefdZdededz dedeeef fdZdedefd Zd!d Z d!d Z d e ddfd Z xZ S )# WorkerThread worker_idrunner RunWorkersreturnNc t | || _ |j | _ |j | _ |j | _ |j | _ |j | _ d | _ d | _ d | _ d| _ d| _ y )NF)rI r& rO runtestspendingoutputworker_timeouttimeoutlogrC start_time_popen_killed_stopped)r$ rO rP rJ s r% r& zWorkerThread.__init__f sq " ~~ mm ,, ::*.(,48 r' c d| j g}| j r|j d n|j d | j }|r|j d| | j }|Wt j | j z }|j d| j j dt | f ddj | z S ) NzWorkerThread #runningstoppedztest=zpid=ztime=z<%s> ) rO is_aliveappendrC r[ time monotonicrZ extendpidr join)r$ infotestpopendts r% __repr__zWorkerThread.__repr__t s 012 ==? KK " KK "~~ KK%v ' !DOO3B KK4 01 !4 568 9&&r' c | j }|y | j ry d| _ t r| d}n| d}t d| t j d t r/t j |j t j y |j y # t $ r Y y t $ r}t d| d| Y d }~y d }~ww xY w)NTz process groupz processzKill )fileflushzFailed to kill z: )r[ r\ r printsysstderroskillpgrg signalSIGKILLkillProcessLookupErrorOSErrorr )r$ rk whatexcs r% _killzWorkerThread._kill s = << V>*DV8$D dVn3::T: = %))V^^4 ! = OD6C7; < < =s$ 4B B C &C .CC c 2 d| _ | j y )NT)r] r} r* s r% r1 zWorkerThread.stop s r' rT output_fdtmp_dirc : t ||| }|| _ d| _ | j r| j t |j | j }|J || j d | _ S # t j $ r' | j rt | j d }Y n t $ r | j rt w xY wn# | j xY w | j d | _ y # | j d | _ w xY w)NFrX ) r r[ r\ r] r} r@ waitrX _wait_completed subprocessTimeoutExpiredrz )r$ rT r r rk retcodes r% _run_processzWorkerThread._run_process s %h 7C & }} **T\\*: *** 2 " DK3 ,, == %$ == %$ JJL " DK " DKs; "C !A9 97C0C 2 CC D C%%D Dstackc t rt j }nt j j }t j d|d }|j | |S )z/Create stdout temporary file (file descriptor).w+backslashreplace)encodingerrors) r locale getencodingrr rD r tempfile TemporaryFile enter_context)r$ r r stdout_files r% create_stdoutzWorkerThread.create_stdout sW ))+Hzz**H ,,T6>4FH K(r' c | j j }|r t dt j }d}||fS t j dd }|j | |j }t r3t j | }t |t j }||fS t |t j }||fS )zCreate JSON file.Nr utf8r )rT json_file_use_stdoutr r STDOUTr r r filenor msvcrt get_osfhandleWINDOWS_HANDLEUNIX_FD)r$ r r json_file json_tmpfilejson_fd json_handles r% create_json_filez WorkerThread.create_json_file s $}} A A C |':':;I L <(( $11$HL -"))+G $*#7#7#@ $[%1%@%@ B <(( %Wl.B.B C <((r' rC r c * |f}| j j r | j j | }nd }i }|r|D cg c] }|df c}|d< | j j r d|d< d|d< | j j d||d|S c c}w )NT match_testsverboseFoutput_on_failure)testsr r) )rT rerunget_match_testsr create_worker_runtests)r$ rC r r r kwargsrj s r% r z#WorkerThread.create_worker_runtests s == --77 BK K!# >I$JkddD\k$JF= ! == * * $F9 */F& '3t}}33 %Ks Bworker_runtests stdout_fdc t j swt j d }t j j | } | j ||| }t j | }t j | ||fS | j || }g }||fS # t j | }t j | w xY w)N test_python_)prefix) r is_wasir mkdtemprt pathabspathr listdirr rmtree)r$ r r r r tmp_filess r% run_tmp_fileszWorkerThread.run_tmp_files s &&n=Gggoog.G * ++O,5w@ JJw / ) ## ''CGI## JJw / )s B ,C r c |j d |j j S # t $ r/}t | j d| d t j d }~ww xY w)Nr z Cannot read process stdout: )rD rE )seekreadstrip ExceptionrB rC r WORKER_BUG)r$ r r| s r% read_stdoutzWorkerThread.read_stdout( sh 6 ##%++- - 6 dnn <SE B%)$)$4$46 6 6s 1 A)*A$$A)r rD c |"|j d |j }nn|j t j k( r&|j d \ }}}|j }n+|j d 5 }|j }d d d s't | j d|t j t j | } | |fS # 1 sw Y LxY w# t $ r1}d| }t | j ||t j d }~ww xY w# t $ r1}d| }t | j ||t j d }~ww xY w) Nr r r z$Failed to read worker process JSON: rG z empty JSONz%Failed to parse worker process JSON: )r r file_typer r rpartitionrstripopenr rB rC r r r from_json) r$ r r rD worker_json_json_fpr| r< r: s r% read_jsonzWorkerThread.read_json4 sK 6' !!!$ * / / 1 $$ (;(;;)/):):4)@&; ^^V^4"),,.K 5 dnnlF$)$4$46 6 6 ))+6F - 54 6 =SEBG dnngv$)$4$46 6 6 6 >cUCG dnngv$)$4$46 6 6sH A9C# ;C C# >D C C# # D ,,DD E),EEc t j 5 }| j | }| j | \ }}| j || }| j ||j \ }}| j | } |'t | j | d t j |dk7 r?t | } | r| d| d}t | j d| | t j | j ||| \ } } d d d rAd| dt | d d j! t# | } | z } j% t' S # 1 sw Y XxY w) N)rD r< rE r ()z Exit code rG z Warning -- z leaked temporary files (): , ) contextlib ExitStackr r r r r r rB rC r TIMEOUTr WORKER_FAILEDr lenrh sortedset_env_changedr9 ) r$ rC r r r r r r r rD namer: msgs r% _runtestzWorkerThread._runtestV sw ! ! #u ,,U3K&*&;&;E&B #I| " 9 9)Y OO "&!3!3O4?4F4F4H"J GY %%k2F!$..*.(- 7 7 !|&w/!( D6 3G!$..Jwi2H&(-(;(;= = "^^I|V LNFF- $0 !!* ,9~&c$))F94E*F)GIC cMF " " $!&&11? $ #s C/EE$c | j j }| j j }| j s t | j }t j | _ || _ | j | }d | _ t j | j z |j _ | j j# d|f |j j% || ry | j sy y # t $ r Y y w xY w# t $ r}|j }Y d }~d }~ww xY w# d | _ w xY w# t& $ r Y y t( $ r2 | j j# dt+ j, f Y y w xY w)NFT)rT fail_fastfail_env_changedr] r. rU r- rd re rZ rC r rB rH r: durationrV put must_stopr@ BaseException traceback format_exc)r$ r r rC rH r| s r% runzWorkerThread.runx sC MM++ ==99-- $T\\ 2I #'.."2!** $ i 8I &*DN,0NN,<t,N ) 23 ##--i9IJ K% -- % # . # I. &*DN y';';'= >? sl D E 1D A0E D E DE D1 D,'D4 ,D11D4 4 D==E F 7FFc | j } |j t y # t j t f$ r+}t d| dt t d| Y d }~y d }~ww xY w)NzFailed to wait for z completion (timeout=r )r[ r WAIT_COMPLETED_TIMEOUTr r rz r r )r$ rk r| s r% r z WorkerThread._wait_completed si & JJ- .))73 & /v 6&&56L&M%Nc G% & & &s $ A(!A##A(rZ c | j d | j sy t j |z }| j d| dt | |t kD rt d| dt | y ~)Ng ?z Waiting for z thread for zFailed to join z in )rh rb rd re rY r WAIT_KILLED_TIMEOUTr )r$ rZ rl s r% wait_stoppedzWorkerThread.wait_stopped sz IIcN==? !J.B HH|D6 ob6I5JK L'' vT/":M9N OP r' rR Nr )!r2 r3 r4 intr& r> rm r} r1 r r r r r r r tupler r r r listr r r r r9 r r r floatr rK rL s @r% rN rN e sd # | '# ' =8 04, ^ , , %n, 8;d , \:#7#7 F ,)j&:&: )uXvX\}E\?] ), X R` $$^ $!$$).sTz4=/H)I$. 6v 6# 6 8 6D= "' C"8 D 2( 2/A 2D:&u r' rN workersrR c g }| D ]^ }|j }|st j |j z }|t k\ s=| dt | d}|j | ` |sy dt | ddj | S )Nr r z running (r r ) rC rd re rZ r r rc r rh )r r_ workerrC rl texts r% get_runningr s G$$ ^^ 1 1 1 " " [?2#6"7q9D NN4 s7|nC '(:'; <<r' c r e Zd Zdededededdf dZddZdd Z de dz fd Z d e ddfd Z d e defdZddZy)rQ num_workersrT loggerresultsrR Nc || _ || _ |j | _ |j | _ || _ t j | _ |j }t | | _ |j | _ | j ,t | j dz | j dz | _ nd | _ d | _ | j j }| t | j | | _ y y )Ng ?i, )r rT rY display_progressr queueQueuerV iter_testsr rU rX minrW r get_jobs)r$ r rT r r r# jobss r% r& zRunWorkers.__init__ s & :: & 7 7 $+ 05 ((* +J7 '' << # 14DLL34F W]H]0^D "&D 26 }}%%' #4#3#3T :D r' c t d| j dz D cg c] }t || c}| _ | j j }| t |d }nd}t | j }t |dd }d| d| d| }| j r2|d t | j d t | j d z }| j | | j D ] }|j y c c}w ) Nr rj r process processeszRun z in parallel using z worker z (timeout: z, worker timeout: r )ranger rN r rT r r r r rX r rW rY start)r$ indexr r nworkersr r r s r% start_workerszRunWorkers.start_workers s %*1d.>.>.B%CE%CE %UD1%CE }}%%' $'EEt||$8Y < eW /8I;0 << &t||4&t':':;= >C llF LLN #!Es D c t j }| j D ] }|j | j D ] }|j | y r )rd re r r1 r )r$ rZ r s r% stop_workerszRunWorkers.stop_workers sA ^^% llF KKM #llF + #r' c , | j j }| j d u}t d | j D r>|rt j t d | j j t S | j j d S # t j $ r Y nw xY w|s(t | j }|r| j | t d | j D r~# t j $ r Y y w xY w)Nc 3 < K | ] }|j y wr )rb ).0r s r% <genexpr>z)RunWorkers._get_result.<locals>.<genexpr> s ?,&//#,s T)exitr r )rT pgorX anyr faulthandlerdump_traceback_laterMAIN_PROCESS_TIMEOUTrV getPROGRESS_UPDATEr Emptyr rY )r$ r use_faulthandlerr_ s r% _get_resultzRunWorkers._get_result s mm LL 4 ?$,,?? 112F7;= {{?? ;;??1?- - ;; %dll3HHW% ?$,,??( {{ s$ B C= B21B2=DDrH c v |j }| j j }t | }|j r|d|j z z }n0|j t k\ r |s|dt |j z z }|s t | j }|r|d| z }| j | j | y )Nz (%s)z -- ) r: rT r r> r< r r r r r r test_index)r$ rH r: r r r_ s r% display_resultzRunWorkers.display_result s !!mm 6{ Gi / // /Doo!223 Gofoo >> >D!$,,/G$wi(( doot4r' itemc |d rV|d }t d| t dt j }| j j || j |S | xj dz c_ |d }|j }| j j || j | j | | j j sd}n |j t j k7 }|r|j }|r t |d |S )z&Returns True if test runner must stop.r r z regrtest worker thread failed: z<regrtest worker>rG T)rp )r r r r r accumulate_resultrT r r: r r rE PASSEDr; rq )r$ r r r: rH show_stdoutrD s r% _process_resultzRunWorkers._process_result) s 7 aJ ;J<H I 35;K;KLF LL * *64== AM 1 G !! &&vt}}= I& }}.. K "<<5<<7K ,,FfD) r' c | j j }| j j }| j d| _ | j }|n%| j | }|j || rn8| j t j | j j! | j# y # t $ r t d| j _ Y qw xY w# | j t j | j j! | j# w xY w)Nr T)rT r r r r r r" r KeyboardInterruptrq r interruptedrX r cancel_dump_traceback_laterrU r1 r )r$ r r r r: s r% r zRunWorkers.runF s MM++ ==99 '')< --d3##I/?@ ||' 88: LL ! , G'+DLL $ , ||' 88: LL s% 9C $C0-C3 /C00C3 3A D?r )r2 r3 r4 r r r r r& r r QueueOutputr r9 r r r" r r) r' r% rQ rQ st ;C ;8 ; ;*5;:>;6(,[4 / :5(: 5t 5 K J : r' rQ )Dr dataclassesr os.pathrt r rv r rr r r rd r typingr r r rj r test.supportr r r r r: r r r r rT r r r r singler utilsr r r r r r r r r r r r r r r r r dataclassr9 r> ExcStrr r' r r@ rB ThreadrN r r rQ r) r' r% <module>r1 sX ' ' . % F F %D D D = ++ ++ . .. # #, T$/ 0 GEN$667% v@U:VV ) N9## Nb =l+ =d = [ [ r'