MOON
Server: Apache
System: Linux server30c.hostingraja.org 3.10.0-962.3.2.lve1.5.63.el7.x86_64 #1 SMP Fri Oct 8 12:03:35 UTC 2021 x86_64
User: jibhires (1887)
PHP: 8.1.30
Disabled: show_source, system, shell_exec, passthru, exec, popen, proc_open, allow_url_fopen, symlink, escapeshellcmd, pcntl_exec
Upload Files
File: //opt/alt/python35/lib64/python3.5/site-packages/aiohttp/__pycache__/http_writer.cpython-35.pyc


���Z��@s�dZddlZddlZddlZddlmZddlmZd
Zej	dd
dg�Z
e
dd�Ze
dd�ZGdd�de�Z
dS)z"Http related parsers and protocol.�N�)�AbstractStreamWriter)�noop�StreamWriter�HttpVersion�
HttpVersion10�
HttpVersion11�major�minorc@s�eZdZdd�Zedd��Zedd��Zdd�Zd	d
d�Zdd
�Z	dddddd�Z
dddd�Zddd�Zdd�Z
dS) rcCs^||_||_||_d|_d|_d|_d|_d|_d|_d|_	dS)NFr)
�	_protocol�
_transport�loop�length�chunked�buffer_size�output_size�_eof�	_compressZ
_drain_waiter)�self�protocol�	transportr
�r�/http_writer.py�__init__s									zStreamWriter.__init__cCs|jS)N)r)rrrrr"szStreamWriter.transportcCs|jS)N)r)rrrrr&szStreamWriter.protocolcCs
d|_dS)NT)r)rrrr�enable_chunking*szStreamWriter.enable_chunkingZdeflatecCs<|dkrdtjntj}tjd|�|_dS)N�gzip�Zwbits)�zlib�	MAX_WBITS�compressobjr)r�encodingZ	zlib_moderrr�enable_compression-s#zStreamWriter.enable_compressioncCskt|�}|j|7_|j|7_|jdksH|jj�rWtjd��|jj|�dS)Nz!Cannot write to closing transport)�lenrrrZ
is_closing�asyncio�CancelledError�write)r�chunk�sizerrr�_write2szStreamWriter._write�drainT�LIMIT�@icCs|jdk	r.|jj|�}|s.t�S|jdk	r�t|�}|j|krk|j||_n)|d|j�}d|_|s�t�S|r�|jr�dt|�jd�}||d}|j|�|j|kr�|r�d|_|j	�St�S)z�Writes chunk of data to a stream.

        write_eof() indicates end of stream.
        writer can't be used after write_eof() method being called.
        write() return drain future.
        Nrz%x
�asciis
)
r�compressrrr"r�encoder(rr))rr&r)r*�	chunk_lenrrrr%;s*		
	
zStreamWriter.writez: z
csS|dj��fdd�|j�D��}|jd�d}|j|�dS)z*Write request/response status and headers.�cs(g|]\}}|�|��qSrr)�.0�k�v)�END�SEPrr�
<listcomp>bs	z.StreamWriter.write_headers.<locals>.<listcomp>zutf-8s
N)�join�itemsr.r()rZstatus_lineZheadersr5r4r)r4r5r�
write_headers^s	&zStreamWriter.write_headers�c�s�|jr
dS|jrz|r.|jj|�}||jj�}|r�|jr�dt|�jd�}||d}n?|jr�|r�dt|�jd�}||d}nd}|r�|j|�|j�IdHd|_d|_	dS)Nz%x
r,s
0

s0

T)
rrr-�flushrr"r.r(r)r)rr&r/rrr�	write_eoffs&			
	zStreamWriter.write_eofc�s(|jjdk	r$|jj�IdHdS)zFlush the write buffer.

        The intended use is to write

          await w.write(data)
          await w.drain()
        N)rrZ
_drain_helper)rrrrr)�szStreamWriter.drainNi)�__name__�
__module__�__qualname__r�propertyrrrr!r(r%r9r<r)rrrrrs	#)rrrr)�__doc__r#�collectionsr�abcrZhelpersr�__all__�
namedtuplerrrrrrrr�<module>s