wce0;ddlmZddlmZmZmZmZmZmZddl Z ddl m Z ddl m Z ddlmZddlmZerdd lmZed d ZGd deeZdZGddZe j0d d d GddZe j0d d d GddZe j0d d d GddZe j0d d d GddZe j0d d d GddZe j0d d d GddZe j0d d d Gdd Ze j0d d d Gd!d"Z e j0d d d Gd#d$Z!e j0d d d Gd%d&Z"e j0d d d Gd'd(Z#e j0d d d Gd)d*Z$e j0d d d Gd+d,Z%e j0d d d Gd-d.Z&e j0d d d Gd/d0Z'e j0d d d Gd1d2Z(Gd3d4Z)y)5)SimpleNamespace) TYPE_CHECKING AwaitableOptionalProtocolTypeTypeVarN)Signal) CIMultiDict)URL)ClientResponse) ClientSession_ParamT_contraT) contravariantc *eZdZdededededfdZy)_SignalCallback_SignalCallback__client_session!_SignalCallback__trace_config_ctx_SignalCallback__paramsreturnNcyN)selfrrrs 1/usr/lib/python3/dist-packages/aiohttp/tracing.py__call__z_SignalCallback.__call__s )__name__ __module__ __qualname__rrrrrrrrrrs1 + !0 %   t_  rr) TraceConfigTraceRequestStartParamsTraceRequestEndParamsTraceRequestExceptionParams TraceConnectionQueuedStartParamsTraceConnectionQueuedEndParams TraceConnectionCreateStartParamsTraceConnectionCreateEndParamsTraceConnectionReuseconnParamsTraceDnsResolveHostStartParamsTraceDnsResolveHostEndParamsTraceDnsCacheHitParamsTraceDnsCacheMissParamsTraceRequestRedirectParamsTraceRequestChunkSentParams TraceResponseChunkReceivedParamsTraceRequestHeadersSentParamsceZdZdZefdeeddfdZ ddeedefdZddZ e dd Z e dd Z e dd Z e dd Ze dd Ze d dZe d!dZe d"dZe d#dZe d$dZe d%dZe d&dZe d'dZe d(dZe d)dZe d*dZy)+r"zFFirst-class used to trace requests launched via ClientSession objects.trace_config_ctx_factoryrNct||_t||_t||_t||_t||_t||_t||_t||_t||_ t||_ t||_ t||_ t||_ t||_t||_t||_||_yr)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)rr4s r__init__zTraceConfig.__init__2s! 4L  4L # 4L (PV P  4L " 4L ! 4L ( 4L & 4L ( 4L & 4L % 4L & 4L $ 4L  4L  4L %*B&rtrace_request_ctxc&|j|S)z&Return a new trace_config_ctx instance)rH)rF)rrHs rtrace_config_ctxzTraceConfig.trace_config_ctxhs--@Q-RRrcD|jj|jj|jj|jj|j j|j j|jj|jj|jj|jj|jj|jj|jj|jj|jj|j jyr)r6freezer7r8r9r:r;r<r=r>r?r@rArBrCrDrErs rrLzTraceConfig.freezens" %%' ##**, ((//1 ##% ""))+ !!((* ((//1 &&--/ ((//1 &&--/ %%,,. &&--/ $$++- %%' &&( %%,,.rc|jSr)r6rMs ron_request_startzTraceConfig.on_request_start%%%rc|jSr)r7rMs ron_request_chunk_sentz!TraceConfig.on_request_chunk_sents***rc|jSr)r8rMs ron_response_chunk_receivedz&TraceConfig.on_response_chunk_received///rc|jSr)r9rMs ron_request_endzTraceConfig.on_request_ends###rc|jSr)r:rMs ron_request_exceptionz TraceConfig.on_request_exceptions)))rc|jSr)r;rMs ron_request_redirectzTraceConfig.on_request_redirects(((rc|jSr)r<rMs ron_connection_queued_startz&TraceConfig.on_connection_queued_startrUrc|jSr)r=rMs ron_connection_queued_endz$TraceConfig.on_connection_queued_end---rc|jSr)r>rMs ron_connection_create_startz&TraceConfig.on_connection_create_startrUrc|jSr)r?rMs ron_connection_create_endz$TraceConfig.on_connection_create_endr`rc|jSr)r@rMs ron_connection_reuseconnz#TraceConfig.on_connection_reuseconn,,,rc|jSr)rArMs ron_dns_resolvehost_startz$TraceConfig.on_dns_resolvehost_startr`rc|jSr)rBrMs ron_dns_resolvehost_endz"TraceConfig.on_dns_resolvehost_ends+++rc|jSr)rCrMs ron_dns_cache_hitzTraceConfig.on_dns_cache_hitrPrc|jSr)rDrMs ron_dns_cache_misszTraceConfig.on_dns_cache_misss&&&rc|jSr)rErMs ron_request_headers_sentz#TraceConfig.on_request_headers_sentrgrrrN)rz0Signal[_SignalCallback[TraceRequestStartParams]])rz4Signal[_SignalCallback[TraceRequestChunkSentParams]])rz9Signal[_SignalCallback[TraceResponseChunkReceivedParams]])rz.Signal[_SignalCallback[TraceRequestEndParams]])rz4Signal[_SignalCallback[TraceRequestExceptionParams]])rz3Signal[_SignalCallback[TraceRequestRedirectParams]])rz9Signal[_SignalCallback[TraceConnectionQueuedStartParams]])rz7Signal[_SignalCallback[TraceConnectionQueuedEndParams]])rz9Signal[_SignalCallback[TraceConnectionCreateStartParams]])rz7Signal[_SignalCallback[TraceConnectionCreateEndParams]])rz7Signal[_SignalCallback[TraceConnectionReuseconnParams]])rz7Signal[_SignalCallback[TraceDnsResolveHostStartParams]])rz5Signal[_SignalCallback[TraceDnsResolveHostEndParams]])rz/Signal[_SignalCallback[TraceDnsCacheHitParams]])rz0Signal[_SignalCallback[TraceDnsCacheMissParams]])rz6Signal[_SignalCallback[TraceRequestHeadersSentParams]])rr r!__doc__rrrGrrJrLpropertyrOrRrTrWrYr[r]r_rbrdrfrirkrmrorqrrrr"r"/sPAP4B(,_(=4B 4Bn>BS!)/!:S S /$&&+ ?++ 0 D00 $$* ?** ) >)) 0 D00 . B.. 0 D00 . B.. - B-- . B.. , @,, &&''- A--rr") auto_attribsfrozenslotsc0eZdZUdZeed<eed<ded<y)r#z0Parameters sent by the `on_request_start` signalmethodurlCIMultiDict[str]headersNrr r!rsstr__annotations__r rrrr#r#s: K H rr#c0eZdZUdZeed<eed<eed<y)r0z5Parameters sent by the `on_request_chunk_sent` signalryrzchunkNrr r!rsr~rr bytesrrrr0r0s? K H Lrr0c0eZdZUdZeed<eed<eed<y)r1z:Parameters sent by the `on_response_chunk_received` signalryrzrNrrrrr1r1sD K H Lrr1c:eZdZUdZeed<eed<ded<eed<y)r$z.Parameters sent by the `on_request_end` signalryrzr{r|responseNrr r!rsr~rr rrrrr$r$s8 K H rr$c:eZdZUdZeed<eed<ded<eed<y)r%z4Parameters sent by the `on_request_exception` signalryrzr{r| exceptionN)rr r!rsr~rr BaseExceptionrrrr%r%s> K H rr%c:eZdZUdZeed<eed<ded<eed<y)r/z3Parameters sent by the `on_request_redirect` signalryrzr{r|rNrrrrr/r/s= K H rr/ceZdZdZy)r&z:Parameters sent by the `on_connection_queued_start` signalNrr r!rsrrrr&r&Drr&ceZdZdZy)r'z8Parameters sent by the `on_connection_queued_end` signalNrrrrr'r'Brr'ceZdZdZy)r(z:Parameters sent by the `on_connection_create_start` signalNrrrrr(r(rrr(ceZdZdZy)r)z8Parameters sent by the `on_connection_create_end` signalNrrrrr)r)!rrr)ceZdZdZy)r*z7Parameters sent by the `on_connection_reuseconn` signalNrrrrr*r*&sArr*ceZdZUdZeed<y)r+z8Parameters sent by the `on_dns_resolvehost_start` signalhostNrr r!rsr~rrrrr+r++s B Irr+ceZdZUdZeed<y)r,z6Parameters sent by the `on_dns_resolvehost_end` signalrNrrrrr,r,2s @ Irr,ceZdZUdZeed<y)r-z0Parameters sent by the `on_dns_cache_hit` signalrNrrrrr-r-9s : Irr-ceZdZUdZeed<y)r.z1Parameters sent by the `on_dns_cache_miss` signalrNrrrrr.r.@s ; Irr.c0eZdZUdZeed<eed<ded<y)r2z7Parameters sent by the `on_request_headers_sent` signalryrzr{r|Nr}rrrr2r2GsA K H rr2c DeZdZdZdddededdfdZd ed ed d ddfd Z d ed ede ddfdZ d ed ede ddfdZ d ed ed d de ddf dZd ed ed d deddf dZd ed ed d de ddf dZd!dZd!dZd!dZd!dZd!dZdeddfdZdeddfdZdeddfdZdeddfdZd ed ed d ddfd Zy)"TracezInternal dependency holder class. Used to keep together the main dependencies used at the moment of send a signal. sessionr trace_configrJrNc.||_||_||_yr) _trace_config_trace_config_ctx_session)rrrrJs rrGzTrace.__init__Ws *!1 rryrzr|r{c K|jjj|j|jt |||d{S7wr)rrOsendrrr#rryrzr|s rsend_request_startzTrace.send_request_startasM''88== MM  " " #FC 9    A A A Arc K|jjj|j|jt |||d{S7wr)rrRrrrr0rryrzrs rsend_request_chunk_sentzTrace.send_request_chunk_sentjsM''==BB MM  " " 'U ;    rc K|jjj|j|jt |||d{S7wr)rrTrrrr1rs rsend_response_chunk_receivedz"Trace.send_response_chunk_receivedssM''BBGG MM  " " ,VS% @    rrc K|jjj|j|jt ||||d{S7wr)rrWrrrr$rryrzr|rs rsend_request_endzTrace.send_request_end|sO''66;; MM  " " !&#w A    A A AArc K|jjj|j|jt ||||d{S7wr)rrYrrrr%)rryrzr|rs rsend_request_exceptionzTrace.send_request_exceptionsO''<<AA MM  " " 'Wi H    rc K|jjj|j|jt ||||d{S7wr)rr;rrrr/rs rsend_request_redirectzTrace.send_request_redirectsO''<<AA MM  " " &vsGX F    rcK|jjj|j|jt d{S7wr)rr]rrrr&rMs rsend_connection_queued_startz"Trace.send_connection_queued_startD''BBGG MM4113S3U    AA A AcK|jjj|j|jt d{S7wr)rr_rrrr'rMs rsend_connection_queued_endz Trace.send_connection_queued_endD''@@EE MM4113Q3S    rcK|jjj|j|jt d{S7wr)rrbrrrr(rMs rsend_connection_create_startz"Trace.send_connection_create_startrrcK|jjj|j|jt d{S7wr)rrdrrrr)rMs rsend_connection_create_endz Trace.send_connection_create_endrrcK|jjj|j|jt d{S7wr)rrfrrrr*rMs rsend_connection_reuseconnzTrace.send_connection_reuseconnsD''??DD MM4113Q3S    rrcK|jjj|j|jt |d{S7wr)rrirrrr+rrs rsend_dns_resolvehost_startz Trace.send_dns_resolvehost_startsG''@@EE MM4113QRV3W    AA A AcK|jjj|j|jt |d{S7wr)rrkrrrr,rs rsend_dns_resolvehost_endzTrace.send_dns_resolvehost_endsG''>>CC MM4113OPT3U    rcK|jjj|j|jt |d{S7wr)rrmrrrr-rs rsend_dns_cache_hitzTrace.send_dns_cache_hitsF''88== MM4113I$3O    rcK|jjj|j|jt |d{S7wr)rrorrrr.rs rsend_dns_cache_misszTrace.send_dns_cache_misssF''99>> MM4113J43P    rc K|jjj|j|jt |||d{S7wr)rrErrrr2rs rsend_request_headerszTrace.send_request_headerssM''@@EE MM  " " )&#w ?    rrr)rr r!rsr"rrGr~r rrrrrrrrrrrrrrrrrrrrrrrrPs    " *      # .@    # ,1    # ,1        $  !          $  !          $  !          S T  3 4  S T  c d   # .@  rr)*typesrtypingrrrrrr attr aiosignalr multidictr yarlr client_reqreprclientrrr__all__r"sr#r0r1r$r%r/r&r'r(r)r*r+r,r-r.r2rrrrrs!NN !)%-TBN(>2 *g-g-TT$d3  4 T$d34T$d34T$d34T$d34T$d34T$d3EE4ET$d3CC4CT$d3EE4ET$d3CC4CT$d3BB4BT$d34 T$d34 T$d34 T$d34 T$d3  4 G G r