nbi|ddlmZddlZddlZddlZddlZejrddlmZ ddZ dd Z Gd d Z ddZ ddZdS)) annotationsNobjobjectreturnboolc |S#t$rYnwxYw |jS#t$rYnwxYw |jduS#t$rYnwxYwt d)zt Checks whether a given file-like object is closed. :param obj: The file-like object to check. Nz)Unable to determine whether fp is closed.)isclosedAttributeErrorclosedfp ValueError)rs l/var/www/html/mdtn/previsions/meteo_cartes/venv/lib/python3.11/site-packages/urllib3_future/util/response.py is_fp_closedr s ||~~       z       v~       @ A AAs) ##. ;;A AAvaluestr typing.Iterable[tuple[str, str]]c#~Ktjdtj}tj||Ed{VdS)zGiven an Alt-Svc value, extract from it the protocol-id and the alt-authority. https://httpwg.org/specs/rfc7838.html#alt-svczD(h[0-9]{1,3}(?:[\-0-9]{0,5}))=(?:[\"\']?)([a-z0-9\-_:.]+)(?:[\"\']?)N)recompile IGNORECASEfindall)rpatterns r parse_alt_svcr+sMjO G z'5)))))))))))c2eZdZdZd dZddZdd Zdd Zd S)BytesQueueBufferaMemory-efficient bytes buffer To return decoded data in read() and still follow the BufferedIOBase API, we need a buffer to always return the correct amount of bytes. This buffer should be filled using calls to put() Our maximum memory usage is determined by the sum of the size of: * self.buffer, which contains the full data * the largest chunk that we will copy in get() rNonecDtj|_d|_dS)Nr) collectionsdequebuffer_sizeselfs r__init__zBytesQueueBuffer.__init__Ds?J?P?R?R  rintc|jSN)r"r#s r__len__zBytesQueueBuffer.__len__Hs zrdatabytesct|j||xjt|z c_dSr()r!appendr"len)r$r*s rputzBytesQueueBuffer.putKs2 4    c$ii rnc0|dkrdS|jstd|dkrtdt|jd|krIt |jdt r)|xj|zc_|jSd}tj }||kr||z }|j}t|}||krct|}|d|||d}}| ||j ||xj|zc_n8| ||xj|zc_||z }|jsn||k| S)Nrrzbuffer is emptyzn should be > 0)r! RuntimeErrorr r. isinstancer+r"popleftioBytesIO memoryviewwrite appendleftgetvalue) r$r0fetchedret remainingchunk chunk_length left_chunk right_chunks rgetzBytesQueueBuffer.getOs 663 0011 1 UU.// / t{1~  ! # # 4;q>5(I(I # JJ!OJJ;&&(( (jllkkG IK''))Eu::L<''"5))*/  *;U9::=NK  *%%% &&{333 i'  %    l* | #G; #kk&||~~rN)rr)rr&)r*r+rr)r0r&rr+)__name__ __module__ __qualname____doc__r%r)r/rBrrrr6sn      !!!!!!rrheadershttplib.HTTPMessagercvddlmmddlm}ddlm}t||js tdt|dd}| s2| }t|ttfr|}fd|jD}|s|r ||| dS) a> Asserts whether all headers have been successfully parsed. Extracts encountered errors from the result of parsing headers. Only works on Python 3. :param http.client.HTTPMessage headers: Headers to verify. :raises urllib3.exceptions.HeaderParsingError: If parsing errors are found. r)!MultipartInvariantViolationDefectStartBoundaryNotFoundDefect)HeaderParsingErrorNzexpected httplib.Message, got .c8g|]}t|f|SrG)r3).0defectrKrLs r z)assert_header_parsing..sE  02ST  r)defects unparsed_data) email.errorsrKrL exceptionsrN http.clientclientr3 HTTPMessage TypeErrortype is_multipart get_payloadr+rrT)rHrNhttplibrUpayloadrTrKrLs @@rassert_header_parsingrass50/////!!!!!! gw2 3 3KIgIIIJJJM    ! !$%%'' gs| , , $#MoGO-O   NNNNOOrresponsehttplib.HTTPResponsec@|j}|dkS)z Checks whether the request of a response has been a HEAD-request. :param http.client.HTTPResponse response: Response to check if the originating request used 'HEAD' as a method. HEAD)_methodupper)rb method_strs ris_response_to_headris#!J      ''r)rrrr)rrrr)rHrIrr)rbrcrr) __future__rrr5rtyping TYPE_CHECKINGrXrYr_rrrrarirGrrrms""""""  "!!!!!!BBBB>****::::::::z7O7O7O7Ot ( ( ( ( ( (r