U
|
I=®d(* ã @ sØ d dl mZ zd dlmZmZ W n$ ek
|
rD d dlmZmZ Y nX zd dlmZ W n" ek
|
rx G dd dZY nX d dlm Z ddl
|
m Z dd l m Z mZmZ d
|
d gZe ZG d d
|
d
|
eZG d d d eZdS )é )Úabsolute_import)ÚMappingÚMutableMapping)ÚRLockc @ s e Zd Zdd Zdd ZdS )r c C s d S ©N© ©Úselfr r úWD:\z\workplace\VsCode\pyvenv\venv\Lib\site-packages\pip/_vendor/urllib3/_collections.pyÚ __enter__ s zRLock.__enter__c C s d S r r )r Úexc_typeÚ exc_valueÚ tracebackr r r
|
Ú__exit__ s zRLock.__exit__N)Ú__name__Ú
|
__module__Ú __qualname__r r r r r r
|
r s r )Ú OrderedDicté )Ú InvalidHeader)ÚiterkeysÚ
|
itervaluesÚPY3ÚRecentlyUsedContainerÚHTTPHeaderDictc @ sV e Zd ZdZeZdddZdd Zdd Zd
|
d Z d d Z
|
dd Z dd Z dd Z dS )r a
|
Provides a thread-safe dict-like container which maintains up to
|
``maxsize`` keys while throwing away the least-recently-used keys beyond
|
``maxsize``.
|
|
:param maxsize:
|
Maximum number of recent elements to retain.
|
|
:param dispose_func:
|
Every time an item is evicted from the container,
|
``dispose_func(value)`` is called. Callback which will get called
|
é
|
Nc C s" || _ || _| ¡ | _t | _d S r )Ú_maxsizeÚ dispose_funcÚ ContainerClsÚ
|
_containerr Úlock)r Úmaxsizer r r r
|
Ú__init__. s
|
z RecentlyUsedContainer.__init__c
|
C s8 | j ( | j |¡}|| j|< |W 5 Q R £ S Q R X d S r )r r Úpop)r ÚkeyÚitemr r r
|
Ú __getitem__5 s
|
z!RecentlyUsedContainer.__getitem__c C sl t }| j@ | j |t ¡}|| j|< t| j| jkrF| jjdd\}}W 5 Q R X | jrh|t k rh| |¡ d S )NF)Úlast)Ú_Nullr r ÚgetÚlenr Úpopitemr )r r$ ÚvalueÚ evicted_valueÚ_keyr r r
|
Ú __setitem__< s
|
z!RecentlyUsedContainer.__setitem__c C s2 | j | j |¡}W 5 Q R X | jr.| |¡ d S r )r r r# r )r r$ r, r r r
|
Ú __delitem__K s z!RecentlyUsedContainer.__delitem__c
|
C s( | j t| jW 5 Q R £ S Q R X d S r )r r* r r r r r
|
Ú__len__R s z RecentlyUsedContainer.__len__c C s t dd S )Nz7Iteration over this class is unlikely to be threadsafe.)ÚNotImplementedErrorr r r r
|
Ú__iter__V s ÿz RecentlyUsedContainer.__iter__c C sH | j tt| j}| j ¡ W 5 Q R X | jrD|D ]}| |¡ q4d S r )r Úlistr r Úclearr )r Úvaluesr, r r r
|
r5 [ s zRecentlyUsedContainer.clearc
|
C s, | j tt| jW 5 Q R £ S Q R X d S r )r r4 r r r r r r
|
Úkeyse s zRecentlyUsedContainer.keys)r N)r r r Ú__doc__r r r" r& r/ r0 r1 r3 r5 r7 r r r r
|
r s
|
|
c sô e Zd ZdZd- fdd Zdd Zdd Zd d
|
Zd d Zd d Z dd Z
|
e sZe j Z e jZe Zdd Zdd ZefddZdd Zdd Zdd Zefd d ZeZeZeZeZd d Z d!d" Z d#d$ Z d%d& Z d'd( Z d)d* Z!e"d+d, Z# Z$S ).r ap
|
:param headers:
|
An iterable of field-value pairs. Must not contain multiple field names
|
when compared case-insensitively.
|
|
:param kwargs:
|
Additional field-value pairs to pass in to ``dict.update``.
|
|
A ``dict`` like container for storing HTTP Headers.
|
|
Field names are stored and compared case-insensitively in compliance with
|
RFC 7230. Iteration provides the first case-sensitive key seen for each
|
case-insensitive pair.
|
|
Using ``__setitem__`` syntax overwrites fields that compare equal
|
case-insensitively in order to maintain ``dict``'s api. For fields that
|
compare equal, instead create a new ``HTTPHeaderDict`` and use ``.add``
|
in a loop.
|
|
If multiple fields that are equal case-insensitively are passed to the
|
constructor or ``.update``, the behavior is undefined and some will be
|
lost.
|
|
>>> headers = HTTPHeaderDict()
|
>>> headers.add('Set-Cookie', 'foo=bar')
|
>>> headers.add('set-cookie', 'baz=quxx')
|
>>> headers['content-length'] = '7'
|
>>> headers['SET-cookie']
|
'foo=bar, baz=quxx'
|
>>> headers['Content-Length']
|
'7'
|
Nc sP t t| ¡ t | _|d k r>t|tr4| |¡ n
|
| |¡ |rL| |¡ d S r )Úsuperr r" r r Ú
|
isinstanceÚ
|
_copy_fromÚextend)r ÚheadersÚkwargs©Ú __class__r r
|
r" s
|
|
zHTTPHeaderDict.__init__c C s ||g| j | ¡ < | j | ¡ S r ©r Úlower©r r$ Úvalr r r
|
r/ s zHTTPHeaderDict.__setitem__c C s | j | ¡ }d |dd
¡S )Nú, r ©r rB ÚjoinrC r r r
|
r& s zHTTPHeaderDict.__getitem__c C s | j | ¡ = d S r rA ©r r$ r r r
|
r0 s zHTTPHeaderDict.__delitem__c C s | ¡ | jkS r )rB r rH r r r
|
Ú __contains__¢ s zHTTPHeaderDict.__contains__c C s^ t |tst|dsdS t |t| s2t| |}tdd | ¡ D tdd | ¡ D kS )Nr7 Fc s s | ]\}}| ¡ |fV qd S r )rB )Ú.0ÚkÚvr r r
|
Ú <genexpr>ª s z(HTTPHeaderDict.__eq__.<locals>.<genexpr>)r: r ÚhasattrÚtypeÚdictÚ
|
itermerged©r Úotherr r r
|
Ú__eq__¥ s ÿzHTTPHeaderDict.__eq__c C s | |¡ S r )rT rR r r r
|
Ú__ne__® s zHTTPHeaderDict.__ne__c C s
|
t | jS r )r* r r r r r
|
r1 · s zHTTPHeaderDict.__len__c c s | j ¡ D ]}|d V q
|
d S )Nr )r r6 )r Úvalsr r r
|
r3 º s zHTTPHeaderDict.__iter__c C s@ z | | }W n$ t k
|
r0 || jkr( | Y S X | |= |S dS )z©D.pop(k[,d]) -> v, remove specified key and return the corresponding value.
|
If key is not found, d is returned if given, otherwise KeyError is raised.
|
N)ÚKeyErrorÚ_HTTPHeaderDict__marker)r r$ Údefaultr, r r r
|
r# ¿ s
|
|
zHTTPHeaderDict.popc C s$ z
|
| |= W n t k
|
r Y nX d S r )rW rH r r r
|
ÚdiscardÐ s
|
zHTTPHeaderDict.discardc C s4 | ¡ }||g}| j ||¡}||k r0| |¡ dS )zâAdds a (name, value) pair, doesn't overwrite the value if it already
|
exists.
|
|
>>> headers = HTTPHeaderDict(foo='bar')
|
>>> headers.add('Foo', 'baz')
|
>>> headers['foo']
|
'bar, baz'
|
N)rB r Ú
|
setdefaultÚappend)r r$ rD Ú key_lowerÚnew_valsrV r r r
|
ÚaddÖ s
|
zHTTPHeaderDict.addc O sì t |dkr td t |¡t |dkr2|d nd}t|tr`| ¡ D ]\}}| ||¡ qHnjt|tr|D ]}| ||| ¡ qnnDt|dr°| ¡ D ]}| ||| ¡ qn|D ]\}}| ||¡ q´|
|
¡ D ]\}}| ||¡ qÒdS )zÀGeneric import function for any type of header-like object.
|
Adapted version of MutableMapping.update in order to insert items
|
with self.add instead of self.__setitem__
|
r z9extend() takes at most 1 positional arguments ({0} given)r r r7 N) r* Ú TypeErrorÚformatr: r Ú iteritemsr_ r rN r7 Úitems)r Úargsr> rS r$ rD r, r r r
|
r< æ s( ÿÿ
|
|
|
zHTTPHeaderDict.extendc C sN z| j | ¡ }W n* tk
|
r< || jkr4g Y S | Y S X |dd
S dS )zmReturns a list of all the values for the named field. Returns an
|
empty list if the key doesn't exist.r N)r rB rW rX )r r$ rY rV r r r
|
Úgetlist s
|
|
zHTTPHeaderDict.getlistc C s dt | jt| ¡ f S )Nz%s(%s))rO r rP rQ r r r r
|
Ú__repr__ s zHTTPHeaderDict.__repr__c C s> |D ]4}| |¡}t|tr$t|}|g| | j| ¡ < qd S r )re r: r4 r rB )r rS r$ rD r r r
|
r; s
|
|
|
zHTTPHeaderDict._copy_fromc C s t | }| | ¡ |S r )rO r; )r Úcloner r r
|
Úcopy! s
|
|
zHTTPHeaderDict.copyc c s< | D ]2}| j | ¡ }|dd
D ]}|d |fV q"qdS )z8Iterate over all header lines, including duplicate ones.r Nr rA )r r$ rV rD r r r
|
rb & s zHTTPHeaderDict.iteritemsc c s8 | D ].}| j | ¡ }|d d |dd
¡fV qdS )z:Iterate over all headers, merging duplicate ones together.r rE r NrF rC r r r
|
rQ - s zHTTPHeaderDict.itermergedc C s t | ¡ S r )r4 rb r r r r
|
rc 3 s zHTTPHeaderDict.itemsc C s d}g }|j D ]h}| |¡rT|s.td| n&|d \}}||d | ¡ f|d< q| dd¡\}}| || ¡ f¡ q| |S )z4Read headers from a Python 2 httplib message object.)ú ú z/Header continuation with no previous header: %séÿÿÿÿri ú:r )r= Ú
|
startswithr ÚstripÚsplitr\ )ÚclsÚmessageÚobs_fold_continued_leadersr= Úliner$ r, r r r
|
Ú from_httplib6 s
|
|
ÿ zHTTPHeaderDict.from_httplib)N)%r r r r8 r" r/ r& r0 rI rT rU r r r r ÚobjectrX r1 r3 r# rZ r_ r< re Ú
|
getheadersÚgetallmatchingheadersÚigetÚget_allrf r; rh rb rQ rc Ú classmethodrt Ú __classcell__r r r? r
|
r j s> ! N)Ú
|
__future__r Úcollections.abcr r Ú ImportErrorÚ collectionsÚ threadingr r Ú
|
exceptionsr Z packages.sixr r r Ú__all__ru r( r r r r r r
|
Ú<module> s L
|
