o g<@sUdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z m Z ddlmZmZmZmZmZmZmZmZddlmZmZddlmZmZmZmZmZm Z m!Z!m"Z"dZ#e$ed dZ%erse%dusqJeZ&e#rGd d d Z'e'e%d Z%e%dusJej(ed d d dZe)Z*de+d<d+ddZ,d,ddZ-d-ddZ.n d+d dZ,d-d!dZ.ej/Gd"d#d#Z0d.d'd(Z1Gd)d*d*e!Z2dS)/zBCallback functions and support for sys.monitoring data collection.) annotationsN)CodeType FrameType)AnyCallableDictListOptionalSet TYPE_CHECKINGcast)short_filename short_stack) AnyCallableTArcTFileDispositionTLineNo TTraceDataTTraceFileData TracerCoreTWarnFnF monitoringc@s$eZdZdZddd Zdd d ZdS)LoggingWrapperz*Wrap a namespace to log all its functions.wrappedr namespacestrreturnNonecCs||_||_dSN)rr)selfrrr O/var/www/html/bloggers_ems/venv/lib/python3.10/site-packages/coverage/sysmon.py__init__=s zLoggingWrapper.__init__nameCallable[..., Any]csdfdd }|S)Nargsrkwargsrcs2tjd||tj|i|S)N.)logrgetattrr)r%r&r#rr r!_wrappedBsz,LoggingWrapper.__getattr__.._wrapped)r%rr&rrrr )rr#r+r r*r! __getattr__AszLoggingWrapper.__getattr__N)rrrrrr)r#rrr$)__name__ __module__ __qualname____doc__r"r,r r r r!r:s rzsys.monitoringT)fullshort_filenames frame_idszSet[int] seen_threadsmsgrrrc Cst}tttj}||dd}|tvr+t|t d|d|dt dD]&}t |d}t |d|d ||d d Wd n1sNwYq-d S) z1Write a message to our detailed debugging log(s).iw07dz New thread  z: )z /tmp/foo.outa:: T)fileflushN) osgetpidr int threadingcurrent_threadidentr4addr(ropenprint)r5pidtidtslugfilenamefr r r!r(Ps   r(argrcCsJt|tr!dt|dd|jddt|jd|jdSt|S)z)Make a customized repr for logged values.z) isinstanceridco_namer co_filenameco_firstlinenorepr)rKr r r!arg_repres  rVnames Optional[str]rcsdfdd }|S)z%Decorate a function to log its calls.methodrrcstdfdd }|S)Nrrr%rc sz._decorator.._wrapped)rrr%rrr) functoolswraps)rYr+rW)rYr! _decoratorrspanopticon.._decoratorN)rYrrrr rWrpr ror! panopticonosrscCdS)zAWrite a message to our detailed debugging log(s), but not really.Nr )r5r r r!r(scGsddd}|S)z5Decorate a function to log its calls, but not really.methrrcSs|Srr )rur r r!rpsrqN)rurrrr rrr r r!rss c@s*eZdZUdZded<ded<ded<dS) CodeInfoz/The information we want about each code object.booltracingzOptional[TTraceFileData] file_datazDict[int, int] | None byte_to_lineN)r-r.r/r0__annotations__r r r r!rvs  rvcoderDict[int, int]cCs>i}|D]\}}}|durt||dD]}|||<qq|S)z6Make a dict mapping byte code offsets to line numbers.N)co_linesrange)r|b2lbstartbendlinenoboffsetr r r!bytes_to_liness rc@seZdZdZd6ddZd7d d Zed8d d Zed8d dZed8ddZ d9ddZ d8ddZ d:ddZ e r?d;ddZnd;ddZedddd.d/Zedd0d?d2d3Zedd0d?d4d5Zd&S)@ SysMonitorzHPython implementation of the raw data tracer for PEP669 implementations.tool_idr?rrcCs`|d|_||d|_d|_|||_i|_g|_i|_i|_d|_ddi|_ d|_ d|_ dS)NFstartsr) trace_arcsshould_start_contextswitch_contextmyid code_infos code_objects last_lineslocal_event_codes sysmon_onstatsstopped _activity)rrr r r!r"s" zSysMonitor.__init__rcCs@tdd|jD}t|j}dt|dd|d|dS)Ncss|]}t|VqdSr)len).0vr r r! sz&SysMonitor.__repr__..z)sumdatavaluesrrQ)rpointsfilesr r r!__repr__s zSysMonitor.__repr__cCsd|_tdus Jt|jdttj|j}tj}|jrMt |j|j |j B||j |j ||j |j||j|j||j |j||j|jnt |j|j ||j |j ||j|jtd|_dS)zStart this Tracer.FNz coverage.pyT)rre use_tool_idrrmpartialregister_callbackeventsrrfPY_START PY_UNWINDsysmon_py_start PY_RESUMEsysmon_py_resume_arcs PY_RETURNsysmon_py_return_arcssysmon_py_unwind_arcsLINEsysmon_line_arcssysmon_line_linesrestart_eventsr)rregisterrr r r!starts(   zSysMonitor.startcCs`|jsdStdus Jt|jd|jD] }t|j|dqi|_t|jd|_dS)zStop this Tracer.NrF)rrerfrrrset_local_events free_tool_id)rr|r r r!stops   zSysMonitor.stopcCs |dS)z+The process has forked, clean up as needed.N)rrr r r! post_forks zSysMonitor.post_forkrwcCs|jS)zHas there been any activity?rrr r r!activity szSysMonitor.activitycCs d|_dS)zReset the activity() flag.FNrrr r r!reset_activity s zSysMonitor.reset_activityOptional[Dict[str, int]]cCrt)z+Return a dictionary of statistics, or None.Nr rr r r! get_statsszSysMonitor.get_statsrcCstjjjSz2Get the frame of the Python code we're monitoring.inspect currentframef_backrr r r! callers_frames zSysMonitor.callers_framecCs tjjSrrrr r r!r s r|@rinstruction_offset MonitorReturnc Csxd|_|jdd7<|jt|}d}d}|dur"|j}|j}|dur|j}|j|}|durHt j }t r=|j }| ||}||j|<|j}|rk|j} | dusVJ| |jvrat|j| <|j| }t|} nd}d} t||| d|jt|<|j||rtjj} |jrtdusJt|j|| j| jB| jB||j t|<|r|j!r|"}|j# |j$|<dStjj%S)z-Handle sys.monitoring.events.PY_START events.TrN)rxryrz)&rrrgetrQrxryrSshould_trace_cacherrrLOG should_tracetracesource_filenamersetrrvrr_rgrrrrerrrrrrrrrTrDISABLE) rr|r code_info tracing_coderyrIdispframe tracenamerrr r r!r$sh            zSysMonitor.sysmon_py_startcCs|}|j|j|<dS)zBHandle sys.monitoring.events.PY_RESUME events for branch coverage.N)rf_linenor)rr|rrr r r!rhsz SysMonitor.sysmon_py_resume_arcsNretvalobjectcCsr|}|jt|}|dur0|jdur0|j|}|dur0||j f}ttt |j ||j |ddS)zBHandle sys.monitoring.events.PY_RETURN events for branch coverage.N) rrrrQryrrTr r rrCpop)rr|rrrr last_linearcr r r!rps  z SysMonitor.sysmon_py_return_arcsrl exception BaseExceptioncCs|}|j|d}t|trdS|jt|}|dur:|jdur<|dur>||j f}t t t |j |dSdSdSdS)zBHandle sys.monitoring.events.PY_UNWIND events for branch coverage.N)rrrrP GeneratorExitrrrQryrTr r rrC)rr|rrrrrrr r r!rs  z SysMonitor.sysmon_py_unwind_arcsline line_numbercCs6|jt|}|jdurttt|j|tjj S)z;Handle sys.monitoring.events.LINE events for line coverage.N) rrQryr r rrCrgrr)rr|rrr r r!rs zSysMonitor.sysmon_line_linescCsd|jt|}d}|jdur0|}|j|}|dur+||f}ttt|j |||j|<|S)z=Handle sys.monitoring.events.LINE events for branch coverage.N) rrQryrrrr r rrC)rr|rrrkrrrr r r!rs   zSysMonitor.sysmon_line_arcs)rr?rr)rr)rr)rrw)rr)rr)r|rrr?rr)r|rrr?rrrr)r|rrr?rrrr)r|rrr?rr)r-r.r/r0r"rrsrrrrrrrrrrrrrrr r r r!rs8           C      r)r5rrr)rKrrr)rWrXrr)r|rrr})3r0 __future__r dataclassesrmrr=os.pathrgr@rctypesrrtypingrrrrr r r r coverage.debugr rcoverage.typesrrrrrrrrrr)rerrrrr4r{r(rVrs dataclassrvrrr r r r!sH ( (       "