S>{i dZddlZddlZddlZddlZddlZddlZddlZddlZddl m Z ddl Z ddl m Z mZddlmZddlmZddlmZmZmZmZmZmZerddlmZdd lmZdd lmZdd lmZdd lm Z dd lm!Z!ddlm"Z"ddlm#Z#ddlm$Z$ddlm%Z%ddl&m'Z'ddl(Z ddlm)Z)m*Z*e+Z,e'de+e,e-dZ.e!e-Z/e'de+e"e+e+e-e"e+dZ0e'dde+iZ1e'de!e0e!e/e!e.e e,e1fdZ2e'dde+iZ3e%e+e-e+fZ4e%e4dfZ5e%e-e-fZ6e%e6e5e!e0fZ7e$e%e,e7fZ8 ddl9m:Z;dd lZ>dd!l?m@Z@e=d"d#ZAd&ZDdaEd'ZFd(ZGd)ZHd*ZId+ZJd,ZKeKfd-ZLd.ZMd/ZNerd0ZOnd1ZOe-d2ZPddZ@Y|wxYw)=a 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)deque)PY33PY311)LRUCache) TYPE_CHECKING)capture_internal_exceptionfilename_for_moduleis_valid_sample_rateloggernanosecond_timeset_in_app_in_frames) FrameType)Any)Callable)Deque)Dict)List)Optional)Set)Sequence)Tuple) TypedDict)SamplingContext ProfilerModeProcessedSampleelapsed_since_start_ns thread_idstack_idProcessedFrame)abs_pathfilenamefunctionlinenomoduleProcessedThreadMetadatanameProcessedProfileframesstackssamplesthread_metadataProfileContext profile_id.)get_hub) get_originalis_module_patched) ThreadPooltimesleepcyNr8Q/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/sentry_sdk/profiler.pyget_gevent_hubr;sr9cyNFr8)argskwargss r:r2r2sr9c2tdxs tdS)N threading_thread)r2r8r9r: is_geventrCs [ ) I->y-IIr9ecf|d}|y|d}||dkDry|djd}||dkDryy)Nprofiles_samplerTprofiles_sample_rater _experimentsF)get)optionsrGrHs r:has_profiling_enabledrLs_12#"#9:',@1,D">2667MN',@1,D r9cttjdytstjdyt }t rtj}ntj}|jd|d}n%|jdijdxs|}|tjk(s|dk(r t|an:|tjk(r t|antdj|tjd jtj tjtjt y ) Nz%[Profiling] Profiler is already setupFz+[Profiling] Profiler requires Python >= 3.3 profiler_moderIr5 frequencyzUnknown profiler mode: {}z.[Profiling] Setting up profiler in {mode} mode)modeT) _schedulerr debugrwarnDEFAULT_SAMPLING_FREQUENCYrCGeventSchedulerrQThreadSchedulerrJ ValueErrorformatsetupatexitregisterteardown_profiler)rKrPdefault_profiler_moderNs r:setup_profilerr_s" <=  AB*I{ !0 4 4 / 4 4{{?#/0  KK + / / @ %$  --- G #$y9 /.. .$y9 4;;MJKK LL8??Z__?U OO%& r9c<ttjdayr7)rRteardownr8r9r:r]r]s Jr9crt|}|"|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|ywr7)frame_id).0 raw_frames r: z extract_stack..sFihy)Fs) rf_backappendtuple enumeraterJ extract_framesetlenhash) ricachecwdmax_stack_depth raw_framesrk frame_idsr*ifidframers r: extract_stackr{s o.J  !!)$    F:FFI FI&3 # =!#z!}c:E IIc5 ! e $:Y/H Y &&r9cZ|jj|jt|fSr7)f_code co_filenamef_linenoget_frame_name)ris r:rgrg+s&    ( ()*<*W XXr9c|jj} |jd}tj j |||t||xsd|d|jdS#t$rd}YNwxYw)N__name__rE)r!r%r"r#r$) r}r~ f_globals Exceptionospathjoinr r)ryrirtr!r%s r:roro0s~++H$$Z0 GGLLh/'9ATF$$  sA(( A65A6c.|jjSr7)r} co_qualname)rzs r:rrOs||'''r9c,|j}|j}|j} |rj|ddk(rbd|jvrT|jdjj D].}||j vsdj|j|cS |r`|ddk(rXd|jvrJ|jdj D].}||j vsdj|j|cS|S#t$rYpwxYw#t$rY|SwxYw)Nrselfz{}.{}cls) r} co_varnamesco_namef_locals __class____mro____dict__rYrAttributeError)rzr}rr'rs r:rrUs$(( ~~ Nf,enn, >>&1;;CCBCs||+&~~cllDAAB Ne+U^^+ >>%088BCs||+&~~cllDAAB -         s=A C73C7C7ADD4D7 DD DDgBcz| |j}||S trt}| |jS t j j}||S t jj}||S y#t$rYwwxYw#t$rYcwxYw#t$rYNwxYw#t$rYywxYw)zK Try to get the id of the current thread, with various fall backs. N)identrrCr; thread_identrAcurrent_thread main_thread)threadr gevent_hubcurrent_thread_idmain_thread_ids r:get_current_thread_idrs  I$  %{#%  ! !...  %446<<  ($ $ )  "..066  %! ! & ?   "            sEB B!B!B. B  B  BB B+*B+. B:9B:cTeZdZ d dZdZdZdZdZdZdZ d Z d Z d Z d Z y)ProfileNc|tn||_||_tjj |_|j|_txsd|_ d|_ |j|_ d|_d|_i|_i|_g|_g|_g|_d|_||_y#t$r d|_ YRwxYw)NrF)rR schedulerhubuuiduuid4hexevent_idsampledr_default_active_thread_idactive_thread_id_start_timestamp_monotonic_nsstart_nsrstop_nsactiveindexed_framesindexed_stacksr*r+r,unique_samples_profile)r transactionrrs r:__init__zProfile.__init__s(1'8i (( #** *?)@)EA& $ 'EEDM       #  DM s&B77C  C ct|_tjdj |jy)Nz.[Profiling] updating active thread id to {tid})tid)rrr rSrYrs r:update_active_thread_idzProfile.update_active_thread_ids6 5 7 < C C)) D  r9cB|jstjdd|_y|jtjdd|_y|jxst j j}|j}|d|_y|j}t|jdr |d|}n|d|d}n|djd}|tjdd|_yt|d stjd d|_ytjt|k|_|jrtjd ytjd j!t|y)a Sets the profile's sampling decision according to the following precdence 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.rGrHrIzA[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)rr rSrr sentry_sdkHubcurrentclientrKcallablerJr warningrandomfloatrY)rsampling_contextrrrKrs r:_set_initial_sampling_decisionz&Profile._set_initial_sampling_decisions}|| LLR !DL  >> ! LLR !DL hh0*..00 > DL .. GKK 23 45'"456FGK + , 8!"89K!.1556LMK   LLS !DL #K D NNP !DL  }}{);; << LL; < LL}EE %k 2E r9c|jr |jry|jsJdtjdd|_|j st |_|jj|y)NNo scheduler specifiedz[Profiling] Starting profileT)rrrr rSrr start_profilingrs r:startz Profile.start5s[||t{{ ~~777~ 34 }}+-DM &&t,r9c|jr |jsy|jsJdtjdd|_|jj |t |_y)Nrz[Profiling] Stopping profileF)rrrr rSstop_profilingr rrs r:stopz Profile.stopAsT||4;; ~~777~ 34  %%d+&( r9c|jxstjj}|jd\}}|j }||_|||f|_|j|S)N)rrrr_stackprofile_context_manager_stater)rr_scope old_profiles r: __enter__zProfile.__enter__LsXhh0*..00::b>5mm  '*E;&?#  r9cV|j|j\}}}|`||_yr7)rrr)rtyvaluetbrrrs r:__exit__zProfile.__exit__Zs* $ ; ;5+  '# r9c<|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_NSrrstrrrnrrqr*rlr+r,rrsysexc_info) rtssampleoffsetrrrrwr*rxrgs r:writez Profile.writecs|{{    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))rArnrrr'r*r+r,)rrr-s r:processzProfile.processsv$--/    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 timestamprdevicerruntime transactions)rr rJrrmachinesystemrpython_implementationpython_versionrrrrr)r event_optrKrs r:to_jsonzProfile.to_jsons7,,. H  $ % $ % N #  %==7   }}Y3"#45 0 0 2!)#++- !668#224 $J/%m4*-(+4<<$--+G'H )* 5g >z J(+00866!22)'& & r9c|jxstjj}|j}|yt |j sy|j |js*|jr|jjddy|jtkr?|jr|jjddtjdyy)NFrr) data_categoryinsufficient_dataz<[Profiling] Discarding profile because insufficient samples.T)rrrrrrLrKr transportrecord_lost_eventrPROFILE_MINIMUM_SAMPLESr rS)rrrs r:validz Profile.validshh0*..00 >$V^^4 << t||  22!3   !8 8  22'y3 LLW Xr9)NN)r __module__ __qualname__rrrrrrrrrrr r8r9r:rrsF  '$R JX - ) $*;X (1 fr9rcFeZdZdZdZdZdZdZdZdZ dZ d Z d Z y ) Schedulerunknowncd|z |_|j|_td|_t |_y)Ng?rbrd)interval make_samplersamplerr new_profilesrpactive_profiles)rrPs r:rzScheduler.__init__s6i ((* "-"ur9c&|j|Sr7)rZrs r:rzScheduler.__enter__s  r9c$|jyr7)ra)rrrrs r:rzScheduler.__exit__s  r9ctr7NotImplementedErrorrs r:rZzScheduler.setup!!r9ctr7rrs r:razScheduler.teardown rr9ctr7rrs r:ensure_runningzScheduler.ensure_runningrr9cZ|j|jj|yr7)rrrlrrs r:rzScheduler.start_profilings"    )r9cyr7r8r!s r:rzScheduler.stop_profiling r9cZtjtdfd}|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)rrrqr r_current_framesitemsrr{rrrrangeaddpopleftrrrlremove) r>r?rnowrrzrrinactive_profilesrrsrtrs r: _sample_stackz-Scheduler.make_sampler.._sample_stack#sM$$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)rgetcwdr)rr0rsrts` @@r:rzScheduler.make_samplers&iik#&= 5~r9N) rr r rQrrrrZrarrrrr8r9r:rrs5 D% """*  Er9rcBeZdZdZdZdZfdZdZdZdZ dZ xZ S) rWzr This scheduler is based on running a daemon thread that will call the sampler at a regular interval. rzsentry.profiler.ThreadSchedulerctt| |d|_d|_d|_t j|_y)NrOF) superrWrrunningrpidrALocklockrrPrs r:rzThreadScheduler.__init__ns: ot- -B  NN$ r9cyr7r8rs r:rZzThreadScheduler.setupxr#r9cz|jr/d|_|j|jjyyyr=r5rrrs r:razThreadScheduler.teardown|4 << DL{{&   "' r9ctj}|jr|j|k(ry|j5|jr|j|k(r dddy||_d|_t j |j|jd|_ |jjdddy#1swYyxYw)NT)r'targetdaemon) rgetpidr5r6r8rAThreadr'runrrrr6s r:rzThreadScheduler.ensure_runningsiik <rosx6   **++?H&)! O#YN  sm   N(!   !>*>*O,#H.E$EF   sN     G Wc\"H CHoG7Hd>.BBCNuX~%=>?O0=,0L"J  ! "1h$ -'`Y : ( -`d)+\yfyx ppfF'iF'RS'iS'Q ::L J s(F&&GG