qh]u d Z ddlmZ ddlZddlZddlZddlmZ ddlm Z m
Z
m Z m Z m
Z
mZmZmZmZmZmZ ddlmZ ddlmZ ddlmZ dd lmZ dd
l m Z dd l m Z dd l m!Z!m"Z" dd
l#m$Z$ ddl%m&Z& ddl'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z. e"e Z ddl/m0Z0m1Z1 dZ2nK# e3$ rC ej4 d dk r*ej5 6 d ej7 d dZ2Y nw xY w ed Z8 G d d Z9dS )z#Raw data collector for coverage.py. ) annotationsN) FrameType) castAnyCallableDictListMappingOptionalSetTupleTypeTypeVar)env)CoverageConfig) CoverageData) short_stack)FileDisposition) ConfigError)human_sorted_itemsisolate_module)CoveragePlugin)PyTracer)TArcTFileDispositionTLineNo
TTraceDataTTraceFnTTracerTWarnFn)CTracerCFileDispositionTCOVERAGE_TEST_TRACERcz:*** COVERAGE_TEST_TRACER is 'c' but can't import CTracer!
FTc e Zd ZU dZg Zded< h dZd@dZdAdZdBd Z dAd Z
dCd Z dCd Z dDd"Z
dEd)ZdCd*ZdCd+ZdCd,ZdCd-ZdFd.ZdGd0ZdHd3Z ej d45 dId7 ZdJd;ZdKd>ZdFd?Zd4S )L Collectora Collects trace data.
Creates a Tracer object for each thread, since they track stack
information. Each Tracer points to the same shared data, contributing
traced data points.
When the Collector is started, it creates a Tracer for the current thread,
and installs a function to create Tracers for each new thread started.
When the Collector is stopped, all active Tracers are stopped.
Threads started while the Collector is stopped will never have Tracers
associated with them.
zList[Collector] _collectors> geventeventletgreenlet should_trace,Callable[[str, FrameType], TFileDisposition]
check_include Callable[[str, FrameType], bool]should_start_context.Optional[Callable[[FrameType], Optional[str]]] file_mapperCallable[[str], str]timidboolbranchwarnr concurrency List[str]returnNonec
|| _ || _ || _ || _ || _ || _ || _ t | j t sJ d| j | d| _ d| _
t | _ d| _
| | d} t r|sd} | r't | _ t" | _ d| _ d| _ n&t* | _ t, | _ d| _ d| _ t/ | j }
|
t0 j z
} | r4d t7 | } t9 d| |
| j z }
t= |
dk r4d t7 |
} t9 d| d}d } d
|
v rd
}d dl }|j | _
n2d |
v rd }d dl!}|j" j | _
nd
|
v rd
}d dl#}|j | _
d|
v rd}n(# tH $ r}d| d}t9 | |d}~ww xY w| j
rJtK | j d s5t9 d& || ' |s|
s d dl }|| _ | ( dS )a Create a collector.
`should_trace` is a function, taking a file name and a frame, and
returning a `coverage.FileDisposition object`.
`check_include` is a function taking a file name and a frame. It returns
a boolean: True if the file should be traced, False if not.
`should_start_context` is a function taking a frame, and returning a
string. If the frame should be the start of a new context, the string
is the new context. If the frame should not be the start of a new
context, return None.
`file_mapper` is a function taking a filename, and returning a Unicode
filename. The result is the name that will be recorded in the data
file.
If `timid` is true, then a slower simpler trace function will be
used. This is important for some environments where manipulation of
tracing functions make the faster more sophisticated trace function not
operate properly.
If `branch` is true, then branches will be measured. This involves
collecting data on which statements followed each other (arcs). Use
`get_arc_data` to get the arc data.
`warn` is a warning function, taking a single string message argument
and an optional slug argument which will be a string or None, to be
used if a warning needs to be issued.
`concurrency` is a list of strings indicating the concurrency libraries
in use. Valid values are "greenlet", "eventlet", "gevent", or "thread"
(the default). "thread" can be combined with one of the other three.
Other values are ignored.
zExpected a list: NFTz, z Unknown concurrency choices: r% z"Conflicting concurrency settings: nothingr, r r+ r* threadz Couldn't trace with concurrency=z , the module isn't installed.concur_id_funczACan't support concurrency={} with {}, only threads are supported.))r- r/ r1 r3 r7 r8 r9
isinstancelist threadingstatic_contextr originr@ HAS_CTRACERr! _trace_classr" file_disposition_classsupports_plugins packed_arcsr r setr CONCURRENCY_CHOICESjoinsortedr
LIGHT_THREADSlenr,
getcurrenteventlet.greenthread greenthreadr* ImportErrorhasattrformat tracer_namereset)selfr- r/ r1 r3 r5 r7 r8 r9 use_ctracer
concurrenciesunknownshow
light_threads do_threadingtriedr, r+ r* exmsgrC s f/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib64/python3.11/site-packages/coverage/collector.py__init__zCollector.__init__L s ^ ) *$8!& &$*D11[[3[tGW3[3[[[1 " -1!mm " ( ; u K % 'D *:D '$(D ! #D (D *9D '$)D ! $D D ,--
."DD F99VG__--D Dd D DEE E%(::
} ! !99VM 2 233D I4 I IJJ J +]**" &.&9##},,"++++&.&:&E##]**
&,&7#=(( # + + +YUYYYC c"" * + wt/@BR'S'S SZZ4++--
'} '
&DN
s AG' '
H 1HH strc T dt | dd| dS )Nz)idrW rY s rc __repr__zCollector.__repr__ s0 E"T((EEE0@0@0B0BEEEE covdatar context
Optional[str]c ` || _ || _ | j | j dS )z!Use `covdata` for recording data.N)rn rD set_context)rY rn ro s rc use_datazCollector.use_data s0 % !455555rm c | j j S )z0Return the class name of the tracer we're using.)rG __name__rk s rc rW zCollector.tracer_name s ))rm c | j D ]}| | j D ]}| dS )z * * 4"&"3F 6; ' ' . #~F 6? + + 6#'#5F 61 2 2 D*.*CF ' 6+ , , 8$($7F ! 6+ , , 8$($7F !
\\^^ F### rm framer eventargr Optional[TTraceFn]c t t j d | }|r
|||| }|S )z0Called on new threads, installs the real tracer.N)syssettracer )rY r r r r s rc _installation_tracez Collector._installation_trace9 sG T!%!3!3!5!5 'E5#&&B rm c Z | j r | j d g | _ g }t j }|r$t |dd }|rt |dg } | }n,# | j r | j d xY w| j | |D ];\ \ }}}} ||||| # t $ r} t d | d} ~ ww xY w| j r!| j | j
dS dS )z#Start collecting trace information.__self__Ntraces)linenoz3fullcoverage must be run with the C trace function.)r) pauserz r gettracegetattrr resumer TypeError RuntimeErrorrC r r )
rY traces0fn0tracer0r r r r r ra s
rc r zCollector.startF s ) R & & ( ( ( EGlnn 9 c:t44G
9!'8R88 ##%%BB
. $++---
%%% ,3 b b ' UE3
b5%V44444
b
b
b"#XYY_aa
b
> > N # #D$< = = = = = > >s$ *A? ?)B(C!!
D +C;;D c | j sJ | j d | ur3t d | j D ] }t d|d|j | j d | u sJ d| d| j d | | j | j r!| j d dS dS )z"Stop collecting trace information.r zself._collectors:z
z!Expected current collector to be z , but it's N)r) printrE r popr )rY r$ s rc stopzCollector.stopn s B t + + % & & &%
.
.,1,,!(,,---- #t+++ [ [ [4CSTVCW [ [ ,++
* R ' ' ) ) ) ) ) * *rm c J | j D ]w}| | }|rKt d t | D ]\ }}t |dd| x| j r | j d dS dS )z+Pause tracing, but be prepared to `resume`.z
Coverage.py tracer stats:z>20rh N)rz r get_statsr r itemsrC r )rY r} statskvs rc r zCollector.pause s l + +F KKMMM$$&&E
+3444 .u{{}} = = + +DAqQ///a//**** > * N # #D ) ) ) ) ) * *rm c | j D ]}| | j r!| j | j dS | dS )z Resume tracing after a `pause`.N)rz r rC r r r )rY r} s rc r zCollector.resume sc l F LLNNNN > ! N # #D$< = = = = = rm c > t d | j D S )zkHas any activity been traced?
Returns a boolean, True if any trace function was invoked.
c 3 > K | ]}| V d S )N)activity).0r} s rc z&Collector._activity.. s, @@6??$$@@@@@@rm )anyrz rk s rc _activityzCollector._activity s# @@4<@@@@@@rm new_contextc | | j r| j }|r|d|z z
}n|}| j | dS )z Switch to a new dynamic context.|N)
flush_datarD rn rr )rY r ro s rc r zCollector.switch_context s`
")G
-3,,!G )))))rm dispositionr c |j }|J |j }|j }| d|d d|_ d|_ dS )z.Disable the plugin mentioned in `disposition`.NzDisabling plug-in z due to previous exceptionF) file_tracer_coverage_plugin_coverage_plugin_namer8 _coverage_enabledtrace)rY r r plugin plugin_names rc r zCollector.disable_plugin sZ !- &&& - 2 P{PPPQQQ#( ! rm N)maxsizefilenamec , | | S )zBA locally cached version of file names mapped through file_mapper.)r3 )rY r s rc cached_mapped_filez Collector.cached_mapped_file s )))rm r| Mapping[str, T] Dict[str, T]c d}t d D ]>} t | } n2# t $ r }|}Y d}~7d}~ww xY wt |t
sJ | fd|D S )zz.Collector.mapped_file_dict.. s2 EEE$!Q1E''**AEEErm )rangerB r r rA Exception)rY r| runtime_err_r ra s ` rc mapped_file_dictzCollector.mapped_file_dict s q A
QWWYY
!
!
!
!
k955 5 55 EEEE%EEEEs !9
AA
Ar r c D | j |j dS )z1Record that `plugin` was disabled during the run.N)r addr )rY r s rc plugin_was_disabledz Collector.plugin_was_disabled s" !!&">?????rm c sdS j r j ri }t t t
t t f j }| D ]I\ }}g }|D ]:}|dz }|dz dz }|dz r|dz }|dz r|dz }|
||f ;|||< Jn7t t t
t t f j } j
| ndt t t
t t f j } j
| fd j D }
j
|
d S )
zSave the collected data to our associated `CoverageData`.
Data may have also been saved along the way. This forces the
last of the data to be saved.
Returns True if there was data to save, False if not.
Fi l l r l c . i | ]\ }}|j v||S r )r r s rc r z(Collector.flush_data.. s7
Q---
q---rm T)r r7 rJ r r re r intrw r r r r rn add_arcsr add_linesr add_file_tracersr~ ) rY arc_data packed_datafnamepackedstuplespackedl1l2 line_datar s ` rc r zCollector.flush_data s ~~ 5 ; E
B 35 "4SX
#6 B B &1&7&7&9&9
-
-NE7 F") 0 0 #g - $
62 =!W- % "HB!W- % "HB
r2h////&,HUOO
- S$t*_ 5tyAA L ! !$"7"7"A"A B B B B T#s3x- 0$)< &> &> &>P* * * *&
*
*
*
*! ! ! !A A A A
*
*
*
*" " " " Y&&&* * * '&*F F F F(@ @ @ @+ + + + + +rm r( ):r
__future__r r osr typesr typingr r r r r r
r r r
r r coverager coverage.configr
coverage.datar coverage.debugr coverage.dispositionr coverage.exceptionsr
coverage.miscr r coverage.pluginr coverage.pytracerr coverage.typesr r r r r r r coverage.tracerr! r" rF rT getenvstderrwriteexitr& r( r rm rc r s * ) " " " " " "
* * * * * * & & & & & & & & & & & & 0 0 0 0 0 0 + + + + + + < < < < < < < < * * * * * * & & & & & & ^B99999999KK ry'((C//
VWWW KKK GCLLH H H H H H H H H Hs
B AC C