
    rp0j8                        S SK Jr  S SKJrJrJr  S SKrS SKJr  S SK	J
r
  S SKJr  SSKJr  \(       a  SS	KJr  \" S
SS9r\\\\4   rSr " S S5      r\R*                  " SSSS9 " S S5      5       r\R*                  " SSSS9 " S S5      5       r\R*                  " SSSS9 " S S5      5       r\R*                  " SSSS9 " S S5      5       r\R*                  " SSSS9 " S S5      5       r\R*                  " SSSS9 " S S5      5       r\R*                  " SSSS9 " S S5      5       r\R*                  " SSSS9 " S S 5      5       r\R*                  " SSSS9 " S! S"5      5       r\R*                  " SSSS9 " S# S$5      5       r\R*                  " SSSS9 " S% S&5      5       r \R*                  " SSSS9 " S' S(5      5       r!\R*                  " SSSS9 " S) S*5      5       r"\R*                  " SSSS9 " S+ S,5      5       r#\R*                  " SSSS9 " S- S.5      5       r$\R*                  " SSSS9 " S/ S05      5       r% " S1 S25      r&g)3    )SimpleNamespace)TYPE_CHECKINGAnyTypeVarN)Signal)CIMultiDict)URL   )ClientResponse)ClientSession_ParamT_contraT)contravariant)TraceConfigTraceRequestStartParamsTraceRequestEndParamsTraceRequestExceptionParams TraceConnectionQueuedStartParamsTraceConnectionQueuedEndParams TraceConnectionCreateStartParamsTraceConnectionCreateEndParamsTraceConnectionReuseconnParamsTraceDnsResolveHostStartParamsTraceDnsResolveHostEndParamsTraceDnsCacheHitParamsTraceDnsCacheMissParamsTraceRequestRedirectParamsTraceRequestChunkSentParams TraceResponseChunkReceivedParamsTraceRequestHeadersSentParamsc                      \ rS rSrSr\4S\\   SS4S jjrSS\S\4S jjr	SS	 jr
\SS
 j5       r\  SS j5       r\  SS j5       r\S S j5       r\  S!S j5       r\  S"S j5       r\  S#S j5       r\  S$S j5       r\  S%S j5       r\  S&S j5       r\  S'S j5       r\  S(S j5       r\  S)S j5       r\S*S j5       r\S+S j5       r\  S,S j5       rSrg)-r   '   zFFirst-class used to trace requests launched via ClientSession objects.trace_config_ctx_factoryreturnNc                    [        U 5      U l        [        U 5      U l        [        U 5      U l        [        U 5      U l        [        U 5      U l        [        U 5      U l        [        U 5      U l        [        U 5      U l        [        U 5      U l	        [        U 5      U l
        [        U 5      U l        [        U 5      U l        [        U 5      U l        [        U 5      U l        [        U 5      U l        [        U 5      U l        Xl        g N)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)selfr"   s     I/home/wildlama/miniconda3/lib/python3.13/site-packages/aiohttp/tracing.py__init__TraceConfig.__init__*   s    KQQU,4L 	#
 4L 	( GMTl4L 	" QWQ
!
 4L 	(
 4L 	&
 4L 	(
 4L 	&
 4L 	%
 4L 	& 4L 	$ JPPTKQRV<4L 	% *B&    trace_request_ctxc                      U R                  US9$ )z&Return a new trace_config_ctx instance)r<   )r6   )r7   r<   s     r8   trace_config_ctxTraceConfig.trace_config_ctxX   s    --@Q-RRr;   c                 D   U R                   R                  5         U R                  R                  5         U R                  R                  5         U R                  R                  5         U R
                  R                  5         U R                  R                  5         U R                  R                  5         U R                  R                  5         U R                  R                  5         U R                  R                  5         U R                  R                  5         U R                  R                  5         U R                  R                  5         U R                  R                  5         U R                  R                  5         U R                   R                  5         g r%   )r&   freezer'   r(   r)   r*   r+   r,   r-   r.   r/   r0   r1   r2   r3   r4   r5   r7   s    r8   rA   TraceConfig.freeze\   s"   %%'##**,((//1##%""))+!!((*((//1&&--/((//1&&--/%%,,.&&--/$$++-%%'&&(%%,,.r;   c                     U R                   $ r%   )r&   rB   s    r8   on_request_startTraceConfig.on_request_startn       %%%r;   c                     U R                   $ r%   )r'   rB   s    r8   on_request_chunk_sent!TraceConfig.on_request_chunk_sentr   s     ***r;   c                     U R                   $ r%   )r(   rB   s    r8   on_response_chunk_received&TraceConfig.on_response_chunk_receivedx        ///r;   c                     U R                   $ r%   )r)   rB   s    r8   on_request_endTraceConfig.on_request_end~   s    ###r;   c                     U R                   $ r%   )r*   rB   s    r8   on_request_exception TraceConfig.on_request_exception   s     )))r;   c                     U R                   $ r%   )r+   rB   s    r8   on_request_redirectTraceConfig.on_request_redirect   s     (((r;   c                     U R                   $ r%   )r,   rB   s    r8   on_connection_queued_start&TraceConfig.on_connection_queued_start   rN   r;   c                     U R                   $ r%   )r-   rB   s    r8   on_connection_queued_end$TraceConfig.on_connection_queued_end        ---r;   c                     U R                   $ r%   )r.   rB   s    r8   on_connection_create_start&TraceConfig.on_connection_create_start   rN   r;   c                     U R                   $ r%   )r/   rB   s    r8   on_connection_create_end$TraceConfig.on_connection_create_end   r^   r;   c                     U R                   $ r%   )r0   rB   s    r8   on_connection_reuseconn#TraceConfig.on_connection_reuseconn        ,,,r;   c                     U R                   $ r%   )r1   rB   s    r8   on_dns_resolvehost_start$TraceConfig.on_dns_resolvehost_start   r^   r;   c                     U R                   $ r%   )r2   rB   s    r8   on_dns_resolvehost_end"TraceConfig.on_dns_resolvehost_end   s     +++r;   c                     U R                   $ r%   )r3   rB   s    r8   on_dns_cache_hitTraceConfig.on_dns_cache_hit   rG   r;   c                     U R                   $ r%   )r4   rB   s    r8   on_dns_cache_missTraceConfig.on_dns_cache_miss   s    &&&r;   c                     U R                   $ r%   )r5   rB   s    r8   on_request_headers_sent#TraceConfig.on_request_headers_sent   rh   r;   )r/   r.   r-   r,   r0   r3   r4   r2   r1   r'   r)   r*   r5   r+   r&   r(   r6   r%   r#   N)r#   z'_TracingSignal[TraceRequestStartParams])r#   z+_TracingSignal[TraceRequestChunkSentParams])r#   z0_TracingSignal[TraceResponseChunkReceivedParams])r#   z%_TracingSignal[TraceRequestEndParams])r#   z+_TracingSignal[TraceRequestExceptionParams])r#   z*_TracingSignal[TraceRequestRedirectParams])r#   z0_TracingSignal[TraceConnectionQueuedStartParams])r#   z._TracingSignal[TraceConnectionQueuedEndParams])r#   z0_TracingSignal[TraceConnectionCreateStartParams])r#   z._TracingSignal[TraceConnectionCreateEndParams])r#   z._TracingSignal[TraceConnectionReuseconnParams])r#   z._TracingSignal[TraceDnsResolveHostStartParams])r#   z,_TracingSignal[TraceDnsResolveHostEndParams])r#   z&_TracingSignal[TraceDnsCacheHitParams])r#   z'_TracingSignal[TraceDnsCacheMissParams])r#   z-_TracingSignal[TraceRequestHeadersSentParams])__name__
__module____qualname____firstlineno____doc__r   typer9   r   r>   rA   propertyrE   rI   rL   rP   rS   rV   rY   r\   r`   rc   rf   rj   rm   rp   rs   rv   __static_attributes__ r;   r8   r   r   '   s   P AP,B(,_(=,B	,B\S# S S/$ & & +	6+ +
 0	;0 0
 $ $ *	6* *
 )	5) )
 0	;0 0
 .	9. .
 0	;0 0
 .	9. .
 -	9- -
 .	9. .
 ,	7, ,
 & & ' ' -	8- -r;   r   )auto_attribsfrozenslotsc                   8    \ rS rSr% Sr\\S'   \\S'   S\S'   Srg)	r      z0Parameters sent by the `on_request_start` signalmethodurlCIMultiDict[str]headersr   N	ry   rz   r{   r|   r}   str__annotations__r	   r   r   r;   r8   r   r      s    :K	Hr;   r   c                   8    \ rS rSr% Sr\\S'   \\S'   \\S'   Sr	g)r      z5Parameters sent by the `on_request_chunk_sent` signalr   r   chunkr   N
ry   rz   r{   r|   r}   r   r   r	   bytesr   r   r;   r8   r   r      s    ?K	HLr;   r   c                   8    \ rS rSr% Sr\\S'   \\S'   \\S'   Sr	g)r      z:Parameters sent by the `on_response_chunk_received` signalr   r   r   r   Nr   r   r;   r8   r   r      s    DK	HLr;   r   c                   B    \ rS rSr% Sr\\S'   \\S'   S\S'   \\S'   Sr	g	)
r      z.Parameters sent by the `on_request_end` signalr   r   r   r   responser   N
ry   rz   r{   r|   r}   r   r   r	   r   r   r   r;   r8   r   r      s    8K	Hr;   r   c                   B    \ rS rSr% Sr\\S'   \\S'   S\S'   \\S'   Sr	g	)
r      z4Parameters sent by the `on_request_exception` signalr   r   r   r   	exceptionr   N)
ry   rz   r{   r|   r}   r   r   r	   BaseExceptionr   r   r;   r8   r   r      s    >K	Hr;   r   c                   B    \ rS rSr% Sr\\S'   \\S'   S\S'   \\S'   Sr	g	)
r      z3Parameters sent by the `on_request_redirect` signalr   r   r   r   r   r   Nr   r   r;   r8   r   r      s    =K	Hr;   r   c                       \ rS rSrSrSrg)r      z:Parameters sent by the `on_connection_queued_start` signalr   Nry   rz   r{   r|   r}   r   r   r;   r8   r   r          Dr;   r   c                       \ rS rSrSrSrg)r   i  z8Parameters sent by the `on_connection_queued_end` signalr   Nr   r   r;   r8   r   r         Br;   r   c                       \ rS rSrSrSrg)r   i
  z:Parameters sent by the `on_connection_create_start` signalr   Nr   r   r;   r8   r   r   
  r   r;   r   c                       \ rS rSrSrSrg)r   i  z8Parameters sent by the `on_connection_create_end` signalr   Nr   r   r;   r8   r   r     r   r;   r   c                       \ rS rSrSrSrg)r   i  z7Parameters sent by the `on_connection_reuseconn` signalr   Nr   r   r;   r8   r   r     s    Ar;   r   c                   $    \ rS rSr% Sr\\S'   Srg)r   i  z8Parameters sent by the `on_dns_resolvehost_start` signalhostr   Nry   rz   r{   r|   r}   r   r   r   r   r;   r8   r   r     s
    B
Ir;   r   c                   $    \ rS rSr% Sr\\S'   Srg)r   i   z6Parameters sent by the `on_dns_resolvehost_end` signalr   r   Nr   r   r;   r8   r   r      s
    @
Ir;   r   c                   $    \ rS rSr% Sr\\S'   Srg)r   i'  z0Parameters sent by the `on_dns_cache_hit` signalr   r   Nr   r   r;   r8   r   r   '  s
    :
Ir;   r   c                   $    \ rS rSr% Sr\\S'   Srg)r   i.  z1Parameters sent by the `on_dns_cache_miss` signalr   r   Nr   r   r;   r8   r   r   .  s
    ;
Ir;   r   c                   8    \ rS rSr% Sr\\S'   \\S'   S\S'   Srg)	r   i5  z7Parameters sent by the `on_request_headers_sent` signalr   r   r   r   r   Nr   r   r;   r8   r   r   5  s    AK	Hr;   r   c            
       n   \ rS rSrSrSSS\S\SS4S	 jrS
\S\	SSSS4S jr
S
\S\	S\SS4S jrS
\S\	S\SS4S jrS
\S\	SSS\SS4
S jrS
\S\	SSS\SS4
S jrS
\S\	SSS\SS4
S jrS#S jrS#S jrS#S jrS#S jrS#S jrS\SS4S jrS\SS4S jrS\SS4S jrS\SS4S  jrS
\S\	SSSS4S! jrS"rg)$Tracei>  ztInternal dependency holder class.

Used to keep together the main dependencies used
at the moment of send a signal.
sessionr   trace_configr>   r#   Nc                 (    X l         X0l        Xl        g r%   )_trace_config_trace_config_ctx_session)r7   r   r   r>   s       r8   r9   Trace.__init__E  s     *!1r;   r   r   r   r   c           	         #    U R                   R                  R                  U R                  U R                  [        XU5      5      I S h  vN $  N7fr%   )r   rE   sendr   r   r   r7   r   r   r   s       r8   send_request_startTrace.send_request_startO  sJ      ''88==MM""#F9
 
 	
 
   A	AAAr   c           	         #    U R                   R                  R                  U R                  U R                  [        XU5      5      I S h  vN $  N7fr%   )r   rI   r   r   r   r   r7   r   r   r   s       r8   send_request_chunk_sentTrace.send_request_chunk_sentX  sJ      ''==BBMM""'U;
 
 	
 
r   c           	         #    U R                   R                  R                  U R                  U R                  [        XU5      5      I S h  vN $  N7fr%   )r   rL   r   r   r   r   r   s       r8   send_response_chunk_received"Trace.send_response_chunk_receiveda  sJ      ''BBGGMM"",V%@
 
 	
 
r   r   c           
         #    U R                   R                  R                  U R                  U R                  [        XX45      5      I S h  vN $  N7fr%   )r   rP   r   r   r   r   r7   r   r   r   r   s        r8   send_request_endTrace.send_request_endj  sJ      ''66;;MM""!&wA
 
 	
 
r   r   c           
         #    U R                   R                  R                  U R                  U R                  [        XX45      5      I S h  vN $  N7fr%   )r   rS   r   r   r   r   )r7   r   r   r   r   s        r8   send_request_exceptionTrace.send_request_exceptionw  sJ      ''<<AAMM""'WH
 
 	
 
r   c           
         #    U R                   R                  R                  U R                  U R                  [        XX45      5      I S h  vN $  N7fr%   )r   r+   r   r   r   r   r   s        r8   send_request_redirectTrace.send_request_redirect  sJ      ''<<AAMM""&vGF
 
 	
 
r   c                    #    U R                   R                  R                  U R                  U R                  [        5       5      I S h  vN $  N7fr%   )r   rY   r   r   r   r   rB   s    r8   send_connection_queued_start"Trace.send_connection_queued_start  C     ''BBGGMM4113S3U
 
 	
 
   AA	A
Ac                    #    U R                   R                  R                  U R                  U R                  [        5       5      I S h  vN $  N7fr%   )r   r\   r   r   r   r   rB   s    r8   send_connection_queued_end Trace.send_connection_queued_end  C     ''@@EEMM4113Q3S
 
 	
 
r   c                    #    U R                   R                  R                  U R                  U R                  [        5       5      I S h  vN $  N7fr%   )r   r`   r   r   r   r   rB   s    r8   send_connection_create_start"Trace.send_connection_create_start  r   r   c                    #    U R                   R                  R                  U R                  U R                  [        5       5      I S h  vN $  N7fr%   )r   rc   r   r   r   r   rB   s    r8   send_connection_create_end Trace.send_connection_create_end  r   r   c                    #    U R                   R                  R                  U R                  U R                  [        5       5      I S h  vN $  N7fr%   )r   rf   r   r   r   r   rB   s    r8   send_connection_reuseconnTrace.send_connection_reuseconn  sC     ''??DDMM4113Q3S
 
 	
 
r   r   c                    #    U R                   R                  R                  U R                  U R                  [        U5      5      I S h  vN $  N7fr%   )r   rj   r   r   r   r   r7   r   s     r8   send_dns_resolvehost_start Trace.send_dns_resolvehost_start  sF     ''@@EEMM4113QRV3W
 
 	
 
   AA
AAc                    #    U R                   R                  R                  U R                  U R                  [        U5      5      I S h  vN $  N7fr%   )r   rm   r   r   r   r   r   s     r8   send_dns_resolvehost_endTrace.send_dns_resolvehost_end  sF     ''>>CCMM4113OPT3U
 
 	
 
r   c                    #    U R                   R                  R                  U R                  U R                  [        U5      5      I S h  vN $  N7fr%   )r   rp   r   r   r   r   r   s     r8   send_dns_cache_hitTrace.send_dns_cache_hit  sE     ''88==MM4113I$3O
 
 	
 
r   c                    #    U R                   R                  R                  U R                  U R                  [        U5      5      I S h  vN $  N7fr%   )r   rs   r   r   r   r   r   s     r8   send_dns_cache_missTrace.send_dns_cache_miss  sE     ''99>>MM4113J43P
 
 	
 
r   c           	         #    U R                   R                  R                  U R                  U R                  [        XU5      5      I S h  vN $  N7fr%   )r   r5   r   r   r   r   r   s       r8   send_request_headersTrace.send_request_headers  sJ      ''@@EEMM"")&w?
 
 	
 
r   )r   r   r   rx   )ry   rz   r{   r|   r}   r   r   r9   r   r	   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r;   r8   r   r   >  s       "  *	 
 
 

 #
.@
	


 #
,1
	


 #
,1
	


 
 $	

 !
 



 
 $	

 !
 



 
 $	

 !
 












S 
T 


3 
4 


S 
T 


c 
d 



 #
.@
	
r;   r   )'typesr   typingr   r   r   attr	aiosignalr   	multidictr   yarlr	   client_reqrepr   clientr   r   _TracingSignal__all__r   sr   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r;   r8   <module>r      s   ! . .   !  )%-TBNM?NJKN*]- ]-@ T$d3    4  T$d3  4 T$d3  4 T$d3  4 T$d3  4 T$d3  4 T$d3E E 4E T$d3C C 4C T$d3E E 4E T$d3C C 4C T$d3B B 4B T$d3  4 T$d3  4 T$d3  4 T$d3  4 T$d3    4 G
 G
r;   