B ¿öYuã@sœdZddlmZddlZddlZddlZddlZddlmZmZddl m Z ddl m Z ddl mZmZdZe d ¡ZGd d „d eƒZGd 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`eZdZeƒZefdd„Zdd„Zdd„Zdd„Z d d „Z d d „Z ddd„Z dd„Z dd„Zd S)Ú AsyncWorkercCs<tƒtdƒ|_t ¡|_d|_d|_d|i|_|  ¡dS)NéÿÿÿÿÚshutdown_timeout) rrÚ_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__cCs"|jt ¡krdS|jo |j ¡S)NF)rÚosÚgetpidrÚis_alive)rrrrr(szAsyncWorker.is_alivecCs| ¡r dS| ¡dS)N)rr)rrrrÚ_ensure_thread-szAsyncWorker._ensure_threadcCsª|j ¡zŽ| ¡sdS|j |j¡|jd}td|ƒ}| |¡s|j  ¡}t d|ƒt d|ƒt j dkrzt dƒnt dƒ| ||¡d|_ Wd|j ¡XdS)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Úacquirerr Ú put_nowaitÚ _terminatorrÚminÚ_timed_queue_joinÚqsizeÚprintrÚnamerÚrelease)rÚtimeoutZinitial_timeoutÚsizerrrÚmain_thread_terminated2s$         z"AsyncWorker.main_thread_terminatedcCs`tƒ|}|j}|j ¡z4x.|jrJ|tƒ}|dkr:dS|jj|dqWdS|j ¡XdS)z‚ implementation of Queue.join which takes a 'timeout' argument returns true on success, false on timeout rF)r'TN)rr Úall_tasks_donerÚunfinished_tasksÚwaitr&)rr'ZdeadlineÚqueueÚdelayrrrr"Ws   zAsyncWorker._timed_queue_joinc Csf|j ¡z>| ¡sFtj|jdd|_|j d¡|j ¡t   ¡|_ Wd|j  ¡t  |j¡XdS)z) Starts the task thread. zraven.AsyncWorker)Útargetr%TN)rrrrÚThreadÚ_targetrÚ setDaemonrrrrr&ÚatexitÚregisterr))rrrrros    zAsyncWorker.startNcCsN|j ¡z2|jr:|j |j¡|jj|dd|_d|_Wd|j ¡XdS)z5 Stops the task thread. Synchronous! )r'N) rrrr rr Újoinrr&)rr'rrrÚstop~s  zAsyncWorker.stopcOs| ¡|j |||f¡dS)N)rr r)rÚcallbackÚargsÚkwargsrrrr-ŒszAsyncWorker.queuecCsvxp|j ¡}zL||jkrP|\}}}y|||ŽWn"tk rTtjdddYnXWd|j ¡XtdƒqWdS)NzFailed processing jobT)Úexc_infor)r Úgetr Ú ExceptionÚloggerÚerrorÚ task_doner)rÚrecordr7r8r9rrrr1s    zAsyncWorker._target)N)Ú__name__Ú __module__Ú __qualname__Úobjectr ÚDEFAULT_TIMEOUTrrrr)r"rr6r-r1rrrrr s % r cs8eZdZddddgZdd„Z‡fdd„Zd d „Z‡ZS) ÚThreadedHTTPTransportÚhttpÚhttpsz threaded+httpzthreaded+httpscCs"t|dƒr|j ¡stƒ|_|jS)NÚ_worker)ÚhasattrrIrr )rrrrÚ get_worker¥sz ThreadedHTTPTransport.get_workerc sNytt|ƒ |||¡Wn*tk rB}z ||ƒWdd}~XYnX|ƒdS)N)ÚsuperrFÚsendr<)rÚurlÚdataÚheadersÚ success_cbÚ failure_cbÚe)Ú __class__rrÚ send_syncªs zThreadedHTTPTransport.send_synccCs| ¡ |j|||||¡dS)N)rKr-rU)rrNrOrPrQrRrrrÚ async_send²sz ThreadedHTTPTransport.async_send)rArBrCÚschemerKrUrVÚ __classcell__rr)rTrrF¡s  rF)Ú__doc__Ú __future__rr3ÚloggingrrrrZraven.transport.baserZraven.transport.httprZraven.utils.compatrrrEÚ getLoggerr=rDr rFrrrrÚs