]jy d dl Z d dlZd dlmZmZ d dlmZ d dlmZmZ d dl m
Z
d dl m Z e rd dl
mZ d dl
mZ d d l
mZ e Z G d
d e ZdS ) N)sleeptime)check_thread_support)QueueFull)logger)MYPY)Any)Optional)Callablec ^ e Zd Zd
dZed Zd Zd Zd Zd Z dd Z
d
Z d Z d Z
dS )BackgroundWorker c t t | | _ t j | _ d | _ d | _ d S N)r r _queue threadingLock_lock_thread_thread_for_pid)self
queue_sizes H/opt/imunify360/venv/lib64/python3.11/site-packages/sentry_sdk/worker.py__init__zBackgroundWorker.__init__ sA J'' ^%%
# c | j t j k rdS | j sdS | j S )NF)r osgetpidr is_aliver s r r zBackgroundWorker.is_alive s@ 29;; . .5| 5|$$&&&r c @ | j s| d S d S r )r startr! s r _ensure_threadz BackgroundWorker._ensure_thread& s' } JJLLLLL r c t |z }| j }|j |j rU|t z
}|dk r |j dS |j | |j U |j dS # |j w xY w)Nr F)timeoutT)r r all_tasks_doneacquireunfinished_tasksreleasewait)r r& deadlinequeuedelays r _timed_queue_joinz"BackgroundWorker._timed_queue_join+ s 66G#
$$&&& +(
9 466)A::
( ( * * * * * $))%)888 (
9 ( ( * * * * *E ( ( * * * *s B+ -"B+ +Cc * | j 5 | j skt j | j d | _ | j d | j t j | _
d d d d S # 1 swxY w Y d S )Nz raven-sentry.BackgroundWorker)targetnameT) r r r Thread_targetr setDaemonr# r r r r! s r r# zBackgroundWorker.start= s
Z 3 3=
3 ( / <.M &&t,,, ""$$$')y{{$ 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3s A3BB B c " t j d | j 5 | j rS | j t n$# t $ r t j d Y nw xY wd| _ d| _ ddd dS # 1 swxY w Y dS )z
Kill worker thread. Returns immediately. Not useful for
waiting on shutdown for events, use `flush` for that.
z"background worker got kill requestz)background worker queue full, kill failedN) r debugr r r
put_nowait _TERMINATORr r r! s r killzBackgroundWorker.killH s 9:::
Z , ,|
,NK**;7777 N N NL!LMMMMMN $ '+$ , , , , , , , , , , , , , , , , , ,s4 B AB A&#B%A&&BB BNc t j d | j 5 | j r |dk r| || d d d n # 1 swxY w Y t j d d S )Nz#background worker got flush requestg zbackground worker flushed)r r7 r r _wait_flush)r r& callbacks r flushzBackgroundWorker.flushY s :;;;
Z 4 4}
43 (333 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 011111s $A AAc t d| }| | sV| j }t j d| | ||| | ||z
d S d S )Ng?z %d event(s) pending on flush)minr/ r qsizer r7 )r r& r= initial_timeoutpendings r r< z BackgroundWorker._wait_flusha s c7++%%o66 >k''))G L7 A A A#'*** " "7_#< = = = = = > >r c | | j | d S # t $ r t j d Y d S w xY w)Nz,background worker queue full, dropping event)r$ r r8 r r r7 r r= s r submitzBackgroundWorker.submitk so I K " "8 , , , , , I I I LG H H H H H H Is 2 AAc v | j } |t u r | j d S | n&# t $ r t j dd Y nw xY w| j n # | j w xY wt d )NTzFailed processing job)exc_infor )r getr9 task_done Exceptionr errorr rE s r r4 zBackgroundWorker._targets s {((H
({** %%''''' I HJJJJ I I IL!84HHHHHHI %%'''' %%'''' !HHH s/ B
A
B
A0-B
/A00B
B()r r )__name__
__module__ __qualname__r propertyr r$ r/ r# r: r> r< rF r4 r r r r s $ $ $ $ ' ' X'
+ + +$ 3 3 3, , ,"2 2 2 2> > >I I I
r r )r r r r sentry_sdk._compatr sentry_sdk._queuer r sentry_sdk.utilsr sentry_sdk._typesr typingr
r r objectr9 r rQ r r <module>rX s 3 3 3 3 3 3 ) ) ) ) ) ) ) ) # # # # # # " " " " " " fhh l l l l lv l l l l lr