o CZ@@sdZddlZddlZddlmZddlmZmZddlm Z ddl m Z ddl m Z mZddlmZeeZz dd lmZmZWney]ed d krYejd ed dZYnwGdddeZddZGdddeZdS)z#Raw data collector for coverage.py.N)env)litemsrange) short_stackabs_file)CoverageExceptionisolate_module)PyTracer)CTracerCFileDispositionCOVERAGE_TEST_TRACERcz:*** COVERAGE_TEST_TRACER is 'c' but can't import CTracer! c@seZdZdZdS)FileDispositionz9A simple value type for recording what to do with a file.N)__name__ __module__ __qualname____doc__rrD/var/www/html/env/lib/python3.10/site-packages/coverage/collector.pyr$srcCs|jj}|dr |SdS)zKWho-Tests-What hack: Determine whether this frame begins a new who-context.testN)f_codeco_name startswith)framefn_namerrrshould_start_context)s rc@seZdZdZgZegdZddZddZddZ d d Z d d Z d dZ ddZ ddZddZddZddZddZddZddZdS) CollectoraCollects 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. )greenleteventletgeventthreadc Csb||_||_||_||_d|_t|_d|_|j |}t |dkr(t d||r.| nd|_ zC|j dkr@ddl}|j|_n3|j dkrOddl} | jj|_n$|j dkr]ddl} | j|_n|j d kse|j smddl} | |_nt d |Wntyt d |j fwttd d|_||rt|_ntpt|_|jturt|_d |_dSt|_d|_dS)aCreate 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. 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). Of these four values, only one can be supplied. Other values are ignored. Nrz$Conflicting concurrency settings: %srrr r!r"zDon't understand concurrency=%sz?Couldn't trace with concurrency=%s, the module isn't installed. COVERAGE_WTWTF) should_trace check_includewarnbranch threadingroriginconcur_id_funcSUPPORTED_CONCURRENCIES intersectionlenrpop concurrencyr getcurrenteventlet.greenthread greenthreadr! ImportErrorintosgetenvwtwresetr _trace_classr r file_disposition_classsupports_pluginsr) selfr%r&timidr(r'r0these_concurrenciesrr r!r)rrr__init__IsV                zCollector.__init__cCsdt||fS)Nz)id tracer_namer=rrr__repr__szCollector.__repr__cCs|jjS)z0Return the class name of the tracer we're using.)r:rrCrrrrBszCollector.tracer_namecCs"|j|jD]}|qdS)znsz&Collector._activity..)anyrGrCrrr _activityhszCollector._activitycCs$|j|i}|jD]}||_q dS)z1Who-Tests-What hack: switch to a new who-context.N)rM setdefaultrGrE)r= new_contextrErJrrrrSps zCollector.switch_contextcCs|sdSdd}|jr|||jn|||j|||j|jrPddl}d t }t |d}||j |Wdn1sKwY|dS) ztSave the collected data to a `CoverageData`. Returns True if there was data to save, False if not. Fc Ss`d}tdD]}zt|}Wnty"}z|}WYd}~qd}~wwn|tdd|DS)z;Return a dict like d, but with keys modified by `abs_file`.Ncss |] \}}t||fVqdSrvr)rxruvrrrrysz=Collector.save_data..abs_file_dict..)rr RuntimeErrordict)d runtime_err_itemsexrrr abs_file_dicts  z*Collector.save_data..abs_file_dictrNzcoverage_wtw_{:06}.pywT)r{r(add_arcsrE add_linesadd_file_tracersrNr8pprintror6getpidopenrMrK)r=covdatarrout_filewtw_outrrr save_dataxs zCollector.save_dataN)rrrrrcsetr,r@rDrBrKr9rYr^rVrprdrgr{rSrrrrrr1s$ Z0) )   r)rr6rZcoveragercoverage.backwardrrcoverage.debugrcoverage.filesr coverage.miscrr coverage.pytracerr coverage.tracerr r r4r7stderrwriteexitobjectrrrrrrrs*