Yf4 vdZddlZddlZddlZddlZddlZddlZddlZddlZddl m Z m Z ddl m Z ddlZddlmZddlmZddlmZddlmZmZmZmZmZmZmZmZerdd lmZdd l m!Z!dd l m"Z"dd l m#Z#dd l m$Z$ddl m%Z%ddl m&Z&ddl m'Z'ddl m(Z(ddl m)Z)ddl*m+Z+ddl,Zddlm-Z-m.Z.m/Z/e0Z1e+de0e1e2dZ3e%e2Z4e+de0e&e0e0e2e&e0dZ5e+dde0iZ6e+de%e5e%e4e%e3e$e1e6fdZ7e+dde0iZ8e)e0e2e0fZ9e)e9dfZ:e)e2e2fZ;e)e;e:e%e5fZm?Z?dd!l@mAZAe?d"d#ZBdaEd$ZFd%ZGd&ZHd'ZId(ZJd)ZKeKfd*ZLd+ZMd,ZNerd-ZOnd.ZOe2d/ZPGd0d1ZQGd2d3e ZRGd4d5eRZSGd6d7eRZTy#eC$rejZBdZAYnwxYw)8a This file is originally based on code from https://github.com/nylas/nylas-perftools, which is published under the following license: The MIT License (MIT) Copyright (c) 2014 Nylas Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions: The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software. THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. N)ABCabstractmethod)deque)PY311)LRUCache) TYPE_CHECKING)capture_internal_exceptionfilename_for_moduleget_current_thread_meta is_geventis_valid_sample_rateloggernanosecond_timeset_in_app_in_frames) FrameType)Any)Callable)Deque)Dict)List)Optional)Set)Sequence)Tuple) TypedDict)EventSamplingContext ProfilerModeProcessedSampleelapsed_since_start_ns thread_idstack_idProcessedFrame)abs_pathfilenamefunctionlinenomoduleProcessedThreadMetadatanameProcessedProfileframesstackssamplesthread_metadataProfileContext profile_id.) get_original) ThreadPooltimesleepec|d}|y|d}||dkDry|djd}|tjd|dkDryy)Nprofiles_samplerTprofiles_sample_rater _experimentszy_experiments['profiles_sample_rate'] is deprecated. Please use the non-experimental profiles_sample_rate option directly.F)getrwarning)optionsr;r<s S/var/www/highfloat_scraper/venv/lib/python3.12/site-packages/sentry_sdk/profiler.pyhas_profiling_enabledrBsr12#"#9:',@1,D">2667MN'  ! # cttjdyt}t rt j }ntj }|jd|d}n>|jdijd}|tjd|xs|}|tj k(s|dk(r t|an:|t j k(r t |antdj|tjd jtj tjtjty ) Nz%[Profiling] Profiler is already setupF profiler_moder=zk_experiments['profiler_mode'] is deprecated. Please use the non-experimental profiler_mode option directly.r7 frequencyzUnknown profiler mode: {}z.[Profiling] Setting up profiler in {mode} mode)modeT) _schedulerrdebugDEFAULT_SAMPLING_FREQUENCYr GeventSchedulerrHThreadSchedulerr>r? ValueErrorformatsetupatexitregisterteardown_profiler)r@rGdefault_profiler_moderEs rAsetup_profilerrUs' <=*I{ !0 4 4 / 4 4{{?#/0  NB7;;OL  $ NNB &>)>  --- G #$y9 /.. .$y9 4;;MJKK LL8??Z__?U OO%& rCc<ttjdayN)rIteardownrCrArSrSs JrCcrt|}|"|j}|j||}|"td|D}g}t |D]K\}} |j | } | "t | |||} |j| | |j| Mt|t|f} | ||fS)aA Extracts the stack starting the specified frame. The extracted stack assumes the specified frame is the top of the stack, and works back to the bottom of the stack. In the event that the stack is more than `MAX_STACK_DEPTH` frames deep, only the first `MAX_STACK_DEPTH` frames will be returned. maxlenc32K|]}t|ywrW)frame_id).0 raw_frames rA z extract_stack.. sFihy)Fs) rf_backappendtuple enumerater> extract_framesetlenhash) racachecwdmax_stack_depth raw_framesrc frame_idsr.ifidframer#s rA extract_stackrss o.J  !!)$    F:FFI FI&3 # =!#z!}c:E IIc5 ! e $:Y/H Y &&rCcZ|jj|jt|fSrW)f_code co_filenamef_linenoget_frame_name)ras rAr_r_#s&    ( ()*<*W XXrCc|jj} |jd}tj j |||t||xsd|d|jdS#t$rd}YNwxYw)N__name__r9)r%r)r&r'r() rurv f_globals Exceptionospathjoinr rw)rqrarlr%r)s rArgrg(s~++H$$Z0 GGLLh/'9ATF$$  sA(( A65A6c.|jjSrW)ru co_qualname)rrs rArxrxGs||'''rCcD|j}|j}|j} |rj|ddk(rbd|jvrT|jdjj D].}||j vsdj|j|cS |r`|ddk(rXd|jvrJ|jdj D].}||j vsdj|j|cS|S#ttf$rYvwxYw#ttf$rY|SwxYw)Nrselfz{}.{}cls) ru co_varnamesco_namef_locals __class____mro____dict__rOrzAttributeErrorrN)rrrurr+rs rArxrxMs.(( ~~ Nf,enn, >>&1;;CCBCs||+&~~cllDAAB Ne+U^^+ >>%088BCs||+&~~cllDAAB - +     +     s=A C73C7C7AD D 4D 7D D  DDgBcTeZdZ d dZdZdZdZdZdZdZ d Z d Z d Z d Z y)ProfileNc|tn||_||_tjj |_|j|_tdxsd|_ d|_ |j|_ d|_d|_i|_i|_g|_g|_g|_d|_||_y#t$r d|_ YRwxYw)NrF)rI schedulerhubuuiduuid4hexevent_idsampledr _default_active_thread_idactive_thread_id_start_timestamp_monotonic_nsstart_nsrstop_nsactiveindexed_framesindexed_stacksr.r/r0unique_samples_profile)r transactionrrs rA__init__zProfile.__init__s(1'8i (( #** *A)B1)E)J& $ 'EEDM       #  DM s)B::C  C ctd|_tjdj |jy)Nrz.[Profiling] updating active thread id to {tid})tid)r rrrJrOrs rAupdate_active_thread_idzProfile.update_active_thread_ids; 7 9! < < C C)) D  rCc2|jstjdd|_y|jtjdd|_ytj j }|jsd|_y|j}t|jdr |d|}n|d|d}n|djd}|tjdd|_yt|d stjd d|_ytjt|k|_|jrtjd ytjd jt|y)a Sets the profile's sampling decision according to the following precedence rules: 1. If the transaction to be profiled is not sampled, that decision will be used, regardless of anything else. 2. Use `profiles_sample_rate` to decide. z@[Profiling] Discarding profile because transaction is discarded.FNz@[Profiling] Discarding profile because profiler was not started.r;r<r=zA[Profiling] Discarding profile because profiling was not enabled. Profiling)sourcez>[Profiling] Discarding profile because of invalid sample rate.z [Profiling] Initializing profilezk[Profiling] Discarding profile because it's not included in the random sample (sample rate = {sample_rate})) sample_rate)rrrJr sentry_sdkScope get_client is_activer@callabler>r r?randomfloatrO)rsampling_contextclientr@rs rA_set_initial_sampling_decisionz&Profile._set_initial_sampling_decisionsu|| LLR !DL  >> ! LLR !DL !!,,.! DL .. GKK 23 45'"456FGK + , 8!"89K!.1556LMK   LLS !DL #K D NNP !DL  }}{);; << LL; < LL}EE %k 2E rCc|jr |jry|jsJdtjdd|_|j st |_|jj|y)NNo scheduler specifiedz[Profiling] Starting profileT)rrrrrJrrstart_profilingrs rAstartz Profile.starts[||t{{ ~~777~ 34 }}+-DM &&t,rCc|jr |jsy|jsJdtjdd|_t |_y)Nrz[Profiling] Stopping profileF)rrrrrJrrrs rAstopz Profile.stopsB||4;; ~~777~ 34 &( rCctjjj}|j}||_||f|_|j |SrW)rscoperget_isolation_scopeprofile_context_manager_stater)rr old_profiles rA __enter__zProfile.__enter__sG  &&::<mm  ',k&:#  rCcT|j|j\}}|`||_yrW)rrr)rtyvaluetbrrs rA__exit__zProfile.__exit__s( !88{  '# rCc<|jsy||jkry||jz }|tkDr|jy|xjdz c_t |}|D]\}\}}} ||j vrt|D]T\} } | |jvst|j|j| <|jj|| Vt|j |j |<|jj|D cgc]} |j| c} |jj|||j |dycc} w#t$r!tt!j"Y1wxYw)Nr )rrMAX_PROFILE_DURATION_NSrrstrrrfrrir.rdr/r0rr sysexc_info) rtssampleoffsetr!rr#ror.rpr_s rAwritez Profile.write's|{{    dmm# + + IIK  q !$V28 ; .C.(Iv ;4#6#66'0';: 8#4+>+>>: ;s+4-E1"A=E1E, 53E1,E11&FFctjDcic]-}t|jdt|ji/}}|j |j |j|dScc}w)Nr+r-) threadingrfridentr+r.r/r0)rthreadr1s rAprocesszProfile.processSsv$--/    FKK(    kkkk||.    s2A0cR|j}t|d|d|d|d|jd|jd||jdd|d d d t j it j t jd t jt jd |d |ddt|j|jz |dddt|j |jn |jdgd S)Nr.in_app_excludein_app_include project_root environmentpythonreleasestart_timestamp1 architecture)r+versionrr0contextstracetrace_id)idr+relative_start_nsrelative_end_nsrr) rrplatformrr timestamprdevicer}runtime transactions)rrr>rrmachinesystemrpython_implementationpython_versionrrrrr)r event_optr@rs rAto_jsonzProfile.to_jsongs7,,. H  $ % $ % N #  %==7   }}Y3"#45 0 0 2!)#++- !668#224 $J/%m4*-(+4<<$--+G'H )* 5g >z J(+00866!22)'& & rCctjj}|jsyt |j sy|j |j s*|jr|jjddy|jtkr?|jr|jjddtjdyy)NFrr) data_categoryinsufficient_dataz<[Profiling] Discarding profile because insufficient samples.T) rrrrrBr@r transportrecord_lost_eventrPROFILE_MINIMUM_SAMPLESrrJ)rrs rAvalidz Profile.valids!!,,.!$V^^4 << t||  22!3   !8 8  22'y3 LLW XrC)NN)rz __module__ __qualname__rrrrrrrrrrrrYrCrArrsF  '$R GR -) $*;X (1 frCrcTeZdZdZdZdZdZedZedZ dZ dZ d Z y ) Schedulerunknowncd|z |_|j|_td|_t |_y)Ng?rZr\)interval make_samplersamplerr new_profilesrhactive_profiles)rrGs rArzScheduler.__init__s6i ((* "-"urCc&|j|SrW)rPrs rArzScheduler.__enter__s  rCc$|jyrW)rX)rrrrs rArzScheduler.__exit__s  rCcyrWrYrs rArPzScheduler.setup rCcyrWrYrs rArXzScheduler.teardownrrCcy)z Ensure the scheduler is running. By default, this method is a no-op. The method should be overridden by any implementation for which it is relevant. NrYrs rAensure_runningzScheduler.ensure_runningsrCcZ|j|jj|yrW)r rrd)rrs rArzScheduler.start_profilings"    )rCcZtjtdfd}|S)N)max_sizec  js jsyt j}t} t j j Dcgc]\}}t|t| f}}}t|D]5} jj jj7g} jD]2} | jr| j!||"|j#| 4|D]} jj%| ycc}}w#t$r tt jYywxYw)z Take a sample of the stack on all the threads in the process. This should be called at a regular interval to collect samples. N)rrrirr_current_framesitemsrrsrr rrangeaddpopleftrrrdremove) argskwargsrnowrrrr_inactive_profilesrrkrlrs rA _sample_stackz-Scheduler.make_sampler.._sample_stacksM$$T-A-At001L!#C '*&9&9&;&A&A&C"UX}UE3?@(<( F$$(():):)B)B)DE F!# // 6>>MM#v. &,,W5 6- 5$$++G4 5G" +3<<>:  s#%D4 "D.D4.D44&EE)r}getcwdr)rrrkrls` @@rArzScheduler.make_samplers&iik#&= 5~rCN) rzrrrHrrrrrPrXr rrrYrCrArrsN D%     * ErCrcBeZdZdZdZdZfdZdZdZdZ dZ xZ S) rMzr This scheduler is based on running a daemon thread that will call the sampler at a regular interval. rzsentry.profiler.ThreadSchedulerct||d|_d|_d|_t j |_y)NrFF)superrrunningrpidrLocklockrrGrs rArzThreadScheduler.__init__4s8 9-  NN$ rCcyrWrYrs rArPzThreadScheduler.setup> rCcz|jr/d|_|j|jjyyyNFr!rrrs rArXzThreadScheduler.teardownB4 << DL{{&   "' rCctj}|jr|j|k(ry|j5|jr|j|k(r dddy||_d|_t j |j|jd|_ |jj dddy#t$rd|_d|_ YdddywxYw#1swYyxYw)aE Check that the profiler has an active thread to run in, and start one if that's not the case. Note that this might fail (e.g. in Python 3.12 it's not possible to spawn new threads at interpreter shutdown). In that case self.running will be False after running this function. NT)r+targetdaemonF) r}getpidr!r"r$rThreadr+runrr RuntimeErrorrr"s rAr zThreadScheduler.ensure_runningIsiik <r^sd6   #$*+   +FFH&)! O#YN  sm   N(!   !>*>*O,#H.E$EF   sN     G Wc\"H CHoG7Hd>.BBCNuX~%=>?O*,0L ! .0f$ -'`Y : ( -`d)rrj sslU'iU'pZ'iZ'w::LJs4F""F87F8