B ¿öYzã@sšdZddlmZddlmZddlmZyBddlZyddlm Z Wn e k rbddl m Z YnXdZ Wne k r‚dZ YnXGdd „d eeƒZ dS) z© raven.transport.gevent ~~~~~~~~~~~~~~~~~~~~~~ :copyright: (c) 2010-2012 by the Sentry Team, see AUTHORS for more details. :license: BSD, see LICENSE for more details. é)Úabsolute_import)ÚAsyncTransport)Ú HTTPTransportN)Ú SemaphoreTcs:eZdZddgZd ‡fdd„ Z‡fdd„Zdd „Z‡ZS) ÚGeventedHTTPTransportz gevent+httpz gevent+httpsédcs,ts tdƒ‚t|ƒ|_tt|ƒj||ŽdS)Nz&GeventedHTTPTransport requires gevent.)Ú has_geventÚ ImportErrorrÚ_lockÚsuperrÚ__init__)ÚselfZmaximum_outstanding_requestsÚargsÚkwargs)Ú __class__©úG/opt/alt/python37/lib/python3.7/site-packages/raven/transport/gevent.pyr s zGeventedHTTPTransport.__init__cs4ˆj ¡t ttˆƒj|||¡ ‡‡‡fdd„¡S)z? Spawn an async request to a remote webserver. csˆ |ˆˆ¡S)N)Ú_done)Úx)Ú failure_cbr Ú success_cbrrÚ.óz2GeventedHTTPTransport.async_send..)r ÚacquireÚgeventÚspawnr rÚsendÚlink)r ÚurlÚdataÚheadersrr)r)rr rrÚ async_send%s z GeventedHTTPTransport.async_sendcGs(|j ¡| ¡r|ƒn ||jƒdS)N)r ÚreleaseZ successfulÚ exception)r Zgreenletrrrrrrr0s zGeventedHTTPTransport._done)r)Ú__name__Ú __module__Ú __qualname__Úschemer r!rÚ __classcell__rr)rrrs r)Ú__doc__Ú __future__rZraven.transport.baserZraven.transport.httprrZ gevent.lockrr Z gevent.corosrrrrrrÚs