Submit
Path:
~
/
/
proc
/
thread-self
/
root
/
opt
/
alt
/
python35
/
lib
/
python3.5
/
site-packages
/
raven
/
transport
/
__pycache__
/
File Content:
threaded.cpython-35.pyc
��Yu � @ s� d Z d d l m Z d d l Z d d l Z d d l Z d d l Z d d l m Z m Z d d l m Z d d l m Z d d l m Z m Z d Z e j d � Z Gd d � d e � Z Gd d � d e e � Z d S)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 Z d Z e � Z e d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z d d d � Z d d � Z d d � Z d S)� AsyncWorkerc C sT t � t d � | _ t j � | _ d | _ d | _ d | i | _ | j � d S)N� �shutdown_timeout���) r r �_queue� threading�Lock�_lock�_thread�_thread_for_pid�options�start)�selfr � r � /threaded.py�__init__ s zAsyncWorker.__init__c C s/ | j t j � k r d S| j o. | j j � S)NF)r �os�getpidr �is_alive)r r r r r ( s zAsyncWorker.is_alivec C s | j � r d S| j � d S)N)r r )r r r r �_ensure_thread- s zAsyncWorker._ensure_threadc C s� | j j � z� | j � s d S| j j | j � | j d } t d | � } | j | � s� | j j � } t d | � t d | � t j d k r� t d � n t d � | j | | � d | _ Wd | j j � Xd 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 j � zH x= | j re | t � } | d k rO d S| j j d | � q) Wd SWd | j j � Xd S)z� implementation of Queue.join which takes a 'timeout' argument returns true on success, false on timeout r Fr( TN)r r �all_tasks_doner �unfinished_tasks�waitr' )r r( �deadline�queue�delayr r r r# W s z AsyncWorker._timed_queue_joinc C s� | j j � zZ | j � sf t j d | j d d � | _ | j j d � | j j � t j � | _ Wd | j j � t j | j � Xd S)z) Starts the task thread. �targetr& zraven.AsyncWorkerTN)r r r r �Thread�_targetr � setDaemonr r r r r' �atexit�registerr* )r r r r r o s zAsyncWorker.startNc C sg | j j � zE | j rQ | j j | j � | j j d | � d | _ d | _ Wd | j j � Xd S)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 � | j j | | | f � d S)N)r r r )r �callback�args�kwargsr r r r/ � s zAsyncWorker.queuec C s� x� | j j � } z\ | | j k r% P| \ } } } y | | | � Wn% t k rl t j d d d �Yn XWd | j j � Xt d � q Wd S)NzFailed processing job�exc_infoTr )r �getr! � Exception�logger�error� task_doner )r �recordr9 r: r; r r r r3 � s zAsyncWorker._target)�__name__� __module__� __qualname__�objectr! �DEFAULT_TIMEOUTr r r r* r# r r8 r/ r3 r r r r r s % r c sL e Z d Z d d d d g Z d d � Z � f d d � Z d d � Z � S) �ThreadedHTTPTransportZhttpZhttpsz threaded+httpzthreaded+httpsc C s3 t | d � s | j j � r, t � | _ | j S)N�_worker)�hasattrrI r r )r r r r � get_worker� s z ThreadedHTTPTransport.get_workerc s] y t t | � j | | | � Wn/ t k rQ } z | | � WYd d } ~ Xn X| � d S)N)�superrH �sendr> )r �url�data�headers� success_cb� failure_cb�e)� __class__r r � send_sync� s z ThreadedHTTPTransport.send_syncc C s) | j � j | j | | | | | � d S)N)rK r/ rU )r rN rO rP rQ rR r r r � async_send� s z ThreadedHTTPTransport.async_send)rC rD rE �schemerK rU rV r r )rT r rH � s rH )�__doc__Z __future__r r5 �loggingr r r r Zraven.transport.baser Zraven.transport.httpr Zraven.utils.compatr r rG � getLoggerr? rF r rH r r r r �<module> s �
Edit
Rename
Chmod
Delete
FILE
FOLDER
Name
Size
Permission
Action
__init__.cpython-35.opt-1.pyc
698 bytes
0644
__init__.cpython-35.pyc
698 bytes
0644
base.cpython-35.opt-1.pyc
1684 bytes
0644
base.cpython-35.pyc
1684 bytes
0644
eventlet.cpython-35.opt-1.pyc
1893 bytes
0644
eventlet.cpython-35.pyc
1893 bytes
0644
exceptions.cpython-35.opt-1.pyc
914 bytes
0644
exceptions.cpython-35.pyc
914 bytes
0644
gevent.cpython-35.opt-1.pyc
2011 bytes
0644
gevent.cpython-35.pyc
2011 bytes
0644
http.cpython-35.opt-1.pyc
1917 bytes
0644
http.cpython-35.pyc
1917 bytes
0644
registry.cpython-35.opt-1.pyc
2819 bytes
0644
registry.cpython-35.pyc
2819 bytes
0644
requests.cpython-35.opt-1.pyc
1279 bytes
0644
requests.cpython-35.pyc
1279 bytes
0644
threaded.cpython-35.opt-1.pyc
5173 bytes
0644
threaded.cpython-35.pyc
5173 bytes
0644
threaded_requests.cpython-35.opt-1.pyc
1560 bytes
0644
threaded_requests.cpython-35.pyc
1560 bytes
0644
tornado.cpython-35.opt-1.pyc
2135 bytes
0644
tornado.cpython-35.pyc
2135 bytes
0644
twisted.cpython-35.opt-1.pyc
3078 bytes
0644
twisted.cpython-35.pyc
3078 bytes
0644
N4ST4R_ID | Naxtarrr
