HEX
Server: Apache/2.4.52 (Ubuntu)
System: Linux spn-python 5.15.0-89-generic #99-Ubuntu SMP Mon Oct 30 20:42:41 UTC 2023 x86_64
User: arjun (1000)
PHP: 8.1.2-1ubuntu2.20
Disabled: NONE
Upload Files
File: //home/arjun/projects/env/lib/python3.10/site-packages/aiohttp/__pycache__/tracing.cpython-310.pyc
o

+we0;�@s�ddlmZddlmZmZmZmZmZmZddl	Z	ddl
mZddlm
Z
ddlmZddlmZerJdd	lmZed
dd�ZGd
d�dee�ZdZGdd�d�Ze	jdddd�Gdd�d��Ze	jdddd�Gdd�d��Ze	jdddd�Gdd�d��Ze	jdddd�Gdd�d��Ze	jdddd�Gdd�d��Ze	jdddd�Gdd�d��Ze	jdddd�Gdd �d ��Ze	jdddd�Gd!d"�d"��Z e	jdddd�Gd#d$�d$��Z!e	jdddd�Gd%d&�d&��Z"e	jdddd�Gd'd(�d(��Z#e	jdddd�Gd)d*�d*��Z$e	jdddd�Gd+d,�d,��Z%e	jdddd�Gd-d.�d.��Z&e	jdddd�Gd/d0�d0��Z'e	jdddd�Gd1d2�d2��Z(Gd3d4�d4�Z)dS)5�)�SimpleNamespace)�
TYPE_CHECKING�	Awaitable�Optional�Protocol�Type�TypeVarN)�Signal)�CIMultiDict)�URL�)�ClientResponse)�
ClientSession�_ParamT_contraT)�
contravariantc	@s*eZdZdededededfdd�ZdS)�_SignalCallback�_SignalCallback__client_session�!_SignalCallback__trace_config_ctx�_SignalCallback__params�returnNcCsdS�N�)�selfrrrrr�H/home/arjun/projects/env/lib/python3.10/site-packages/aiohttp/tracing.py�__call__sz_SignalCallback.__call__)�__name__�
__module__�__qualname__rrrrrrrrrrs����r)�TraceConfig�TraceRequestStartParams�TraceRequestEndParams�TraceRequestExceptionParams� TraceConnectionQueuedStartParams�TraceConnectionQueuedEndParams� TraceConnectionCreateStartParams�TraceConnectionCreateEndParams�TraceConnectionReuseconnParams�TraceDnsResolveHostStartParams�TraceDnsResolveHostEndParams�TraceDnsCacheHitParams�TraceDnsCacheMissParams�TraceRequestRedirectParams�TraceRequestChunkSentParams� TraceResponseChunkReceivedParams�TraceRequestHeadersSentParamsc@s^eZdZdZefdeeddfdd�Z	d<deedefdd	�Zd=d
d�Z	e
d>d
d��Ze
		d?dd��Ze
		d@dd��Z
e
dAdd��Ze
		dBdd��Ze
		dCdd��Ze
		dDdd ��Ze
		!dEd"d#��Ze
		$dFd%d&��Ze
		'dGd(d)��Ze
		*dHd+d,��Ze
		-dId.d/��Ze
		0dJd1d2��Ze
dKd4d5��Ze
dLd7d8��Ze
		9dMd:d;��ZdS)NrzFFirst-class used to trace requests launched via ClientSession objects.�trace_config_ctx_factoryrNcCs�t|�|_t|�|_t|�|_t|�|_t|�|_t|�|_t|�|_t|�|_t|�|_	t|�|_
t|�|_t|�|_t|�|_
t|�|_t|�|_t|�|_||_dSr)r	�_on_request_start�_on_request_chunk_sent�_on_response_chunk_received�_on_request_end�_on_request_exception�_on_request_redirect�_on_connection_queued_start�_on_connection_queued_end�_on_connection_create_start�_on_connection_create_end�_on_connection_reuseconn�_on_dns_resolvehost_start�_on_dns_resolvehost_end�_on_dns_cache_hit�_on_dns_cache_miss�_on_request_headers_sent�_trace_config_ctx_factory)rr/rrr�__init__2sD����������������
zTraceConfig.__init__�trace_request_ctxcCs|j|d�S)z&Return a new trace_config_ctx instance)rB)r@)rrBrrr�trace_config_ctxhszTraceConfig.trace_config_ctxcCs�|j��|j��|j��|j��|j��|j��|j��|j��|j	��|j
��|j��|j��|j
��|j��|j��|j��dSr)r0�freezer1r2r3r4r5r6r7r8r9r:r;r<r=r>r?�rrrrrDns 














zTraceConfig.freeze�0Signal[_SignalCallback[TraceRequestStartParams]]cC�|jSr)r0rErrr�on_request_start��zTraceConfig.on_request_start�4Signal[_SignalCallback[TraceRequestChunkSentParams]]cCrGr)r1rErrr�on_request_chunk_sent��z!TraceConfig.on_request_chunk_sent�9Signal[_SignalCallback[TraceResponseChunkReceivedParams]]cCrGr)r2rErrr�on_response_chunk_received�rLz&TraceConfig.on_response_chunk_received�.Signal[_SignalCallback[TraceRequestEndParams]]cCrGr)r3rErrr�on_request_end�rIzTraceConfig.on_request_end�4Signal[_SignalCallback[TraceRequestExceptionParams]]cCrGr)r4rErrr�on_request_exception�rLz TraceConfig.on_request_exception�3Signal[_SignalCallback[TraceRequestRedirectParams]]cCrGr)r5rErrr�on_request_redirect�rLzTraceConfig.on_request_redirect�9Signal[_SignalCallback[TraceConnectionQueuedStartParams]]cCrGr)r6rErrr�on_connection_queued_start�rLz&TraceConfig.on_connection_queued_start�7Signal[_SignalCallback[TraceConnectionQueuedEndParams]]cCrGr)r7rErrr�on_connection_queued_end�rLz$TraceConfig.on_connection_queued_end�9Signal[_SignalCallback[TraceConnectionCreateStartParams]]cCrGr)r8rErrr�on_connection_create_start�rLz&TraceConfig.on_connection_create_start�7Signal[_SignalCallback[TraceConnectionCreateEndParams]]cCrGr)r9rErrr�on_connection_create_end�rLz$TraceConfig.on_connection_create_end�7Signal[_SignalCallback[TraceConnectionReuseconnParams]]cCrGr)r:rErrr�on_connection_reuseconn�rLz#TraceConfig.on_connection_reuseconn�7Signal[_SignalCallback[TraceDnsResolveHostStartParams]]cCrGr)r;rErrr�on_dns_resolvehost_start�rLz$TraceConfig.on_dns_resolvehost_start�5Signal[_SignalCallback[TraceDnsResolveHostEndParams]]cCrGr)r<rErrr�on_dns_resolvehost_end�rLz"TraceConfig.on_dns_resolvehost_end�/Signal[_SignalCallback[TraceDnsCacheHitParams]]cCrGr)r=rErrr�on_dns_cache_hit�rIzTraceConfig.on_dns_cache_hit�0Signal[_SignalCallback[TraceDnsCacheMissParams]]cCrGr)r>rErrr�on_dns_cache_miss�rIzTraceConfig.on_dns_cache_miss�6Signal[_SignalCallback[TraceRequestHeadersSentParams]]cCrGr)r?rErrr�on_request_headers_sent�rLz#TraceConfig.on_request_headers_sentr�rN)rrF)rrJ)rrM)rrO)rrQ)rrS)rrU)rrW)rrY)rr[)rr])rr_)rra)rrc)rre)rrg)rrr�__doc__rrrArrCrD�propertyrHrKrNrPrRrTrVrXrZr\r^r`rbrdrfrhrrrrr/s���
�7��
�
������������r)�auto_attribs�frozen�slotsc@�*eZdZUdZeed<eed<ded<dS)rz0Parameters sent by the `on_request_start` signal�method�url�CIMultiDict[str]�headersN�rrrrj�str�__annotations__rrrrrr��

rc@�*eZdZUdZeed<eed<eed<dS)r,z5Parameters sent by the `on_request_chunk_sent` signalrprq�chunkN�rrrrjrurvr�bytesrrrrr,�rwr,c@rx)r-z:Parameters sent by the `on_response_chunk_received` signalrprqryNrzrrrrr-�rwr-c@�2eZdZUdZeed<eed<ded<eed<dS)r z.Parameters sent by the `on_request_end` signalrprqrrrs�responseN�rrrrjrurvrr
rrrrr ��
r c@r|)r!z4Parameters sent by the `on_request_exception` signalrprqrrrs�	exceptionN)rrrrjrurvr�
BaseExceptionrrrrr!�rr!c@r|)r+z3Parameters sent by the `on_request_redirect` signalrprqrrrsr}Nr~rrrrr+rr+c@�eZdZdZdS)r"z:Parameters sent by the `on_connection_queued_start` signalN�rrrrjrrrrr"�r"c@r�)r#z8Parameters sent by the `on_connection_queued_end` signalNr�rrrrr#r�r#c@r�)r$z:Parameters sent by the `on_connection_create_start` signalNr�rrrrr$r�r$c@r�)r%z8Parameters sent by the `on_connection_create_end` signalNr�rrrrr%!r�r%c@r�)r&z7Parameters sent by the `on_connection_reuseconn` signalNr�rrrrr&&r�r&c@�eZdZUdZeed<dS)r'z8Parameters sent by the `on_dns_resolvehost_start` signal�hostN�rrrrjrurvrrrrr'+�
r'c@r�)r(z6Parameters sent by the `on_dns_resolvehost_end` signalr�Nr�rrrrr(2r�r(c@r�)r)z0Parameters sent by the `on_dns_cache_hit` signalr�Nr�rrrrr)9r�r)c@r�)r*z1Parameters sent by the `on_dns_cache_miss` signalr�Nr�rrrrr*@r�r*c@ro)r.z7Parameters sent by the `on_request_headers_sent` signalrprqrrrsNrtrrrrr.Grwr.c
@sfeZdZdZdddededdfdd	�Zd
ededd
ddfdd�Z	d
edede
ddfdd�Zd
edede
ddfdd�Zd
ededd
de
ddf
dd�Zd
ededd
deddf
dd�Zd
ededd
de
ddf
dd�Zd2dd�Zd2dd �Zd2d!d"�Zd2d#d$�Zd2d%d&�Zd'eddfd(d)�Zd'eddfd*d+�Zd'eddfd,d-�Zd'eddfd.d/�Zd
ededd
ddfd0d1�ZdS)3�Tracez�Internal dependency holder class.

    Used to keep together the main dependencies used
    at the moment of send a signal.
    �sessionr�trace_configrCrNcCs||_||_||_dSr)�
_trace_config�_trace_config_ctx�_session)rr�r�rCrrrrAWs
zTrace.__init__rprqrsrrc��&�|jj�|j|jt|||��IdHSr)r�rH�sendr�r�r�rrprqrsrrr�send_request_starta��

�zTrace.send_request_startryc�r�r)r�rKr�r�r�r,�rrprqryrrr�send_request_chunk_sentjr�zTrace.send_request_chunk_sentc�r�r)r�rNr�r�r�r-r�rrr�send_response_chunk_receivedsr�z"Trace.send_response_chunk_receivedr}c	��(�|jj�|j|jt||||��IdHSr)r�rPr�r�r�r �rrprqrsr}rrr�send_request_end|��
�zTrace.send_request_endr�c	�r�r)r�rRr�r�r�r!)rrprqrsr�rrr�send_request_exception�r�zTrace.send_request_exceptionc	�r�r)r�r5r�r�r�r+r�rrr�send_request_redirect�r�zTrace.send_request_redirectc�� �|jj�|j|jt��IdHSr)r�rVr�r�r�r"rErrr�send_connection_queued_start���
�z"Trace.send_connection_queued_startc�r�r)r�rXr�r�r�r#rErrr�send_connection_queued_end�r�z Trace.send_connection_queued_endc�r�r)r�rZr�r�r�r$rErrr�send_connection_create_start�r�z"Trace.send_connection_create_startc�r�r)r�r\r�r�r�r%rErrr�send_connection_create_end�r�z Trace.send_connection_create_endc�r�r)r�r^r�r�r�r&rErrr�send_connection_reuseconn�r�zTrace.send_connection_reuseconnr�c��"�|jj�|j|jt|��IdHSr)r�r`r�r�r�r'�rr�rrr�send_dns_resolvehost_start���
�z Trace.send_dns_resolvehost_startc�r�r)r�rbr�r�r�r(r�rrr�send_dns_resolvehost_end�r�zTrace.send_dns_resolvehost_endc�r�r)r�rdr�r�r�r)r�rrr�send_dns_cache_hit�r�zTrace.send_dns_cache_hitc�r�r)r�rfr�r�r�r*r�rrr�send_dns_cache_miss�r�zTrace.send_dns_cache_missc�r�r)r�r?r�r�r�r.r�rrr�send_request_headers�r�zTrace.send_request_headersri)rrrrjrrrArurr�r{r�r�r
r�r�r�r�r�r�r�r�r�r�r�r�r�r�rrrrr�Ps����
�
���
�	���
�	���
�	����
�
����
�
����
�




����r�)*�typesr�typingrrrrrr�attr�	aiosignalr	�	multidictr
�yarlr�
client_reqrepr
�clientrrr�__all__r�srr,r-r r!r+r"r#r$r%r&r'r(r)r*r.r�rrrr�<module>s^ 
+