Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/cheroot/test/__pycache__/test_server.cpython-39.pyc
Ðазад
a p�h9A � @ s0 d Z ddlZddlZddlZddlZddlZddlZddlZddlZ ddl Z ddl Z ddl Z ddl mZ ddlmZmZ ddlmZmZmZmZ ddlmZmZmZ ddlmZ dd l m Z m Z m Z ep�eZ e j!j"e#ed � d d �Z$e j!j"ed d �Z%e j&dd�dd� �Z'e j&dd� �Z(e j&dd� �Z)dd� Z*dd� Z+e j!�,de-e.e/e0f�dd � �Z1d d � Z2e j!�,d e e f�d d!� �Z3e$d"d#� �Z4e$d$d%� �Z5d&Z6d'Z7G d(d)� d)e�Z8e j&d*d+� �Z9e$e%e j!j:d,dd-�d.d/� ���Z;e j!j"e d0d �e$e%d1d2� ���Z<e j!j"ed3d �e j!j,d4d5d6d7�e j!�=d8�d9d:� ���Z>e j!j"e#ed;� d<d �e j!�,d e e f�d=d>� ��Z?eZ@e�sxe@�sxe j!�Ae>�Z>e j&d?d@� �ZBe j&dAd4� �ZCe j&dBd8� �ZDe j!�,dCdDdEeEdF�fdDdGeEdF�fdHdIdDeEdF�eEdF�fddEeEdF�fddGeEdF�fdJdeEdF�eEdF�ff �dKdL� �ZFe j!�,dMdN�dOdP� �ZGdQdR� ZHdS )SzTests for the HTTP server.� N)� DefaultGc� )�bton�ntob)�IS_LINUX�IS_MACOS� IS_WINDOWS� SYS_PLATFORM)�IS_UID_GID_RESOLVABLE�Gateway� HTTPServer)� ThreadPool)�ANY_INTERFACE_IPV4�ANY_INTERFACE_IPV6�EPHEMERAL_PORT�AF_UNIXz:UNIX domain sockets are only available under UNIX-based OS��reasonz9Peercreds lookup does not work under macOS/BSD currently.)�abstract�file)�paramsc C s dj f i t� ��}| �|�S )�9Check that bound UNIX socket address is stored in server.zunix_{request.param}_sock)�format�locals�getfixturevalue)�request�name� 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_server.py�unix_sock_file, s r c C s4 t st�djtd�� d�dttt� � ��f�� � S )z'Return an abstract UNIX socket address.z2{os} does not support an abstract socket namespace)�os� s cheroot-test-socket) r �pytest�skipr r �joinr �str�uuid�uuid4�decoder r r r �unix_abstract_sock3 s ���r) c c s* t �� \} }|V t�| � t�|� dS )zYield a unix file socket.N)�tempfile�mkstempr �close�unlink)Z tmp_sock_fhZtmp_sock_fnamer r r �unix_file_sockA s r. c C s~ t ttftd�} | jrJ �| jjr&J �| �� | js8J �| jjsDJ �| jjD ]}|jsLJ �qL| �� | jjrpJ �| jrzJ �dS )zBCheck that prepare() makes the server ready, and stop() clears it.�� bind_addr�gatewayN) r r r r �ready�requests�_threads�prepare�stop)� httpserverZthrr r r � test_prepare_makes_server_readyL s � r8 c C sf t ttftd�} | �� tj| jd�}|�� |� d� |� � sDJ �| � � |� d� |� � rbJ �dS )�0Check that stop() interrupts running of serve().r/ ��target� �?N) r r r r r5 � threading�Thread�serve�startr$ �is_aliver6 )r7 � serve_threadr r r �test_stop_interrupts_servec s � rC �exc_clsc s� dj t�� d��t� �tttftd��t� � �� ����fdd�}�� � t j |d�}|� � |�d� |�� stJ �� ���_|�d� |�� r�J ���� �u s�J �dS ) z0Check that assigning interrupt stops the server.zshould catch {uuid!s})r& r/ c sL z �� � W n: � yF } z"t| ��kr2���� W Y d } ~ n d } ~ 0 0 d S �N)r? r% �put)�e�rD r7 Z interrupt_msgZraise_marker_sentinelZresult_qr r rB � s z+test_server_interrupt.<locals>.serve_threadr: r< N)r r& r' �objectr r r r �queue�Queuer5 r= r> r@ r$ rA Z interrupt� get_nowait)rD rB r rH r �test_server_interruptw s" � rM c C s| t ttftd�} | �� dd� }|| jj_tj | j d�}|� � |� | j trPdnd � |�� rdJ �| jjrpJ �| �� dS )r9 r/ c _ s t � �d S rE )�KeyboardInterrupt)�args�kwargsr r r �raise_keyboard_interrupt� s zTtest_serving_is_false_and_stop_returns_after_ctrlc.<locals>.raise_keyboard_interruptr: � r N)r r r r r5 Z _connections� _selector�selectr= r> r? r@ r$ Zexpiration_interval� IS_SLOW_ENVrA Z_servingr6 )r7 rQ rB r r r �2test_serving_is_false_and_stop_returns_after_ctrlc� s � � rV �ip_addrc C s6 | � |tf�}|jd |ks J �|jd tks2J �dS )z0Check that bound IP address is stored in server.r � N)�sendr r0 )� http_serverrW r7 r r r �test_bind_addr_inet� s r[ c C s | � |�}|j|ksJ �dS )r N�rY r0 �rZ r r7 r r r �test_bind_addr_unix� s r^ c C s | � |�}|j|ksJ �dS )zBCheck that bound UNIX abstract socket address is stored in server.Nr\ )rZ r) r7 r r r � test_bind_addr_unix_abstract� s r_ z/peer_creds/idsz/peer_creds/textsc s$ e Zd Z� fdd�Zdd� Z� ZS )� _TestGatewayc sz | j }|j}t|j�}|tkrH|j|j|jf}| �d� t t |��� d S |t krl| �d� |j |jf�� d S tt| ��� S )N�|�!)�req�connr �uri�PEERCRED_IDS_URIZpeer_pidZpeer_uidZpeer_gid� send_payloadr$ �mapr% �PEERCRED_TEXTS_URIZ peer_userZ peer_group�superr` �respond)�selfrc rd Zreq_uriZ peer_creds�� __class__r r rk � s z_TestGateway.respondc C s& | j }d|_|�� |�t|�� d S )Ns 200 OK)rc �statusZensure_headers_sent�writer )rl �payloadrc r r r rg � s z_TestGateway.send_payload)�__name__� __module__� __qualname__rk rg � __classcell__r r rm r r` � s r` c C s | � |�}t|_d|_|S )z3Construct a test server with ``peercreds_enabled``.T)rY r` r1 Zpeercreds_enabledr] r r r �peercreds_enabled_server� s rv � )ZrerunsZ reruns_delayc C s� |}|j }t|t�r |�� }tjj|dd�}djf i t� ��}t � � t � � t � � f}d� tt|��}t�� �X tj|t | d�}|�� |j|ks�J �tj|t | d�}|jdks�J �W d � n1 s�0 Y dS )z2Check that ``PEERCRED`` lookup works when enabled.� ��safe�http+unix://{quoted}ra ��timeouti� N)r0 � isinstance�bytesr( �urllib�parse�quoter r r �getpid�getuid�getgidr$ rh r% �requests_unixsocket� monkeypatchr3 �getrf �raise_for_status�textri � status_code) �http_request_timeoutrv r7 r0 �quoted� unix_base_uriZexpected_peercredsZpeercreds_resp�peercreds_text_respr r r �test_peercreds_unix_sock s( ��r� zDModules `grp` and `pwd` are not available under the current platformc C s� |}d|_ |j}t|t�r"|�� }tjj|dd�}djf i t � ��}ddl }ddl }|� t �� �j|�t �� �jf}d�tt|��}t�� �8 tj|t | d�} | �� | j |ks�J �W d � n1 s�0 Y dS ) z6Check that ``PEERCRED`` resolution works when enabled.Trx ry r{ r Nrb r| ) Zpeercreds_resolve_enabledr0 r~ r r( r� r� r� r r �grp�pwd�getpwuidr r� �pw_name�getgrgidr� �gr_namer$ rh r% r� r� r3 r� ri r� r� ) r� rv r7 r0 r� r� r� r� Zexpected_textcredsr� r r r �$test_peercreds_unix_sock_with_lookup" s( � �r� z\This regression test is for a Linux bug, and the resource module is not available on Windows�resource_limit)i i �r� )Zindirect�many_open_socketsc sb | j j� � �fdd��t� �_�| j _| �d� t�j�dksBJ �t�fdd��jD ��s^J �dS )a> Test the server does not crash with a high file-descriptor value. This test shouldn't cause a server crash when trying to access file-descriptor higher than 1024. The earlier implementation used to rely on ``select()`` syscall that doesn't support file descriptors with numbers higher than 1024. c s �j �| j�� � � | �S rE )�filenos�add�socket�fileno)rd )�_old_process_conn�native_process_connr r r� g s zAtest_high_number_of_file_descriptors.<locals>.native_process_conn�/r c 3 s | ]}|� kV qd S rE r )�.0�fnr� r r � <genexpr>u r! z7test_high_number_of_file_descriptors.<locals>.<genexpr>N)Zserver_instanceZ process_conn�setr� �connect�len�any)Znative_server_clientr� r )r� r� r� r �$test_high_number_of_file_descriptorsJ s r� � SO_REUSEPORTz5socket.SO_REUSEPORT is not supported on this platformc C s� t �|t�d d }t � |�}|�t jt jd� |�|tf� t|�� dd� t dd�}|� |d�}|� � |� � |� � |jdu s�J �dS )z5Check that port initialized externally can be reused.r rX Nr T)r0 r1 � reuse_portr5 )r� � getaddrinfor � setsockopt� SOL_SOCKETr� �bindr � getsocknamer �spyr5 r6 r, Z spy_exception)rZ rW Zmocker�family�s�serverr� r r r �test_reuse_portx s � r� c c s4 t � �� � dV W d � n1 s&0 Y dS )z7Disable garbage collection when this fixture is in use.N)r Znogcr r r r � _garbage_bin� s r� c c sn t jddd�}|�|j�\}}|�|j| jd |f� z | jV W |�|j||f� n|�|j||f� 0 dS )z7Set the resource limit two times bigger then requested.�resourcez&The "resource" module is Unix-specificr r N)r" Z importorskipZ getrlimitZ RLIMIT_NOFILEZ setrlimit�param)r r� Z soft_limitZ hard_limitr r r r� � s � � c c s� | � d� g }zdt|�D ]&}t�� }|�|� |�� |kr q@q|d �� }||ksXJ �|V W |D ] }|�� qdn|D ] }|�� qx0 dS )z<Allocate a lot of file descriptors by opening dummy sockets.r� ���N)r �ranger� �appendr� r, )r r� Z test_sockets�_�sockZthe_highest_filenoZ test_socketr r r r� � s �)� minthreads� maxthreads�inited_maxthreadsrX ����infr� )rX rX rX )rX r r )r r r c C s. t d| |d�}|j| ks J �|j|ks*J �dS )z�Test setting the number of threads in a ThreadPool. The ThreadPool should properly set the min+max number of the threads to use in the pool if those limits are valid. N�r� �min�max)r r� r� )r� r� r� �tpr r r � test_threadpool_threadrange_set� s �r� �r� r� �error) )r� r� �min=-1 must be > 0)r� r r� )r� rX r� )r� r r� )r r� �min=0 must be > 0)r r r� )r rX r� )r r r� )rX r �KExpected an integer or the infinity value for the `max` argument but got 0.)rX r< zMExpected an integer or the infinity value for the `max` argument but got 0.5.)r r r� )r �1zMExpected an integer or the infinity value for the `max` argument but got '1'.)r rX zmax=1 must be > min=2c C sD t jttf|d�� td| |d� W d � n1 s60 Y dS )z�Test that a ThreadPool rejects invalid min/max values. The ThreadPool should raise an error with the proper message when initialized with an invalid min+max number of threads. ��matchNr� )r" �raises� ValueError� TypeErrorr r� r r r �#test_threadpool_invalid_threadrange� s �r� c C s^ | � tddd� � tdd�}|�� tjtdd�� |�� W d � n1 sP0 Y dS )z�Test for ThreadPool multi-start behavior. Tests that when calling start() on a ThreadPool multiple times raises a :exc:`RuntimeError` Z _spawn_workerc S s t jdd�S )NT)r2 )�types�SimpleNamespace)r� r r r �<lambda>( r! z7test_threadpool_multistart_validation.<locals>.<lambda>N)r� z%Threadpools can only be started once.r� )�setattrr r@ r" r� � RuntimeError)r� r� r r r �%test_threadpool_multistart_validation s � r� )I�__doc__r rJ r� r* r= r� r& � urllib.parser� r" r3 r� Zpypytools.gc.customr �_compatr r r r r r r� r r r Zworkers.threadpoolr Ztestingr r r rU �markZskipif�hasattrZunix_only_sock_testZnon_macos_sock_testZfixturer r) r. r8 rC Z parametrize�IOErrorrN �OSErrorr� rM rV r[ r^ r_ rf ri r` rv Zflakyr� r� Z usefixturesr� r� ZISSUE511Zforkedr� r� r� �floatr� r� r� r r r r �<module> s� �� �� $ �� �!�� ��� � � �� �
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка