ó …¾^Yc@s"dZddlZddlZddlmZddlmZddlmZddl m Z m Z ddl m Z e eƒZyddlmZmZWnLek rèejd ƒd krßejjd ƒejd ƒndZnXd efd„ƒYZd„Zdefd„ƒYZdS(s#Raw data collector for coverage.py.iÿÿÿÿN(tenv(tiitems(tabs_file(tCoverageExceptiontisolate_module(tPyTracer(tCTracertCFileDispositiontCOVERAGE_TEST_TRACERtcs:*** COVERAGE_TEST_TRACER is 'c' but can't import CTracer! itFileDispositioncBseZdZRS(s9A simple value type for recording what to do with a file.(t__name__t __module__t__doc__(((s4/tmp/pip-build-hU8Cw8/coverage/coverage/collector.pyR #scCs#|jj}|jdƒr|SdS(sKWho-Tests-What hack: Determine whether this frame begins a new who-context.ttestN(tf_codetco_namet startswith(tframetfn_name((s4/tmp/pip-build-hU8Cw8/coverage/coverage/collector.pytshould_start_context(s t CollectorcBsªeZdZgZeddddgƒZd„Zd„Zd„Zd„Z d „Z d „Z d „Z d „Z d „Zd„Zd„Zd„Zd„Zd„ZRS(sCollects 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. tgreenletteventlettgeventtthreadc Csø||_||_||_||_d|_d|_|jj|ƒ}t |ƒdkrmt d|ƒ‚n|r|j ƒnd|_ yÆ|j dkrµddl }|j|_n˜|j dkrâddl} | jj|_nk|j dkr ddl} | j|_nA|j d ks%|j r=ddl} | |_nt d |ƒ‚Wn'tk rwt d |j fƒ‚nXttjd d ƒƒ|_|jƒ|r¯t|_ntp¸t|_|jtkrât|_t|_nt|_t |_dS(s€Create a collector. `should_trace` is a function, taking a file name, 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, 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. is$Conflicting concurrency settings: %stRiÿÿÿÿNRRRsDon't understand concurrency=%ss?Couldn't trace with concurrency=%s, the module isn't installed.t COVERAGE_WTWi(!t should_tracet check_includetwarntbranchtNonet threadingtconcur_id_functSUPPORTED_CONCURRENCIESt intersectiontlenRtpopt concurrencyRt getcurrentteventlet.greenthreadt greenthreadRt ImportErrortinttostgetenvtwtwtresetRt _trace_classRRtfile_disposition_classtTruetsupports_pluginsR tFalse( tselfRRttimidRRR'tthese_concurrenciesRRRR!((s4/tmp/pip-build-hU8Cw8/coverage/coverage/collector.pyt__init__GsL                 cCsdt|ƒ|jƒfS(Ns(tidt tracer_name(R6((s4/tmp/pip-build-hU8Cw8/coverage/coverage/collector.pyt__repr__žscCs |jjS(s0Return the class name of the tracer we're using.(R1R (R6((s4/tmp/pip-build-hU8Cw8/coverage/coverage/collector.pyR;¡scCs/|jjƒx|jD]}|jƒqWdS(s<Clear out existing data, but stay ready for more collection.N(tdatatclearttracerstreset_activity(R6ttracer((s4/tmp/pip-build-hU8Cw8/coverage/coverage/collector.pyt _clear_data¥s cCsui|_i|_|j|jdes(tanyR?(R6((s4/tmp/pip-build-hU8Cw8/coverage/coverage/collector.pyt _activity_scCs6|jj|iƒ}x|jD]}||_qWdS(s1Who-Tests-What hack: switch to a new who-context.N(RDt setdefaultR?R=(R6t new_contextR=RA((s4/tmp/pip-build-hU8Cw8/coverage/coverage/collector.pyRJgscCsÍ|jƒstSd„}|jr;|j||jƒƒn|j||jƒƒ|j||jƒƒ|jr¿ddl }dj t j ƒƒ}t |dƒ}|j |j|ƒWdQXn|jƒtS(stSave the collected data to a `CoverageData`. Returns True if there was data to save, False if not. cSstd„t|ƒDƒƒS(s;Return a dict like d, but with keys modified by `abs_file`.css'|]\}}t|ƒ|fVqdS(N(R(RlRjtv((s4/tmp/pip-build-hU8Cw8/coverage/coverage/collector.pys ys(tdictR(td((s4/tmp/pip-build-hU8Cw8/coverage/coverage/collector.pyt abs_file_dictwsiÿÿÿÿNscoverage_wtw_{:06}.pytw(RnR5Rtadd_arcsR=t add_linestadd_file_tracersRER/tpprinttformatR-tgetpidtopenRDRBR3(R6tcovdataRtRytout_filetwtw_out((s4/tmp/pip-build-hU8Cw8/coverage/coverage/collector.pyt save_dataos      (R R R RYtsetR#R9R<R;RBR0RPRURMReRZR]RnRJR€(((s4/tmp/pip-build-hU8Cw8/coverage/coverage/collector.pyR/s" W    0 ) )   (R R-RQtcoverageRtcoverage.backwardRtcoverage.filesRt coverage.miscRRtcoverage.pytracerRtcoverage.tracerRRR+R.tstderrtwritetexitR tobjectR RR(((s4/tmp/pip-build-hU8Cw8/coverage/coverage/collector.pyts$