Z> dd!l?m@Z@ e=d"d# ZAn# eB$ r d$ Z;ejC ZAd% Z>dZ@Y nw xY wd& ZDdaEd'ZFd(ZGd) ZHd* ZId+ ZJd,ZK ejL ZMeMeKfd-ZNd. ZOd/ ZPerd0 ZQnd1 ZQ e-d2 ZRd t d pt d S )N threading_thread)r2 r8 r9 r: is_geventrC s [ ) ) I->y-I-IIr9 e c | d }|dS | d }||dk rdS | d d }||dk rdS dS )Nprofiles_samplerTprofiles_sample_rater _experimentsF)get)optionsrG rH s r: has_profiling_enabledrL sp 12#t"#9:',@1,D,Dt">2667MNN',@1,D,Dt 5r9 c t t j d dS t st j d dS t
}t
r
t j }n t j }|
d | d }n+|
di
d p|}|t j k s|dk rt | a nC|t j k rt | a n"t d | t j d t j
t
t j t d S ) Nz%[Profiling] Profiler is already setupFz+[Profiling] Profiler requires Python >= 3.3
profiler_moderI r5 frequencyzUnknown profiler mode: {}z.[Profiling] Setting up profiler in {mode} mode)modeT)
_schedulerr debugr warnDEFAULT_SAMPLING_FREQUENCYrC GeventSchedulerrQ ThreadSchedulerrJ
ValueErrorformatsetupatexitregisterteardown_profiler)rK rP default_profiler_moderN s r: setup_profilerr_ sp <===u ABBBu*I{{ 5
!0 4 / 4 {{?##/ 0
KK + + / / @ @
%$ --- G # #$y999
/. . .$y999
4;;MJJKKK
L8??Z_?UU
O%&&& 4r9 c J t t d a d S r7 )rR teardownr8 r9 r: r] r] s%
JJJr9 c t | }| | j }| | |} | t d |D }g }t | D ]^\ }} | | }
|
-t
| || | }
| | |
| |
_t | 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.
maxlenNc 3 4 K | ]}t | V d S r7 )frame_id).0 raw_frames r: z extract_stack.. s* FFihy))FFFFFFr9 )
r f_backappendtuple enumeraterJ
extract_framesetlenhash) ri cachecwdmax_stack_depth
raw_framesrk frame_idsr* ifidframer s r:
extract_stackr{ s o...J
!)$$$
FF:FFFFFI
FI&& 3 # =!#z!}c::E IIc5 ! ! !
e :Y/H Y &&r9 c D | j j | j t | fS r7 )f_code co_filenamef_linenoget_frame_name)ri s r: rg rg . s ()*W>W XXr9 c |j j } |j d }n# t $ r d }Y nw xY wt j || |t || pd | d |j dS )N__name__rE )r! r% r" r# r$ ) r} r~ f_globals Exceptionospathjoinr r )ry ri rt r! r% s r: ro ro 3 s +H$Z0 GLLh//'99ATF$ s
++c | j j S r7 )r} co_qualname)rz s r: r r R s
|''r9 c | j }|j }|j } |rU|d dk rId| j v r@| j d j j D ](}||j v r d |j | c S )n# t $ r Y nw xY w |rP|d dk rDd| j v r;| j d j D ](}||j v r d |j | c S )n# t $ r Y nw xY w|S )Nr selfz{}.{}cls)
r} co_varnamesco_namef_locals __class____mro____dict__rY r AttributeError)rz r} r r' r s r: r r X sV ( ~
B Nf,,en,, >&1;C B BCs|++ &~~clD A AAAA , D
B Ne++U^++ >%08 B BCs|++ &~~clD A AAAA , D s1 AA/ -A/ /
A<;A< AC C
C C g Bc h | | j }||S n# t $ r Y nw xY wt r(t }| |j S # t $ r Y nw xY w t j j }||S n# t $ r Y nw xY w t j j }||S n# t $ r Y nw xY wdS )zK
Try to get the id of the current thread, with various fall backs.
N)identr rC r; thread_identrA current_thread main_thread)threadr
gevent_hubcurrent_thread_idmain_thread_ids r: get_current_thread_idr s* I$ % D
{{ #%%
!
!..!
% 4 6 6 < ($ $ )
".006 %! ! &
4sA
A
AAA4 4
B BB" "
B/.B/c V e Zd Z d
dZd Zd Zd Zd Zd Zd Z d Z
d
Z d Z d Z
dS )ProfileNc |t n|| _ || _ t j j | _ |j | _ t pd| _ d | _
|j | _ n# t $ r
d| _ Y nw xY wd| _ d| _ i | _ i | _ g | _ g | _ g | _ d| _ | |_ d S )Nr F)rR schedulerhubuuiduuid4hexevent_idsampledr _default_active_thread_idactive_thread_id _start_timestamp_monotonic_nsstart_nsr stop_nsactiveindexed_framesindexed_stacksr* r+ r, unique_samples_profile)r transactionr r s r: __init__zProfile.__init__ s (1'8i
(
#* *?)@)@)EA& $ ' EDMM DMMM # s A+ +A?>A?c t | _ t j d | j d S )Nz.[Profiling] updating active thread id to {tid})tid)r r r rS rY r s r: update_active_thread_idz Profile.update_active_thread_id sM 5 7 7 < C C)
D
r9 c H | j s t j d d| _ dS | j t j d d| _ dS | j pt
j j }|j }| d| _ dS |j }t | d r |d | }n,|d |d }n|d d }| t j d d| _ dS t |d
s t j
d d| _ dS t j t | k | _ | j rt j d dS t j d
t | dS )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.rG rH rI 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)r r rS r r
sentry_sdkHubcurrentclientrK callablerJ r
warningrandomfloatrY )r sampling_contextr r rK r s r: _set_initial_sampling_decisionz&Profile._set_initial_sampling_decision s | LR
!DL F > ! LR
!DL Fh0*.0 > DL F. GKK 233 4 4 N5'"456FGGKK
+
,
8!"89KK!.1556LMMK LS
!DL F#K DDD NP
!DL F
}{););; < L; < < < < < L} E E %k 2 2 E
r9 c | j r| j rd S | j s
J d t j d d| _ | j st
| _ | j | d S )NNo scheduler specifiedz [Profiling] Starting profileT)r r r r rS r r start_profilingr s r: startz
Profile.start8 s{ | t{ F~77 777~ 3444 } . + - -DM &&t,,,,,r9 c | j r| j sd S | j s
J d t j d d| _ | j | t
| _ d S )Nr z [Profiling] Stopping profileF)r r r r rS stop_profilingr r r s r: stopz Profile.stopD so | 4; F~77 777~ 3444 %%d+++&(( r9 c | j pt j j }|j d \ }}|j }| |_ |||f| _ | | S )N)r r r r _stackprofile_context_manager_stater )r r _scope old_profiles r: __enter__zProfile.__enter__O sQ h0*.0:b>5m
'*E;&?#
r9 c V | | j \ }}}| `||_ d S r7 )r r r )r tyvaluetbr r r s r: __exit__zProfile.__exit__] s/ $ ; 5+ '#
r9 c j sd S | j k rd S | j z
}|t k r d S xj dz
c_ t | }|D ] \ }\ }}} | j vrt | D ]J\ } }
|
j vrz!Profile.write.. s! QQQ8,X6QQQr9 r )r r MAX_PROFILE_DURATION_NSr r strr rn r rq r* rl r+ r, r r sysexc_info) r tssampleoffsetr r r rw r* rx rg s ` r: writez
Profile.writef s { F
Fdm# + + + IIKKK F q !$V 28 ; ; .C.(Iv
; 4#666'0';'; : : 8#4+>>>>:::::
;- ; ;s /CD>>*E,+E,c h d t j D }| j | j | j |dS )Nc ` i | ]+}t |j d t |j i,S )r' )r r r' )rh r s r:
z#Profile.process.. sH
FK((
r9 r) )rA rn r* r+ r, )r r- s r: processzProfile.process sN
$-//
kk| .
r9 c x | }t |d |d |d |d | d | j d|| dd |d d
d t j it j t j d t j t j d |d
|d dt | j | j z
|d d d t | j
| j n| j
dgd S )Nr* in_app_excludein_app_include project_root environmentpythonrelease start_timestamp1 architecture)r' versionr r 0contextstracetrace_id)idr' relative_start_nsrelative_end_nsr r ) r r platformr r timestampr devicer runtime transactions)r r
rJ r r machinesystemr python_implementationpython_versionr r r r r )r event_optrK r s r: to_jsonzProfile.to_json sZ ,,.. H $ % $ % N #
%== 77
}}Y33"#45 0 2 2 !))#+--
!688#244 $J/ %m 4 *- (+4<$-+G'H'H )* 5g >z J(+ 08 66 ! 2) ) '&
&
&
r9 c p | j pt j j }|j }|dS t |j sdS | j | j s%|j r |j dd dS | j
t k r9|j r |j dd t j
d dS dS )NFr r )
data_categoryinsufficient_dataz<[Profiling] Discarding profile because insufficient samples.T)r r r r r rL rK r transportrecord_lost_eventr PROFILE_MINIMUM_SAMPLESr rS )r r r s r: validz
Profile.valid s h0*.0 >5$V^44 5 < t|
22! 3 5 !8 8 8
22'y 3
LW X X X5tr9 )NN)r
__module__ __qualname__r r r r r r r r r r r r8 r9 r: r r s
'$ '$ '$ '$R
J J JX
-
-
- ) ) ) $ $ $*; *; *;X
(1
1
1
f r9 r c H e Zd ZdZd Zd Zd Zd Zd Zd Z d Z
d Z d
Z d S ) Schedulerunknownc d|z | _ | | _ t d | _ t | _ d S )Ng ?rb rd )interval make_samplersamplerr new_profilesrp active_profiles)r rP s r: r zScheduler.__init__ sG i
((** " - - - "uu r9 c . | | S r7 )rZ r s r: r zScheduler.__enter__ s
r9 c . | d S r7 )ra )r r r r s r: r zScheduler.__exit__ s
r9 c t r7 NotImplementedErrorr s r: rZ zScheduler.setup !!r9 c t r7 r r s r: ra zScheduler.teardown r r9 c t r7 r r s r: ensure_runningzScheduler.ensure_running r r9 c b | | j | d S r7 )r# r rl r r s r: r zScheduler.start_profiling s1 )))))r9 c d S r7 r8 r% s r: r zScheduler.stop_profiling r9 c ` t j t d fd}|S )N )max_sizec x
j s
j sdS t
j }t } fdt j D }n1# t $ r$ t t j Y dS w xY wt | D ]3}
j
j 4g }
j D ]5}|j
r| || | | 6|D ] }
j | dS )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.
Nc V g | ]%\ }}t | t | f&S r8 )r r{ )rh r rz rs rt s r: r zAScheduler.make_sampler.._sample_stack..? sD "U XX}UE3 ? ?@ r9 )r r rq r r _current_framesitemsr r r rangeaddpopleftr r rl remove) r> r? r nowr r inactive_profilesr rs rt r s r:
_sample_stackz-Scheduler.make_sampler.._sample_stack& s $
T-A
t 011L!##C
&)&9&;&;&A&A&C&C "
+3<>>:::
<((
F
F$(():)B)B)D)DEEEE " /
6
6> 6MM#v.... &,,W5555,
5
5$++G4444
5
5s 2A( (*BB)r getcwdr )r r5 rs rt s ` @@r: r zScheduler.make_sampler sL ikk#&&&= 5 = 5 = 5 = 5 = 5 = 5 = 5~ r9 N)
r r r rQ r r r rZ ra r# r r r r8 r9 r: r r s D% % %
" " "" " "" " "* * *
E E E E E r9 r c B e Zd ZdZdZdZ fdZd Zd Zd Z d Z
xZ S ) rW zr
This scheduler is based on running a daemon thread that will call
the sampler at a regular interval.
r z sentry.profiler.ThreadSchedulerc t t | | d| _ d | _ d | _ t
j | _ d S )NrO F) superrW r runningr pidrA Locklockr rP r s r: r zThreadScheduler.__init__q sN
ot$$-- -BBB N$$ r9 c d S r7 r8 r s r: rZ zThreadScheduler.setup{ r' r9 c j | j r)d| _ | j | j d S d S d S r= r: r r r s r: ra zThreadScheduler.teardown E < # DL{& """"" # #&&r9 c n t j }| j r
| j |k rd S | j 5 | j r| j |k r d d d d S || _ d| _ t j | j | j d | _ | j
d d d d S # 1 swxY w Y d S )NT)r' targetdaemon) r getpidr: r; r= rA Threadr' runr r r r; s r: r# z ThreadScheduler.ensure_running s ikk < DHOO F
Y |
C DH DL
$* $(SWXXXDK K s B*A
B**B.1B.c
t j }| j rh| t j |z
}|| j k rt | j |z
t j }| j fd S d S r7 r4 perf_counterr: r r thread_sleepr lastelapseds r: rH zThreadScheduler.run ""l ' LLNNN
'))D0G && T]W 4555 $&&D l ' ' ' ' 'r9 r r r __doc__rQ r' r rZ ra r# rH
__classcell__r s @r: rW rW h s
D ,D% % % % %
# # # 0' ' ' ' ' ' 'r9 rW c B e Zd ZdZdZdZ fdZd Zd Zd Z d Z
xZ S ) rV as
This scheduler is based on the thread scheduler but adapted to work with
gevent. When using gevent, it may monkey patch the threading modules
(`threading` and `_thread`). This results in the use of greenlets instead
of native threads.
This is an issue because the sampler CANNOT run in a greenlet because
1. Other greenlets doing sync work will prevent the sampler from running
2. The greenlet runs in the same thread as other greenlets so when taking
a sample, other greenlets will have been evicted from the thread. This
results in a sample containing only the sampler's code.
geventz sentry.profiler.GeventSchedulerc t 't d | j t t
| | d| _ d | _ d | _ t j | _ d S )Nz"Profiler mode: {} is not availablerO F)
r3 rX rY rQ r9 rV r r: r r; rA r< r= r> s r: r zGeventScheduler.__init__ sw A H H S STT T
ot$$-- -BBB
N$$ r9 c d S r7 r8 r s r: rZ zGeventScheduler.setup r' r9 c j | j r)d| _ | j | j d S d S d S r= rA r s r: ra zGeventScheduler.teardown rB r9 c V t j }| j r
| j |k rd S | j 5 | j r| j |k r d d d d S || _ d| _ t d | _ | j | j d d d d S # 1 swxY w Y d S )NTr ) r rF r: r; r= r3 r spawnrH rI s r: r# z GeventScheduler.ensure_running s
ikk < DHOO F
Y ( ( |
C ( ( ( ( ( ( ( ( DH DL$Q--DK K dh ' ' ' ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( (s B AB B"%B"c
t j }| j rh| t j |z
}|| j k rt | j |z
t j }| j fd S d S r7 rK rN s r: rH zGeventScheduler.run rQ r9 rR rU s @r: rV rV s D ,D% % % % %$
# # #( ( (*' ' ' ' ' ' 'r9 rV r7 )YrS r[ r r r r rA r4 r collectionsr r sentry_sdk._compatr r sentry_sdk._lru_cacher sentry_sdk._typesr sentry_sdk.utilsr r r
r r r
typesr typingr r r r r r r r r typing_extensionsr sentry_sdk.tracingr r r ThreadIdintr ProcessedStackr r& r( r. FrameIdFrameIdsStackIdExtractedStackExtractedSamplerW r0 r;
gevent.monkeyr1 r2 gevent.threadpoolr3 rM ImportErrorr5 rC rR rU r rL r_ r] MAX_STACK_DEPTHr6 CWDr{ rg ro r r r objectr r rW rV r8 r9 r: ru s 6
* * * * * * * * * * * * * * + + + + + + J@ ++++++ ????????H i&)!
O #YN Y
sm
N (i!
!y>*>*O, #H.E$E F
Y s N
G
Wc\"H CHoG7Hd>.BBCN uX~%= >?O000000========,,,,,, <00LL
:L
JJJ
J J J
!
"1 1 1h bikk # -' -' -' -'`Y Y Y
: 5( ( ( ( - - -` #d)) + + + +\y y y y yf y y yx p p p p p p p p fF' F' F' F' F'i F' F' F'RS' S' S' S' S'i S' S' S' S' S's " F FF