Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
Repository URL to install this package:
|
Version:
0.1.9-1 ▾
|
odigos
/
etc
/
odigos-vmagent
/
instrumentations
/
python
/
urllib3
/
http2
/
__pycache__
/
connection.cpython-311.pyc
|
|---|
§
3ç©g|1 ã ó d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dl Zd dl
Zddl m Z ddl
mZ ddlmZmZ ddlmZ ddlmZ eZ ej d ¦ « Z ej e¦ « Z ej d
¦ « Z ej d ¦ « Z ddZ ddZ G d dej! e ¦ « Z" G d de¦ « Z# G d de¦ « Z$dS )é )Ú annotationsNé )Ú
_TYPE_BODY)ÚHTTPHeaderDict)ÚHTTPSConnectionÚ_get_default_user_agent)ÚConnectionError)ÚBaseHTTPResponseÚTs ^[!#$%&'*+\-.^_`|~0-9a-z]+$s* [\0\x00\x0a\x0d\r\n]|^[ \r\n\t]|[ \r\n\t]$ÚnameÚbytesÚreturnÚboolc óP t t | ¦ « ¦ « S )a5
"An implementation that validates fields according to the definitions in Sections
5.1 and 5.5 of [HTTP] only needs an additional check that field names do not
include uppercase characters." (https://httpwg.org/specs/rfc9113.html#n-field-validity)
`http.client._is_legal_header_name` does not validate the field name according to the
HTTP 1.1 spec, so we do that here, in addition to checking for uppercase characters.
This does not allow for the `:` character in the header name, so should not
be used to validate pseudo-headers.
)r ÚRE_IS_LEGAL_HEADER_NAMEÚmatch)r s ú?/tmp/pip-target-fm9nfsjo/lib/python/urllib3/http2/connection.pyÚ_is_legal_header_namer s! õ Õ'×-Ò-¨dÑ3Ô3Ñ 4Ô 4Ð4ó Úvaluec óP t t | ¦ « ¦ « S )aK
"A field value MUST NOT contain the zero value (ASCII NUL, 0x00), line feed
(ASCII LF, 0x0a), or carriage return (ASCII CR, 0x0d) at any position. A field
value MUST NOT start or end with an ASCII whitespace character (ASCII SP or HTAB,
0x20 or 0x09)." (https://httpwg.org/specs/rfc9113.html#n-field-validity)
)r ÚRE_IS_ILLEGAL_HEADER_VALUEÚsearch)r s r Ú_is_illegal_header_valuer , s! õ Õ*×1Ò1°%Ñ8Ô8Ñ 9Ô 9Ð9r c ó. e Zd ZdZdZddZddZddZdS )Ú
_LockedObjectaX
A wrapper class that hides a specific object behind a lock.
The goal here is to provide a simple way to protect access to an object
that cannot safely be simultaneously accessed from multiple threads. The
intended use of this class is simple: take hold of it with a context
manager, which returns the protected object.
)ÚlockÚ_objÚobjr c óD t j ¦ « | _ || _ d S ©N)Ú threadingÚRLockr r )Úselfr s r Ú__init__z_LockedObject.__init__D s Ý OÑ%Ô% Ø r r c óB | j ¦ « | j S r! )r Úacquirer ©r$ s r Ú __enter__z_LockedObject.__enter__H s Ø ×ÒÑÔÐØyÐr Úexc_typeútype[BaseException] | NoneÚexc_valúBaseException | NoneÚexc_tbútypes.TracebackType | NoneÚNonec ó8 | j ¦ « d S r! )r Úrelease)r$ r* r, r. s r Ú__exit__z_LockedObject.__exit__L s ð
×ÒÑÔÐÐÐr N)r r )r r )r* r+ r, r- r. r/ r r0 )Ú__name__Ú
__module__Ú __qualname__Ú__doc__Ú __slots__r% r) r3 © r r r r 6 sa ðð ðIð
ð ð ð ðð ð ð ð ð ð ð ð ð r r c ó e Zd Z d*d+ fd
Zd,d Zd- fd
Zd.dZd/dZd*d0dZd1dZ d2d3d Z
d4d Z d5d d d d!d6d(Z d- fd) Z
xZS )7ÚHTTP2ConnectionNÚhostÚstrÚportú
int | NoneÚkwargsú
typing.Anyr r0 c óæ | ¦ « | _ d | _ g | _ d|v sd|v rt d¦ « t ¦ « j ||fi |¤ | j t d¦ « d S )NÚproxyÚ proxy_configz$Proxies aren't supported with HTTP/2z%Tunneling isn't supported with HTTP/2)Ú _new_h2_connÚ_h2_connÚ
_h2_streamÚ_headersÚNotImplementedErrorÚsuperr% Ú _tunnel_host)r$ r< r> r@ Ú __class__s r r% zHTTP2Connection.__init__V s ø ð ×)Ò)Ñ+Ô+
Ø&*Ø35
à fÐ Ð °&Ð 8Ð 8Ý%Ð&LÑMÔMÐ MàÔtÐ.Ð. vÐ.Ð.Ð.à Ô Ð (Ý%Ð&MÑNÔNÐ Nð )Ð (r ú)_LockedObject[h2.connection.H2Connection]c ó t j d¬¦ « }t t j |¬¦ « ¦ « S )NT)Ú client_side)Úconfig)Úh2rP ÚH2Configurationr Ú
connectionÚ H2Connection)r$ rP s r rE z HTTP2Connection._new_h2_conne s; Ý×*Ò*°tÐ*Ñ<Ô<Ý R]× 7Ò 7¸vÐ 7Ñ FÔ FÑGÔGÐGr c ó t ¦ « ¦ « | j 5 }| ¦ « | ¦ « x}r| j |¦ « d d d ¦ « d S # 1 swxY w Y d S r! )rJ ÚconnectrF Úinitiate_connectionÚ data_to_sendÚsockÚsendall)r$ ÚconnrX rL s r rV zHTTP2Connection.connecti sÁ ø Ý
ÑÔÐØ
]ð 0dØ × $Ò $Ñ &Ô &Ð &Ø #× 0Ò 0Ñ 2Ô 2Ð2|ð
0Ø ×!Ò! ,Ñ/Ô/Ð/ð 0ð 0ð 0ñ 0ô 0ð 0ð 0ð 0ð 0ð 0ð 0ð 0øøøð 0ð 0ð 0ð 0ð 0ð 0s ©AA;Á;A?ÂA?ÚmethodÚurlc óª d|v rt d¦ « d|v rt d¦ « |pd| _ | |¦ « d| j v rd| j d| j pd }n| j d| j pd }| j d
¦ « | j d | ¦ « f¦ « | j d | ¦ « f¦ « | j d
| ¦ « f¦ « | j 5 }| ¦ « | _
ddd¦ « dS # 1 swxY w Y dS )z®putrequest
This deviates from the HTTPConnection method signature since we never need to override
sending accept-encoding headers or the host header.
Ú skip_hostz`skip_host` isn't supportedÚskip_accept_encodingz&`skip_accept_encoding` isn't supportedú/ú:ú[z]:i» )s :schemes httpss :methods
:authoritys :pathN) rI Ú _request_urlÚ_validate_pathr< r> rH ÚappendÚencoderF Ú get_next_available_stream_idrG )r$ r\ r] r@ Ú authorityr[ s r Ú
putrequestzHTTP2Connection.putrequestp s´ ð &Ð Ð Ý%Ð&CÑDÔDÐ DØ ! VÐ +Ð +Ý%Ð&NÑOÔOÐ Oà J 3ÔØ ×ÒCÑ Ô Ð à $)Ð Ð Ø;DIÐ;Ð;¨¬Ð)9°cÐ;Ð;IIà 9Ð9Ð9 t¤yÐ'7°CÐ9Ð9Ià
× Ò Ð 3Ñ4Ô4Ð4Ø
× Ò j¨&¯-ª-©/¬/Ð :Ñ;Ô;Ð;Ø
× Ò m¨Y×-=Ò-=Ñ-?Ô-?Ð @ÑAÔAÐAØ
× Ò h¨¯
ª
© ¬ Ð 5Ñ6Ô6Ð6à
]ð BdØ "× ?Ò ?Ñ AÔ ADOð Bð Bð Bñ Bô Bð Bð Bð Bð Bð Bð Bð Bøøøð Bð Bð Bð Bð Bð Bs Ä!EÅE ÅE Úheaderú str | bytesÚvaluesc óÔ t |t ¦ « r| ¦ « n|}| ¦ « }t |¦ « s t dt |¦ « ¦ « |D ]w}t |t ¦ « r| ¦ « n|}t
|¦ « r t dt |¦ « ¦ « | j ||f¦ « xd S )NzIllegal header name zIllegal header value ) Ú
isinstancer= rg Úlowerr Ú
ValueErrorr rH rf )r$ rk rm r s r Ú putheaderzHTTP2Connection.putheader sá å$.¨vµsÑ$;Ô$;ÐG ÀØ Ý$ VÑ,Ô,ð CÝ Ð AµC¸±K´KÐ AÐ AÑBÔBÐ Bàð 2ð 2EÝ&0°½Ñ&<Ô&<ÐGELLNNNÀ%EÝ'¨Ñ.Ô.ð
GÝ Ð!E½¸U¹¼Ð!EÐ!EÑFÔFÐFØ M× Ò &¨% Ñ 1Ô 1Ð 1Ð 1ð 2ð 2r Ú message_bodyc ó& | j t d¦ « | j 5 }| | j | j |d u ¬¦ « | ¦ « x}r| j |¦ « d d d ¦ « n # 1 swxY w Y g | _ d S )Nú Must call `putrequest` first.)Ú stream_idÚheadersÚ
end_stream)rG r rF Ú send_headersrH rX rY rZ )r$ rs r[ rX s r Ú
endheaderszHTTP2Connection.endheaders sà Ø ?Ð "Ý!Ð"AÑBÔBÐ Bà
]ð 0dØ × Ò Ø /Ø
Ø (¨DÐ 0ð
ñ
ô
ð
ð
$× 0Ò 0Ñ 2Ô 2Ð2|ð
0Ø ×!Ò! ,Ñ/Ô/Ð/ð 0ð 0ð 0ñ 0ô 0ð 0ð 0ð 0ð 0ð 0ð 0øøøð 0ð 0ð 0ð 0ð
s AA?Á?BÂBÚdatac óº | j t d¦ « | j 5 }| ¦ « x}r| j |¦ « t
|d¦ « r½ | | j ¦ « }|snwt |t ¦ « r| ¦ « }| | j |d¬¦ « | ¦ « x}r| j |¦ « |
| j ¦ « ddd¦ « dS t |t ¦ « r| ¦ « } t |t ¦ « rN| | j |d¬¦ « | ¦ « x}r| j |¦ « nl|D ]O}| | j |d¬¦ « | ¦ « x}r| j |¦ « P|
| j ¦ « n-# t $ r t dt! |¦ « z ¦ « w xY wddd¦ « dS # 1 swxY w Y dS )zSend data to the server.
`data` can be: `str`, `bytes`, an iterable, or file-like objects
that support a .read() method.
Nru ÚreadTF)rx z6`data` should be str, bytes, iterable, or file. got %r)rG r rF rX rY rZ Úhasattrr} Ú blocksizero r= rg Ú send_datarx r
Ú TypeErrorÚtype)r$ r{ r[ rX Úchunks r ÚsendzHTTP2Connection.sendª sÄ ð
?Ð "Ý!Ð"AÑBÔBÐ Bà
]ð # dØ #× 0Ò 0Ñ 2Ô 2Ð2|ð
0Ø ×!Ò! ,Ñ/Ô/Ð/åtVÑ$Ô$ð
ð8Ø II d¤nÑ 5Ô 5EØ ð Ø Ý! %Ñ-Ô-ð /Ø %§ ¢ ¡¤ØNN 4¤?°EÀeNÑLÔLÐLØ'+×'8Ò'8Ñ':Ô':Ð:|ð 8Ø ×)Ò)¨,Ñ7Ô7Ð7ð8ð ¤Ñ0Ô0Ð0Øð # ð # ð # ñ # ô # ð # ð # ð # õ" $¥Ñ$Ô$ð
%Ø{{}}ð
Ý d¥EÑ*Ô*ð 5ØNN 4¤?°DÀTNÑJÔJÐJØ'+×'8Ò'8Ñ':Ô':Ð:|ð 8Ø ×)Ò)¨,Ñ7Ô7Ð7øà!%ð <ð <Ø t¤¸È%ÑPÔPÐPØ+/×+<Ò+<Ñ+>Ô+>Ð><ð <Ø I× -Ò -¨lÑ ;Ô ;Ð ;øØOO D¤OÑ4Ô4Ð4øøÝ ð
ð
ð
Ý ØLÝ4jjñ!ñô ð ð
øøøð?# ð # ð # ñ # ô # ð # ð # ð # ð # ð # ð # ð # øøøð # ð # ð # ð # ð # ð # s1 C1IÄ )IÅCHÈIÈ*I É IÉIÉIÚhttprw ú typing.Mapping[str, str] | NoneÚschemec ó t d¦ « )Nz;HTTP/2 does not support setting up a tunnel through a proxy)rI )r$ r< r> rw r s r Ú
set_tunnelzHTTP2Connection.set_tunnel× s õ "Ø Iñ
ô
ð
r Ú
HTTP2Responsec ó¨ d }t ¦ « }| j 5 }d}|sv| j d¦ « x}r&| |¦ « }|D ]
}t |t j j ¦ « rt ¦ « }|j
D ]i\ } }
| dk r"t |
¦ « ¦ « }-|
| d¦ « |
d¦ « ¦ « j¢t |t j j ¦ « r+||j z
}| |j |j ¦ « ìt |t j j ¦ « rd}| ¦ « x} r| j | ¦ « |¯vd d d ¦ « n # 1 swxY w Y |J t- ||| j t1 |¦ « ¬¦ « S )NFiÿÿ s :statusÚasciiT)Ústatusrw Ú request_urlr{ )Ú bytearrayrF rY ÚrecvÚ receive_dataro rQ ÚeventsÚResponseReceivedr rw ÚintÚdecodeÚaddÚ DataReceivedr{ Úacknowledge_received_dataÚflow_controlled_lengthrv Ú StreamEndedrX rZ r rd r
) r$ r r{ r[ rx Ú
received_datar Úeventrw rk r rX s r Ú getresponsezHTTP2Connection.getresponseâ s* ð Ý{{Ø
]ð 4dØ JØ ñ
4à$(¤I§N¢N°5Ñ$9Ô$9Ð9=ñ .Ø !× .Ò .¨}Ñ =Ô =FØ!'ð .ñ .Ý% eR¬YÔ-GÑHÔHð .Ý&4Ñ&6Ô&6GØ16´ ð &ð &¡
¨Ø#)¨ZÒ#7Ð#7Ý-0°· ² ± ´ Ñ-@Ô-@ F Fà$+§K¢KØ(.¯
ª
°gÑ(>Ô(>ÀÇ Â ÈWÑ@UÔ@Uñ%&ô %&ð %&ð %&ð &õ (¨r¬yÔ/EÑ FÔ Fð .Ø E¤JÑ .DØ × :Ò :Ø %Ô <¸e¼oñ ô ð ð õ (¨r¬yÔ/DÑ EÔ Eð .Ø)-Jùà#'×#4Ò#4Ñ#6Ô#6Ð6<ð 4ØI×%Ò% lÑ3Ô3Ð3ð3 !ñ
4ð 4ð 4ð 4ñ 4ô 4ð 4ð 4ð 4ð 4ð 4ð 4øøøð 4ð 4ð 4ð 4ð: Ð!Ð!Ð!Ý ØØØ Ô)Ýtð
ñ
ô
ð
s E<F Æ F$Æ'F$T)Úpreload_contentÚdecode_contentÚenforce_content_lengthÚbodyú_TYPE_BODY | Noner r r r c ó$ d|v r | j | j | j ¦ « | ||¦ « |pi }| ¦ « D ]:\ } }
| ¦ « dk r|
dk r$| | |
¦ « ;dt | j ¦ « vr"| dt ¦ « ¦ « |r-|
|¬¦ « | |¦ « dS |
¦ « dS )zSend an HTTP/2 requestÚchunkedNztransfer-encodings
user-agent)rs ) rY Ú
settimeoutÚtimeoutrj Úitemsrp rr ÚdictrH r rz r ) r$ r\ r] r¡ rw r r r r@ ÚkÚvs r ÚrequestzHTTP2Connection.request s ð Ð Ð ð
à 9Ð Ø I× Ò ¤ Ñ .Ô .Ð .à Ñ$Ô$Ð$à-RØMMOOð %ð %DAqØwwyyÐ /Ò/Ð/°A¸²N°NØàq !Ñ$Ô$Ð$Ð$à ¥ T¤]Ñ 3Ô 3Ð 3Ð 3Ø NN=Õ*AÑ*CÔ*CÑ DÔ DÐ Dà ð Ø OO¨OÑ .Ô .Ð .Ø IIdOOOOOà OOÑ Ô Ð Ð Ð r c ó | j 5 } | ¦ « | ¦ « x}r| j |¦ « n# t
$ r Y nw xY wd d d ¦ « n # 1 swxY w Y | ¦ « | _ d | _ g | _ t ¦ «
¦ « d S r! ) rF Úclose_connectionrX rY rZ Ú ExceptionrE rG rH rJ Úclose)r$ r[ r{ rL s r r¯ zHTTP2Connection.close3 sü ø Ø
]ð dð
Ø×%Ò%Ñ'Ô'Ð'Ø ×,Ò,Ñ.Ô.Ð.4ð ,ØI×%Ò% dÑ+Ô+Ð+øøÝ ð
ð
ð
Øð
øøøð ð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð ð ×)Ò)Ñ+Ô+
Ø Ø
å
s5 A,AAÁA,Á
A ÁA,Á A Á A,Á,A0Á3A0r! )r< r= r> r? r@ rA r r0 )r rM ©r r0 )r\ r= r] r= r@ rA r r0 )rk rl rm rl r r0 )rs rA r r0 )r{ rA r r0 )NNr
)
r< r= r> r? rw r r r= r r0 )r r )NN)r\ r= r] r= r¡ r¢ rw r r r r r r r r@ rA r r0 )r4 r5 r6 r% rE rV rj rr rz r r r r« r¯ Ú
__classcell__©rL s @r r; r; U sj ø à,0ð
Oð
Oð
Oð
Oð
Oð
Oð
Oð Hð Hð Hð Hð0ð 0ð 0ð 0ð 0ð 0ð Bð Bð Bð Bð> 2ð 2ð 2ð 2ð ð ð ð ð ð +ð +ð +ð +ð` Ø37Ø ð
ð
ð
ð
ð
ð(
ð (
ð (
ð (
ð\ #'Ø37ð % ð !%Ø #Ø'+ð% ð % ð % ð % ð % ð % ðNð ð ð ð ð ð ð ð ð r r; c óL e Zd Z dd fd
Zedd¦ « ZddZddZ xZS )r Fr r rw r r r= r{ r
r r r r0 c ót t ¦ « ||ddd ||¬¦ « || _ d| _ d S )Né zHTTP/2)r rw ÚversionÚversion_stringÚreasonr r r )rJ r% Ú_dataÚlength_remaining)r$ r rw r r{ r rL s r r% zHTTP2Response.__init__F sR ø õ ×ÒØØàØ#àØ)Ø#ð ñ
ô
ð
ð
Ø !Ô Ð Ð r c ó | j S r! )r¹ r( s r r{ zHTTP2Response.data\ s
àzÐr c ó d S r! r9 r( s r Úget_redirect_locationz#HTTP2Response.get_redirect_location` s Øtr c ó d S r! r9 r( s r r¯ zHTTP2Response.closec s Ø r )F) r r rw r r r= r{ r
r r r r0 )r r
r° ) r4 r5 r6 r% Úpropertyr{ r½ r¯ r± r² s @r r r D s ø ð %ð
"ð "ð "ð "ð "ð "ð "ð, ðð ð ñ Xððð ð ð ð
ð
ð
ð
ð
ð
ð
ð
r r )r r
r r )r r
r r )%Ú
__future__r ÚloggingÚrer" ÚtypesÚtypingÚ h2.configrQ Ú
h2.connectionÚ h2.eventsÚ_base_connectionr Ú _collectionsr rS r r Ú
exceptionsr Úresponser
Úorig_HTTPSConnectionÚTypeVarr Ú getLoggerr4 ÚlogÚcompiler r r r ÚGenericr r; r r9 r r ú<module>rÒ sÛ ðØ "Ð "Ð "Ð "Ð "Ð "à Ø Ø Ð Ð Ð Ø Ø
à Ð Ð Ð Ø Ð Ð Ð Ø Ð Ð Ð à )Ð )Ð )Ð )Ð )Ð )Ø )Ð )Ð )Ð )Ð )Ð )Ø AÐ AÐ AÐ AÐ AÐ AÐ AÐ AØ (Ð (Ð (Ð (Ð (Ð (Ø 'Ð 'Ð 'Ð 'Ð 'Ð 'à&Ð àFN3ÑÔàgÔÑ!Ô!à$"*Ð%DÑEÔEÐ Ø 'RZÐ(VÑ WÔ WÐ ð 5ð 5ð 5ð 5ð :ð :ð :ð :ð ð ð ð ð FN 1Ô%ñ ô ð ð>lð lð lð lð loñ lô lð lð^
ð
ð
ð
ð
Ð$ñ
ô
ð
ð
ð
r