6
^)( d Z ddlmZ ddlZddlZddlZddlZddlmZmZ ddl m
Z
ddl m Z ddl
mZmZ dZ ej d Z G d
d e Z G d d
e
e ZdS )z
raven.transport.threaded
~~~~~~~~~~~~~~~~~~~~~~~~
:copyright: (c) 2010-2012 by the Sentry Team, see AUTHORS for more details.
:license: BSD, see LICENSE for more details.
)absolute_importN)sleeptime)AsyncTransport)
HTTPTransport)Queue
check_threads
z
sentry.errorsc ^ e Zd Z e ZefdZd Zd Zd Z d Z
d Z d dZ d Z
d
ZdS ) AsyncWorkerc t t d | _ t j | _ d | _ d | _ d|i| _ | d S )Nshutdown_timeout)
r r _queue threadingLock_lock_thread_thread_for_pidoptionsstart)selfr s j/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib/python3.11/site-packages/raven/transport/threaded.py__init__zAsyncWorker.__init__ sX Bii ^%%
# 0
c ~ | j t j k rdS | j o| j S )NF)r osgetpidr is_aliver s r r zAsyncWorker.is_alive( s6 29;; . .5|7 5 5 7 77r c Z | rd S | d S N)r r r s r _ensure_threadzAsyncWorker._ensure_thread- s( ==?? F
r c B | j 5 | s d d d d S | j | j | j d }t
d| }| | s| j }t d|z t d|z t j dk rt d nt d | ||z
d | _ d d d d S # 1 swxY w Y d S )Nr g?z6Sentry is attempting to send %i pending error messageszWaiting up to %s secondsntzPress Ctrl-Break to quitzPress Ctrl-C to quit)
r r r
put_nowait _terminatorr min_timed_queue_joinqsizeprintr namer )r timeoutinitial_timeoutsizes r main_thread_terminatedz"AsyncWorker.main_thread_terminated2 s
Z ==??
K " "4#3 4 4 4l#56G "#w / /O))/::
B {((**N 07:;;;7d??455550111&&w '@AAA DL= s DC DDDc t |z }| j }|j |j rU|t z
}|dk r |j dS |j | |j U |j dS # |j w xY w)z
implementation of Queue.join which takes a 'timeout' argument
returns true on success, false on timeout
r Fr- T)r r all_tasks_doneacquireunfinished_tasksreleasewait)r r- deadlinequeuedelays r r) z AsyncWorker._timed_queue_joinS s 66G#
$$&&& +(
9 466)A::
( ( * * * * * $))%)888
(
9
( ( * * * * *E ( ( * * * *s B+ -"B+ +Cc
| j | skt j | j d | _ | j d | j t j
| _ | j t j | j dS # | j t j | j w xY w)z)
Starts the task thread.
zraven.AsyncWorker)targetr, TN)r r4 r r Thread_targetr setDaemonr r r r r6 atexitregisterr0 r s r r zAsyncWorker.startk s
9==??
3 ( /t|J] ^ ^ ^ &&t,,, ""$$$')y{{$ J OD 7 8 8 8 8 8
J OD 7 8 8 8 8s A?C 4DNc | j 5 | j rH| j | j | j | d| _ d| _ ddd dS # 1 swxY w Y dS )z5
Stops the task thread. Synchronous!
r2 N)r r r r& r' joinr )r r- s r stopzAsyncWorker.stopz s Z , ,|
, &&t'7888 !!'!222 # '+$ , , , , , , , , , , , , , , , , , ,s AA%%A),A)c h | | j |||f d S r" )r# r r& )r callbackargskwargss r r9 zAsyncWorker.queue s7 $ 788888r c | j } || j u r | j d S |\ }}} ||i | n,# t $ r t
dd Y nw xY w| j n # | j w xY wt d )NTzFailed processing job)exc_infor )r getr' task_done Exceptionloggererrorr )r recordrF rG rH s r r> zAsyncWorker._target s
[__&&F
(T --- %%'''''
*0&$I Hd-f---- I I ILL!84LHHHHHI %%'''' %%'''' !HHH
s5 B B A B &A:7B 9A::B B2r" )__name__
__module__ __qualname__objectr' DEFAULT_TIMEOUTr r r# r0 r) r rD r9 r> r r r r s &((K(7 8 8 8
B+ + +0
9
9
9 , , , ,9 9 9 r r c 2 e Zd Zg dZd Z fdZd Z xZS )ThreadedHTTPTransport)httphttpsz
threaded+httpzthreaded+httpsc t | d r| j st | _ | j S )N_worker)hasattrr\ r r r s r
get_workerz ThreadedHTTPTransport.get_worker s< tY'' )t|/D/D/F/F )&==DL|r c t t | ||| | d S # t $ r} || Y d }~d S d }~ww xY wr" )superrX sendrM )r urldataheaders
success_cb
failure_cbe __class__s r send_syncz ThreadedHTTPTransport.send_sync sv ' . . 3 3Cw G G G
JLLLLL JqMMMMMMMMM s *9
A AAc h | | j ||||| d S r" )r^ r9 ri )r rb rc rd re rf s r
async_sendz ThreadedHTTPTransport.async_send sB NCw
J H H H H Hr )rQ rR rS schemer^ ri rk
__classcell__)rh s @r rX rX sh
A
A
AF
H H H H H H Hr rX )__doc__
__future__r r@ loggingr r r r raven.transport.baser raven.transport.httpr raven.utils.compatr r rU getLoggerrN rT r rX rV r r ru s( ' & & & & &
/ / / / / / . . . . . . 3 3 3 3 3 3 3 3 ? + +} } } } }& } } }@H H H H HNM H H H H Hr