
    bCi;                        S SK Jr  S SKJrJrJr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 " S S\\   5      rSr " S S5      r\	R0                  " SSSS9 " S S5      5       r\	R0                  " SSSS9 " S S5      5       r\	R0                  " SSSS9 " S S5      5       r\	R0                  " SSSS9 " S S5      5       r\	R0                  " SSSS9 " S S5      5       r\	R0                  " SSSS9 " S S5      5       r\	R0                  " SSSS9 " S S 5      5       r\	R0                  " SSSS9 " S! S"5      5       r \	R0                  " SSSS9 " S# S$5      5       r!\	R0                  " SSSS9 " S% S&5      5       r"\	R0                  " SSSS9 " S' S(5      5       r#\	R0                  " SSSS9 " S) S*5      5       r$\	R0                  " SSSS9 " S+ S,5      5       r%\	R0                  " SSSS9 " S- S.5      5       r&\	R0                  " SSSS9 " S/ S05      5       r'\	R0                  " SSSS9 " S1 S25      5       r( " S3 S45      r)g)5    )SimpleNamespace)TYPE_CHECKING	AwaitableOptionalProtocolTypeTypeVarN)Signal)CIMultiDict)URL   )ClientResponse)ClientSession_ParamT_contraT)contravariantc            	       4    \ rS rSrS\S\S\S\S   4S jrSr	g)	_SignalCallback   _SignalCallback__client_session!_SignalCallback__trace_config_ctx_SignalCallback__paramsreturnNc                     g N )selfr   r   r   s       I/home/james-whalen/.local/lib/python3.13/site-packages/aiohttp/tracing.py__call___SignalCallback.__call__   s         r   )
__name__
__module____qualname____firstlineno__r   r   r   r   r   __static_attributes__r   r    r   r   r      s1    	+	 !0	 %		
 t_	r    r   )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_factoryr   Nc                    [        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 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   r9   s     r   __init__TraceConfig.__init__2   s   
 4L 	
 4L 	#
 4L 	( PVP

 4L 	"
 4L 	!
 4L 	(
 4L 	&
 4L 	(
 4L 	&
 4L 	%
 4L 	&
 4L 	$
 4L 	
 4L 	
 4L 	% *B&r    trace_request_ctxc                      U R                  US9$ )z&Return a new trace_config_ctx instance)rN   )rK   )r   rN   s     r   trace_config_ctxTraceConfig.trace_config_ctxh   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@   rA   rB   rC   rD   rE   rF   rG   rH   rI   rJ   r   s    r   rS   TraceConfig.freezen   s"   %%'##**,((//1##%""))+!!((*((//1&&--/((//1&&--/%%,,.&&--/$$++-%%'&&(%%,,.r    c                     U R                   $ r   )r;   rT   s    r   on_request_startTraceConfig.on_request_start       %%%r    c                     U R                   $ r   )r<   rT   s    r   on_request_chunk_sent!TraceConfig.on_request_chunk_sent   s     ***r    c                     U R                   $ r   )r=   rT   s    r   on_response_chunk_received&TraceConfig.on_response_chunk_received        ///r    c                     U R                   $ r   )r>   rT   s    r   on_request_endTraceConfig.on_request_end   s    ###r    c                     U R                   $ r   )r?   rT   s    r   on_request_exception TraceConfig.on_request_exception   s     )))r    c                     U R                   $ r   )r@   rT   s    r   on_request_redirectTraceConfig.on_request_redirect   s     (((r    c                     U R                   $ r   )rA   rT   s    r   on_connection_queued_start&TraceConfig.on_connection_queued_start   r`   r    c                     U R                   $ r   )rB   rT   s    r   on_connection_queued_end$TraceConfig.on_connection_queued_end        ---r    c                     U R                   $ r   )rC   rT   s    r   on_connection_create_start&TraceConfig.on_connection_create_start   r`   r    c                     U R                   $ r   )rD   rT   s    r   on_connection_create_end$TraceConfig.on_connection_create_end   rp   r    c                     U R                   $ r   )rE   rT   s    r   on_connection_reuseconn#TraceConfig.on_connection_reuseconn        ,,,r    c                     U R                   $ r   )rF   rT   s    r   on_dns_resolvehost_start$TraceConfig.on_dns_resolvehost_start   rp   r    c                     U R                   $ r   )rG   rT   s    r   on_dns_resolvehost_end"TraceConfig.on_dns_resolvehost_end   s     +++r    c                     U R                   $ r   )rH   rT   s    r   on_dns_cache_hitTraceConfig.on_dns_cache_hit   rY   r    c                     U R                   $ r   )rI   rT   s    r   on_dns_cache_missTraceConfig.on_dns_cache_miss   s    &&&r    c                     U R                   $ r   )rJ   rT   s    r   on_request_headers_sent#TraceConfig.on_request_headers_sent   rz   r    )rD   rC   rB   rA   rE   rH   rI   rG   rF   r<   r>   r?   rJ   r@   r;   r=   rK   r   r   N)r   z0Signal[_SignalCallback[TraceRequestStartParams]])r   z4Signal[_SignalCallback[TraceRequestChunkSentParams]])r   z9Signal[_SignalCallback[TraceResponseChunkReceivedParams]])r   z.Signal[_SignalCallback[TraceRequestEndParams]])r   z4Signal[_SignalCallback[TraceRequestExceptionParams]])r   z3Signal[_SignalCallback[TraceRequestRedirectParams]])r   z9Signal[_SignalCallback[TraceConnectionQueuedStartParams]])r   z7Signal[_SignalCallback[TraceConnectionQueuedEndParams]])r   z9Signal[_SignalCallback[TraceConnectionCreateStartParams]])r   z7Signal[_SignalCallback[TraceConnectionCreateEndParams]])r   z7Signal[_SignalCallback[TraceConnectionReuseconnParams]])r   z7Signal[_SignalCallback[TraceDnsResolveHostStartParams]])r   z5Signal[_SignalCallback[TraceDnsResolveHostEndParams]])r   z/Signal[_SignalCallback[TraceDnsCacheHitParams]])r   z0Signal[_SignalCallback[TraceDnsCacheMissParams]])r   z6Signal[_SignalCallback[TraceRequestHeadersSentParams]])r!   r"   r#   r$   __doc__r   r   rL   r   rP   rS   propertyrW   r[   r^   rb   re   rh   rk   rn   rr   ru   rx   r|   r   r   r   r   r%   r   r    r   r&   r&   /   s   P AP4B(,_(=4B	4Bn >BS!)/!:S	S/$ & & +	?+ +
 0	D0 0
 $ $ *	?* *
 )	>) )
 0	D0 0
 .	B. .
 0	D0 0
 .	B. .
 -	B- -
 .	B. .
 ,	@, ,
 & & ' ' -	A- -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	r!   r"   r#   r$   r   str__annotations__r   r%   r   r    r   r'   r'      s    :K	Hr    r'   c                   8    \ rS rSr% Sr\\S'   \\S'   \\S'   Sr	g)r4      z5Parameters sent by the `on_request_chunk_sent` signalr   r   chunkr   N
r!   r"   r#   r$   r   r   r   r   bytesr%   r   r    r   r4   r4      s    ?K	HLr    r4   c                   8    \ rS rSr% Sr\\S'   \\S'   \\S'   Sr	g)r5      z:Parameters sent by the `on_response_chunk_received` signalr   r   r   r   Nr   r   r    r   r5   r5      s    DK	HLr    r5   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
r!   r"   r#   r$   r   r   r   r   r   r%   r   r    r   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)
r!   r"   r#   r$   r   r   r   r   BaseExceptionr%   r   r    r   r)   r)      s    >K	Hr    r)   c                   B    \ rS rSr% Sr\\S'   \\S'   S\S'   \\S'   Sr	g	)
r3   i  z3Parameters sent by the `on_request_redirect` signalr   r   r   r   r   r   Nr   r   r    r   r3   r3     s    =K	Hr    r3   c                       \ rS rSrSrSrg)r*   i  z:Parameters sent by the `on_connection_queued_start` signalr   Nr!   r"   r#   r$   r   r%   r   r    r   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    r   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    r   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    r   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    r   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r!   r"   r#   r$   r   r   r   r%   r   r    r   r/   r/   +  s
    B
Ir    r/   c                   $    \ rS rSr% Sr\\S'   Srg)r0   i2  z6Parameters sent by the `on_dns_resolvehost_end` signalr   r   Nr   r   r    r   r0   r0   2  s
    @
Ir    r0   c                   $    \ rS rSr% Sr\\S'   Srg)r1   i9  z0Parameters sent by the `on_dns_cache_hit` signalr   r   Nr   r   r    r   r1   r1   9  s
    :
Ir    r1   c                   $    \ rS rSr% Sr\\S'   Srg)r2   i@  z1Parameters sent by the `on_dns_cache_miss` signalr   r   Nr   r   r    r   r2   r2   @  s
    ;
Ir    r2   c                   8    \ rS rSr% Sr\\S'   \\S'   S\S'   Srg)	r6   iG  z7Parameters sent by the `on_request_headers_sent` signalr   r   r   r   r   Nr   r   r    r   r6   r6   G  s    AK	Hr    r6   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)$TraceiP  ztInternal dependency holder class.

Used to keep together the main dependencies used
at the moment of send a signal.
sessionr   trace_configrP   r   Nc                 (    X l         X0l        Xl        g r   )_trace_config_trace_config_ctx_session)r   r   r   rP   s       r   rL   Trace.__init__W  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   rW   sendr   r   r'   r   r   r   r   s       r   send_request_startTrace.send_request_starta  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   r[   r   r   r   r4   r   r   r   r   s       r   send_request_chunk_sentTrace.send_request_chunk_sentj  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   r^   r   r   r   r5   r   s       r   send_response_chunk_received"Trace.send_response_chunk_receiveds  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   rb   r   r   r   r(   r   r   r   r   r   s        r   send_request_endTrace.send_request_end|  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   re   r   r   r   r)   )r   r   r   r   r   s        r   send_request_exceptionTrace.send_request_exception  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   r3   r   s        r   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   rk   r   r   r   r*   rT   s    r   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   rn   r   r   r   r+   rT   s    r   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   rr   r   r   r   r,   rT   s    r   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   ru   r   r   r   r-   rT   s    r   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   rx   r   r   r   r.   rT   s    r   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   r|   r   r   r   r/   r   r   s     r   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   r   r   r   r   r0   r   s     r   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   r   r   r   r   r1   r   s     r   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   r   r   r   r   r2   r   s     r   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   rJ   r   r   r   r6   r   s       r   send_request_headersTrace.send_request_headers  sJ      ''@@EEMM"")&w?
 
 	
 
r   )r   r   r   r   )r!   r"   r#   r$   r   r&   r   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   r   r   P  s       "  *	 
 
 

 #
.@
	


 #
,1
	


 #
,1
	


 
 $	

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

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

 !
 












S 
T 


3 
4 


S 
T 


c 
d 



 #
.@
	
r    r   )*typesr   typingr   r   r   r   r   r	   attr	aiosignalr
   	multidictr   yarlr   client_reqrepr   clientr   r   r   __all__r&   sr'   r4   r5   r(   r)   r3   r*   r+   r,   r-   r.   r/   r0   r1   r2   r6   r   r   r    r   <module>r     s   ! N N   !  )%-TBN(>2 *g- g-T 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    