Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/tornado/test/__pycache__/httpserver_test.cpython-39.pyc
Ðазад
a _�h�� � @ s� d dl mZmZ d dlmZmZmZmZmZm Z d dl m Z d dl m Z d dlmZ d dlmZmZmZmZ d dlmZ d dlmZ d d lmZ d d lm Z d d l m Z d d l m Z m!Z!m"Z"m#Z#m$Z$ d d l%m&Z& d dl'm(Z(m)Z)m*Z* d dl+m,Z, d dl-Z-d dl.Z.d dl/Z/d dl0Z0d dl1Z1d dl2Z2d dl3Z3d dl4Z4d dl5Z5d dl6m7Z7 d dl8Z8e8j9�rdd dl8m:Z:m;Z; dd� Z<G dd� de �Z=G dd� de)�Z>e5�?e@e2dd�dk d �ZAG d d � d e!�ZBG d d � d eC�ZDG d!d"� d"eBeD�ZEeAG d#d$� d$eBeD��ZFeAG d%d&� d&eBeD��ZGG d'd(� d(eBeD�ZHG d)d*� d*e5jI�ZJG d+d,� d,e)�ZKG d-d.� d.e �ZLG d/d0� d0e)�ZMG d1d2� d2e)�ZNG d3d4� d4e �ZOG d5d6� d6e �ZPG d7d8� d8e=�ZQG d9d:� d:e!e=�ZRG d;d<� d<e=�ZSe5�?eTe1d=� �p�e3jUd>kd?�G d@dA� dAe"��ZVG dBdC� dCe �ZWG dDdE� dEeC�ZXG dFdG� dGeXe �ZYG dHdI� dIeXe �ZZG dJdK� dKe �Z[G dLdM� dMe �Z\e&G dNdO� dOe ��Z]G dPdQ� dQe �Z^G dRdS� dSe �Z_dS )T� )�gen�netutil)� json_decode� json_encode�utf8�_unicode�recursive_unicode� native_str)�HTTP1Connection)� HTTPError)� HTTPServer)� HTTPHeaders�HTTPMessageDelegate� HTTPServerConnectionDelegate�ResponseStartLine)�IOStream)�Event)�gen_log)�ssl_options_to_context��SimpleAsyncHTTPClient)�AsyncHTTPTestCase�AsyncHTTPSTestCase� AsyncTestCase� ExpectLog�gen_test)� skipOnTravis)� Application�RequestHandler�stream_request_body)�closingN)�BytesIO)�Dict�Listc � sN g � G � �fdd�dt �}t| d��|� }��|�I dH |j|jd�� �fS )zaReads an HTTP response from `stream` and returns a tuple of its start_line, headers and body.c s, e Zd Zdd� Z� fdd�Z�fdd�ZdS )z"read_stream_body.<locals>.Delegatec S s || _ || _d S �N)�headers� start_line��selfr& r% � r) ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/tornado/test/httpserver_test.py�headers_received: s z3read_stream_body.<locals>.Delegate.headers_receivedc s � � |� d S r$ )�append�r( �chunk)�chunksr) r* � data_received> s z0read_stream_body.<locals>.Delegate.data_receivedc s � � � d S r$ )�detach�r( )�connr) r* �finishA s z)read_stream_body.<locals>.Delegate.finishN)�__name__� __module__� __qualname__r+ r0 r4 r) �r/ r3 r) r* �Delegate9 s r9 TN� )r r � read_responser& r% �join)�streamr9 Zdelegater) r8 r* �read_stream_body4 s r> c @ s e Zd Zdd� Zdd� ZdS )�HandlerBaseTestCasec C s t d| jjfg�S �N�/)r � __class__�Handlerr2 r) r) r* �get_appK s zHandlerBaseTestCase.get_appc O s" | j |i |��}|�� t|j�S r$ )�fetch�rethrowr �body)r( �args�kwargs�responser) r) r* � fetch_jsonN s z HandlerBaseTestCase.fetch_jsonN)r5 r6 r7 rD rK r) r) r) r* r? J s r? c @ s& e Zd Zd dd�Zdd� Zdd� ZdS ) �HelloWorldRequestHandler�httpc C s || _ d S r$ )�expected_protocol)r( �protocolr) r) r* � initializeU s z#HelloWorldRequestHandler.initializec C s$ | j j| jkrtd��| �d� d S )Nzunexpected protocol� Hello world)�requestrO rN � Exceptionr4 r2 r) r) r* �getX s z HelloWorldRequestHandler.getc C s | � dt| jj� � d S )NzGot %d bytes in POST)r4 �lenrR rG r2 r) r) r* �post] s z HelloWorldRequestHandler.postN)rM )r5 r6 r7 rP rT rV r) r) r) r* rL T s rL �OPENSSL_VERSION_INFO)r r )� r z(old version of ssl module and/or opensslc @ s e Zd Zdd� ZdS )� BaseSSLTestc C s t dttdd�fg�S )NrA �https�rO )r rL �dictr2 r) r) r* rD m s zBaseSSLTest.get_appN)r5 r6 r7 rD r) r) r) r* rY l s rY c @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd S )� SSLTestMixinc C s t f d| �� it�� ��S )N� ssl_version)r\ �get_ssl_versionr Zdefault_ssl_optionsr2 r) r) r* �get_ssl_optionsr s ��z SSLTestMixin.get_ssl_optionsc C s t � �d S r$ )�NotImplementedErrorr2 r) r) r* r_ x s z SSLTestMixin.get_ssl_versionc C s | � d�}| �|jd� d S )NrA � Hello world�rE � assertEqualrG �r( rJ r) r) r* �test_ssl{ s zSSLTestMixin.test_sslc C s& | j dddd d�}| �|jd� d S )NrA �POST�Ai� ��methodrG s Got 5000 bytes in POSTrc re r) r) r* �test_large_post s z SSLTestMixin.test_large_postc C s� t td��� t tddd��^ | �ttf��0 | j| �d��dd�ddd d � W d � n1 s`0 Y W d � n1 s~0 Y W d � n1 s�0 Y d S ) Nz (SSL Error|uncaught exception)zUncaught exceptionF��requiredrA �https:�http:� T)�request_timeout�connect_timeout� raise_error)r r � assertRaises�IOErrorr rE �get_url�replacer2 r) r) r* �test_non_ssl_request� s �z!SSLTestMixin.test_non_ssl_requestc C s� t td��Z}| �ttf��, | j| �d��dd�dd� W d � n1 sL0 Y W d � n1 sj0 Y | �|j � d S )Nz SSL ErrorrA rn ro T)rs ) r r rt ru r rE rv rw Z assertFalseZ logged_stack)r( Z expect_logr) r) r* �test_error_logging� s �Bz SSLTestMixin.test_error_loggingN) r5 r6 r7 r` r_ rf rk rx ry r) r) r) r* r] q s r] c @ s e Zd Zdd� ZdS )� SSLv23Testc C s t jS r$ )�ssl�PROTOCOL_SSLv23r2 r) r) r* r_ � s zSSLv23Test.get_ssl_versionN�r5 r6 r7 r_ r) r) r) r* rz � s rz c @ s e Zd Zdd� ZdS )� SSLv3Testc C s t jS r$ )r{ ZPROTOCOL_SSLv3r2 r) r) r* r_ � s zSSLv3Test.get_ssl_versionNr} r) r) r) r* r~ � s r~ c @ s e Zd Zdd� ZdS )� TLSv1Testc C s t jS r$ )r{ �PROTOCOL_TLSv1r2 r) r) r* r_ � s zTLSv1Test.get_ssl_versionNr} r) r) r) r* r � s r c @ s e Zd Zdd� ZdS )�SSLContextTestc C s" t t�| ��}t|tj�s J �|S r$ )r r r` � isinstancer{ � SSLContext)r( �contextr) r) r* r` � s z SSLContextTest.get_ssl_optionsN)r5 r6 r7 r` r) r) r) r* r� � s r� c @ s e Zd Zdd� Zdd� ZdS )�BadSSLOptionsTestc C s t � }| jtt|ddid� d S )N�keyfilez/__missing__.crt�Z ssl_options)r rt �KeyErrorr )r( � applicationr) r) r* �test_missing_arguments� s �z(BadSSLOptionsTest.test_missing_argumentsc C sz t � }tj�t�}tj�|d�}tj�|d�}| jttft |ddid� | jttft ||dd�d� t |||d�d� dS ) z6A missing SSL key should cause an immediate exception.ztest.crtztest.key�certfilez/__mising__.crtr� z/__missing__.key)r� r� N) r �os�path�dirname�__file__r< rt � ValueErrorru r )r( r� Z module_dirZexisting_certificateZ existing_keyr) r) r* �test_missing_key� s, ��� �z"BadSSLOptionsTest.test_missing_keyN)r5 r6 r7 r� r� r) r) r) r* r� � s r� c @ s e Zd Zdd� ZdS )�MultipartTestHandlerc C sH | � | jjd | �d�| jjd d jt| jjd d d �d�� d S )NzX-Header-Encoding-Test�argument�filesr rG )�headerr� �filename�filebody)r4 rR r% � get_argumentr� r� r r2 r) r) r* rV � s ��zMultipartTestHandler.postN)r5 r6 r7 rV r) r) r) r* r� � s r� c @ sB e Zd Zdd� Zdd� Zddd�Zdd � Zd d � Zed d � �Z dS )�HTTPConnectionTestc C s dt fdtfgS )Nz /multipart�/hello)r� rL r2 r) r) r* � get_handlers� s �z HTTPConnectionTest.get_handlersc C s t | �� �S r$ )r r� r2 r) r) r* rD � s zHTTPConnectionTest.get_app� c s� t tt�� ���r�� j�� �fdd�� ��|�|tdt|� �g �| | | � � j��fdd��\}}}|W d � S 1 s�0 Y d S )Nc s �� d� �� f�S �N� 127.0.0.1)�connect� get_http_portr) �r( r= r) r* �<lambda>� r: z.HTTPConnectionTest.raw_fetch.<locals>.<lambda>zContent-Length: %dc s t � �S r$ )r> r) )r= r) r* r� r: ) r r �socket�io_loop�run_sync�writer< r rU )r( r% rG �newliner& r) r� r* � raw_fetch� s" ����� � z HTTPConnectionTest.raw_fetchc C s� | � g d�d�ddd�d�dd�d �dd �d�d dg ��}t|�}| �d |d � | �d|d � | �d|d � | �d |d � d S )N)s POST /multipart HTTP/1.0s6 Content-Type: multipart/form-data; boundary=1234567890s X-Header-encoding-test: �r� s- Content-Disposition: form-data; name=argumentr: � ázutf-8s --1234567890u; Content-Disposition: form-data; name="files"; filename="ó"r � ús --1234567890--� ér� r� � ór� r� )r� r< �encoder rd �r( rJ �datar) r) r* �test_multipart_form s, ����z&HTTPConnectionTest.test_multipart_formc C s, dD ]"}| j dgd|d�}| �|d� qd S )N)r� � s GET /hello HTTP/1.0r: )r� rb )r� rd )r( r� rJ r) r) r* � test_newlines( s z HTTPConnectionTest.test_newlinesc c s� t t�� �}|�d| �� f�V |�d�g d���V |�d�V }| �|�d�|� |�d� |�d�V }| �|�d�|� |�d�V }t � t |� d���}|� t|d ��V }| �|d � |�� d S ) Nr� r� )s POST /hello HTTP/1.1s Content-Length: 1024s Expect: 100-continues Connection: closer� � s HTTP/1.1 100 s aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa� HTTP/1.1 200�latin1�Content-Lengths Got 1024 bytes in POST)r r� r� r� r� r< � read_until� assertTrue� startswithr �parser �decode� read_bytes�intrd �close)r( r= r� � first_line� header_datar% rG r) r) r* �test_100_continue. s" �� z$HTTPConnectionTest.test_100_continueN)r� ) r5 r6 r7 r� rD r� r� r� r r� r) r) r) r* r� � s r� c @ s e Zd Zdd� Zdd� ZdS )� EchoHandlerc C s | � t| jj�� d S r$ �r� r rR � argumentsr2 r) r) r* rT M s zEchoHandler.getc C s | � t| jj�� d S r$ r� r2 r) r) r* rV P s zEchoHandler.postN�r5 r6 r7 rT rV r) r) r) r* r� L s r� c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S ) �TypeCheckHandlerc C s i | _ dtfdtfdtfdtfdtfdtfdtfdtfg}|D ] \}}| �|t| j|�|� q>| �d t| jj�� �d t� | �d t| jj�� �d t� | �d t| jj �� �d t� | �d t| jj �� �d j t� | �dt| jj �� �d t� | �dt| jj �� �d d t � d S )Nrj �uri�version� remote_iprO �hostr� �queryZ header_keyr � header_valueZ cookie_keyZ cookie_valueZarg_key� arg_value) �errors�str� check_type�getattrrR �listr% �keys�values�cookies�valuer� �bytes)r( �fields�field� expected_typer) r) r* �prepareU s( � � zTypeCheckHandler.preparec C s" | � d| jjt� | �| j� d S )NrG )r� rR rG r� r� r� r2 r) r) r* rV p s zTypeCheckHandler.postc C s | � | j� d S r$ )r� r� r2 r) r) r* rT t s zTypeCheckHandler.getc C s& t |�}||kr"d||f | j|< d S )Nzexpected %s, got %s)�typer� )r( �name�objr� Z actual_typer) r) r* r� w s zTypeCheckHandler.check_typeN)r5 r6 r7 r� rV rT r� r) r) r) r* r� T s r� c @ sD e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dS )�HTTPServerTestc C s t dtfdtfdtfg�S )N�/echo� /typecheck� //doubleslash)r r� r� r2 r) r) r* rD ~ s ��zHTTPServerTest.get_appc C s* | � d�}t|j�}| �|ddgi� d S )Nz/echo?foo=%C3%A9�foor� �rE r rG rd r� r) r) r* �test_query_string_encoding� s z)HTTPServerTest.test_query_string_encodingc C s, | � d�}t|j�}| �|dddgi� d S )Nz/echo?foo=&foo=r� � r� r� r) r) r* �test_empty_query_string� s z&HTTPServerTest.test_empty_query_stringc C s4 | j dddd�}t|j�}| �|dgdgd�� d S )Nr� rg z foo=&bar=ri r� )r� �barr� r� r) r) r* �test_empty_post_parameters� s z)HTTPServerTest.test_empty_post_parametersc C sX ddi}| j d|d�}t|j�}| �|i � | j ddd|d�}t|j�}| �|i � d S )N�Cookie�foo=barz/typecheck?foo=bar�r% r� rg �rj rG r% r� )r( r% rJ r� r) r) r* � test_types� s � zHTTPServerTest.test_typesc C s. | � d�}| �d|j� | �t|j�i � d S )Nr� �� )rE rd �coder rG re r) r) r* �test_double_slash� s z HTTPServerTest.test_double_slashc C s` t td��& | jddddidd�}W d � n1 s60 Y | �d|j� | �d |j� d S ) Nz"Invalid x-www-form-urlencoded bodyr� rg z Content-Typez!application/x-www-form-urlencoded� �)rj r% rG r� s {})r r rE rd r� rG re r) r) r* �test_malformed_body� s �$z"HTTPServerTest.test_malformed_bodyN) r5 r6 r7 rD r� r� r� r� r� r� r) r) r) r* r� } s r� c sl e Zd Zdd� Z� fdd�Z� fdd�Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z e dd� �Z � ZS )�HTTPServerRawTestc C s t dtfg�S )Nr� �r r� r2 r) r) r* rD � s zHTTPServerRawTest.get_appc s4 t t� ��� tt�� �� _� j�� fdd�� d S )Nc s � j �d� �� f�S r� )r= r� r� r) r2 r) r* r� � r: z)HTTPServerRawTest.setUp.<locals>.<lambda>)�superr� �setUpr r� r= r� r� r2 �rB r2 r* r� � s �zHTTPServerRawTest.setUpc s | j �� tt| ��� d S r$ )r= r� r� r� �tearDownr2 r� r) r* r� � s zHTTPServerRawTest.tearDownc C s. | j �� | j�tjdd�| j� | �� d S )N���MbP?��seconds)r= r� r� � add_timeout�datetime� timedelta�stop�waitr2 r) r) r* �test_empty_request� s z$HTTPServerRawTest.test_empty_requestc s~ t td��` � j�d� � j�� fdd��\}}}� �d|j� � �d|j� � �d|j � W d � n1 sp0 Y d S )N� .*Malformed HTTP request line� asdf c s t � j�S r$ �r> r= r) r2 r) r* r� � r: zFHTTPServerRawTest.test_malformed_first_line_response.<locals>.<lambda>�HTTP/1.1� z Bad Request) r r r= r� r� r� rd r� r� �reason�r( r& r% rJ r) r2 r* �"test_malformed_first_line_response� s � z4HTTPServerRawTest.test_malformed_first_line_responsec C sZ t td��< | j�d� | j�tjdd�| j� | � � W d � n1 sL0 Y d S )Nr r 皙�����?r� � r r r= r� r� r� r� r� r r r2 r) r) r* � test_malformed_first_line_log� s z/HTTPServerRawTest.test_malformed_first_line_logc C sZ t td��< | j�d� | j�tjdd�| j� | � � W d � n1 sL0 Y d S )Nz1.*Malformed HTTP message.*no colon in header lines GET / HTTP/1.0 asdf r r� r r2 r) r) r* �test_malformed_headers� s z(HTTPServerRawTest.test_malformed_headersc sH � j �d�dd�� � j�� fdd��\}}}� �t|�ddgi� d S )Nsp POST /echo HTTP/1.1 Transfer-Encoding: chunked Content-Type: application/x-www-form-urlencoded 4 foo= 3 bar 0 r� r� c s t � j�S r$ r r) r2 r) r* r� � r: z=HTTPServerRawTest.test_chunked_request_body.<locals>.<lambda>r� r� �r= r� rw r� r� rd r r r) r2 r* �test_chunked_request_body� s �� � z+HTTPServerRawTest.test_chunked_request_bodyc sH � j �d�dd�� � j�� fdd��\}}}� �t|�ddgi� d S )Nsp POST /echo HTTP/1.1 Transfer-Encoding: Chunked Content-Type: application/x-www-form-urlencoded 4 foo= 3 bar 0 r� r� c s t � j�S r$ r r) r2 r) r* r� r: zBHTTPServerRawTest.test_chunked_request_uppercase.<locals>.<lambda>r� r� r r r) r2 r* � test_chunked_request_uppercase� s �� � z0HTTPServerRawTest.test_chunked_request_uppercasec c sN t td��0 | j�d�dd�� | j�� V W d � n1 s@0 Y d S )Nz(.*Only integer Content-Length is alloweds. POST /echo HTTP/1.1 Content-Length: foo bar r� r� )r r r= r� rw �read_until_closer2 r) r) r* �test_invalid_content_length s �� z-HTTPServerRawTest.test_invalid_content_length)r5 r6 r7 rD r� r� r r r r r r r r � __classcell__r) r) r� r* r� � s r� c @ s< e Zd ZG dd� de�Zdd� Zdd� Zdd� Zd d � Zd S ) � XHeaderTestc @ s e Zd Zdd� ZdS )zXHeaderTest.Handlerc C s. | � d| jj� | �t| jj| jjd�� d S )N�request-version)r� �remote_protocol)Z set_headerrR r� r� r\ r� rO r2 r) r) r* rT ' s ��zXHeaderTest.Handler.getN�r5 r6 r7 rT r) r) r) r* rC & s rC c C s t ddgd�S )NTz5.5.5.5)�xheadersZtrusted_downstream�r\ r2 r) r) r* �get_httpserver_options0 s z"XHeaderTest.get_httpserver_optionsc C s | � | �d�d d� ddi}| � | jd|d�d d� ddi}| � | jd|d�d d� dd i}| � | jd|d�d d � dd i}| � | jd|d�d d � dd i}| � | jd|d�d d� dd i}| � | jd|d�d d� dd i}| � | jd|d�d d� d S )NrA r� r� z X-Real-IP�4.4.4.4r� �X-Forwarded-Forz127.0.0.1, 4.4.4.4z2620:0:1cfe:face:b00c::3z ::1, 2620:0:1cfe:face:b00c::3z4.4.4.4<script>z4.4.4.4, 5.5.5.5<script>zwww.google.com�rd rK )r( Z valid_ipv4�valid_ipv4_listZ valid_ipv6Zvalid_ipv6_listZ invalid_charsZinvalid_chars_listZ invalid_hostr) r) r* �test_ip_headers3 s> �������zXHeaderTest.test_ip_headersc C sN ddi}| j d|d�}|jd �d�r0| �d� t|j�}| �|d d � d S ) Nr z127.0.0.1, 4.4.4.4, 5.5.5.5rA r� r zHTTP/2�requires HTTP/1.xr� r )rE r% r� �skipTestr rG rd )r( r �resp�resultr) r) r* �test_trusted_downstream[ s z#XHeaderTest.test_trusted_downstreamc C s� | � | �d�d d� ddi}| � | jd|d�d d� ddi}| � | jd|d�d d� ddi}| � | jd|d�d d� dd i}| � | jd|d�d d� dd i}| � | jd|d�d d� d S ) NrA r rM �X-SchemerZ r� zX-Forwarded-Protoz https , httpz http,https�unknownr )r( Z https_schemeZhttps_forwardedZhttps_multi_forwardedZhttp_multi_forwardedZ bad_forwardedr) r) r* �test_scheme_headerse s. �����z XHeaderTest.test_scheme_headersN) r5 r6 r7 r rC r r r% r( r) r) r) r* r % s ( r c s, e Zd Zdd� Z� fdd�Zdd� Z� ZS )�SSLXHeaderTestc C s t dtjfg�S r@ )r r rC r2 r) r) r* rD � s zSSLXHeaderTest.get_appc s t t| ��� }d|d< |S )NTr )r� r) r )r( �outputr� r) r* r � s z%SSLXHeaderTest.get_httpserver_optionsc C s^ | � | �d�d d� ddi}| � | jd|d�d d� ddi}| � | jd|d�d d� d S )NrA r rZ r& rM r� r' r )r( Z http_schemeZ bad_schemer) r) r* � test_request_without_xprotocol� s ��z-SSLXHeaderTest.test_request_without_xprotocol)r5 r6 r7 rD r r+ r r) r) r� r* r) � s r) c @ s, e Zd ZG dd� de�Zdd� Zdd� ZdS )�ManualProtocolTestc @ s e Zd Zdd� ZdS )zManualProtocolTest.Handlerc C s | � t| jjd�� d S )Nr[ )r� r\ rR rO r2 r) r) r* rT � s z ManualProtocolTest.Handler.getNr r) r) r) r* rC � s rC c C s t dd�S )NrZ r[ r r2 r) r) r* r � s z)ManualProtocolTest.get_httpserver_optionsc C s | � | �d�d d� d S )NrA rO rZ r r2 r) r) r* �test_manual_protocol� s z'ManualProtocolTest.test_manual_protocolN)r5 r6 r7 r rC r r- r) r) r) r* r, � s r, �AF_UNIX�cygwinz+unix sockets not supported on this platformc sD e Zd ZdZ� fdd�Z� fdd�Zedd� �Zedd � �Z� Z S ) �UnixSocketTesta� HTTPServers can listen on Unix sockets too. Why would you want to do this? Nginx can proxy to backends listening on unix sockets, for one thing (and managing a namespace for unix sockets can be easier than managing a bunch of TCP port numbers). Unfortunately, there's no way to specify a unix socket in a url for an HTTP client, so we have to test this by hand. c s� t t� ��� t�� � _tj�� jd�� _ t � � j �}t dt fg�}t|�� _� j�|� tt�tj��� _� j�� fdd�� d S )Nz test.sockr� c s � j �� j�S r$ )r= r� �sockfiler) r2 r) r* r� � r: z&UnixSocketTest.setUp.<locals>.<lambda>)r� r0 r� �tempfile�mkdtemp�tmpdirr� r� r< r1 r Zbind_unix_socketr rL r �serverZ add_socketr r� r. r= r� r� )r( �sockZappr� r2 r* r� � s zUnixSocketTest.setUpc sB | j �� | j�| jj� | j�� t�| j � t t | �� � d S r$ ) r= r� r� r� r5 Zclose_all_connectionsr �shutil�rmtreer4 r� r0 r� r2 r� r) r* r� � s zUnixSocketTest.tearDownc c sj | j �d� | j �d�V }| �|d� | j �d�V }t�|�d��}| j �t|d ��V }| �|d� d S )Ns GET /hello HTTP/1.0 r� s HTTP/1.1 200 OK r� r� r� rb ) r= r� r� rd r r� r� r� r� )r( rJ r� r% rG r) r) r* �test_unix_socket� s z UnixSocketTest.test_unix_socketc c sR t td��( | j�d� | j�� V }W d � n1 s80 Y | �|d� d S )NzMalformed HTTP message froms garbage � HTTP/1.1 400 Bad Request )r r r= r� r rd re r) r) r* � test_unix_socket_bad_request� s *z+UnixSocketTest.test_unix_socket_bad_request) r5 r6 r7 �__doc__r� r� r r9 r; r r) r) r� r* r0 � s r0 c s� e Zd ZdZdd� Z� fdd�Z� fdd�Zejdd � �Z ejd d � �Z ejd d � �Z dd� Z e dd� �Ze dd� �Ze dd� �Ze dd� �Ze dd� �Ze dd� �Ze d d � �Ze d d � �Ze d d!� �Ze d"d#� �Z� ZS )$� KeepAliveTestz�Tests various scenarios for HTTP 1.1 keep-alive support. These tests don't use AsyncHTTPClient because we want to control connection reuse and closing. c C s\ G dd� dt �}G dd� dt �}G dd� dt �}t� | _td|fd|fd |t| jd �fg�S ) Nc @ s e Zd Zdd� Zdd� ZdS )z+KeepAliveTest.get_app.<locals>.HelloHandlerc S s | � d� d S �NrQ �r4 r2 r) r) r* rT � s z/KeepAliveTest.get_app.<locals>.HelloHandler.getc S s | � d� d S r> r? r2 r) r) r* rV � s z0KeepAliveTest.get_app.<locals>.HelloHandler.postNr� r) r) r) r* � HelloHandler� s r@ c @ s e Zd Zdd� ZdS )z+KeepAliveTest.get_app.<locals>.LargeHandlerc S s" | � d�dd� td�D ��� d S )Nr� c s s | ]}t |d �d V qdS )� � N)�chr)�.0�ir) r) r* � <genexpr>� r: zBKeepAliveTest.get_app.<locals>.LargeHandler.get.<locals>.<genexpr>i )r� r< �ranger2 r) r) r* rT � s z/KeepAliveTest.get_app.<locals>.LargeHandler.getNr r) r) r) r* � LargeHandler� s rH c @ s* e Zd Zdd� Zejdd� �Zdd� ZdS )z3KeepAliveTest.get_app.<locals>.FinishOnCloseHandlerc S s || _ d S r$ �� cleanup_event)r( rJ r) r) r* rP � s z>KeepAliveTest.get_app.<locals>.FinishOnCloseHandler.initializec s s | � � | j�� V d S r$ )�flushrJ r r2 r) r) r* rT � s z7KeepAliveTest.get_app.<locals>.FinishOnCloseHandler.getc S s | � d� d S )N�closedr? r2 r) r) r* �on_connection_close� s zGKeepAliveTest.get_app.<locals>.FinishOnCloseHandler.on_connection_closeN)r5 r6 r7 rP r � coroutinerT rM r) r) r) r* �FinishOnCloseHandler� s rO rA z/largez/finish_on_closerI )r r rJ r r\ )r( r@ rH rO r) r) r* rD � s ���zKeepAliveTest.get_appc s t t| ��� d| _d S )Ns HTTP/1.1)r� r= r� � http_versionr2 r� r) r* r� s zKeepAliveTest.setUpc sF | j �tjdd�| j� | �� t| d�r4| j�� t t | �� � d S )Nr� r� r= ) r� r� r� r� r r �hasattrr= r� r� r= r� r2 r� r) r* r� s zKeepAliveTest.tearDownc c s( t t�� �| _| j�d| �� f�V d S r� )r r� r= r� r� r2 r) r) r* r� s zKeepAliveTest.connectc c sL | j �d�V }| �|�d�|� | j �d�V }t�|�d��}t�|��d S )Nr� r� r� r� ) r= r� r� r� r r� r� r �Return)r( r� � header_bytesr% r) r) r* � read_headers! s zKeepAliveTest.read_headersc c s4 | � � V | _| j�t| jd ��V }| �d|� d S )Nr� rb )rT r% r= r� r� rd )r( rG r) r) r* r; ) s zKeepAliveTest.read_responsec C s | j �� | ` d S r$ )r= r� r2 r) r) r* r� / s zKeepAliveTest.closec c sB | � � V | j�d� | �� V | j�d� | �� V | �� d S )N� GET / HTTP/1.1 �r� r= r� r; r� r2 r) r) r* �test_two_requests3 s z KeepAliveTest.test_two_requestsc c sV | � � V | j�d� | �� V | j�� V }| �| � | �| jd d� | �� d S )Ns% GET / HTTP/1.1 Connection: close � Connectionr� ) r� r= r� r; r r� rd r% r� �r( r� r) r) r* �test_request_close< s z KeepAliveTest.test_request_closec c sZ d| _ | �� V | j�d� | �� V | j�� V }| �| � | �d| jv� | �� d S )N� HTTP/1.0s GET / HTTP/1.0 rX ) rP r� r= r� r; r r� r% r� rY r) r) r* � test_http10G s zKeepAliveTest.test_http10c c sl d| _ | �� V | j�d� | �� V | �| jd d� | j�d� | �� V | �| jd d� | �� d S )Nr[ �* GET / HTTP/1.0 Connection: keep-alive rX � Keep-Alive�rP r� r= r� r; rd r% r� r2 r) r) r* �test_http10_keepaliveR s z#KeepAliveTest.test_http10_keepalivec c sl d| _ | �� V | j�d� | �� V | �| jd d� | j�d� | �� V | �| jd d� | �� d S )Nr[ s, GET / HTTP/1.0 Connection: keep-alive rX r^ r] r_ r2 r) r) r* � test_http10_keepalive_extra_crlf^ s z.KeepAliveTest.test_http10_keepalive_extra_crlfc c s6 | � � V | j�d� | �� V | �� V | �� d S �Ns$ GET / HTTP/1.1 GET / HTTP/1.1 rV r2 r) r) r* �test_pipelined_requestsj s z%KeepAliveTest.test_pipelined_requestsc c s, | � � V | j�d� | �� V | �� d S rb rV r2 r) r) r* �test_pipelined_cancelr s z#KeepAliveTest.test_pipelined_cancelc c s: | � � V | j�d� | �� V | j�d�V | �� d S )Ns GET /large HTTP/1.1 rB )r� r= r� rT r� r� r2 r) r) r* �test_cancel_during_downloadz s z)KeepAliveTest.test_cancel_during_downloadc c s6 | � � V | j�d� | �� V | �� | j�� d S )Ns! GET /finish_on_close HTTP/1.1 )r� r= r� rT r� rJ �setr2 r) r) r* �test_finish_while_closed� s z&KeepAliveTest.test_finish_while_closedc c sl d| _ | �� V | j�d� | �� V | �| jd d� | j�d� | �� V | �| jd d� | �� d S )Nr[ sL POST / HTTP/1.0 Connection: keep-alive Transfer-Encoding: chunked 0 rX r^ r] r_ r2 r) r) r* �test_keepalive_chunked� s � z$KeepAliveTest.test_keepalive_chunked)r5 r6 r7 r< rD r� r� r rN r� rT r; r� r rW rZ r\ r` ra rc rd re rg rh r r) r) r� r* r= � s> * r= c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )� GzipBaseTestc C s t dtfg�S r@ r� r2 r) r) r* rD � s zGzipBaseTest.get_appc C sH t � }tjd|d�}|�t|�� |�� |�� }| jdd|ddid�S )N�w��mode�fileobjrA rg �Content-Encoding�gzipr� )r! ro �GzipFiler� r r� �getvaluerE )r( rG �bytesioZ gzip_fileZcompressed_bodyr) r) r* � post_gzip� s �zGzipBaseTest.post_gzipc C s, | j dddd�}| �t|j�ddgi� d S )NrA rg r� ri r� r� )rE � assertEqualsr rG re r) r) r* �test_uncompressed� s z GzipBaseTest.test_uncompressedN)r5 r6 r7 rD rs ru r) r) r) r* ri � s ri c @ s e Zd Zdd� Zdd� ZdS )�GzipTestc C s t dd�S )NT)�decompress_requestr r2 r) r) r* r � s z GzipTest.get_httpserver_optionsc C s& | � d�}| �t|j�ddgi� d S )Nr� r� r� )rs rt r rG re r) r) r* � test_gzip� s zGzipTest.test_gzipN)r5 r6 r7 r rx r) r) r) r* rv � s rv c @ s e Zd Zdd� ZdS )�GzipUnsupportedTestc C sJ t td�� | �d�}W d � n1 s*0 Y | �t|j�i � d S )Nz Unsupported Content-Encodingr� )r r rs rt r rG re r) r) r* �test_gzip_unsupported� s (z)GzipUnsupportedTest.test_gzip_unsupportedN)r5 r6 r7 rz r) r) r) r* ry � s ry c @ sl e Zd ZdZdZdd� Zdd� ZG dd� de�Zd d � Z d d � Z d d� Z dd� Z dd� Z dd� Zdd� ZdS )�StreamingChunkSizeTests2 01234567890123456789012345678901234567890123456789� c C s t � S r$ r r2 r) r) r* �get_http_client� s z&StreamingChunkSizeTest.get_http_clientc C s t | jdd�S )NT)� chunk_sizerw )r\ � CHUNK_SIZEr2 r) r) r* r � s z-StreamingChunkSizeTest.get_httpserver_optionsc @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S ) z&StreamingChunkSizeTest.MessageDelegatec C s || _ d S r$ )� connection)r( r� r) r) r* �__init__� s z/StreamingChunkSizeTest.MessageDelegate.__init__c C s g | _ d S r$ )� chunk_lengthsr' r) r) r* r+ � s z7StreamingChunkSizeTest.MessageDelegate.headers_receivedc C s | j �t|�� d S r$ )r� r, rU r- r) r) r* r0 � s z4StreamingChunkSizeTest.MessageDelegate.data_receivedc C sN t t| j��}| j�tddd�tdtt|��i�� | j� |� | j� � d S )Nr r� �OKr� ) r r r� r� � write_headersr r r� rU r� r4 )r( Z response_bodyr) r) r* r4 � s � z-StreamingChunkSizeTest.MessageDelegate.finishN)r5 r6 r7 r� r+ r0 r4 r) r) r) r* �MessageDelegate� s r� c C s G dd� dt �}|� S )Nc @ s e Zd Zdd� ZdS )z+StreamingChunkSizeTest.get_app.<locals>.Appc S s t �|�S r$ )r{ r� )r( Z server_connZ request_connr) r) r* � start_request� s z9StreamingChunkSizeTest.get_app.<locals>.App.start_requestN)r5 r6 r7 r� r) r) r) r* �App� s r� )r )r( r� r) r) r* rD � s z StreamingChunkSizeTest.get_appc K sx | j dddi|��}|�� t|j�}| �t| j�t|�� |D ]2}| �|| j dt |� � | � |ddt |� � q@|S )NrA rj rg zoversized chunk: r z empty chunk: )rA ) rE rF r rG rd rU �BODY�sumZassertLessEqualr r� � assertGreater)r( rI rJ r/ r~ r) r) r* �fetch_chunk_sizes� s �z(StreamingChunkSizeTest.fetch_chunk_sizesc C sJ t � }tjd|d�}|�|� |�� |�� }t|�t|�krFtd��|S )Nrj rk z#body did not shrink when compressed)r! ro rp r� r� rq rU rS )r( rG rr Zgzfile� compressedr) r) r* �compress� s z StreamingChunkSizeTest.compressc C s" | j | jd�}| �g d�|� d S )N)rG )r| r| r| � )r� r� rd )r( r/ r) r) r* �test_regular_body s z(StreamingChunkSizeTest.test_regular_bodyc C s | j | �| j�ddid� d S )Nrn ro )rG r% )r� r� r� r2 r) r) r* �test_compressed_body s �z+StreamingChunkSizeTest.test_compressed_bodyc s, � fdd�}� j |d�}� �g d�|� d S )Nc s( | � j d d� � | � j dd � � d S �N� )r� �r� r2 r) r* � body_producer s z?StreamingChunkSizeTest.test_chunked_body.<locals>.body_producer)r� )r| � r| � )r� rd )r( r� r/ r) r2 r* �test_chunked_body s z(StreamingChunkSizeTest.test_chunked_bodyc s> | � | j�� | �t� �d� � fdd�}| j|ddid� d S )Nr� c s$ | � d d� � | � dd � � d S r� r) r� �r� r) r* r� s zEStreamingChunkSizeTest.test_chunked_compressed.<locals>.body_producerrn ro )r� r% )r� r� r� rU r� )r( r� r) r� r* �test_chunked_compressed s �z.StreamingChunkSizeTest.test_chunked_compressedN)r5 r6 r7 r� r r} r r r� rD r� r� r� r� r� r� r) r) r) r* r{ � s r{ c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S ) �MaxHeaderSizeTestc C s t dtfg�S r@ �r rL r2 r) r) r* rD ( s zMaxHeaderSizeTest.get_appc C s t dd�S )NrB )Zmax_header_sizer r2 r) r) r* r + s z(MaxHeaderSizeTest.get_httpserver_optionsc C s, | j dddid�}|�� | �|jd� d S )NrA �X-FillerZdaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaar� rb )rE rF rd rG re r) r) r* �test_small_headers. s z$MaxHeaderSizeTest.test_small_headersc C s� t tddd��r z"| jdddidd� | �d � W n> typ } z&|jd ur\| �|jjd � W Y d }~n d }~0 0 W d � n1 s�0 Y d S ) NzUnsatisfiable readFrl rA r� A� aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaT)r% rs z did not raise expected exception)i� iW )r r rE Zfailr rJ ZassertInr� )r( �er) r) r* �test_large_headers3 s z$MaxHeaderSizeTest.test_large_headersN)r5 r6 r7 rD r r� r� r) r) r) r* r� ' s r� c s^ e Zd Zdd� Zdd� Z� fdd�Z� fdd�Zejd d � �Z e d d � �Z e d d� �Z � Z S )�IdleTimeoutTestc C s t dtfg�S r@ r� r2 r) r) r* rD B s zIdleTimeoutTest.get_appc C s t dd�S )Ng�������?)Zidle_connection_timeoutr r2 r) r) r* r E s z&IdleTimeoutTest.get_httpserver_optionsc s t t| ��� g | _d S r$ )r� r� r� �streamsr2 r� r) r* r� H s zIdleTimeoutTest.setUpc s& t t| ��� | jD ] }|�� qd S r$ )r� r� r� r� r� r� r� r) r* r� L s zIdleTimeoutTest.tearDownc c s: t t�� �}|�d| �� f�V | j�|� t�|��d S r� )r r� r� r� r� r, r rR r� r) r) r* r� Q s zIdleTimeoutTest.connectc c s* | � � V }t� }|�|j� |�� V d S r$ )r� r �set_close_callbackrf r )r( r= �eventr) r) r* �test_unused_connectionX s z&IdleTimeoutTest.test_unused_connectionc c sf | � � V }t� }|�|j� td�D ]2}|�d� |�d�V |�d�V }| �|d� q$|� � V d S )Nr� rU r� � rb ) r� r r� rf rG r� r� r� rd r )r( r= r� rE r� r) r) r* �test_idle_after_use_ s z#IdleTimeoutTest.test_idle_after_use)r5 r6 r7 rD r r� r� r rN r� r r� r� r r) r) r� r* r� @ s r� c @ s� e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Ze� e j d kd �d d� �Z dd� Z e� e j d kd �dd� �Zdd� Zdd� Zedd� �Zedd� �ZdS ) �BodyLimitsTestc C s8 G dd� dt �}tG dd� dt ��}td|fd|fg�S )Nc @ s e Zd Zdd� ZdS )z/BodyLimitsTest.get_app.<locals>.BufferedHandlerc S s | � tt| jj��� d S r$ )r� r� rU rR rG r2 r) r) r* �puts s z3BodyLimitsTest.get_app.<locals>.BufferedHandler.putN)r5 r6 r7 r� r) r) r) r* �BufferedHandlerr s r� c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S ) z0BodyLimitsTest.get_app.<locals>.StreamingHandlerc S s d| _ d S )Nr )� bytes_readr2 r) r) r* rP x s z;BodyLimitsTest.get_app.<locals>.StreamingHandler.initializec S sL d| j jv r$| j j�t| �d��� d| j jv rH| j j�t| �d��� d S )NZ expected_size� body_timeout)rR r� r� Zset_max_body_sizer� r� Zset_body_timeout�floatr2 r) r) r* r� { s � �z8BodyLimitsTest.get_app.<locals>.StreamingHandler.preparec S s | j t|�7 _ d S r$ )r� rU rY r) r) r* r0 � s z>BodyLimitsTest.get_app.<locals>.StreamingHandler.data_receivedc S s | � t| j�� d S r$ )r� r� r� r2 r) r) r* r� � s z4BodyLimitsTest.get_app.<locals>.StreamingHandler.putN)r5 r6 r7 rP r� r0 r� r) r) r) r* �StreamingHandlerv s r� � /buffered� /streaming)r r r )r( r� r� r) r) r* rD q s �zBodyLimitsTest.get_appc C s t ddd�S )Nrp i )r� Z max_body_sizer r2 r) r) r* r � s z%BodyLimitsTest.get_httpserver_optionsc C s t � S r$ r r2 r) r) r* r} � s z BodyLimitsTest.get_http_clientc C s@ | j dddd�}| �|jd� | j dddd�}| �|jd� d S )Nr� �PUTs aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaari s 4096r� rc re r) r) r* �test_small_body� s z BodyLimitsTest.test_small_bodyc C sP t td��$ | jdddd d�}W d � n1 s40 Y | �|jd� d S )N�.*Content-Length too longr� r� � a� ( ri r �r r rE rd r� re r) r) r* �test_large_body_buffered� s 2z'BodyLimitsTest.test_large_body_buffered�ntzflaky on windowsc C sP t td��$ | jdddd� d�}W d � n1 s40 Y | �|jd� d S )N�.*chunked body too larger� r� c S s | dd �S �Nr� r� r) r� r) r) r* r� � r: zABodyLimitsTest.test_large_body_buffered_chunked.<locals>.<lambda>�rj r� r r� re r) r) r* � test_large_body_buffered_chunked� s �$z/BodyLimitsTest.test_large_body_buffered_chunkedc C sP t td��$ | jdddd d�}W d � n1 s40 Y | �|jd� d S )Nr� r� r� r� r� ri r r� re r) r) r* �test_large_body_streaming� s 2z(BodyLimitsTest.test_large_body_streamingc C sP t td��$ | jdddd� d�}W d � n1 s40 Y | �|jd� d S )Nr� r� r� c S s | dd �S r� r) r� r) r) r* r� � r: zBBodyLimitsTest.test_large_body_streaming_chunked.<locals>.<lambda>r� r r� re r) r) r* �!test_large_body_streaming_chunked� s �$z0BodyLimitsTest.test_large_body_streaming_chunkedc C s& | j dddd d�}| �|jd� d S )N� /streaming?expected_size=10240r� r� r� ri � 10240rc re r) r) r* �"test_large_body_streaming_override� s �z1BodyLimitsTest.test_large_body_streaming_overridec C s& | j dddd� d�}| �|jd� d S )Nr� r� c S s | dd �S r� r) r� r) r) r* r� � r: zKBodyLimitsTest.test_large_body_streaming_chunked_override.<locals>.<lambda>r� r� rc re r) r) r* �*test_large_body_streaming_chunked_override� s �z9BodyLimitsTest.test_large_body_streaming_chunked_overridec c s� t t�� �}zj|�d| �� f�V |�d� ttd�� |�� V }W d � n1 sV0 Y | �|d� W |� � n |� � 0 d S )Nr� s@ PUT /streaming?body_timeout=0.1 HTTP/1.0 Content-Length: 42 zTimeout reading bodyr: ) r r� r� r� r� r r r rd r� )r( r= rJ r) r) r* � test_timeout� s � (zBodyLimitsTest.test_timeoutc c s� t t�� �}z�|�d| �� f�V |�d� |�dd � t|�V \}}}| �|d� |�d� ttd�� |� � V }W d � n1 s�0 Y | �|d� W |� � n |� � 0 d S ) Nr� sF PUT /streaming?expected_size=10240 HTTP/1.1 Content-Length: 10240 r� r� r� s2 PUT /streaming HTTP/1.1 Content-Length: 10240 r� r: ) r r� r� r� r� r> rd r r r r� )r( r= r& r% rJ r� r) r) r* � test_body_size_override_reset� s � � (z,BodyLimitsTest.test_body_size_override_resetN)r5 r6 r7 rD r r} r� r� �unittest�skipIfr� r� r� r� r� r� r� r r� r� r) r) r) r* r� p s r� c @ s e Zd Zdd� Zdd� ZdS )�LegacyInterfaceTestc s � fdd�}|S )Nc sp | j �d�� _� js:| j�tddd�t� � | j�� d S d}| j�t dt |� �� | j�|� | j�� d S )NzHTTP/1.r� r� r� rb z'HTTP/1.1 200 OK Content-Length: %d ) r� r� �http1r� r� r r r4 r� r rU )rR �messager2 r) r* �handle_request� s � � z3LegacyInterfaceTest.get_app.<locals>.handle_requestr) )r( r� r) r2 r* rD � s zLegacyInterfaceTest.get_appc C s, | � d�}| js| �d� | �|jd� d S )NrA r! rb )rE r� r" rd rG re r) r) r* �test_legacy_interface s z)LegacyInterfaceTest.test_legacy_interfaceN)r5 r6 r7 rD r� r) r) r) r* r� � s r� )`�tornador r Ztornado.escaper r r r r r Ztornado.http1connectionr Ztornado.httpclientr Ztornado.httpserverr Ztornado.httputilr r r r Ztornado.iostreamr Z tornado.locksr Z tornado.logr Ztornado.netutilr Ztornado.simple_httpclientr Ztornado.testingr r r r r Ztornado.test.utilr Z tornado.webr r r � contextlibr r� ro r� r7 r� r{ �sysr2 r� �ior! �typing� TYPE_CHECKINGr" r# r> r? rL r� r� Z skipIfOldSSLrY �objectr] rz r~ r r� ZTestCaser� r� r� r� r� r� r� r r) r, rQ �platformr0 r= ri rv ry r{ r� r� r� r� r) r) r) r* �<module> s� �0) ]);m_ �1 D _/
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка