Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/zmq/tests/asyncio/__pycache__/_test_asyncio.cpython-39.pyc
Ðазад
a a�h> � @ s� d Z ddlZddlmZ ddlZddlZddlZddlmZ ddlZddl m Z z$ddl Z ddl m Z ddlmZ W n" ey� ejdkr�� dZ Y n0 ddlmZ dd lmZmZ dd lmZ G d d � d e�ZG d d� de�ZG dd� de�ZdS )zTest asyncio support� N)�Process)�mark)�u)�AsyncioAuthenticator)� � )�CancelledError)�BaseZMQTestCase�SkipTest)�TestThreadAuthenticationc @ s e Zd Zdd� Zdd� ZdS )�ProcessForTeardownTestc C s t �| � || _d S �N)r �__init__�event_loop_policy_class)�selfr � r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/zmq/tests/asyncio/_test_asyncio.pyr s z ProcessForTeardownTest.__init__c C s� t �| �� � tj�� }|�tj�}|� d� t j dd� �}t � � }t j ||�dd�}z|� |� W n t jyx Y n0 ds�J d��dS ) z;Leave context, socket and event loop upon implicit disposal�tcp://127.0.0.1c s s | � � E d H d S r )�recv)�socketr r r �never_ending_task+ s z5ProcessForTeardownTest.run.<locals>.never_ending_task� ��timeoutFz,never_ending_task was completed unexpectedlyN)�asyncioZset_event_loop_policyr �zaio�Context�instancer �zmqZPAIR�bind_to_random_port� coroutine�get_event_loop�wait_for�run_until_complete� TimeoutError)r �actxr r �loop�coror r r �run# s zProcessForTeardownTest.runN)�__name__� __module__� __qualname__r r( r r r r r s r c s" e Zd ZedurejZ� fdd�Z� fdd�Zdd� Zdd � Z d d � Z d d � Z dd� Z e jeed� dd�dd� �Ze jeed� dd�dd� �Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d,� Z d-d.� Z e j je j �!d/�d0d�d1d2� �Z"d3d4� Z#d5d6� Z$� Z%S )7�TestAsyncIOSocketNc s6 t d u rt� �t �� | _t �| j� tt| ��� d S r )r r Znew_event_loopr& �set_event_loop�superr, �setUp�r �� __class__r r r/ = s zTestAsyncIOSocket.setUpc s | j �� t� �� d S r )r& �closer. �tearDownr0 r1 r r r4 D s zTestAsyncIOSocket.tearDownc C s* | j �tj�}t|tj�s J �|�� d S r )�contextr r �PUSH� isinstancer �Socketr3 )r �sr r r �test_socket_classH s z#TestAsyncIOSocket.test_socket_classc C sP t jj�� }t j�� }|�� |�� t|�t ju s8J �t|�t jju sLJ �d S r )r r r r �term�type)r r% �ctxr r r � test_instance_subclass_firstM s z.TestAsyncIOSocket.test_instance_subclass_firstc C sP t j�� }t jj�� }|�� |�� t|�t ju s8J �t|�t jju sLJ �d S r )r r r r r; r< )r r= r% r r r � test_instance_subclass_secondU s z/TestAsyncIOSocket.test_instance_subclass_secondc s$ t j� fdd��}� j�|� � d S )Nc 3 sT � � tjtj�\} }|�� }|�� r(J �| �d�E d H |E d H }� �|dg� d S )N� hi)�create_bound_pairr r6 �PULL�recv_multipart�done�send� assertEqual)�a�b�f�recvdr0 r r �test^ s z3TestAsyncIOSocket.test_recv_multipart.<locals>.test�r r r& r# �r rK r r0 r �test_recv_multipart] s z%TestAsyncIOSocket.test_recv_multipartc s$ t j� fdd��}� j�|� � d S )Nc 3 s� � � tjtj�\} }|�� }|�� }|�� r0J �|�� r<J �| �ddg�E d H |E d H }|�� sfJ �� �|�� d� � �|d� d S �Nr@ � there) rA r r6 rB r rD �send_multipartrF �result�rG rH �f1�f2rJ r0 r r rK i s z)TestAsyncIOSocket.test_recv.<locals>.testrL rM r r0 r � test_recvh s zTestAsyncIOSocket.test_recvZRCVTIMEOzrequires RCVTIMEO)�reasonc s$ t j� fdd��}� j�|� � d S )Nc 3 s� � � tjtj�\} }d|_|�� }d|_|�� }� �tj�� |E d H W d � n1 s\0 Y | � ddg�E d H |E d H }|� � s�J �� � |ddg� d S )N�d �� r@ rP ) rA r r6 rB Zrcvtimeor rC � assertRaises�AgainrQ rD rF rS r0 r r rK y s ( z1TestAsyncIOSocket.test_recv_timeout.<locals>.testrL rM r r0 r �test_recv_timeoutw s z#TestAsyncIOSocket.test_recv_timeoutZSNDTIMEOzrequires SNDTIMEOc s$ t j� fdd��}� j�|� � d S )Nc 3 sR � � tj�} d| _� �tj�� | �d�E d H W d � n1 sD0 Y d S )NrX s not going anywhere)r r r6 ZsndtimeorZ r[ rE )r9 r0 r r rK � s z1TestAsyncIOSocket.test_send_timeout.<locals>.testrL rM r r0 r �test_send_timeout� s z#TestAsyncIOSocket.test_send_timeoutc s$ t j� fdd��}� j�|� � d S )Nc 3 sv � � tjtj�\} }|�� }|�� r(J �td�}| �|�E d H |E d H }|�� sVJ �� �|� � |� � �||� d S )Nu πøøπ) rA r r6 rB Z recv_stringrD r Z send_stringrF rR )rG rH rI �msgrJ r0 r r rK � s z0TestAsyncIOSocket.test_recv_string.<locals>.testrL rM r r0 r �test_recv_string� s z"TestAsyncIOSocket.test_recv_stringc s$ t j� fdd��}� j�|� � d S )Nc 3 sx � � tjtj�\} }|�� }|�� r(J �tdd�}| �|�E d H |E d H }|�� sXJ �� �|� � |� � �||� d S �N� �rG ) rA r r6 rB � recv_jsonrD �dict� send_jsonrF rR �rG rH rI �objrJ r0 r r rK � s z.TestAsyncIOSocket.test_recv_json.<locals>.testrL rM r r0 r �test_recv_json� s z TestAsyncIOSocket.test_recv_jsonc s$ t j� fdd��}� j�|� � d S )Nc 3 s6 � � tjtj�\} }|�� }|�� r(J �|�� t�d�E d H t dd�}| � |�E d H t j dk r�t �t�� |E d H }W d � q�1 s�0 Y n8t �tjj�� |E d H }W d � n1 s�0 Y |�� s�J �|jdd�E d H }|s�J �t�d�E d H |�� }tj|dd�E d H }||k�s2J �d S )Nr ra rb )r � r )rA r r6 rB rc rD �cancelr �sleeprd re �sys� version_info�pytest�raisesr � exceptions�pollr" )rG rH rI rg rJ �eventsr0 r r rK � s& *( z8TestAsyncIOSocket.test_recv_json_cancelled.<locals>.testrL rM r r0 r �test_recv_json_cancelled� s z*TestAsyncIOSocket.test_recv_json_cancelledc s$ t j� fdd��}� j�|� � d S )Nc 3 sx � � tjtj�\} }|�� }|�� r(J �tdd�}| �|�E d H |E d H }|�� sXJ �� �|� � |� � �||� d S r` ) rA r r6 rB Z recv_pyobjrD rd Z send_pyobjrF rR rf r0 r r rK � s z/TestAsyncIOSocket.test_recv_pyobj.<locals>.testrL rM r r0 r �test_recv_pyobj� s z!TestAsyncIOSocket.test_recv_pyobjc s8 dd� �dd� � t j� ��fdd��}�j�|� � d S )Nc S s8 g }|� | �dg �� t�| d ��d�}|�|� |S )N� identities�content�utf8)�extend�get�json�dumps�encode�append)r^ �framesrv r r r � serialize� s z:TestAsyncIOSocket.test_custom_serialize.<locals>.serializec S s* | d d� }t �| d �d��}||d�S )N���rw )ru rv )rz �loads�decode)r~ ru rv r r r � deserialize� s �z<TestAsyncIOSocket.test_custom_serialize.<locals>.deserializec 3 s� �� tjtj�\} }dddd�i}| �|��E d H |�� �E d H }|d |d ksXJ �|d sdJ �|�|��E d H | �� �E d H }|d |d ks�J �|d r�J �d S )Nrv ra �bee�rG rH ru )rA r �DEALER�ROUTER�send_serialized�recv_serialized)rG rH r^ rJ �r2�r� r r r r rK � s �� z5TestAsyncIOSocket.test_custom_serialize.<locals>.testrL rM r r� r �test_custom_serialize� s z'TestAsyncIOSocket.test_custom_serializec s$ t j� fdd��}� j�|� � d S )Nc 3 s� � � tjtj�\} }dddd�i}t�t��$ | �ttj �E d H W d � n1 sV0 Y | � d�E d H t�t��" |� tj �E d H }W d � n1 s�0 Y d S )Nrv ra r� r� s not json) rA r r� r� rn ro � TypeErrorr� rz r{ rE r� r� )rG rH r^ rJ r0 r r rK s �� 2 z;TestAsyncIOSocket.test_custom_serialize_error.<locals>.testrL rM r r0 r �test_custom_serialize_error� s z-TestAsyncIOSocket.test_custom_serialize_errorc s$ t j� fdd��}� j�|� � d S )Nc 3 s� � � tjtj�\} }|�tj�}� �tj�� |E d H W d � n1 sL0 Y | �d�E d H |� � E d H |�tj�}|� � s�J �|E d H }� � |d� d S )Ns ping) rA r r6 rB r ZDONTWAITrZ r[ rE rq rD rF )�push�pullrI r^ r0 r r rK s ( z2TestAsyncIOSocket.test_recv_dontwait.<locals>.testrL rM r r0 r �test_recv_dontwait s z$TestAsyncIOSocket.test_recv_dontwaitc s$ t j� fdd��}� j�|� � d S )Nc 3 s� � � tjtj�\} }|�� }|�� }|�� s0J �|�� s<J �|�� rHJ �| �ddg�E d H |E d H }|� � srJ �|�� s~J �� � |ddg� d S rO ) rA r r6 rB r rC rj rD rQ � cancelledrF rS r0 r r rK " s z0TestAsyncIOSocket.test_recv_cancel.<locals>.testrL rM r r0 r �test_recv_cancel! s z"TestAsyncIOSocket.test_recv_cancelc s$ t j� fdd��}� j�|� � d S )Nc 3 s� � � tjtj�\} }|jdd�}t�d�E d H � �|�� d� |jdd�}|� � rXJ �|E d H }� �|d� |jdd�}|� � r�J �| � ddg�E d H |E d H }� �|tj � |� � E d H }� �|ddg� d S )Nr r r rY r@ rP ) rA r r6 rB rq r rk rF rR rD rQ �POLLINrC )rG rH rI �evtrJ r0 r r rK 2 s z)TestAsyncIOSocket.test_poll.<locals>.testrL rM r r0 r � test_poll1 s zTestAsyncIOSocket.test_pollc s$ t j� fdd��}� j�|� � d S )Nc 3 s� t �� } d}| �t j�}| �t j�}� j�||g� |�|� |�|� t � � }|� |t j � |j dd�}|�� rvJ �|�ddg� |E d H }� �||t j fg� |�� }� �|ddg� d S )Nz inproc://testrY r r@ rP )r r r r6 rB Zsocketsrx �bind�connectr �Poller�registerr� rq rD rQ rF rC )r= �urlrG rH ZpollerrI r� rJ r0 r r rK I s z5TestAsyncIOSocket.test_poll_base_socket.<locals>.testrL rM r r0 r �test_poll_base_socketH s z'TestAsyncIOSocket.test_poll_base_socketc s$ t j� fdd��}� j�|� � d S )Nc 3 sb � � tjtj�\} }|jdd�}|�� td�D ] }t�d�E d H |� � r0 qRq0|� � s^J �d S )Nr r ra r ) rA r r6 rB rq r3 �ranger rk r� )rG rH rI �_r0 r r rK ` s z:TestAsyncIOSocket.test_poll_on_closed_socket.<locals>.testrL rM r r0 r �test_poll_on_closed_socket_ s z,TestAsyncIOSocket.test_poll_on_closed_socket�winz)Windows does not support polling on filesc C s& t jdd� �}t �� }|�|� � d S )Nc s s t �� } t�� \}}t�|d�}t�|d�}| �|tj� | �|tj� | j dd�E d H }t |�}|� � |vsrJ �|� � |v s�J �||� � tjks�J �| � |� |� d� |�� | j dd�E d H }t |�}|� � |v s�J �||� � tjks�J �|�d�dk�sJ �|�� |�� d S )N�rb�wbr r � xrY )r r� �os�pipe�fdopenr� r r� �POLLOUTrq rd �fileno� unregister�write�flush�readr3 )�p�r�wZevtsr r r rK u s* z-TestAsyncIOSocket.test_poll_raw.<locals>.test)r r r! r# )r rK r& r r r � test_poll_rawq s z TestAsyncIOSocket.test_poll_rawc s t j� fdd��}d S )Nc s2 t �� } | �t j�}t�|�}t|� j�s.J �d S r )r r r rB r r8 r7 Z socket_class)r= r9 Zasync_sr0 r r rK � s z+TestAsyncIOSocket.test_shadow.<locals>.test)r r rM r r0 r � test_shadow� s z TestAsyncIOSocket.test_shadowc C sb t t�� �}t|�}|�� z6|�d� | �|jd|jrBd|j nd� W |�� n |�� 0 d S )N� r z Python process died with code %dzprocess teardown hangs) r< r Zget_event_loop_policyr �start�joinrF �exitcode� terminate)r r �procr r r �test_process_teardown� s � �z'TestAsyncIOSocket.test_process_teardown)&r) r* r+ r r r r/ r4 r: r> r? rN rV r Zskipif�hasattrr r\ r] r_ rh rs rt r� r� r� r� r� r� r� rn rl �platform� startswithr� r� r� � __classcell__r r r1 r r, 9 s> % � !r, c sZ e Zd ZdZedurejZdd� Z� fdd�Z� fdd�Z d d � Z d d � Z d d� Z � Z S )�TestAsyncioAuthenticationz-Test authentication running in a asyncio taskNc C s6 | j }|r2|�d�d �� }|�d�r2|�dd�}|S )z`Rewrite doc strings from TestThreadAuthentication from 'threaded' to 'asyncio'. � r z threaded authz asyncio auth)Z_testMethodDoc�split�stripr� �replace)r �docr r r �shortDescription� s z*TestAsyncioAuthentication.shortDescriptionc s2 t d u rt� �t�� | _t �| j� t� �� d S r )r r r Z ZMQEventLoopr& r- r. r/ r0 r1 r r r/ � s z TestAsyncioAuthentication.setUpc s t � �� | j�� d S r )r. r4 r& r3 r0 r1 r r r4 � s z"TestAsyncioAuthentication.tearDownc C s t | j�S r )r r5 r0 r r r � make_auth� s z#TestAsyncioAuthentication.make_authc s$ t j� ��fdd��}�j�|� �S )z9Check if client can connect to server using tcp transportc 3 sl d} d}�� |�}� �d||f � dg}��|�E d H � �d�E d H rh� �� E d H }��||� d} | S )NFr z%s:%is Hello WorldrY T)r r� rQ rq rC rF )rR Ziface�portr^ Zrcvd_msg��clientr �serverr r �go� s z1TestAsyncioAuthentication.can_connect.<locals>.gorL )r r� r� r� r r� r � can_connect� s z%TestAsyncioAuthentication.can_connectc s4 |r �j n�j�tj� ��fdd��}| j�|� �S )Nc 3 s, �� d�E d H std���f i � ��E d H S )Ni� z Should have received a message)rq r$ r ��kwargsr r r r r' � s z4TestAsyncioAuthentication._select_recv.<locals>.coro)rC r r r r& r# )r � multipartr r� r' r r� r � _select_recv� s z&TestAsyncioAuthentication._select_recv)r) r* r+ �__doc__r r r r� r/ r4 r� r� r� r� r r r1 r r� � s r� ) r� rz �multiprocessingr r� rl rn r r Zzmq.utils.strtypesr r Z zmq.asyncior Zzmq.auth.asyncior � ImportErrorrm �concurrent.futuresr Z zmq.testsr r Zzmq.tests.test_authr r r, r� r r r r �<module> s0 s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка