File: //opt/saltstack/salt/lib/python3.10/site-packages/aiohttp/__pycache__/http_parser.cpython-310.pyc
o
;jr� � @ s� U d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlmZ d dlm Z d dl
m Z m Z m
Z
mZmZmZmZmZ d dlmZmZmZ d dlmZ dd lmZ dd
lm Z dd l m Z m Z m Z m!Z!m"Z" dd l#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+ dd
l,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5 ddl6m7Z7m8Z8m9Z9 ddl:m;Z;m<Z< ddl=m>Z> e r�ddl?m@Z@ dZAed ZBeCejD�ZEeeCeF eGd< e�Hd�ZIeeF eGd< e�JdeI� d��ZKee eF eGd< e�JdejL�ZMee eF eGd< e�Jd ejL�ZNee eF eGd < e�Jd �ZOee eP eGd < e�Jd �ZQee eF eGd!< eRh d"��ZSeeReF eGd#< G d$d%� d%e�ZTG d&d'� d'e�ZUed(eTeU�ZVG d)d*� d*e�ZWG d+d,� d,e�ZXG d-d.� d.e�ZYG d/d0� d0�ZZd1eeF d2e[fd3d4�Z\G d5d6� d6e j]eeV �Z^G d7d8� d8e^eT �Z_G d9d:� d:e^eU �Z`G d;d<� d<�ZaG d=d>� d>�Zbe_Zce`ZdeTZeeUZfz e)�s�dd?lgm_Z_m`Z`mTZTmUZU e_Zhe`ZieTZjeUZkW dS W dS el�y� Y dS w )@� N)�suppress)�IntEnum)�Pattern)�
TYPE_CHECKING�Any�ClassVar�Final�Generic�Literal�
NamedTuple�TypeVar)� CIMultiDict�CIMultiDictProxy�istr)�URL� )�hdrs)� BaseProtocol)�
HAS_BROTLI�HAS_ZSTD�BrotliDecompressor�ZLibDecompressor�ZSTDDecompressor)�
_EXC_SENTINEL�DEBUG�DEFAULT_CHUNK_SIZE�EMPTY_BODY_METHODS�EMPTY_BODY_STATUS_CODES�
NO_EXTENSIONS�BaseTimerContext�
set_exception) �BadHttpMessage�
BadHttpMethod�
BadStatusLine�ContentEncodingError�ContentLengthError�
InvalidHeader�InvalidURLError� LineTooLong�TransferEncodingError)� HttpVersion�
HttpVersion10�
HttpVersion11)�
EMPTY_PAYLOAD� StreamReader)�
RawHeaders)�ResponseHandler)�
HeadersParser�
HttpParser�HttpRequestParser�HttpResponseParser�RawRequestMessage�RawResponseMessage)�
�
�ASCIISETz!#$%&'*+-.^_`|~�_TCHAR_SPECIALSz
[0-9A-Za-zz]+�TOKENREzHTTP/(\d)\.(\d)�VERSREz\d+�DIGITSs [0-9a-fA-F]+� HEXDIGITSz[\x00-\x08\x0a-\x1f\x7f]� _FIELD_VALUE_FORBIDDEN_CTL_RE>
z
user-agentzcontent-lengthztransfer-encoding�hostz max-forwardsZserverz content-typeZetagzcontent-locationz
content-range�SINGLETON_HEADERSc @ sb e Zd ZU eed< eed< eed< ded< eed< eed< edB ed < eed
< eed < eed < dS )
r5 �method�path�version�CIMultiDictProxy[str]�headers� raw_headers� should_closeN� compression�upgrade�chunked�url) �__name__�
__module__� __qualname__�str�__annotations__r* r/ �boolr � rS rS �G/opt/saltstack/salt/lib/python3.10/site-packages/aiohttp/http_parser.pyr5 o s
r5 c @ s^ e Zd ZU eed< eed< eed< ee ed< eed< e ed< edB ed< e ed < e ed
< dS ) r6 rD �code�reasonrF rG rH NrI rJ rK )
rM rN rO r* rQ �intrP r r/ rR rS rS rS rT r6 | s
r6 �_MsgTc @ s e Zd ZdZdZdZdS )� PayloadStater r � N)rM rN rO �PAYLOAD_COMPLETE�PAYLOAD_NEEDS_INPUT�PAYLOAD_HAS_PENDING_INPUTrS rS rS rT rY � s rY c @ s e Zd ZdZdZdZdZdS )�
ParseStater r rZ � N)rM rN rO �
PARSE_NONE� PARSE_LENGTH�
PARSE_CHUNKED�PARSE_UNTIL_EOFrS rS rS rT r^ � s
r^ c @ s e Zd ZdZdZdZdZdZdS )�
ChunkStater r rZ r_ � N)rM rN rO �PARSE_CHUNKED_SIZE�PARSE_CHUNKED_CHUNK�PARSE_CHUNKED_CHUNK_EOFZPARSE_MAYBE_TRAILERS�PARSE_TRAILERSrS rS rS rT rd � s rd c @ sR e Zd Z ddededededd f
d
d �Zd ee ded
e f fdd�Z
d S )r1 � � � F�
max_line_size� max_headers�max_field_size�lax�returnNc C s || _ || _|| _|| _d S �N)rl rm rn �_lax)�selfrl rm rn ro rS rS rT �__init__� s
zHeadersParser.__init__�linesrE c C s t � }g }d}|| }t|�}|�rz
|�dd�\}}W n ty( t|�d �w t|�dkr3t|��|d |d hddh@ rCt|��|�d�}|�dd �} t�| �sWt|��|d7 }|| }| j oi|oi|d d
v }
|
r�t|�} |g} |
r�| t|�7 } | | j
kr�|d d � | � }
t |
d d
� d | j
��| �
|� |d7 }||k r�|| }|r�|d d
v }
nd }n|
sud � | �}|�d�}|�dd �}| j r�d|v s�d|v s�d|v r�t|��n t�|�r�t|��| j s�| |v r�| �� tv r�td| � d���|�| |� |�
||f� |st|�t|�fS )Nr � :r ���� � s �utf-8�surrogateescape)rx ry s : � �d � ...�
�
� z Duplicate 'z' header found.)r
�len�split�
ValueErrorr& �lstrip�decoder; � fullmatchrr rn �joinr( �append�stripr? �search�lowerrA r! �addr �tuple)rs ru rF rG Z lines_idx�lineZ
line_countZbnameZbvalue�nameZ continuation�
header_lengthZ
bvalue_lstZ header_line�valuerS rS rT �
parse_headers� sr
�
�
��
�
�AzHeadersParser.parse_headers)rj rk rj F) rM rN rO rW rR rt �list�bytesr� r/ r� rS rS rS rT r1 � s* �����
� �
�r1 rF rp c C s" | � tjd�}|�� o|�� dv S )z)Check if the upgrade header is supported.� > Z websocketZtcp)�getr �UPGRADE�isasciir� )rF �urS rS rT �_is_supported_upgrade� s r� c @ s� e Zd ZU dZee ed< d6d edB d
ej dB d e
d e
d
e
de
de dB de
dB de dB de
e dB dededede
ddf dd�Zejdee defdd ��Zejd e defd d ��Zd7d d!�Zd7d"d#�ZdedB fd$d%�Zd&d'ejej ej fd(ed)e d*ed+e d,e d-e de ee ee!f eef fd.d/�Z"dee de d0e#edB e dB eef fd1d2�Z$d3eddfd4d5�Z%dS )8r2 Fro N� rj � Tr �protocol�loop�limitrl rm rn �timerrU rB �payload_exception�response_with_body�read_until_eof�auto_decompress�max_msg_queue_sizerp c C s� || _ || _|| _|| _|| _|| _|| _|| _| | _|
| _| | _ | | _
g | _ d| _ d| _
d | _d | _d| _|
| _|| _t|||| j�| _|| _d| _d S )Nr| Fr )r� r� rl rm rn r� rU rB r� r� r� �_lines�_tail� _upgraded�_payload�_payload_parser�_payload_has_more_data�_auto_decompress�_limitr1 ro �_headers_parser�_max_msg_queue_size�_msg_in_flight)rs r� r� r� rl rm rn r� rU rB r� r� r� r� r� rS rS rT rt s2
�
zHttpParser.__init__ru c C � d S rq rS )rs ru rS rS rT �
parse_message4 � zHttpParser.parse_message�tec C r� rq rS �rs r� rS rS rT �_is_chunked_te7 r� zHttpParser._is_chunked_tec C s | j d usJ �| j �� d S rq )r� �
pause_reading�rs rS rS rT r� : s zHttpParser.pause_readingc C s | j dkr| j d8 _ dS dS )z;Protocol drained a queued message; free a slot for parsing.r r N)r� r� rS rS rT �message_consumed> s
�zHttpParser.message_consumedc C s� | j d ur| j �� | j jrd | _ d S | jr | j�| j� | jrG| jd dkr-| j�d� tt�� | �| j�W d � S 1 sBw Y d S )Nrw z
r| ) r� �feed_eof�doner� r� r� r � Exceptionr� r� rS rS rT r� C s
�
�zHttpParser.feed_eofr7 r| �data�SEP�EMPTY�CONTENT_LENGTH� METH_CONNECT�SEC_WEBSOCKET_KEY1c s g }| j r| j | d}| _ t|�}d} | j}
| j} d} | |k s$| j�rm| jd u �r�| j�s�| jr@| j| jkr@|| d � | _ �n-|� || �}
|
| krT| j
sT|
t|� } q |
| k�r�| r_t d��|| |
� }|dkrn|� d�}t|�| krt
|d d� d | ��| j
�|� | j} t| j
�| jkr�t d ��|
t|� } | j
d
|k�r�| jt| j
� }z
| �| j
��W | j
�� n| j
�� w d td B f� �fd d
� }|� }|�jv r�t|���jo�t�j�| _t�d| j�}t�dd�}| jd us�J �|tv p�t |o�|t v �}|�sC|d u�r |dk�s�j �rC| j�sCt | j| j |
| j!d�}t"||�j |�j#| j$| j%| j&| j'| j(| j| j|| j!d�}|j)�sB|| _np||k�rvt*�t+��sPJ �t | j| j |
| j!d�}d| _t"|�j�j#| j&| j'| j(| j| j|| j!d�
| _n=|�s�|d u �r�| j,�r�t | j| j |
| j!d�}t"||�j |�j#| j$| j%| j&| j'| j(| j| j|| j!d�}|j)�s�|| _nt-}|��|f� | j�r�| jd7 _�j.} n�|| d � | _ t| j �| jk�r�t
| j d d� d | j��|}n�| jd u �r�| j�r�| j
�r�J �ns| j
�r J �| jd u�sJ �z| j�/|| d � |�\}}W n8 t0�yO } z+|}| j1d u�r/| �1t2|��}t3| jj4||� t5j6}d}t*|tt7f��rE� W Y d }~nd }~ww |t5j8k| _|t5j6u�r]nd} t|�}d | _| |k s$| js$|�r|| |k �r||| d � }n|}|| j|fS )Nr| r Fz Data after `Connection: close`r8 �
r} r~ zToo many headers receivedrw rp c s2 �j �� �} | d u r d S t�| �st� ��t| �S rq )rF r� r= r� r& rW )Z
length_hdr�r� �msgrS rT �get_content_length� s
z0HttpParser.feed_data.<locals>.get_content_lengthrB rU )r� r� r� )
�lengthrK rB rI rU r� r� ro �headers_parserrl rn � max_trailersr� T) rB rI r� ro r� rl rn r� r� r )9r� r� r� rl r� r� r� r� r� �findr� r! �rstripr( r� rn rm r� �clearrW rF r& rJ r� �getattrrB r� r rR r rK r. r� r� �HttpPayloadParserrI rU r� r� ro r� r� �
isinstancer5 r� r- rH � feed_datar� r� rP r �payloadrY r[ r) r] )rs r� r� r� r� r� r� �messagesZdata_lenZ start_posr� �max_line_lengthrH �posr� r� r� r� rB rU Z
empty_bodyr� Zpayload_parserZ
payload_stateZunderlying_excZ reraised_excrS r� rT r� T sd
�
�
� ����
�
� ���� � �� ���� �� T zHttpParser.feed_datarE c C s� | j �|�\}}d}d}d}d}|�tjd�}|r9dd� |D �} d| v r'd}nd| v r-d}d | v r9|�tj�r9d}|�tjd
�}
|
�� rL|
� � d v rL|
}|�tj
�} | durf| � | �r]d}tj |v rft
d ��||||||fS )
z�Parses RFC 5322 headers from a stream.
Line continuations are supported. Returns list of header name
and value pairs. Header name is in upper case.
NFrS c S s: h | ]}d d� |� d�D �D ] }|r|�� r|�� �qqS )c s s � | ]}|� d �V qdS )� N)r� )�.0�partrS rS rT � <genexpr>Z s � z5HttpParser.parse_headers.<locals>.<setcomp>.<genexpr>�,)r� r� r� )r� Z
conn_value�tokenrS rS rT � <setcomp>W s ����z+HttpParser.parse_headers.<locals>.<setcomp>�closeTz
keep-aliverJ r� > �deflate�gzip�zstd�brz6Transfer-Encoding can't be present with Content-Length)r� r� Zgetallr Z
CONNECTIONr� r� ZCONTENT_ENCODINGr� r� �TRANSFER_ENCODINGr� r� r! ) rs ru rF rG Z
close_conn�encodingrJ rK Z conn_valuesZ conn_tokens�encr� rS rS rT r� C s8
�
�zHttpParser.parse_headers�valc C s
|| _ dS )zZSet connection upgraded (to websocket) mode.
:param bool val: new state.
N)r� )rs r� rS rS rT � set_upgradedy s
zHttpParser.set_upgraded)NNr� rj r� rj NNNNTFTr �rp N)&rM rN rO ro r rR rQ r �asyncioZAbstractEventLooprW r rP �type�
BaseExceptionrt �abc�abstractmethodr� r� rX r� r� r� r� r� r r� r� r� �_SEPr r� r. r� r/ r� r� rS rS rS rT r2 s�
�������� �
�
� �
���
�-
�������
� p��
�6r2 c @ s8 e Zd ZdZdee defdd�Zdede fdd�Z
d S )
r3 z�Read request status line.
Exception .http_exceptions.BadStatusLine
could be raised in case of any errors in status line.
Returns RawRequestMessage.
ru rp c C s� |d � dd�}z |jddd�\}}}W n ty t|�d �w t�|�s*t|��t�|�}|d u r7t|��tt |�
d��t |�
d���}|dkrRt j |d d
�}nD|�
d �rq|�d �\} }
} | �d
�\} } }
t j | |
| d d�}n%|dkr�|dkr�t |d d�}nt |d d�}|jdkr�t|jdd�� d���| �|dd � �\}}}}}}|tkr�tj|vr�td��|d u r�|tkr�d }nd}t||||||||||�
S )Nr rz r{ � rZ ��maxsplitr ZCONNECTT)Z authority�encoded�/�#�?)rC Z query_string�fragmentr� �*ZOPTIONS)r� r� )�errors�latin1z!Missing 'Host' header in request.F)r� r� r� r" r; r� r< r# r* rW �groupr �build�
startswith� partition�schemer' �encoder� r, r ZHOSTr! r+ r5 )rs ru r� rB rC rD �match� version_orL Z path_partZ_hash_separatorZ url_fragmentZ_question_mark_separatorZqs_partrF rG r� rI rJ rK rS rS rT r� � sp
�
�
� ��z HttpRequestParser.parse_messager� c C s8 |j ddd�d �d�}|�� r|�� dkrdS td��) Nr� r r� rw r� rK Tz'Request has invalid `Transfer-Encoding`)�rsplitr� r� r� r! r� rS rS rT r� � s z HttpRequestParser._is_chunked_teN) rM rN rO �__doc__r� r� r5 r� rP rR r� rS rS rS rT r3 � s Sr3 c s� e Zd ZU dZded< e Z ddededB de de d e
e e
e e
f eef f
� fd
d �
Zd e e d e fd
d�Zded efdd�Z� ZS )r4 z�Read response status line and headers.
BadStatusLine could be raised in case of any errors in status line.
Returns RawResponseMessage.
r0 r� Nr� r� �args�kwargsrp c s0 |d u r
t rdnd}t� j||g|�R i |��S )Nr7 r8 )r �superr� )rs r� r� r r �� __class__rS rT r� � s z HttpResponseParser.feed_dataru c
C sb |d � dd�}z
|jdd�\}}W n ty t|�d �w z
|jdd�\}}W n ty8 |�� }d}Y nw t�|�}|d u rFt|��tt|� d��t|� d���}t
|�dks`t �|�sdt|��t|�}| � |dd � �\} }
} } }
}| d u r�|t
kr�d } n!d
| kr�d k s�n |d v r�d
} ntj| v s�tj| v r�d
} nd } t|||�� | |
| | |
|� S )Nr rz r{ r r� r� rZ r_ Tr} �� > i0 �� F)r� r� r� r# r� r< r� r* rW r� r� r= r� r+ r r� r� r6 )rs ru r� rD �statusrV r� r Zstatus_irF rG r� rI rJ rK rS rS rT r� � s\
� �
� �z HttpResponseParser.parse_messager� c C s |j ddd�d �d��� dkS )Nr� r r� rw r� rK )r r� r� r� rS rS rT r� 6 s z!HttpResponseParser._is_chunked_terq )rM rN rO r rQ r ro r� r� r r� r� r6 r. rR r� r� rP r� �
__classcell__rS rS r rT r4 � s$
������ :r4 c @ s� e Zd Z d#ddded�dededB d ed
edB d edB d edB d
ededededededededdf dd�Z d$dd�Z
d$dd�Z d%d e d e
d e deee f fd!d"�ZdS )&r� NFTrj r� )rl rn r� r� r� r� rK rI rU rB r� r� ro r� rl rn r� r� rp c
C s� d| _ d| _tj| _tj| _d| _d| _ || _
| | _ |
| _ | | _
| | _|
| _d| _g | _d| _d| _|rA|rA| j
rAt|||d�}n|}|sQtj| _|�� d| _n!|rXtj| _n|d urrtj| _|| _ || _| j dkrr|�� d| _|| _d S )Nr Fr| )�max_decompress_sizeT)�_length�_pausedr^ rc �_typerd rf �_chunk� _chunk_size� _chunk_tailr� rr r� �_max_line_size�_max_field_size�
_max_trailers�_more_data_available�_trailer_linesr� � _eof_pending�
DeflateBufferr` r� rb ra �_length_expectedr� )rs r� r� rK rI rU rB r� r� ro r� rl rn r� r� Z real_payloadrS rS rT rt < sF �
zHttpPayloadParser.__init__c C s
d| _ d S )NT)r r� rS rS rT r� y s
z HttpPayloadParser.pause_readingc C s� | j tjkr,d| _| jr | jrd| _d S | j�dd�| _| js | j�� d| _ d| _d S | j tj
krD| j | j }t
d|� d| j � d���| j tjkrNtd��d S ) NTFr| r z;Not enough data to satisfy content length header (received z of z bytes).z2Not enough data to satisfy transfer length header.)r r^ rc r r r r� r� r� r� ra r r
r% rb r) )rs ZreceivedrS rS rT r� | s2 �
��� ��zHttpPayloadParser.feed_eofr7 � ;�chunkr� � CHUNK_EXTc C s� | j tjkr_| jr| j| }d| _| j}t|t|� d�| _| j�|d|� |�| _ | j rJ| j
r?d| _
||d� | _t j dfS | j�dd�| _ | j s-| jdkr]| j�
� t j||d� fS �nb| j tjk�r�| jr�| jtjkr�| j}| jtjkr{| j}t| j�|kr�t| jdd� d |��| j| }d| _|s�| j �r| jtjk�rQ|�|�}|dk�rI|| jkr�t|dd� d | j��|�|d|�}|dkr�|d|� }d|||� } v r�td| ���}
t| j|
� |
�n|d|� }| jr�|� � }t � t |��st|d|� � d d
��}
t| j|
� |
�t!t"|�d �} ||t|� d� }| dk�r<tj| _| j�r;|�#d ��r;|d
d� }ntj| _| | _$| j�%� n|| _t j&dfS | jtjk�r�| j
�rgd| _
|| _t j dfS | j$}t|t|� d�| _$| j�|d|� |�| _ ||d� }| j �r�q�| j$�r�d| _
t j&dfS tj'| _| j�(� | jtj'k�r�| j�r�|�#d ��r�|d
d� }|dt|�� |k�r�|t|�d� }tj| _n(t|�t|�k�s�||dt|�� k�r�td�}
t| j|
� |
�|| _t j&dfS | jtjk�rz|�|�}|dk �r|| _t j&dfS |d|� } ||t|� d� }|dk�r*| �)d �} t| �| jk�r>t| dd� d | j��| j*�+| � t| j*�| j,k�rQt-d��| j*d dk�rzz| j.�/| j*�\}
}W | j*�0� n| j*�0� w | j�
� t j|fS |s�| j s�nA| j tj1k�r�| j�|t|��| _ | j �r�| j
�r�d| _
t j dfS | j�dd�| _ | j �s�| j2�r�| j�
� d| _3d| _2t jdfS t j&dfS )a� Receive a chunk of data to process.
Return:
PayloadState - The current state of payload processing.
This function may be called with empty bytes after returning
PAYLOAD_HAS_PENDING_INPUT to continue processing after a pause.
bytes - If payload is complete, this is the unconsumed bytes intended for the
next message/payload, b"" otherwise.
r| r NFr} r~ r8 z"Unexpected LF in chunk-extension: �asciir{ � r� r z3Chunk size mismatch: expected CRLF after chunk datazToo many trailers receivedrw T)4r r^ ra r r
�maxr� r� r� r r rY r] r� r[ rb r rd rg r ri r r( rf r� r) r rr r� �rer� r> r� rW r� r� r �begin_http_chunk_receivingr\ rh �end_http_chunk_receivingr� r r� r r! r� r� r� rc r r� )rs r r� r �requiredr� r� �iZsize_b�ext�exc�sizer� ZtrailersZ raw_trailersrS rS rT r� � s
�
�
� �
� � �
�
�
(�
�
��w
�
zHttpPayloadParser.feed_data)NFNNNTTFr� )r7 r )rM rN rO r r. rW rR rP r1 rt r� r� r� r� r� rY r� rS rS rS rT r� ; sr �
�������� �
� �
����
�
=
����
�r� c @ s� e Zd ZU dZeed< efdededB de ddfdd �Z
e fd
e d e ddfd d
�Z
dede defdd�Zddd�Zddd�Zddd�ZdS )r zDDeflateStream decompress stream and feed data into specified stream.� decompressor�outr� Nr rp c C sv || _ d| _| j|_|| _d| _| |dkr!ts td��t� | _n|dkr0t s+td��t
� | _nt |d�| _|| _ d S )Nr Fr� zECan not decode content-encoding: brotli (br). Please install `Brotli`r� zRCan not decode content-encoding: zstandard (zstd). Please install `backports.zstd`)r� )
r* r( �total_compressed_bytesr� �_started_decodingr r$ r r) r r r �_max_decompress_size)rs r* r� r rS rS rT rt P s( �
�
zDeflateBuffer.__init__r' � exc_causec C s t | j||� d S rq )r r* )rs r' r. rS rS rT r p s zDeflateBuffer.set_exceptionr r( c C s� | j |7 _ | j | j_| js$| jdkr$|d d@ dkr$t| jdd�| _| jj}|tj kr/dnt
| j |�}z
| jj ||d�}W n t
yM td| j ��w d| _|r\| j�|t|�� | jjS ) Nr� r � � T)r� Zsuppress_deflate_header)�
max_lengthz#Can not decode content-encoding: %s)r( r* r+ r, r� r r) Z
_low_water�sys�maxsizer r- Zdecompress_syncr� r$ r� r� Zdata_available)rs r r( Z low_waterr1 rS rS rT r� w s.
�
�� ��zDeflateBuffer.feed_datac C sD | j �� }|r J �| jdkr| jdkr| j jstd��| j�� d S )Nr r� )r) �flushr( r� �eofr$ r* r� )rs r rS rS rT r� � s
zDeflateBuffer.feed_eofc C � | j �� d S rq )r* r" r� rS rS rT r" � � z(DeflateBuffer.begin_http_chunk_receivingc C r6 rq )r* r# r� rS rS rT r# � r7 z&DeflateBuffer.end_http_chunk_receivingr� )rM rN rO r r rQ r r. rP rW rt r r� r r� rR r� r� r" r# rS rS rS rT r K s2
����
�#���
�
#
r )r3 r4 r5 r6 )mr� r� r! �stringr2 �
contextlibr �enumr r �typingr r r r r r
r r Z multidictr
r r Zyarlr r� r Z
base_protocolr Zcompression_utilsr r r r r Zhelpersr r r r r r r r Zhttp_exceptionsr! r" r# r$ r% r& r' r( r) Z http_writerr* r+ r, Zstreamsr- r. Ztypedefsr/ Z client_protor0 �__all__r� �set� printabler9 rP rQ �escaper: �compiler; �ASCIIr< r= r> r� r? � frozensetrA r5 r6 rX rY r^ rd r1 rR r� �ABCr2 r3 r4 r� r ZHttpRequestParserPyZHttpResponseParserPyZRawRequestMessagePyZRawResponseMessagePyZ _http_parserZHttpRequestParserCZHttpResponseParserCZRawRequestMessageCZRawResponseMessageC� ImportErrorrS rS rS rT �<module> s�
( (,
" � �
\ dV c
� �