Edit File: threaded.cpython-37.pyc
B ��Yu � @ s� d Z ddlmZ ddlZddlZddlZddlZddlmZmZ ddl m Z ddl m Z ddl mZmZ dZe�d �ZG d d � d e�ZG d 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)�sleep�time)�AsyncTransport)� HTTPTransport)�Queue� check_threads� z sentry.errorsc @ s` e Zd Ze� Zefdd�Zdd� Zdd� Zdd� Z d d � Z d d � Z ddd�Z dd� 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 | � � r d 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| � t j dkrzt 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� q W 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 z AsyncWorker._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�� s t� | _| 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 z ThreadedHTTPTransport.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