File: //usr/local/lib/python3.10/dist-packages/aiohttp/__pycache__/tracing.cpython-310.pyc
o
���g!; � @ s� d dl mZ d dlmZmZmZmZmZmZm Z d dl
Z
d dl m Z d dl
mZ d dlmZ ddlmZ erLdd lmZ e d
d d �ZG d
d� dee �ZdZG dd� d�Ze
jd d d d�G dd� d��Ze
jd d d d�G dd� d��Ze
jd d d d�G dd� d��Z e
jd d d d�G dd� d��Z e
jd d d d�G dd � d ��Z e
jd d d d�G d d � d ��Z e
jd d d d�G d d � d ��Z e
jd d d d�G d!d"� d"��Z!e
jd d d d�G d#d$� d$��Z"e
jd d d d�G d%d&� d&��Z#e
jd d d d�G d'd(� d(��Z$e
jd d d d�G d)d*� d*��Z%e
jd d d d�G d+d,� d,��Z&e
jd d d d�G d-d.� d.��Z'e
jd d d d�G d/d0� d0��Z(e
jd d d d�G d1d2� d2��Z)G d3d4� d4�Z*dS )5� )�SimpleNamespace)�
TYPE_CHECKING� Awaitable�Mapping�Optional�Protocol�Type�TypeVarN)�Signal)� CIMultiDict)�URL� )�ClientResponse)�
ClientSession�_ParamT_contraT)�
contravariantc @ s* e Zd Zdedededed fdd�ZdS )�_SignalCallback� _SignalCallback__client_session�!_SignalCallback__trace_config_ctx�_SignalCallback__params�returnNc C s d S �N� )�selfr r r r r �:/usr/local/lib/python3.10/dist-packages/aiohttp/tracing.py�__call__ s z_SignalCallback.__call__)�__name__�
__module__� __qualname__r r r r r r r r r r s ����r )� TraceConfig�TraceRequestStartParams�TraceRequestEndParams�TraceRequestExceptionParams� TraceConnectionQueuedStartParams� TraceConnectionQueuedEndParams� TraceConnectionCreateStartParams� TraceConnectionCreateEndParams� TraceConnectionReuseconnParams� TraceDnsResolveHostStartParams� TraceDnsResolveHostEndParams�TraceDnsCacheHitParams�TraceDnsCacheMissParams�TraceRequestRedirectParams�TraceRequestChunkSentParams� TraceResponseChunkReceivedParams� TraceRequestHeadersSentParamsc @ sf e Zd ZdZefdee ddfdd�Z d<deee e f defdd �Z
d=d
d �Z e d>d
d��Z
e d?dd��Ze d@dd��Ze dAdd��Ze dBdd��Ze dCd d ��Ze dDd d ��Ze !dEd"d#��Ze $dFd%d&��Ze 'dGd(d)��Ze *dHd+d,��Ze -dId.d/��Ze 0dJd1d2��Ze dKd4d5��Ze dLd7d8��Ze 9dMd:d;��Z dS )Nr zFFirst-class used to trace requests launched via ClientSession objects.�trace_config_ctx_factoryr Nc C s� t | �| _t | �| _t | �| _t | �| _t | �| _t | �| _t | �| _t | �| _t | �| _ t | �| _
t | �| _ t | �| _ t | �| _
t | �| _t | �| _t | �| _|| _d S r )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)r r0 r r r �__init__1 sD ����������������
zTraceConfig.__init__�trace_request_ctxc C s | j |d�S )z&Return a new trace_config_ctx instance)rC )rA )r rC r r r �trace_config_ctxg s z TraceConfig.trace_config_ctxc C s� | j �� | j�� | j�� | j�� | j�� | j�� | j�� | j�� | j �� | j
�� | j �� | j �� | j
�� | j�� | j�� | j�� d S r )r1 �freezer2 r3 r4 r5 r6 r7 r8 r9 r: r; r< r= r> r? r@ �r r r r rE m s
zTraceConfig.freeze�0Signal[_SignalCallback[TraceRequestStartParams]]c C � | j S r )r1 rF r r r �on_request_start � z TraceConfig.on_request_start�4Signal[_SignalCallback[TraceRequestChunkSentParams]]c C rH r )r2 rF r r r �on_request_chunk_sent� � z!TraceConfig.on_request_chunk_sent�9Signal[_SignalCallback[TraceResponseChunkReceivedParams]]c C rH r )r3 rF r r r �on_response_chunk_received� rM z&TraceConfig.on_response_chunk_received�.Signal[_SignalCallback[TraceRequestEndParams]]c C rH r )r4 rF r r r �on_request_end� rJ zTraceConfig.on_request_end�4Signal[_SignalCallback[TraceRequestExceptionParams]]c C rH r )r5 rF r r r �on_request_exception� rM z TraceConfig.on_request_exception�3Signal[_SignalCallback[TraceRequestRedirectParams]]c C rH r )r6 rF r r r �on_request_redirect� rM z TraceConfig.on_request_redirect�9Signal[_SignalCallback[TraceConnectionQueuedStartParams]]c C rH r )r7 rF r r r �on_connection_queued_start� rM z&TraceConfig.on_connection_queued_start�7Signal[_SignalCallback[TraceConnectionQueuedEndParams]]c C rH r )r8 rF r r r �on_connection_queued_end� rM z$TraceConfig.on_connection_queued_end�9Signal[_SignalCallback[TraceConnectionCreateStartParams]]c C rH r )r9 rF r r r �on_connection_create_start� rM z&TraceConfig.on_connection_create_start�7Signal[_SignalCallback[TraceConnectionCreateEndParams]]c C rH r )r: rF r r r �on_connection_create_end� rM z$TraceConfig.on_connection_create_end�7Signal[_SignalCallback[TraceConnectionReuseconnParams]]c C rH r )r; rF r r r �on_connection_reuseconn� rM z#TraceConfig.on_connection_reuseconn�7Signal[_SignalCallback[TraceDnsResolveHostStartParams]]c C rH r )r< rF r r r �on_dns_resolvehost_start� rM z$TraceConfig.on_dns_resolvehost_start�5Signal[_SignalCallback[TraceDnsResolveHostEndParams]]c C rH r )r= rF r r r �on_dns_resolvehost_end� rM z"TraceConfig.on_dns_resolvehost_end�/Signal[_SignalCallback[TraceDnsCacheHitParams]]c C rH r )r> rF r r r �on_dns_cache_hit� rJ z TraceConfig.on_dns_cache_hit�0Signal[_SignalCallback[TraceDnsCacheMissParams]]c C rH r )r? rF r r r �on_dns_cache_miss� rJ z TraceConfig.on_dns_cache_miss�6Signal[_SignalCallback[TraceRequestHeadersSentParams]]c C rH r )r@ rF r r r �on_request_headers_sent� rM z#TraceConfig.on_request_headers_sentr �r N)r rG )r rK )r rN )r rP )r rR )r rT )r rV )r rX )r rZ )r r\ )r r^ )r r` )r rb )r rd )r rf )r rh ) r r r �__doc__r r rB r r �strrD rE �propertyrI rL rO rQ rS rU rW rY r[ r] r_ ra rc re rg ri r r r r r . s� ��
�7��
�
� � � � � � � � � � � �r )� auto_attribs�frozen�slotsc @ �* e Zd ZU dZeed< eed< ded< dS )r z0Parameters sent by the `on_request_start` signal�method�url�CIMultiDict[str]�headersN�r r r rk rl �__annotations__r r r r r r � �
r c @ �* e Zd ZU dZeed< eed< eed< dS )r- z5Parameters sent by the `on_request_chunk_sent` signalrr rs �chunkN�r r r rk rl rw r �bytesr r r r r- � rx r- c @ ry )r. z:Parameters sent by the `on_response_chunk_received` signalrr rs rz Nr{ r r r r r. � rx r. c @ �2 e Zd ZU dZeed< eed< ded< eed< dS )r! z.Parameters sent by the `on_request_end` signalrr rs rt ru �responseN�r r r rk rl rw r r r r r r r! � �
r! c @ r} )r" z4Parameters sent by the `on_request_exception` signalrr rs rt ru � exceptionN)r r r rk rl rw r �
BaseExceptionr r r r r" � r� r" c @ r} )r, z3Parameters sent by the `on_request_redirect` signalrr rs rt ru r~ Nr r r r r r, r� r, c @ � e Zd ZdZdS )r# z:Parameters sent by the `on_connection_queued_start` signalN�r r r rk r r r r r# � r# c @ r� )r$ z8Parameters sent by the `on_connection_queued_end` signalNr� r r r r r$ r� r$ c @ r� )r% z:Parameters sent by the `on_connection_create_start` signalNr� r r r r r% r� r% c @ r� )r& z8Parameters sent by the `on_connection_create_end` signalNr� r r r r r& r� r& c @ r� )r' z7Parameters sent by the `on_connection_reuseconn` signalNr� r r r r r' % r� r' c @ � e Zd ZU dZeed< dS )r( z8Parameters sent by the `on_dns_resolvehost_start` signal�hostN�r r r rk rl rw r r r r r( * �
r( c @ r� )r) z6Parameters sent by the `on_dns_resolvehost_end` signalr� Nr� r r r r r) 1 r� r) c @ r� )r* z0Parameters sent by the `on_dns_cache_hit` signalr� Nr� r r r r r* 8 r� r* c @ r� )r+ z1Parameters sent by the `on_dns_cache_miss` signalr� Nr� r r r r r+ ? r� r+ c @ rq )r/ z7Parameters sent by the `on_request_headers_sent` signalrr rs rt ru Nrv r r r r r/ F rx r/ c
@ sf e Zd ZdZdddededdfdd �Zd
ed ed d
ddfdd�Z d
ed ede
ddfdd�Z d
ed ede
ddfdd�Z d
ed ed d
de
ddf
dd�Zd
ed ed d
deddf
dd�Zd
ed ed d
de
ddf
dd �Zd2d d �Zd2d d �Zd2d!d"�Zd2d#d$�Zd2d%d&�Zd'eddfd(d)�Zd'eddfd*d+�Zd'eddfd,d-�Zd'eddfd.d/�Zd
ed ed 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_configrD r Nc C s || _ || _|| _d S r )�
_trace_config�_trace_config_ctx�_session)r r� r� rD r r r rB V s
zTrace.__init__rr rs ru rt c � �& �| j j�| j| jt|||��I d H S r )r� rI �sendr� r� r �r rr rs ru r r r �send_request_start` � �
�zTrace.send_request_startrz c � r� r )r� rL r� r� r� r- �r rr rs rz r r r �send_request_chunk_senti r� z Trace.send_request_chunk_sentc � r� r )r� rO r� r� r� r. r� r r r � send_response_chunk_receivedr r� z"Trace.send_response_chunk_receivedr~ c � �( �| j j�| j| jt||||��I d H S r )r� rQ r� r� r� r! �r rr rs ru r~ r r r �send_request_end{ � �
�zTrace.send_request_endr� c � r� r )r� rS r� r� r� r" )r rr rs ru r� r r r �send_request_exception� r� z Trace.send_request_exceptionc � r� r )r� r6 r� r� r� r, r� r r r �send_request_redirect� r� zTrace.send_request_redirectc � � �| j j�| j| jt� �I d H S r )r� rW r� r� r� r# rF r r r � send_connection_queued_start� � �
�z"Trace.send_connection_queued_startc � r� r )r� rY r� r� r� r$ rF r r r �send_connection_queued_end� r� z Trace.send_connection_queued_endc � r� r )r� r[ r� r� r� r% rF r r r � send_connection_create_start� r� z"Trace.send_connection_create_startc � r� r )r� r] r� r� r� r& rF r r r �send_connection_create_end� r� z Trace.send_connection_create_endc � r� r )r� r_ r� r� r� r' rF r r r �send_connection_reuseconn� r� z Trace.send_connection_reuseconnr� c � �" �| j j�| j| jt|��I d H S r )r� ra r� r� r� r( �r r� r r r �send_dns_resolvehost_start� � �
�z Trace.send_dns_resolvehost_startc � r� r )r� rc r� r� r� r) r� r r r �send_dns_resolvehost_end� r� z Trace.send_dns_resolvehost_endc � r� r )r� re r� r� r� r* r� r r r �send_dns_cache_hit� r� zTrace.send_dns_cache_hitc � r� r )r� rg r� r� r� r+ r� r r r �send_dns_cache_miss� r� zTrace.send_dns_cache_missc � r� r )r� r@ r� r� r� r/ r� r r r �send_request_headers� r� zTrace.send_request_headersrj ) r r r rk r r rB rl r r� r| r� r� r r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r r� O s� ���
�
���
� ���
� ���
� ����
�
����
�
����
�
����r� )+�typesr �typingr r r r r r r �attr� aiosignalr
� multidictr �yarlr �
client_reqrepr �clientr r r �__all__r �sr r- r. r! r" r, r# r$ r% r& r' r( r) r* r+ r/ r� r r r r �<module> s^ $ +