/usr/local/lib64/python3.6/site-packages/aiohttp/__pycache__
Edit: /usr/local/lib64/python3.6/site-packages/aiohttp/__pycache__/helpers.cpython-36.pyc (26037B)
3
8%Egg @ s0 U d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl
Z
ddl Z ddl Z ddl
Z
ddlZddlZddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ dd lm Z dd
l m Z m Z m Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/ dd l0m1Z1 dd l2m3Z3m4Z4 ddl5Z5ddl6Z6dd
l7m8Z8m9Z9 ddl:m;Z; ddl
m?Z?m@Z@ ddlAmBZBmCZC dZDe
jE dkZFe
jE dkZGe jHdkZIe jHdkZJe jHdkZKe jHdkZLe jHdkZMe jHdk r ddlNZNeNjO de(ejP e*d d d d!ZQnejQZQe-d"ZRe-d#ZSeT ZUe UeVe jWjXd$ZYeVYeZe j[d%d&p|e j[j\ o|eVe jWjXd'Z]eV]d(d) e^dd*D Z_d+d) e^dd,D e`d-hB Zad.d/d0d1d2d3d4d5d6d7d8d9d:d;dd?e`d@hZbe_eaA ebA ZcG dAdB dBZdG dCd deddDdEdFgZee;e+e;e(ee f dGdHdIZfe(ej dJdKdLZge6jhdMdMdMdNG dOdP dPZie!ejeif dJdQdRZkde(ejP dSd dTdUZlde(ejP ejPd dVdWZme eVdXdYdZZne;e+e;e(ee f dGd[d\Zoe6jhdMdMdMdNG d]d^ d^Zpejqd_d`ejepdadbdcZrde e(ej e(ej dddedfZse jtdgZudhd) e^d,d-D dihB ZvejejdjdkdlZwdejeVejejejdndodpZxG dqdr dreCe#eR ZyG dsdt dte#eR ZzezZ{yddul|mzZ} eYse}ZzW n e~k
r Y nX dvZdwZe jteZe jtee jdxZe jtejdyZe jtejdye jdxZe)ej e)e e(e.ejef eVdzd{d|ZejeeeZejeeeZe(e.ejeeef eVd}d~dZejdJddZdae(e daejdJddZdddddZeTejeejPe(ej dddZe g e f eejPe(ej dddZG dd dZG dd de d ZG dd deZG dd deZe(e e5jdddZG dd dZdeRddddZdeddddZG dd de'eje f ZdZe jteZde dZe jteZe jtd.e dZdZe6jhdMdMdMdNG dd dZejddddZe(ej e(ej dddZdS )zVarious helper functions N)
namedtuple)suppress) HeaderParser) parsedate)ceil)Path)
TracebackType)AnyCallableContextManagerDict GeneratorGenericIterableIteratorListMappingOptionalPatternSetTupleTypeTypeVarUnioncast)quote)
getproxies proxy_bypass) MultiDictMultiDictProxy)URL )hdrs)
client_loggerinternal_logger)PathLikeProtocol BasicAuth
ChainMapProxyETagDarwinWindows
zasyncio.Task[Any])loopreturnc C s t tjj| }dd |D S )Nc S s h | ]}|j s|qS )done).0tr4 r4 ;/usr/local/lib64/python3.6/site-packages/aiohttp/helpers.py M s z all_tasks..)listasyncioTask all_tasks)r2 tasksr4 r4 r8 r= I s r= _T_SZAIOHTTP_NO_EXTENSIONSZdev_modeFPYTHONASYNCIODEBUGc C s h | ] }t |qS r4 )chr)r6 ir4 r4 r8 r9 a s r9 c C s h | ] }t |qS r4 )rB )r6 rC r4 r4 r8 r9 b s ()<>@,;:\"/[]?={} c @ s e Zd Zed dddZdS )noopN)r3 c c s
d V d S )Nr4 )selfr4 r4 r8 __await__~ s znoop.__await__)NNN)__name__
__module__ __qualname__r
r\ r4 r4 r4 r8 rZ } s rZ c st e Zd ZdZdeeed d fdd
Zedeed ddd Zedd
eee d d d d
Z
edddZ Z S )r' z!Http basic authentication helper. latin1)loginpasswordencodingr3 c sB |d krt d|d kr t dd|kr0t dt j| |||S )Nz"None is not allowed as login valuez%None is not allowed as password valuerN z5A ":" is not allowed in login (RFC 1945#section-11.1))
ValueErrorsuper__new__)clsrb rc rd ) __class__r4 r8 rg s zBasicAuth.__new__) auth_headerrd r3 c C s y|j dd\}}W n tk
r0 tdY nX |j dkrJtd| y tj|jdddj|}W n tjk
r td Y nX y|j d
d\}}W n tk
r td Y nX | |||d S )
z s z$proxies_from_env..c S s i | ]\}}t ||qS r4 )r )r6 r r r4 r4 r8 r s r r z)%s proxies %s are not supported, ignoringr r! )r r )
r itemsr schemer# r upperhostauthenticatorsr' r r r ) Z
proxy_urlsZ netrc_objstrippedretprotovalr r Zauth_from_netrcZloginsrc rb r4 r4 r8 proxies_from_env s*
r zOptional[asyncio.Task[Any]]c C s( t jdkrtj| dS tjj| dS d S )Nr, r. )r2 )r, r. )sys version_infor; current_taskr< )r2 r4 r4 r8 r s
r c C sB | d krt j } | j s>tjdtdd | j r>tjddd | S )Nz5The object should be created within an async functionr, )
stacklevelT)
stack_info) r; get_event_loop
is_runningwarningswarnDeprecationWarning get_debugr$ r )r2 r4 r4 r8 get_running_loop s
r )objr3 c C s$ t tdd }|d k r || S dS d S )NisasyncgenfunctionF)getattrinspect)r funcr4 r4 r8 r 2 s r c C sp | j dk r&t| j r&td| j dt }y|| j }W n$ tk
r^ td| dY nX |j|jfS dS )z5Get a permitted proxy for the given URL from the env.Nz Proxying is disallowed for ``zNo proxies found for `z ` in the env)r r LookupErrorr r KeyErrorr r )rx Zproxies_in_envZ
proxy_infor4 r4 r8 get_env_proxy_for_url: s r c @ s e Zd ZU eeeddS )MimeTypezMultiDictProxy[str]N)r] r^ r_ r typesubtypesuffix
parametersr4 r4 r4 r8 r H s
r 8 )maxsize)mimetyper3 c
C s | st dddtt dS | jd}t }xb|dd D ]R}|sBq8ttttf d|krb|jddn|df\}}|j|j j |j d q8W |d j j }|d krd
}d |krttttf |jd dn|df\}}d |krttttf |jd dn|df\}} t ||| t|dS )
a Parses a MIME type into its components.
mimetype is a MIME type string.
Returns a MimeType object.
Example:
>>> parse_mimetype('text/html; charset=utf-8')
MimeType(type='text', subtype='html', suffix='',
parameters={'charset': 'utf-8'})
r` )r r r r rM r! NrU z "r *z*/*rQ +)
r r r rn r r r addro strip)
r partsparamsitemkeyvalueZfulltypemtypestyper r4 r4 r8 parse_mimetypeP s&
, " .r )r defaultr3 c C s@ t | dd }|r s z quoted_string..)QCONTENTsetre not_qtext_resub)r r4 r4 r8
quoted_string s r utf-8)disptype quote_fields_charsetr r3 c
K sJ | st t| k r"tdj| | }|rFg }x|j D ]\}}| sVt t|k rftdj|||r|j dkrt|d|d}|j|d| f n`y t|}W n@ tk
r dj |dt|d|df}|j|d |f Y nX |j|d| f q:|j
d d
j
d d }|j|d| f q:W d
j dd |D } d
j || f}|S )ak Sets ``Content-Disposition`` header for MIME.
This is the MIME payload Content-Disposition header from RFC 2183
and RFC 7579 section 4.2, not the HTTP Content-Disposition from
RFC 6266.
disptype is a disposition type: inline, attachment, form-data.
Should be valid extension token (see RFC 2183)
quote_fields performs value quoting to 7-bit MIME headers
according to RFC 7578. Set to quote_fields to False if recipient
can take 8-bit file names and field values.
_charset specifies the charset to use when quote_fields is True.
params is a dict with disposition params.
z!bad content disposition type {!r}z+bad content disposition parameter {!r}={!r}filenamer` )rd z"%s"z''r rO z\\rP z\"z; c s s | ]}d j |V qdS )rU N)join)r6 pairr4 r4 r8 s z-content_disposition_header..) TOKENr re formatr ro r appendr r replace)
r r r r r Zlparamsr r ZqvalZsparamsr4 r4 r8 content_disposition_header s2 r c @ s e Zd ZU eeef dS )_TSelfN)r] r^ r_ r r r? _cacher4 r4 r4 r8 r s
r c @ s^ e Zd ZdZedef ddddZd
ee ee e
eddd Z ee edd
d d Z dS )reifyaU Use as a class method decorator.
It operates almost exactly like
the Python `@property` decorator, but it puts the result of the
method it decorates into the instance dict after the first call,
effectively replacing the function it decorates with an instance
variable. It is, in Python parlance, a data descriptor.
.N)wrappedr3 c C s || _ |j| _|j| _d S )N)r r r] r )r[ r r4 r4 r8 __init__ s zreify.__init__)instownerr3 c C sd y c @ s~ e Zd ZdZejee ddddZe d e
e
dddd Z dd
d d Z eej
d
d
dZdd
ddZdd
ddZdS )
TimeoutHandlezTimeout handleN)r2 r7 r3 c C s || _ || _g | _d S )N)_timeout_loop
_callbacks)r[ r2 r7 r4 r4 r8 r y s zTimeoutHandle.__init__.)callbackargskwargsr3 c O s | j j|||f d S )N)rB r )r[ rC rD rE r4 r4 r8 register s zTimeoutHandle.register)r3 c C s | j j d S )N)rB clear)r[ r4 r4 r8 close s zTimeoutHandle.closec C sL | j }|d k rD|dkrD| jj | }|dkr4t|}| jj|| jS d S d S )Nr r8 )r@ rA r# r r9 __call__)r[ r7 r; r4 r4 r8 start s zTimeoutHandle.startBaseTimerContextc C s8 | j d k r.| j dkr.t| j}| j|j |S t S d S )Nr )r@ TimerContextrA rF r7 TimerNoop)r[ timerr4 r4 r8 rN s
zTimeoutHandle.timerc C sB x2| j D ](\}}}tt ||| W d Q R X qW | j j d S )N)rB r r3 rG )r[ r= rD rE r4 r4 r8 rI s
zTimeoutHandle.__call__).N)r] r^ r_ r r; AbstractEventLoopr floatr r
r rF rH HandlerJ rN rI r4 r4 r4 r8 r? v s
r? c @ s e Zd ZdS )rK N)r] r^ r_ r4 r4 r4 r8 rK s rK c @ s> e Zd ZedddZeee ee ee ddddZ dS )rM )r3 c C s | S )Nr4 )r[ r4 r4 r8 __enter__ s zTimerNoop.__enter__N)exc_typeexc_valexc_tbr3 c C s d S )Nr4 )r[ rS rT rU r4 r4 r8 __exit__ s zTimerNoop.__exit__)
r] r^ r_ rK rR r r
BaseExceptionr rV r4 r4 r4 r8 rM s
rM c @ sf e Zd ZdZejddddZedddZe e
e e e e e e e
d d
d Zddd d
ZdS )rL z&Low resolution timeout context managerN)r2 r3 c C s || _ g | _d| _d S )NF)rA _tasks
_cancelled)r[ r2 r4 r4 r8 r s zTimerContext.__init__)r3 c C s: t | jd}|d kr td| jr*tjd | jj| | S )N)r2 z4Timeout context manager should be used inside a task)r rA r rY r; TimeoutErrorrX r )r[ taskr4 r4 r8 rR s zTimerContext.__enter__)rS rT rU r3 c C s, | j r| j j |tjkr(| jr(tjd d S )N)rX popr; CancelledErrorrY rZ )r[ rS rT rU r4 r4 r8 rV s
zTimerContext.__exit__c C s, | j s(xt| jD ] }|j qW d| _ d S )NT)rY r rX cancel)r[ r[ r4 r4 r8 r7 s zTimerContext.timeout)r] r^ r_ r r; rO r rK rR r r rW r r rV r7 r4 r4 r4 r8 rL s
rL )delayr3 c C sJ | d ks| dkrt jd S t }|j }|| }| dkr@t|}t j|S )Nr r8 )
async_timeoutr7 r r# r Z
timeout_at)r_ r2 r
r; r4 r4 r8 ceil_timeout s
ra c @ s e Zd ZU edddgZdZee dZee eef e
Z eddddZ e
edd d
Ze
ee dd d Ze
ee dd
dZdS ) HeadersMixin
_content_type
_content_dict_stored_content_typeN)rawr3 c C sT || _ |d kr d| _i | _n4t jd| }|j | _|j }t|dd | _d S )Nzapplication/octet-streamzContent-Type: r! )re rc rd r parsestrget_content_type
get_paramsdict)r[ rf msgr r4 r4 r8 _parse_content_type s
z HeadersMixin._parse_content_type)r3 c C s( | j jtj}| j|kr"| j| | jS )z7The value of content part for Content-Type HTTP header.)_headersr r" CONTENT_TYPEre rl rc )r[ rf r4 r4 r8 content_type s
zHeadersMixin.content_typec C s. | j jtj}| j|kr"| j| | jjdS )z7The value of charset part for Content-Type HTTP header.charset)rm r r" rn re rl rd )r[ rf r4 r4 r8 rp s
zHeadersMixin.charsetc C s& | j jtj}|dk r t|S dS dS )z(The value of Content-Length HTTP header.N)rm r r" CONTENT_LENGTHr" )r[ content_lengthr4 r4 r8 rr s
zHeadersMixin.content_length)r] r^ r_ frozensetATTRSrc r r rd r sentinelre rl propertyro rp r" rr r4 r4 r4 r8 rb s
rb zasyncio.Future[_T])futresultr3 c C s | j s| j| d S )N)r5
set_result)rw rx r4 r4 r8 ry s ry )rw excr3 c C s | j s| j| d S )N)r5
set_exception)rw rz r4 r4 r8 r{ ! s r{ c @ s e Zd ZdZeeeef ddddZddddZ eed d
d Z
deeed d
dZ e dddZ
ee dddZeed ddZedddZedddZdS )r( _mapsN)mapsr3 c C s t || _d S )N)tupler| )r[ r} r4 r4 r8 r ) s zChainMapProxy.__init__)r3 c C s t dj| jd S )Nz4Inheritance class {} from ChainMapProxy is forbidden)rz r r] )rh r4 r4 r8 __init_subclass__, s z ChainMapProxy.__init_subclass__)r r3 c C s: x,| j D ]"}y|| S tk
r( Y qX qW t|d S )N)r| r )r[ r mappingr4 r4 r8 __getitem__2 s
zChainMapProxy.__getitem__)r r r3 c C s || kr| | S |S )Nr4 )r[ r r r4 r4 r8 r : s zChainMapProxy.getc C s t t j| j S )N)lenr unionr| )r[ r4 r4 r8 __len__= s zChainMapProxy.__len__c C s* i }x t | jD ]}|j| qW t|S )N)reversedr| updateiter)r[ dr r4 r4 r8 __iter__A s zChainMapProxy.__iter__c s t fdd| jD S )Nc 3 s | ]} |kV qd S )Nr4 )r6 m)r r4 r8 r I s z-ChainMapProxy.__contains__..)anyr| )r[ r r4 )r r8 __contains__H s zChainMapProxy.__contains__c C s
t | jS )N)r r| )r[ r4 r4 r8 __bool__K s zChainMapProxy.__bool__c C s dj tt| j}d| dS )Nz, zChainMapProxy(rH )r mapreprr| )r[ r r4 r4 r8 __repr__N s zChainMapProxy.__repr__)r| )N)r] r^ r_ __slots__r r r r r r r r r" r r r objectr r r r r4 r4 r4 r8 r( & s z[!#-}\x80-\xff]+z(W/)?"(z)"z)(?:\s*,\s*|$)|(.)r c @ s e Zd ZU edZedS )r) FN)r] r^ r_ r r Zis_weakr r4 r4 r4 r8 r) ] s
)r r3 c C s( | t kr$tj| r$td| dd S )NzValue z, is not a valid etag. Maybe it contains '"'?)ETAG_ANY _ETAGC_RE fullmatchre )r r4 r4 r8 validate_etag_valuec s r )date_strr3 c C sH | dk rDt | }|dk rDtt tj|dd dtjjiS Q R X dS )z/Process a date string, return a datetime objectNr- tzinfo)r r re r r r )r timetupler4 r4 r8 parse_http_datej s
"r )r' r( r) )r, r- )r, r. )r, r/ )r, r0 )r, r1 )r, r. )N)N)N)N)Tr )r r; rp rt r r functoolsr r r platformrer r# r r: collectionsr r email.parserr email.utilsr mathr pathlibr typesr typingr r
r r r
r r r r r r r r r r r r r urllib.parser urllib.requestr r r` attrZ multidictr r Zyarlr r` r" logr# r$ Ztypedefsr% r& __all__systemZIS_MACOSr r ZPY_36ZPY_37ZPY_38ZPY_310ZPY_311Zidna_sslZpatch_match_hostnamerO r= r? r@ r ru r r r Z
NO_EXTENSIONSr r ignore_environmentDEBUGrangeZCHARrB ZCTLZ
SEPARATORSr rZ r' r r sr r r r r r r r lru_cacher r compiler r r r r r Zreify_pyZ_helpersZreify_c ImportErrorZ
_ipv4_patternZ
_ipv6_patternZ _ipv4_regex
IGNORECASEZ _ipv6_regexrr Z _ipv4_regexbZ _ipv6_regexbr r partialr r r r r r r$ r" r& r1 r6 rP TimerHandler< r> r? rK rM rL Timeoutra rb ry rW r{ r( Z_ETAGCr Z _QUOTED_ETAGZQUOTED_ETAG_REZLIST_QUOTED_ETAG_REr r) r r r4 r4 r4 r8 s P
= +
/
3
(
.
+ 0.