| Server IP : 192.158.238.246 / Your IP : 3.128.171.15 Web Server : LiteSpeed System : Linux uniform.iwebfusion.net 4.18.0-553.27.1.lve.1.el8.x86_64 #1 SMP Wed Nov 20 15:58:00 UTC 2024 x86_64 User : jenniferflocom ( 1321) PHP Version : 8.1.32 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /opt/alt/python38/lib64/python3.8/site-packages/aiohttp/__pycache__/ |
Upload File : |
U
'�7`8 � @ s� d dl mZ d dlmZmZmZmZmZ d dlZd dl m
Z
d dl m Z ddl
mZ ddlmZ er�d d lmZ dd
lmZ ed d d
�ZG dd� dee �ZdZG dd� d�Zejd d d d�G dd� d��Zejd d d d�G dd� d��Zejd d d d�G dd� d��Z ejd d d d�G dd� d��Z ejd d d d�G d d � d ��Z ejd d d d�G d d � d ��Z ejd d d d�G d d!� d!��Z ejd d d d�G d"d#� d#��Z!ejd d d d�G d$d%� d%��Z"ejd d d d�G d&d'� d'��Z#ejd d d d�G d(d)� d)��Z$ejd d d d�G d*d+� d+��Z%ejd d d d�G d,d-� d-��Z&ejd d d d�G d.d/� d/��Z'ejd d d d�G d0d1� d1��Z(G d2d3� d3�Z)dS )4� )�SimpleNamespace)�
TYPE_CHECKING� Awaitable�Optional�Type�TypeVarN)� CIMultiDict)�URL� )�ClientResponse)�Signal)�Protocol)�
ClientSession�_ParamT_contraT)�
contravariantc @ s$ e Zd Zeeeed d�dd�ZdS )�_SignalCallbackN)� _SignalCallback__client_session�!_SignalCallback__trace_config_ctx�_SignalCallback__params�returnc C s d S �N� )�selfr r r r r �B/opt/alt/python38/lib64/python3.8/site-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� TraceResponseChunkReceivedParamsc @ sZ e Zd ZdZefee dd�dd�Zd9ee ed�dd�Zdd �d
d �Z e
d d �d
d��Z e
dd �dd��Z e
dd �dd��Z
e
dd �dd��Ze
dd �dd��Ze
dd �d d ��Ze
d d �d d ��Ze
d!d �d"d#��Ze
d$d �d%d&��Ze
d'd �d(d)��Ze
d*d �d+d,��Ze
d-d �d.d/��Ze
d0d �d1d2��Ze
d3d �d4d5��Ze
d6d �d7d8��ZdS ):r zJFirst-class used to trace requests launched via ClientSession
objects.N)�trace_config_ctx_factoryr c C s� 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�_trace_config_ctx_factory)r r. r r r �__init__4 s\ ���������������zTraceConfig.__init__)�trace_request_ctxr c C s | j |d�S )z( Return a new trace_config_ctx instance )r@ )r> )r r@ r r r �trace_config_ctxg s z TraceConfig.trace_config_ctx�r c C s� | j �� | j�� | j�� | j�� | j�� | j�� | j�� | j�� | j �� | j
�� | j �� | j �� | j
�� | j�� | j�� d S r )r/ �freezer0 r1 r2 r3 r4 r5 r6 r7 r8 r9 r: r; r< r= �r r r r rC m s
zTraceConfig.freezez0Signal[_SignalCallback[TraceRequestStartParams]]c C s | j S r )r/ rD r r r �on_request_start~ s z TraceConfig.on_request_startz4Signal[_SignalCallback[TraceRequestChunkSentParams]]c C s | j S r )r0 rD r r r �on_request_chunk_sent� s z!TraceConfig.on_request_chunk_sentz9Signal[_SignalCallback[TraceResponseChunkReceivedParams]]c C s | j S r )r1 rD r r r �on_response_chunk_received� s z&TraceConfig.on_response_chunk_receivedz.Signal[_SignalCallback[TraceRequestEndParams]]c C s | j S r )r2 rD r r r �on_request_end� s zTraceConfig.on_request_endz4Signal[_SignalCallback[TraceRequestExceptionParams]]c C s | j S r )r3 rD r r r �on_request_exception� s z TraceConfig.on_request_exceptionz3Signal[_SignalCallback[TraceRequestRedirectParams]]c C s | j S r )r4 rD r r r �on_request_redirect� s z TraceConfig.on_request_redirectz9Signal[_SignalCallback[TraceConnectionQueuedStartParams]]c C s | j S r )r5 rD r r r �on_connection_queued_start� s z&TraceConfig.on_connection_queued_startz7Signal[_SignalCallback[TraceConnectionQueuedEndParams]]c C s | j S r )r6 rD r r r �on_connection_queued_end� s z$TraceConfig.on_connection_queued_endz9Signal[_SignalCallback[TraceConnectionCreateStartParams]]c C s | j S r )r7 rD r r r �on_connection_create_start� s z&TraceConfig.on_connection_create_startz7Signal[_SignalCallback[TraceConnectionCreateEndParams]]c C s | j S r )r8 rD r r r �on_connection_create_end� s z$TraceConfig.on_connection_create_endz7Signal[_SignalCallback[TraceConnectionReuseconnParams]]c C s | j S r )r9 rD r r r �on_connection_reuseconn� s z#TraceConfig.on_connection_reuseconnz7Signal[_SignalCallback[TraceDnsResolveHostStartParams]]c C s | j S r )r: rD r r r �on_dns_resolvehost_start� s z$TraceConfig.on_dns_resolvehost_startz5Signal[_SignalCallback[TraceDnsResolveHostEndParams]]c C s | j S r )r; rD r r r �on_dns_resolvehost_end� s z"TraceConfig.on_dns_resolvehost_endz/Signal[_SignalCallback[TraceDnsCacheHitParams]]c C s | j S r )r< rD r r r �on_dns_cache_hit� s z TraceConfig.on_dns_cache_hitz0Signal[_SignalCallback[TraceDnsCacheMissParams]]c C s | j S r )r= rD r r r �on_dns_cache_miss� s z TraceConfig.on_dns_cache_miss)N)r r r �__doc__r r r? r rA rC �propertyrE rF rG rH rI rJ rK rL rM rN rO rP rQ rR rS r r r r r 0 sj �� 4 �� �����������r )Z auto_attribs�frozen�slotsc @ s* e Zd ZU dZeed< eed< ded< dS )r z1 Parameters sent by the `on_request_start` signal�method�url�CIMultiDict[str]�headersN)r r r rT �str�__annotations__r r r r r r � s
r c @ s* e Zd ZU dZeed< eed< eed< dS )r, z6 Parameters sent by the `on_request_chunk_sent` signalrX rY �chunkN�r r r rT r\ r] r �bytesr r r r r, � s
r, c @ s* e Zd ZU dZeed< eed< eed< dS )r- z; Parameters sent by the `on_response_chunk_received` signalrX rY r^ Nr_ r r r r r- � s
r- c @ s2 e Zd ZU dZeed< eed< ded< eed< dS )r z/ Parameters sent by the `on_request_end` signalrX rY rZ r[ �responseN�r r r rT r\ r] r r r r r r r � s
r c @ s2 e Zd ZU dZeed< eed< ded< eed< dS )r! z5 Parameters sent by the `on_request_exception` signalrX rY rZ r[ � exceptionN)r r r rT r\ r] r �
BaseExceptionr r r r r! � s
r! c @ s2 e Zd ZU dZeed< eed< ded< eed< dS )r+ z4 Parameters sent by the `on_request_redirect` signalrX rY rZ r[ ra Nrb r r r r r+ s
r+ c @ s e Zd ZdZdS )r" z; Parameters sent by the `on_connection_queued_start` signalN�r r r rT r r r r r"
s r" c @ s e Zd ZdZdS )r# z9 Parameters sent by the `on_connection_queued_end` signalNre r r r r r# s r# c @ s e Zd ZdZdS )r$ z; Parameters sent by the `on_connection_create_start` signalNre r r r r r$ s r$ c @ s e Zd ZdZdS )r% z9 Parameters sent by the `on_connection_create_end` signalNre r r r r r% s r% c @ s e Zd ZdZdS )r& z8 Parameters sent by the `on_connection_reuseconn` signalNre r r r r r& s r& c @ s e Zd ZU dZeed< dS )r' z9 Parameters sent by the `on_dns_resolvehost_start` signal�hostN�r r r rT r\ r] r r r r r' # s
r' c @ s e Zd ZU dZeed< dS )r( z7 Parameters sent by the `on_dns_resolvehost_end` signalrf Nrg r r r r r( * s
r( c @ s e Zd ZU dZeed< dS )r) z1 Parameters sent by the `on_dns_cache_hit` signalrf Nrg r r r r r) 1 s
r) c @ s e Zd ZU dZeed< dS )r* z2 Parameters sent by the `on_dns_cache_miss` signalrf Nrg r r r r r* 8 s
r* c @ s( e Zd ZdZdeedd�dd�Zeeddd�d d
�Z eee
dd �d d
�Z eee
dd �dd�Z eede
dd�dd�Zeededd�dd�Zeede
dd�dd�Zdd�dd�Zdd�dd �Zdd�d d �Zdd�d d �Zdd�d!d"�Zedd#�d$d%�Zedd#�d&d'�Zedd#�d(d)�Zedd#�d*d+�ZdS ),�TracezcInternal class used to keep together the main dependencies used
at the moment of send a signal.r N)�session� trace_configrA r c C s || _ || _|| _d S r )�
_trace_config�_trace_config_ctx�_session)r ri rj rA r r r r? C s zTrace.__init__rZ )rX rY r[ r c � s$ | j j�| j| jt|||��I d H S r )rk rE �sendrm rl r )r rX rY r[ r r r �send_request_startM s
�zTrace.send_request_start)rX rY r^ r c � s$ | j j�| j| jt|||��I d H S r )rk rF rn rm rl r, �r rX rY r^ r r r �send_request_chunk_sentV s
�z Trace.send_request_chunk_sentc � s$ | j j�| j| jt|||��I d H S r )rk rG rn rm rl r- rp r r r � send_response_chunk_received_ s
�z"Trace.send_response_chunk_received)rX rY r[ ra r c � s& | j j�| j| jt||||��I d H S r )rk rH rn rm rl r �r rX rY r[ ra r r r �send_request_endh s
�zTrace.send_request_end)rX rY r[ rc r c � s& | j j�| j| jt||||��I d H S r )rk rI rn rm rl r! )r rX rY r[ rc r r r �send_request_exceptionu s
�z Trace.send_request_exceptionc � s& | j j�| j| jt||||��I d H S r )rk r4 rn rm rl r+ rs r r r �send_request_redirect� s
�zTrace.send_request_redirectrB c � s | j j�| j| jt� �I d H S r )rk rK rn rm rl r" rD r r r � send_connection_queued_start� s
�z"Trace.send_connection_queued_startc � s | j j�| j| jt� �I d H S r )rk rL rn rm rl r# rD r r r �send_connection_queued_end� s
�z Trace.send_connection_queued_endc � s | j j�| j| jt� �I d H S r )rk rM rn rm rl r$ rD r r r � send_connection_create_start� s
�z"Trace.send_connection_create_startc � s | j j�| j| jt� �I d H S r )rk rN rn rm rl r% rD r r r �send_connection_create_end� s
�z Trace.send_connection_create_endc � s | j j�| j| jt� �I d H S r )rk rO rn rm rl r& rD r r r �send_connection_reuseconn� s
�z Trace.send_connection_reuseconn)rf r c � s | j j�| j| jt|��I d H S r )rk rP rn rm rl r' �r rf r r r �send_dns_resolvehost_start� s
�z Trace.send_dns_resolvehost_startc � s | j j�| j| jt|��I d H S r )rk rQ rn rm rl r( r| r r r �send_dns_resolvehost_end� s
�z Trace.send_dns_resolvehost_endc � s | j j�| j| jt|��I d H S r )rk rR rn rm rl r) r| r r r �send_dns_cache_hit� s
�zTrace.send_dns_cache_hitc � s | j j�| j| jt|��I d H S r )rk rS rn rm rl r* r| r r r �send_dns_cache_miss� s
�zTrace.send_dns_cache_miss)r r r rT r r r? r\ r ro r` rq rr r rt rd ru rv rw rx ry rz r{ r} r~ r r� r r r r rh ? s` � �
�
� � � �
rh )*�typesr �typingr r r r r �attrZ multidictr Zyarlr Z
client_reqrepr Zsignalsr Ztyping_extensionsr
Zclientr r r �__all__r �sr r, r- r r! r+ r" r# r$ r% r& r' r( r) r* rh r r r r �<module> sZ
"