Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/zmq/tests/__pycache__/test_future.cpython-39.pyc
Ðазад
a a�h�+ � @ s� d dl mZ d dlZd dlZd dlZd dlZe�d�Zd dlZd dl m Z d dl m Z d dl mZ d dlmZ G dd � d e�ZdS ) � )� timedeltaNz tornado.gen)�future)�IOLoop)�u)�BaseZMQTestCasec s> e Zd ZejZ� fdd�Z� fdd�Zdd� Zdd� Zd d � Z d d � Z d d� Z dd� Z e jjeed� dd�dd� �Ze jjeed� dd�dd� �Ze jjdd� �Ze jjd d � �Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Z d*d+� Z e jje j � d,�d-d�d.d/� �Z!d0d1� Z"e jje j � d,�d2d�d3d4� �Z#� Z$S )5�TestFutureSocketc s$ t � | _| j�� tt| ��� d S �N)r �loopZ make_current�superr �setUp��self�� __class__� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/zmq/tests/test_future.pyr s zTestFutureSocket.setUpc s6 t t| ��� | jr"| jjdd� t�� t�� d S �NT)Zall_fds)r r �tearDownr �closer Z clear_currentZclear_instancer r r r r s zTestFutureSocket.tearDownc C s* | j �tj�}t|tj�s J �|�� d S r )�context�socket�zmq�PUSH� isinstancer ZSocketr �r �sr r r �test_socket_class# s z"TestFutureSocket.test_socket_classc C sL | j �� }tj �� }|�� |�� t|�tj u s6J �t|�| j u sHJ �d S r )�Context�instancer �term�type)r �actx�ctxr r r � test_instance_subclass_first( s z-TestFutureSocket.test_instance_subclass_firstc C sL t j�� }| j�� }|�� |�� t|�t ju s6J �t|�| ju sHJ �d S r )r r r r r )r r" r! r r r � test_instance_subclass_second0 s z.TestFutureSocket.test_instance_subclass_secondc s" t j� fdd��}� j�|� d S )Nc 3 sL � � tjtj�\} }|�� }|�� r(J �| �d�V |V }� �|dg� d S )N� hi)�create_bound_pairr r �PULL�recv_multipart�done�send� assertEqual)�a�b�f�recvdr r r �test9 s z2TestFutureSocket.test_recv_multipart.<locals>.test��gen� coroutiner Zrun_sync�r r0 r r r �test_recv_multipart8 s z$TestFutureSocket.test_recv_multipartc s" t j� fdd��}� j�|� d S )Nc 3 s~ � � tjtj�\} }|�� }|�� }|�� r0J �|�� r<J �| �ddg�V |V }|�� s^J �� �|�� d� � �|d� d S �Nr% � there) r& r r r' �recvr) �send_multipartr+ �result�r, r- �f1�f2r/ r r r r0 D s z(TestFutureSocket.test_recv.<locals>.testr1 r4 r r r � test_recvC s zTestFutureSocket.test_recvc s" t j� fdd��}� j�|� d S )Nc 3 s� � � tjtj�\} }|�� }|�� }|�� s0J �|�� s<J �|�� rHJ �| �ddg�V |V }|� � sjJ �|�� svJ �� � |ddg� d S r6 ) r& r r r' r8 r( �cancelr) r9 Z cancelledr+ r; r r r r0 S s z/TestFutureSocket.test_recv_cancel.<locals>.testr1 r4 r r r �test_recv_cancelR s z!TestFutureSocket.test_recv_cancelZRCVTIMEOzrequires RCVTIMEO)�reasonc s" t j� fdd��}� j�|� d S )Nc 3 s� � � tjtj�\} }d|_|�� }d|_|�� }t�tj �� |V W d � n1 sX0 Y | � ddg�V |V }|� � s�J �� � |ddg� d S )N�d �� r% r7 ) r& r r r' Zrcvtimeor8 r( �pytest�raises�Againr9 r) r+ r; r r r r0 d s $ z0TestFutureSocket.test_recv_timeout.<locals>.testr1 r4 r r r �test_recv_timeoutb s z"TestFutureSocket.test_recv_timeoutZSNDTIMEOzrequires SNDTIMEOc s" t j� fdd��}� j�|� d S )Nc 3 sN � � tj�} d| _t�tj�� | �d�V W d � n1 s@0 Y d S )NrB � not going anywhere)r r r ZsndtimeorD rE rF r* �r r r r r0 u s z0TestFutureSocket.test_send_timeout.<locals>.testr1 r4 r r r �test_send_timeouts s z"TestFutureSocket.test_send_timeoutc s" t j� fdd��}� j�|� d S )Nc 3 sN � � tj�} t�tj��" | jdtjd�V W d � n1 s@0 Y d S �NrH )�flags)r r r rD rE rF r* �NOBLOCKrI r r r r0 s z0TestFutureSocket.test_send_noblock.<locals>.testr1 r4 r r r �test_send_noblock} s z"TestFutureSocket.test_send_noblockc s" t j� fdd��}� j�|� d S )Nc 3 sP � � tj�} t�tj��$ | jdgtjd�V W d � n1 sB0 Y d S rK )r r r rD rE rF r9 rM rI r r r r0 � s z:TestFutureSocket.test_send_multipart_noblock.<locals>.testr1 r4 r r r �test_send_multipart_noblock� s z,TestFutureSocket.test_send_multipart_noblockc s" t j� fdd��}� j�|� d S )Nc 3 sn � � tjtj�\} }|�� }|�� r(J �td�}| �|�V |V }|�� sNJ �� �|� � |� � �||� d S )Nu πøøπ) r& r r r' Z recv_stringr) r Z send_stringr+ r: )r, r- r. �msgr/ r r r r0 � s z/TestFutureSocket.test_recv_string.<locals>.testr1 r4 r r r �test_recv_string� s z!TestFutureSocket.test_recv_stringc s" t j� fdd��}� j�|� d S )Nc 3 sp � � tjtj�\} }|�� }|�� r(J �tdd�}| �|�V |V }|�� sPJ �� �|� � |� � �||� d S �N� �r, ) r& r r r' � recv_jsonr) �dict� send_jsonr+ r: �r, r- r. �objr/ r r r r0 � s z-TestFutureSocket.test_recv_json.<locals>.testr1 r4 r r r �test_recv_json� s z TestFutureSocket.test_recv_jsonc s" t j� fdd��}� j�|� d S )Nc 3 s� � � tjtj�\} }|�� }|�� r(J �|�� t�d�V t dd�}| � |�V t � t j�� |V }W d � n1 sz0 Y |�� s�J �|jdd�V }|s�J �t�d�V t�tdd�|�� �V }||ks�J �d S )Nr rS rT ��timeout)�seconds)r& r r r' rU r) r? r2 �sleeprV rW rD rE r ZCancelledError�pollZ with_timeoutr )r, r- r. rY r/ �eventsr r r r0 � s $ z7TestFutureSocket.test_recv_json_cancelled.<locals>.testr1 r4 r r r �test_recv_json_cancelled� s z)TestFutureSocket.test_recv_json_cancelledc s" t j� fdd��}� j�|� d S )Nc 3 sp � � tjtj�\} }|�� }|�� r(J �tdd�}| �|�V |V }|�� sPJ �� �|� � |� � �||� d S rR ) r& r r r' Z recv_pyobjr) rV Z send_pyobjr+ r: rX r r r r0 � s z.TestFutureSocket.test_recv_pyobj.<locals>.testr1 r4 r r r �test_recv_pyobj� s z TestFutureSocket.test_recv_pyobjc s6 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)rP �framesrd r r r � serialize� s z9TestFutureSocket.test_custom_serialize.<locals>.serializec S s* | d d� }t �| d �d��}||d�S )N���re )rc rd )rh �loads�decode)rl rc rd r r r � deserialize� s �z;TestFutureSocket.test_custom_serialize.<locals>.deserializec 3 s� �� tjtj�\} }dddd�i}| �|��V |�� �V }|d |d ksPJ �|d s\J �|�|��V | �� �V }|d |d ks�J �|d r�J �d S )Nrd rS �bee�r, r- rc )r& r �DEALER�ROUTER�send_serialized�recv_serialized)r, r- rP r/ �r2�rq r rm r r r0 � s �� z4TestFutureSocket.test_custom_serialize.<locals>.testr1 r4 r ry r �test_custom_serialize� s z&TestFutureSocket.test_custom_serializec s" t j� fdd��}� j�|� d S )Nc 3 s� � � tjtj�\} }dddd�i}t�t�� | �ttj �V W d � n1 sR0 Y | � d�V t�t�� |� tj �V }W d � n1 s�0 Y d S )Nrd rS rr rs s not json) r& r rt ru rD rE � TypeErrorrv rh ri r* rw ro )r, r- rP r/ r r r r0 � s �� . z:TestFutureSocket.test_custom_serialize_error.<locals>.testr1 r4 r r r �test_custom_serialize_error� s z,TestFutureSocket.test_custom_serialize_errorc s" t j� fdd��}� j�|� d S )Nc 3 s� � � tjtj�\} }|jdd�}|�� s,J �� �|�� d� |jdd�}|�� rTJ �|V }� �|d� |jdd�}|�� r~J �| �ddg�V |V }� �|tj � |� � V }� �|ddg� d S )Nr r[ � rC r% r7 ) r& r r r' r_ r) r+ r: r9 �POLLINr( )r, r- r. �evtr/ r r r r0 s z(TestFutureSocket.test_poll.<locals>.testr1 r4 r r r � test_poll s zTestFutureSocket.test_poll�winz Windows unsupported socket typec 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� |V }� �||t j fg� |�� }� �|ddg� |�� |�� | �� d S )Nz inproc://testrC r[ r% r7 )r r r r r' Zsocketsrf �bind�connectr �Poller�registerr~ r_ r) r9 r+ r( r r )r" �urlr, r- Zpollerr. r r/ r r r r0 " s& z4TestFutureSocket.test_poll_base_socket.<locals>.testr1 r4 r r r �test_poll_base_socket s z&TestFutureSocket.test_poll_base_socketc C s. | � tj�}| jjdd� d | _|js*J �d S r )r r ZPUBr r �closedr r r r �test_close_all_fds; s z#TestFutureSocket.test_close_all_fdsz)Windows does not support polling on filesc C s t jdd� �}| j�|� d S )Nc s s t �� } t�� \}}t�|d�}t�|d�}| �|tj� | �|tj� | j dd�V }t |�}|� � |vsnJ �|� � |v s~J �||� � tjks�J �| � |� |� d� |�� | j dd�V }t |�}|� � |v s�J �||� � tjks�J �|�d�dks�J �|�� |�� d S )N�rb�wbr} r[ � xrC )r r� �os�pipe�fdopenr� r r~ �POLLOUTr_ rV �fileno� unregister�write�flush�readr )�p�r�wZevtsr r r r0 E s* z,TestFutureSocket.test_poll_raw.<locals>.testr1 r4 r r r � test_poll_rawA s z TestFutureSocket.test_poll_raw)%�__name__� __module__� __qualname__r r r r r r# r$ r5 r> r@ rD �markZskipif�hasattrr rG rJ �nowrN rO rQ rZ ra rb rz r| r� �sys�platform� startswithr� r� r� � __classcell__r r r r r sF % � �r )�datetimer r� rh r� rD Z importorskipr2 r Z zmq.eventloopr Ztornado.ioloopr Zzmq.utils.strtypesr Z zmq.testsr r r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка