Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/cheroot/test/__pycache__/test_conn.cpython-39.pyc
Ðазад
a p�h�� � @ s� d Z ddlZddlmZ ddlZddlZddlZddlZddl Z ddl m Z ddl ZddlZddlZddlmZmZ ddlmZmZ ddlmZmZmZm Z ddl Z ej dd� d kZ ep�e Z!d Z"d Z#G d d � d ej$�Z$G dd� d�Z%ej&dd� �Z'ej&dd� �Z(ej&dd� �Z)dd� Z*dd� Z+dd� Z,ej-�.d d �d d � �Z/ej-�.d d �d d!� �Z0ej-�.d"d#ej1d$ej-j2e�ored%d&d'�d(�f�d)d*� �Z3d+d,� Z4ej-�.d-ej1ej5ej6d&d.d/�ej1ej5ej7d&d0d/�ej1ej5ej8d&d1d/�ej1dej8d&d2ej-j2e d3d4�d5�ej1ej5ej9d&d6d/�ej1e:d7d8d9d/�ej1ej5d:d8d;d/�fej1e;ej6d&d<d/�ej1e<ej7d&d=d/�ej1e<ej9d&d>d/�f �d?d@� �Z=dAdB� Z>dCdD� Z?ej-j2e�o�e�o�e �o�e! dEd&d'�dFdG� �Z@ej-j2e�o�e�o�e �o�e! dEd&d'�dHdI� �ZAej-�.dJdK�dLdM� �ZBdNdO� ZCdPdQ� ZDdRdS� ZEej-�.dTdU�dVdW� �ZFdXdY� ZGej-j2eedZ��d4�d[d\� �ZHd]d^� ZId_d`� ZJej-�.dadb�dcdd� �ZKej-j2ded4�dfdg� �ZLej-�.dhdi�djdk� �ZMG dldm� dm�ZNG dndo� do�ZOdpdq� ZPdS )rzETests for TCP connection handling, including proper and timely close.� N)�match)� namedtuple)�trim�unwrap)�helper�webtest)�IS_CI�IS_MACOS�IS_PYPY� IS_WINDOWS� )� � � z(pPeErRsSiIsStTeEnNcCeE oOfF vViIsSiIoOnNc @ s� e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dd� Z dd� Z dd� Zeeeeeeeee e e e e d� ZdS )� Controllerz!Controller for serving WSGI apps.c C s dS )zRender Hello world.z Hello, world!� ��req�respr r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/cheroot/test/test_conn.py�hello! s zController.helloc C s t S )zRender ``pov`` value.)�povr r r r r % s zController.povc C s* d| j d v r td�|jd< dd� }|� S )zRender streaming response.�set_clZ QUERY_STRING� �Content-Lengthc s s t d�D ]} t| �V qd S )Nr )�range�str)�xr r r �content. s z"Controller.stream.<locals>.content)�environr �headers)r r r r r r �stream) s zController.streamc C s@ | j d dks td| j d ��| j d �� �d�}d|�d�S )z%Process file upload and render thank.�REQUEST_METHOD�POSTz'POST' != request.method %rz wsgi.input�utf-8� thanks for '�')r �AssertionError�read�decode)r r Zinput_contentsr r r �upload4 s ��zController.uploadc C s d|_ dS )z Render response with status 204.Z204z Code = 204��statusr r r r � custom_204> s zController.custom_204c C s d|_ dS )z Render response with status 304.Z304z Code = 304r+ r r r r � custom_304C s zController.custom_304c C s d|_ dS )z Render response with status 500.z500 Internal Server Error�okr+ r r r r �err_before_readH s zController.err_before_readc C s dgd S )zRender 1MB response.A aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa� r r r r r �one_megabyte_of_aM s z Controller.one_megabyte_of_ac C s d|j d< dS )z3Render buffered response with invalid length value.�5r zI have too many bytes�r r r r r �wrong_cl_bufferedQ s z Controller.wrong_cl_bufferedc C s d|j d< ddgS )z5Render unbuffered response with invalid length value.r3 r zI tooz have too many bytesr4 r r r r �wrong_cl_unbufferedV s z Controller.wrong_cl_unbufferedc C s | � d��d�S )z�Encode PATH_INFO correctly depending on Python version. WSGI 1.0 is a mess around unicode. Create endpoints that match the PATH_INFO that it produces. r$ zlatin-1)�encoder) )�stringr r r �_munge[ s zController._munge) �/hello�/pov�/page1�/page2�/page3�/stream�/upload� /custom/204� /custom/304�/err_before_readz/one_megabyte_of_a�/wrong_cl_buffered�/wrong_cl_unbufferedN)�__name__� __module__� __qualname__�__doc__r r r! r* r- r. r0 r2 r5 r6 r9 �handlersr r r r r s4 �r c @ s8 e Zd ZdZedg d��Zdd� Zdejdfdd �Z d S ) �ErrorLogMonitorzCMock class to access the server error_log calls made by the server.� ErrorLogCall)�msg�level� tracebackc C s g | _ g | _dS )z�Initialize the server error log monitor/interceptor. If you need to ignore a particular error message use the property ``ignored_msgs`` by appending to the list the expected error messages. N)�calls� ignored_msgs��selfr r r �__init__y s zErrorLogMonitor.__init__� Fc C s, |rt �� }nd}| j�t�|||�� dS )z2Intercept the call to the server error_log method.rU N)� traceback_� format_excrP �appendrK rL )rS rM rN rO Ztblinesr r r �__call__� s zErrorLogMonitor.__call__N) rF rG rH rI r rL rT �logging�INFOrY r r r r rK t s rK c sD t � }� fdd�}||jd< | j� |� _d� _t� _| � _d� _� S )z:Attach a WSGI app to the given server and preconfigure it.c s t � j�S �N)r �timeoutr �Z wsgi_serverr r �_timeout� s z$raw_testing_server.<locals>._timeoutz/timeout�� r )r rJ �server_instance�wsgi_app�max_request_body_sizer] � server_clientZkeep_alive_conn_limit)Zwsgi_server_clientZappr_ r r^ r �raw_testing_server� s re c c s^ |� | dt� � | V | jjD ]:\}}}|tjkr4q || jjv s J djf i t� ��f��q dS )z�Modify the "raw" base server to monitor the error_log messages. If you need to ignore a particular error message use the property ``testing_server.error_log.ignored_msgs`` by appending to the list the expected error messages. � error_logzTFound error in the error log: message = '{c_msg}', level = '{c_level}' {c_traceback}N) �setattrrK rf rP rZ �WARNINGrQ �format�locals)re � monkeypatchZc_msgZc_levelZ c_tracebackr r r �testing_server� s ��rl c C s | j S )z5Get and return a test client out of the given server.)rd )rl r r r � test_client� s rm c C s | � � dd� |D �v S )z Check that a header is present.c s s | ]\}}|� � V qd S r\ ��lower)�.0�k�_r r r � <genexpr>� � z header_exists.<locals>.<genexpr>rn )� header_namer r r r � header_exists� s rv c s | � � � fdd�|D �v S )z2Check that a header with a given value is present.c 3 s" | ]\}}|� kr|� � V qd S r\ rn )rp rq �v�� header_valuer r rs � s �z#header_has_value.<locals>.<genexpr>rn )ru ry r r rx r �header_has_value� s �rz c C s� | � � }d|_|�� | jd|d�\}}}t|dd� �}|dksFJ �|dd� dksZJ �|t�� ksjJ �td |�rxJ �| jd |d�\}}}t|dd� �}|dks�J �|dd� dks�J �|t�� ks�J �td |�r�J �| jd |d gd �\}}}t|dd� �}|dk�sJ �|dd� dk�s&J �|t�� k�s8J �td d|��sJJ �t � t j j �� | jd|d� W d � n1 �s~0 Y dS )z%Test persistent HTTP/1.1 connections.Fr; �� http_connNr �� � �OK� Connectionr< r= )r� �close)r| r r� )�get_connection� auto_open�connect�get�intr r7 rv rz �pytest�raises�http�client� NotConnected�rm �http_connection� status_line�actual_headers�actual_resp_body� actual_statusr r r �"test_HTTP11_persistent_connections� s< � � � r� r )FTc C sB | � � }d|_|�� | jd|d�\}}}t|dd� �}|dksFJ �|dd� dksZJ �|t�� ksjJ �td |�rxJ �|r�| jd |d�\}}}td |�s�J �td d |�r�J �td |�r�J �|dks�J �|dd� dks�J �|dks�J ��nJ| jd|d�\}}}td |��rJ �|dk�s J �|dd� dk�s4J �|dk�sBJ �d}|D ]*\}} |� � dk�rJt | �dk�rJd}�qJ|�r�td d |��r�J �nPtd d |��s�J �t � t jj�� | jd|d� W d � n1 �s�0 Y | jd|d�\}}}|dk�sJ �|dd� dk�sJ �|dk�s&J �td |��r6J �|�� dS )z;Test serving of streaming responses with HTTP/1.1 protocol.Fr; r{ Nr r} r~ r r� �/stream?set_cl=Yesr r� �Transfer-Encoding� 0123456789r? ztransfer-encoding�chunkedTrt )r� r� r� r� r� r r7 rv rz ro r r� r� r� r� r� �headr� ) rm r r� r� r� r� r� Zchunked_responserq rw r r r �test_streaming_11� s\ � � � .� r� c C s | j j}d| j _| �� }d|_|�� | jd|dgdd�\}}}t|dd� �}|dks\J �|d d� d kspJ �|t�� ks�J �t d d |�s�J �|�r | jd |dgdd�\}}}t|dd� �}|dks�J �|d d� d ks�J �|dks�J �t d|�s�J �t d d |��s J �t d|��r�J �n�| jd|dgdd�\}}}t|dd� �}|dk�sVJ �|d d� d k�slJ �|dk�szJ �t d|��r�J �t d d |��r�J �t d|��r�J �t � t jj�� | jd|dd� W d � n1 �s�0 Y || j _|�� dS )z;Test serving of streaming responses with HTTP/1.0 protocol.�HTTP/1.0Fr; �r� � Keep-Alive)r| r �protocolNr r} r~ r r� r� r� r� r r� r? �r| r� )ra r� r� r� r� r� r� r r7 rz rv r� r� r� r� r� r� )rm r �original_server_protocolr� r� r� r� r� r r r �test_streaming_10I s^ � � � �&r� �http_server_protocolr� zHTTP/1.1z)Fails under PyPy in CI for unknown reasonF)�reason�strict)�marksc C s� | j j}|| j _d}| �� }d|_|�� | jd|d�\}}}t|dd� �}|dksZJ �|dd� d ksnJ �|t�� ks~J �t d |�r�J �| jd d g||d �\}}}t|dd� �}|dks�J �|dd� d ks�J �|t�� ks�J �t d d|�s�J �t ddj f i t � ��|��sJ �| jd ||d�\}}}t|dd� �}|dk�sJJ �|dd� d k�s`J �|t�� k�srJ �t d |��r�J �t d|��r�J �|| j _|� � dS )z$Test Keep-Alive enabled connections.r� Fr= )r� Nr r} r~ r r� r> r� �r r| r� r� �-timeout={test_client.server_instance.timeout}r� )ra r� r� r� r� r� r� r r7 rv rz ri rj r� ) rm r� r� Zhttp_client_protocolr� r� r� r� r� r r r �test_keepalive� sR � � � � r� c sr d� j _� fdd�}d� fdd� }d� fdd � }tjjtjjtjjf}|� }||� |d � |� }||� |d� ||� |d� |� }||d d � |d� t�|�� ||� W d � n1 s�0 Y |d� t � d� ||� |d� t � d� |d � t�|�� ||� W d � n1 �s,0 Y |d � ||� |d � t� j _|� � |� � |� � d S )z*Test management of Keep-Alive connections.r c s � � � } d| _| �� | S )NF)r� r� r� )r� �rm r r � connection� s z2test_keepalive_conn_management.<locals>.connectionTc s� � j ddg| dd�\}}}t|d d� �}|dks6J �|dd � dksJJ �|t�� ksZJ �|r�td d |�snJ �td d jf i t� ��|�s�J �n td |�r�J �td |�r�J �d S ) Nr> r� r� r� r r} r~ r r� r� r� )r� r� r r7 rz ri rj rv )�conn� keepaliver� r� r� r� r� r r �request� s& � �� z/test_keepalive_conn_management.<locals>.request� �?c sL t � � | }� jjj}|| kr"d S t � � |ks J djf i t� ��f��q d S )Nz1idle conn count mismatch, wanted {count}, got {n})�timera � _connectionsZ_num_connectionsri rj )�countr] �deadline�nr� r r � check_server_idle_conn_count� s ��zDtest_keepalive_conn_management.<locals>.check_server_idle_conn_countr F)r� Ng333333�?)T)r� ) ra r] r� r� � BadStatusLine�CannotSendRequestr� r� r� r� �sleepr� )rm r� r� r� Zdisconnect_errors�c1�c2�c3r r� r � test_keepalive_conn_management� sH � & (r� )�simulated_exception� error_number�exception_leakszsocket.error(ECONNRESET))�idzsocket.error(EPIPE)z simulated socket.error(ENOTCONN)zreal socket.error(ENOTCONN)z$Now reproducible this way on Windows)r� )r� r� zsocket.error(ESHUTDOWN)� TzRuntimeError(666)���zsocket.error(-1)z ConnectionResetError(ECONNRESET)zBrokenPipeError(EPIPE)zBrokenPipeError(ESHUTDOWN)c s �du r dn�| d��|j jj�� �����fdd�� ��|j jd� � |�� }d|_|�� |�d� |�d|j � d �� |� � t d t r�d nd �D ] }t �d � t� d�r� q�q��dur҈ jj�u s�J �n&t� jjtj�s�J �� jjj| ks�J �� j|u �sJ �dS )a Test there's no traceback on broken connection during close. It artificially causes :py:data:`~errno.ECONNRESET` / :py:data:`~errno.EPIPE` / :py:data:`~errno.ESHUTDOWN` / :py:data:`~errno.ENOTCONN` as well as unrelated :py:exc:`RuntimeError` and :py:exc:`socket.error(-1) <socket.error>` on the server socket when :py:meth:`socket.shutdown() <socket.socket.shutdown>` is called. It's triggered by closing the client socket before the server had a chance to respond. The expectation is that only :py:exc:`RuntimeError` and a :py:exc:`socket.error` with an unusual error code would leak. With the :py:data:`None`-parameter, a real non-simulated :py:exc:`OSError(107, 'Transport endpoint is not connected') <OSError>` happens. NzSimulated socket errorc s| �� | d�jj| jd�� �d ur<�� | jd�jj�d�� ��| jd�� _z �| � W n �yp d� _Y n0 d� _d S )N�socket)�wraps�shutdown)Z side_effectTF)rg Z mock_moduleZMockr� �spy�fin_spy�exception_leakedrR ��_close_kernel_socketZ exc_instance�mockerrk Zold_close_kernel_socketr� r r r� � s � � zCtest_broken_connection_during_tcp_fin.<locals>._close_kernel_socketr� F� GET /hello HTTP/1.1�Host: %s�asciir r r g�������?r� )ra �ConnectionClassr� rg r� r� r� �send�hostr7 r� r � IS_SLOW_ENVr� r� �hasattrr� Z spy_exception� isinstancer� �error�errnor� )r� r� r� rk r� rm r� rr r r� r �%test_broken_connection_during_tcp_finE s8 D ��� �r� c s� dd� � � �fdd�}�� |jjjd|� |�� �d� |�� |jjdd� }|jj� � t j dft j d ft j d ff}t|�t|�ks�J �t||�D ]>\\}}\} } } || ks�J �t|| �dus�J | �d |����q�dS ) z:Test that unhandled internal error cascades into shutdown.c _ s t d��d S �Nr� )�ConnectionResetError)�_args�_kwargsr r r �_raise_connection_reset� s zZtest_broken_connection_during_http_communication_fallback.<locals>._raise_connection_resetc s. �� | jjd� � �� | jjd� � � � d S )Nr� �write)rg r� �rfile�wfilerR �r� rk r r �_read_request_line� s zUtest_broken_connection_during_http_communication_fallback.<locals>._read_request_line�read_request_line� GET / HTTP/1.1Nz^socket\.error 666$zK^Got a connection error while handling a connection from .*:\d{1,5} \(666\)a& A fatal exception happened\. Setting the server interrupt flag to ConnectionResetError\(666,?\) and giving up\.\n\nPlease, report this on the Cheroot tracker at <https://github\.com/cherrypy/cheroot/issues/new/choose>, providing a full reproducer with as much context and details as possible\.$� does not match )rg ra r� �RequestHandlerClassr� r� �joinrf rP �clearrZ rh r[ �CRITICAL�len�zip�_matches_pattern) rk rm rl �wsgi_server_threadr� �actual_log_entries�expected_log_entries�expected_log_level�expected_msg_regex� actual_msg�actual_log_level�_tbr r� r �9test_broken_connection_during_http_communication_fallback� s8 � ���� �r� c C s� dd� }||j jd< | �� }|jdddd� |�d|j� |�� |�� |jj dd� }|jj � � t j d ft j d ft j d ff}t|�t|�ks�J �t||�D ]>\\}}\} } } || ks�J �t|| �dus�J | �d |����q�dS ) zATest that a keyboard interrupt from HTTP handler causes shutdown.c S s t d��d S )Nz)simulated test handler keyboard interrupt)�KeyboardInterrupt�Z_reqZ_respr r r �_trigger_kb_intr s z7test_kb_int_from_http_handler.<locals>._trigger_kb_intrz/kb_intr�GETT�� skip_host�HostNzy^Got a server shutdown request while handling a connection from .*:\d{1,5} \(simulated test handler keyboard interrupt\)$zi^Setting the server interrupt flag to KeyboardInterrupt\('simulated test handler keyboard interrupt',?\)$z#^Keyboard Interrupt: shutting down$r� )rb rJ r� � putrequest� putheaderr� � endheadersr� rf rP r� rZ �DEBUGr[ r� r� r� ) rm rl r� r� r| r� r� r� r� r� r� r� r r r � test_kb_int_from_http_handler� s8 ����� �r� z@Fails under PyPy 3.6 under Ubuntu 20.04 in CI for unknown reasonc s\ G dd� dt �� � fdd�}||jjd< | �|jjd�}|�� }|jdddd � |�d |j � |� � |j snqft |j j�d ks�J �|j jd k r�q�t |j j�d ks�J �td �|_|j jr�J �|�� |jjd d � }|jj�� tjdftjdff} t |�t | �k�sJ �t| |�D ]D\\} } \} } }| | k�s2J �t| | �d u�sJ | �d| �����qd S )z=Ensure worker threads are resilient to in-handler exceptions.c @ s e Zd ZdZdS )zAtest_unhandled_exception_in_request_handler.<locals>.SillyMistakez)A simulated crash within an HTTP handler.N�rF rG rH rI r r r r � SillyMistake: s r� c s � d��d S )Nu2 simulated unhandled exception 💣 in test handlerr r� �r� r r �_trigger_scary_exc= s zGtest_unhandled_exception_in_request_handler.<locals>._trigger_scary_excz /scary_excr� r� Tr� r� r �test requesting shutdownNu� ^Unhandled error while processing an incoming connection SillyMistake\('simulated unhandled exception 💣 in test handler',?\)$�"^SystemExit raised: shutting down$r� )� BaseExceptionrb rJ r� ra r� r� r� r� r� r� �calledr� �requests�_threads�idle� SystemExit� interruptr� rf rP r� rZ �ERRORr[ r� r� )r� rk rm rl r� r �server_connection_close_spyr| r� r� r� r� r� r� r� r r r �+test_unhandled_exception_in_request_handler+ sL � ��� � �r c sl G dd� dt �� |jjjj�� �fdd�}|�|jjjd|� | �|jjd�}t|jj �dksbJ �|� � � d� |j sxqp|jj dk r�qxt|jj �dks�J �td d � |jj D ��s�J �td �|_|jj r�J �|�� |jjd d � }|jj�� tjd ftjdff}t|�t|�k�sJ �t||�D ]D\\} } \} } } | | k�sBJ �t| | �d u�s"J | �d| �����q"d S )z<Ensure worker threads are resilient to unhandled exceptions.c @ s e Zd ZdZdS )z?test_remains_alive_post_unhandled_exception.<locals>.ScaryCrashz&A simulated crash during HTTP parsing.Nr� r r r r � ScaryCrash� s r c s �| � � d��d S r� r rR �r Z_orig_read_request_liner r r� � s zGtest_remains_alive_post_unhandled_exception.<locals>._read_request_liner� r� r r� c s s | ]}|� � V qd S r\ )�is_alive)rp Z worker_threadr r r rs � s �z>test_remains_alive_post_unhandled_exception.<locals>.<genexpr>r NzM^Unhandled error while processing an incoming connection ScaryCrash\(666,?\)$r r� )r ra r� r� r� rg r� r� r r r� r� r r �allr r r� rf rP r� rZ r r[ r� r� )r� rk rm rl r� r� r r� r� r� r� r� r� r� r r r �+test_remains_alive_post_unhandled_exceptionv sX ��� � ��� � �r �timeout_before_headers)TFc C sz | � � }d|_|�� |s:|�d� |�d|j �d�� t�td � |j |j dd�}|� � |j dksnJ �|� � d S ) zbCheck timeout without sending any data. The server will close the connection with a 408. Fr� r� r� r r� ��method� N)r� r� r� r� r� r7 r� r� r] �response_class�sock�beginr, r� )rm r r� �responser r r �test_HTTP11_Timeout� s r c C sL d}| � � }|jddt dd� |�d|j� |�� |j|jdd�}|�� |j dks\J �|� � }t t�� � }||ks|J �|� d � |� d |j � d �� |�� |j|jdd�}|�� |j dks�J �|� � }d }||ks�J �t�td � |� d � |� d |j � d �� |�� |j|jdd�}z |�� W nP tjtjjf�yR Y nR t�y� } zt�|| � W Y d}~n(d}~0 0 |j dk�r�t�||� � � |�� | � � }|jdddd� |�d|j� |�� |j|jdd�}|�� |j dk�sJ �|� � }t� � }||k�s J �|�d � t�td � |j|jdd�}z |�� W nP tjtjjf�yr Y nR t�y� } zt�|| � W Y d}~n(d}~0 0 |j dk�r�t�||� � � |�� | � � }|jdddd� |�d|j� |�� |j|jdd�}|�� |j dk�s"J �|� � }t� � }||k�s@J �|�� dS )zuCheck timeout after at least one request has succeeded. The server should close the connection without 408. z=Writing to timed out socket didn't fail as it should have: %sr� z /timeout?t=%sTr� r� r r} r� r� r� � Hello, world!r Nr r; ) r� r� r] r� r� r� r r r r, r( r r7 �_output� _send_outputr� r� r� r� r� r� r� � Exceptionr� �failr� r r� )rm Zfail_msgr� r Z actual_bodyZ expected_body�exr r r �!test_HTTP11_Timeout_after_request� s� $ $ r" c C s | � � }|jdddd� |�d|j� |�� td�D ]�}|�d| �d�� |�d |j �d �� |�� |j |j dd �}|j � d d �|_ |� � |�d�}|jdks�J �|dks6J �q6|j |j dd �}|� � |�� }|jdks�J �|dks�J �|�� dS )zXTest HTTP/1.1 pipelining. :py:mod:`http.client` doesn't support this directly. r� r: Tr� r� � zGET /hello?%s HTTP/1.1z iso-8859-1r� r� r �rbr � r} r N)r� r� r� r� r� r r r7 r r r �makefile�fpr r( r, r� )rm r� Ztrialr �bodyr r r �test_HTTP11_pipeliningM s, � r) c C s� | � � }|jdddd� |�d|j� |�dd� |�dd � |�� |�d � |j|jdd �}|�� \}}}|d kszJ �|� � |� � |jdddd� |�d|j� |�dd� |�dd � |�dd� |�� |j|jdd �}|�� \}}}|d ks�J �|j � � � � }|�r(t�d| � q��q(q�d} |�| � |�� t�|�\} } } t| dd� �} | dk�slJ �d| �� �d��� }| |k�s�J �|� � dS )z$Test 100-continue header processing.r# r@ Tr� r� � Content-Type� text/plainr �4s d'ohr �d Z17�Expect� 100-continuez2100 Continue should not output any headers. Got %r� I am a small fileNr r} r% r& )r� r� r� r� r� r� r r � _read_statusr� r� r' �readline�stripr� r r r �shbr� r) r7 )rm r� r �_versionr, �_reason�versionr� �liner( r� �_actual_headersr� r� �expected_resp_bodyr r r �test_100_Continuew sL �� r; rc )r r` c C s� | j j}|| j _| �� }|jdddd� |�d|j� |�dd� |�dd � |�d d � |�� |j|jdd �}|� � \}}}|d ks�J �d}|r�|j � � � � }q�|� d� |�� t�|�\} } } t| dd� �} | dks�J �|�d� |�d|j �d�� |�d� |�d� |�d� |�� |j|jdd �}|� � \} }}|d k�sTJ �d}|�rp|j � � � � }�qXd}|� |� |�� t�|�\} }} t| dd� �} | dk�s�J �d|�� �d��� }| |k�s�J �|�� || j _dS ) z9Test a max_request_body_size of 0 (the default) and 1001.r# rC Tr� r� r* r+ r Z1000r. r/ r r- s� xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxNr �� s POST /upload HTTP/1.1r� r� s Content-Type: text/plains Content-Length: 17s Expect: 100-continuer0 r} r% r& )ra rc r� r� r� r� r� r r r1 r' r2 r3 r� r r r4 r� r r7 r r) r� )rm rc Zold_maxr� r r5 r, r6 �skipr� r9 r� r� r7 r� r( r� r: r r r �test_readall_or_close� sT r> c C s< | � � }d|_|�� | jd|d�\}}}t|dd� �}|dksFJ �|dd� dksZJ �|t�� ksjJ �td |�rxJ �| jd |d�\}}}t|dd� �}|d ks�J �td |�r�J �|d ks�J �td |�r�J �| jd|d�\}}}t|dd� �}|dk�sJ �td |��rJ �|d k�s J �td |��r0J �|�� dS )z.Test HTTP queries with an empty response body.Fr; r{ Nr r} r~ r r� rA �� r rt rB i0 ) r� r� r� r� r� r r7 rv r� r� r r r �test_No_Message_Body� s8 � � � r@ z� Headers from earlier request leak into the request line for a subsequent request, resulting in 400 instead of 413. See cherrypy/cheroot#69 for details. c C sT | � � }d}|jdddd� |�d|j� |�dd� |�d d � |�d d � |�� |�|� |�� }t�|�\}}}t |d d� �}|dks�J �|dd � dks�J �dd � � }||ks�J �d� d�}|jdddd� |�d|j� |�dd� |�d d� |�� |�|� |�� }t�|�\}} }t |d d� �}|dk�sHJ �|� � d S )z1Test HTTP uploads with chunked transfer-encoding.sF 8;key=value xx xxxx 5 yyyyy 0 Content-Type: application/json r# r@ Tr� r� r� r� ZTrailerr* r �3Nr r} r~ r zthanks for '%s's xx xxxxyyyyys )s 3e3s� xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx� 0rt rt r+ � ) r� r� r� r� r� r� � getresponser r4 r� r7 r� r� ) rm r� r( r r� r9 r� r� r: r� r r r �test_Chunked_Encoding s: � rE c C s� | � � }|jdddd� |�d|j� |�dd� |�dd � |�� |�� }t�|�\}}}t|d d � �}|d kszJ �d }||ks�J �|� � d S )z�Try a non-chunked request where Content-Length exceeds limit. (server.max_request_body_size). Assert error before body send. r# r@ Tr� r� r* r+ r Z9999Nr rC sC The entity sent with the request exceeds the maximum allowed bytes.) r� r� r� r� r� rD r r4 r� r� )rm r� r r� r9 r� r� r: r r r �test_Content_Length_inW s � rF c C sD | j dddgd�\}}}t|dd� �}|dks4J �|dks@J �dS ) z6Test that malicious Content-Length header returns 400.r@ )r* r+ )r znot-an-integerr4 Nr i� s Malformed Content-Length Header.)�postr� )rm r� r9 r� r� r r r �test_Content_Length_not_intq s �� rH )�uri�expected_resp_statusr: ))rD r< sL The requested resource returned more bytes than the declared Content-Length.)rE r} s I tooc C s� | � � }|jd|dd� |�d|j� |�� |�� }t�|�\}}}t|dd� �} | |ksbJ �||ksnJ �|� � | j j j � d� dS )z_Test response with Content-Length less than the response body. (non-chunked response) r� Tr� r� Nr )z@ValueError('Response body exceeds the declared Content-Length.')zAValueError('Response body exceeds the declared Content-Length.',))r� r� r� r� r� rD r r4 r� r� ra rf rQ �extend) rm rI rJ r: r� r r� r9 r� r� r r r �test_Content_Length_out� s rL zbSometimes this test fails due to low timeout. Ref: https://github.com/cherrypy/cherrypy/issues/598c C s� | � � }tj�dd|j|jf �}|�d�}t�t d � d}|rh|�|�}|sRqh||7 }|t |�8 }q>t |�dksxJ �|dd ks�J �|d ks�J �|� � d S ) z5Test serving large file with a read timeout in place.z %s://%s:%s/one_megabyte_of_ar� i g333333�?i � i s aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaar1 r N) r� �urllibr� �urlopenr� �portr( r� r� r] r� r� )rm r� Zremote_data_conn�buf� remaining�datar r r �test_598� s& �� rS �invalid_terminator)s s c C sR | � � }|�d| � |j|jdd�}|�� |�� }d}||ksFJ �|�� dS )z1Test HTTP queries with no valid CRLF terminators.s GET /hello HTTP/1.1%sr� r s HTTP requires CRLF terminatorsN)r� r� r r r r( r� )rm rT r� r r� r: r r r � test_No_CRLF� s rU c @ s e Zd ZdZdd� Zdd� ZdS )� FaultySelectz:Mock class to insert errors in the selector.select method.c C s || _ d| _d| _dS )z:Initilize helper class to wrap the selector.select method.FN)�original_select�request_served�os_error_triggered)rS rW r r r rT � s zFaultySelect.__init__c C s | j rd| _td��| �|�S )z'Intercept the calls to selector.select.Tz(Error while selecting the client socket.)rX rY �OSErrorrW )rS r] r r r rY � s zFaultySelect.__call__N�rF rG rH rI rT rY r r r r rV � s rV c @ s e Zd ZdZdd� Zdd� ZdS )� FaultyGetMapz;Mock class to insert errors in the selector.get_map method.c C s || _ d| _d| _dS )z;Initilize helper class to wrap the selector.get_map method.FN)�original_get_map� sabotage_conn� conn_closed)rS r] r r r rT � s zFaultyGetMap.__init__c C sF | j r"| js"dd� | �� �� D �nd}|D ]}|�� d| _q*| �� S )z(Intercept the calls to selector.get_map.c s s, | ]$\}\}}}}t |tjj�r|V qd S r\ )r� �cheroot�server�HTTPConnection)rp rr r� r r r rs � s �z(FaultyGetMap.__call__.<locals>.<genexpr>r T)r^ r_ r] �itemsr� )rS Zsabotage_targetsr� r r r rY � s �� ��zFaultyGetMap.__call__Nr[ r r r r r\ � s r\ c C s� t | jjjj�}|�| jjjd|� t| jjjjj�}|�| jjjjd|� | jddgd�\}}}|dksnJ �d |_ |_ t � | jj d � |js�J �|js�J �d S ) z�Test the error handling segment of HTTP connection selection. See :py:meth:`cheroot.connections.ConnectionManager.get_conn`. �select�get_mapr< r� r4 z200 OKTr N)rV ra r� � _selectorrd rg r\ re r� r^ rX r� r� Zexpiration_intervalrY r_ )rm rk Z faux_selectZ faux_get_mapZ resp_statusZ _resp_headersZ _resp_bodyr r r � test_invalid_selected_connection s0 �� � �� rg )QrI r� �rer r� r� �sysr� rZ rO rV � collectionsr � http.clientr� �urllib.requestrM r� Z jaraco.textr r Z cheroot.testr r Zcheroot._compatr r r r Zcheroot.serverr` � version_infoZIS_PY36r� r] r r rK Zfixturere rl rm rv rz r� �markZ parametrizer� r� �paramZxfailr� r� r� � ECONNRESET�EPIPE�ENOTCONN� ESHUTDOWN� RuntimeErrorr� �BrokenPipeErrorr� r� r� r r r r" r) r; r> r@ rE rF rH rL rS rU rV r\ rg r r r r �<module> s4 V +� K� E���� :h � � ��� �� ������- P90� E� S� ^*7� A)�� /� !� �
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0.15 |
proxy
|
phpinfo
|
ÐаÑтройка