Edit File: worker.cpython-37.pyc
B Z~�_y � @ s� d dl Z d dlZd dlmZmZ d dlmZ d dlmZmZ d dl m Z d dl m Z e r|d dl mZ d dl mZ d d l mZ e� ZG d d � d e�ZdS ) � N)�sleep�time)�check_thread_support)�Queue�Full)�logger)�MYPY)�Any)�Optional)�Callablec @ sd e Zd Zddd�Zedd� �Zdd� Zdd � Zd d � Zd d � Z ddd�Z dd� Z dd� Z dd� Z dS )�BackgroundWorker� c C s* t � t|�| _t�� | _d | _d | _d S )N)r r �_queue� threading�Lock�_lock�_thread�_thread_for_pid)�selfZ queue_size� r �B/opt/alt/python37/lib/python3.7/site-packages/sentry_sdk/worker.py�__init__ s zBackgroundWorker.__init__c C s& | j t�� krdS | js dS | j�� S )NF)r �os�getpidr �is_alive)r r r r r s zBackgroundWorker.is_alivec C s | j s| �� d S )N)r �start)r r r r �_ensure_thread& s z BackgroundWorker._ensure_threadc C s` t � | }| j}|j�� z4x.|jrJ|t � }|dkr:dS |jj|d� q W dS |j�� X d S )Nr F)�timeoutT)r r Zall_tasks_done�acquireZunfinished_tasks�wait�release)r r Zdeadline�queue�delayr r r �_timed_queue_join+ s z"BackgroundWorker._timed_queue_joinc C sN | j �> | js@tj| jdd�| _| j�d� | j�� t� � | _ W d Q R X d S )Nz raven-sentry.BackgroundWorker)�target�nameT) r r r �Thread�_targetr � setDaemonr r r r )r r r r r = s zBackgroundWorker.startc C sb t �d� | j�H | jrTy| j�t� W n tk rF t �d� Y nX d| _d| _W dQ R X 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 r r r �killH s zBackgroundWorker.killNc C sD t �d� | j� | jr,|dkr,| �||� W d Q R X t �d� d S )Nz#background worker got flush requestg zbackground worker flushed)r r) r r � _wait_flush)r r �callbackr r r �flushY s zBackgroundWorker.flushc C sN t d|�}| �|�sJ| j�� }t�d|� |d k r<|||� | �|| � d S )Ng�������?z %d event(s) pending on flush)�minr# r Zqsizer r) )r r r. Zinitial_timeout�pendingr r r r- a s z BackgroundWorker._wait_flushc C s< | � � y| j�|� W n tk r6 t�d� Y nX d S )Nz,background worker queue full, dropping event)r r r* r r r) )r r. r r r �submitk s zBackgroundWorker.submitc C sf x`| j �� }z<|tkrP y |� W n" tk rD tjddd� Y nX W d | j �� X td� qW d S )NzFailed processing jobT)�exc_infor )r �getr+ � Exceptionr �errorZ task_doner )r r. r r r r' s s zBackgroundWorker._target)r )N)�__name__� __module__� __qualname__r �propertyr r r# r r, r/ r- r2 r' r r r r r s r )r r r r Zsentry_sdk._compatr Zsentry_sdk._queuer r Zsentry_sdk.utilsr Zsentry_sdk._typesr �typingr r r �objectr+ r r r r r �<module> s