Da

✏️ Editing: threaded.cpython-37.pyc

������Yu������������������@���s����d�Z�ddlmZ�ddlZddlZddlZddlZddlmZmZ�ddl	m
Z
�ddlmZ�ddl
mZmZ�dZe�d	�ZG�d
d��de�ZG�dd
��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)�sleep�time)�AsyncTransport)�
HTTPTransport)�Queue�
check_threads�
���z
sentry.errorsc���������������@���s`���e�Zd�Ze��Zefdd�Zdd��Zdd��Zdd��Z	d	d
��Z
dd��Zddd�Zdd��Z
dd��Zd
S�)�AsyncWorkerc�������������C���s<���t����td�|�_t���|�_d�|�_d�|�_d|i|�_|��	���d�S�)N����shutdown_timeout)
r���r����_queue�	threading�Lock�_lock�_thread�_thread_for_pid�options�start)�selfr�����r����I/opt/alt/python37/lib/python3.7/site-packages/raven/transport/threaded.py�__init__���s����

zAsyncWorker.__init__c�������������C���s"���|�j�t���krdS�|�jo |�j���S�)NF)r����os�getpidr����is_alive)r���r���r���r���r���(���s����zAsyncWorker.is_alivec�������������C���s���|�����rd�S�|�����d�S�)N)r���r���)r���r���r���r����_ensure_thread-���s����zAsyncWorker._ensure_threadc�������������C���s����|�j�����z�|����sd�S�|�j�|�j��|�jd�}td|�}|��|�s�|�j�	��}t
d|���t
d|���tjdkrzt
d��nt
d��|��||���d�|�_
W�d�|�j�����X�d�S�)Nr���g�������?z6Sentry is attempting to send %i pending error messageszWaiting up to %s seconds�ntzPress Ctrl-Break to quitzPress Ctrl-C to quit)r����acquirer���r
����
put_nowait�_terminatorr����min�_timed_queue_join�qsize�printr����namer����release)r����timeoutZinitial_timeout�sizer���r���r����main_thread_terminated2���s$����

z"AsyncWorker.main_thread_terminatedc�������������C���s`���t���|�}|�j}|j����z4x.|jrJ|t����}|dkr:dS�|jj|d��qW�dS�|j����X�dS�)z�
        implementation of Queue.join which takes a 'timeout' argument

returns true on success, false on timeout
        r���F)r'���TN)r���r
����all_tasks_doner����unfinished_tasks�waitr&���)r���r'���Zdeadline�queue�delayr���r���r���r"���W���s����

zAsyncWorker._timed_queue_joinc����������	���C���sf���|�j�����z>|����sFtj|�jdd�|�_|�j�d��|�j����t	�
��|�_W�d|�j�����t
�|�j��X�dS�)z)
        Starts the task thread.
        zraven.AsyncWorker)�targetr%���TN)r���r���r���r����Thread�_targetr����	setDaemonr���r���r���r���r&����atexit�registerr)���)r���r���r���r���r���o���s����

zAsyncWorker.startNc�������������C���sN���|�j�����z2|�jr:|�j�|�j��|�jj|d��d|�_d|�_W�d|�j�����X�dS�)z5
        Stops the task thread. Synchronous!
        )r'���N)	r���r���r���r
���r���r ����joinr���r&���)r���r'���r���r���r����stop~���s����

zAsyncWorker.stopc�������������O���s���|������|�j�|||f��d�S�)N)r���r
���r���)r����callback�args�kwargsr���r���r���r-�������s����zAsyncWorker.queuec�������������C���sv���xp|�j����}zL||�jkrP�|\}}}y|||��W�n"�tk
rT���tjddd��Y�nX�W�d�|�j�����X�td��qW�d�S�)NzFailed processing jobT)�exc_infor���)r
����getr ����	Exception�logger�error�	task_doner���)r����recordr7���r8���r9���r���r���r���r1�������s����

zAsyncWorker._target)N)�__name__�
__module__�__qualname__�objectr ����DEFAULT_TIMEOUTr���r���r���r)���r"���r���r6���r-���r1���r���r���r���r���r
������s���%
r
���c�������������������s8���e�Zd�ZddddgZdd��Z��fdd�Zd	d
��Z���ZS�)�ThreadedHTTPTransport�http�httpsz
threaded+httpzthreaded+httpsc�������������C���s"���t�|�d�r|�j���st��|�_|�jS�)N�_worker)�hasattrrI���r���r
���)r���r���r���r����
get_worker����s����z ThreadedHTTPTransport.get_workerc����������
������sN���yt�t|���|||��W�n*�tk
rB�}�z||��W�d�d�}~X�Y�nX�|���d�S�)N)�superrF����sendr<���)r����url�data�headers�
success_cb�
failure_cb�e)�	__class__r���r����	send_sync����s
����zThreadedHTTPTransport.send_syncc�������������C���s���|������|�j|||||��d�S�)N)rK���r-���rU���)r���rN���rO���rP���rQ���rR���r���r���r����
async_send����s����z ThreadedHTTPTransport.async_send)rA���rB���rC����schemerK���rU���rV����
__classcell__r���r���)rT���r���rF�������s���rF���)�__doc__�
__future__r���r3����loggingr���r���r���r���Zraven.transport.baser���Zraven.transport.httpr���Zraven.utils.compatr���r���rE����	getLoggerr=���rD���r
���rF���r���r���r���r����<module>���s���
�

📁 Sid Gifari File Manager