Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/zmq/tests/__pycache__/__init__.cpython-39.pyc
Ðазад
a a�h� � @ s d dl Z d dlZd dlmZ d dlmZ zd dlmZ W n eyV d dlmZ Y n0 d dl m Z d dl Z d dl m Z z d dlZd dl mZ dZW n ey� d ZY n0 d e jv Zd d � Ze jed d�Ze je �� dk dd�ZG dd� de�ZG dd� de�ZG dd� d�Zdd� Z dS )� N)�Thread)�TestCase��SkipTest)�mark)�jsonapi)�greenTF�PyPyc C s | S �N� )�xr r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/zmq/tests/__init__.py�<lambda> � r zDoesn't work on PyPy)�reason)� zrequires zmq >= 4c s� e Zd ZdZdZedd� �Zdd� Z� fdd�Z� fd d �Z e j e j d fd d �Z dd� Z dd� Zdd� Zdd� Zdd� Zdd� Zdd� Z� ZS ) �BaseZMQTestCaseF� c C s | j r tjS tjS d S r )r �gzmq�Context�zmq��selfr r r r - s zBaseZMQTestCase.Contextc C s | j �|�}| j�|� |S r )�context�socket�sockets�append)r � socket_type�sr r r r 4 s zBaseZMQTestCase.socketc s6 t t| ��� | jr ts td��| j�� | _g | _ d S )Nzrequires gevent) �superr �setUpr � have_geventr r �instancer r r �� __class__r r r 9 s zBaseZMQTestCase.setUpc s� t | jg�}| jr4| j�� }|�|j� |�d� q |D ]H}t|jd�}d|_|� � |j | j d� |� � r8d t jjj_td��q8tt| ��� d S )Nr )�targetT��timeout�?context could not terminate, open sockets likely remain in test)�setr r �pop�add�closer �term�daemon�start�join�teardown_timeout�is_aliver Zsugarr Z _instance� RuntimeErrorr r �tearDown)r �contexts�sock�ctx�tr# r r r4 @ s zBaseZMQTestCase.tearDownztcp://127.0.0.1c C sh | j �|�}|�tjd� |�|�}| j �|�}|�tjd� |�d||f � | j�||g� ||fS )z/Create a bound socket pair using a random port.r z%s:%s) r r � setsockoptr ZLINGERZbind_to_random_port�connectr �extend)r Ztype1Ztype2Z interface�s1�port�s2r r r �create_bound_pairQ s z!BaseZMQTestCase.create_bound_pairc C s( |� |� |�� }|� |� |�� }|S r )�send�recv)r r< r> �msgZmsg2Zmsg3r r r � ping_pong\ s zBaseZMQTestCase.ping_pongc C s: t jd u rtd��|�|� |�� }|�|� |�� }|S )NzNo json library)r Zjsonmodr Z send_jsonZ recv_json�r r< r> �o�o2Zo3r r r �ping_pong_jsonc s z BaseZMQTestCase.ping_pong_jsonc C s( |� |� |�� }|� |� |�� }|S r )Z send_pyobjZ recv_pyobjrD r r r �ping_pong_pyobjl s z BaseZMQTestCase.ping_pong_pyobjc O sn z||i |�� W nL t jy^ } z2| �|j|dt �|�t �|j�f � W Y d }~nd }~0 0 | �d� d S )N�*wrong error raised, expected '%s' got '%s'� Function did not raise any error)r �ZMQError� assertEqual�errno�fail�r rM �func�args�kwargs�er r r �assertRaisesErrnos s � z!BaseZMQTestCase.assertRaisesErrnoc K s� t �� dkrt�d� t j|gg g |�dd�d�\}}}t|�dksLJ d��t j|�dd�B |d< |rl|j n|j }|f i |��S ) zIcall recv[_multipart] in a way that raises if there is nothing to receive)� � r g�������?r' � r& r z Should have received a message�flags) r �zmq_version_info�time�sleep�selectr* �lenZDONTWAIT�get�recv_multipartrA )r � multipartr rR �r�wr rA r r r � _select_recv| s "z BaseZMQTestCase._select_recvc K s | j d|fi |��S )z=call recv in a way that raises if there is nothing to receiveF�rc �r r rR r r r rA � s zBaseZMQTestCase.recvc K s | j d|fi |��S )zGcall recv_multipart in a way that raises if there is nothing to receiveTrd re r r r r_ � s z BaseZMQTestCase.recv_multipart)�__name__� __module__� __qualname__r r1 �propertyr r r r4 r ZPAIRr? rC rG rH rT rc rA r_ � __classcell__r r r# r r ) s r c @ s e Zd ZdS )�PollZMQTestCaseN)rf rg rh r r r r rk � s rk c @ s0 e Zd ZdZdZdZdd� Zdd� Zdd � Zd S ) � GreenTestz/Mixin for making green versions of test classesTr c O sz |t jkrtd��z||i |�� W nF t jyj t�� d }| �|j|dt �|�t �|j�f � Y n 0 | �d� d S )Nz Skipping because we're green.rV rI rJ ) r �EAGAINr rK �sys�exc_inforL rM rN rO r r r rT � s � zGreenTest.assertRaisesErrnoc C st t | jg�}| jr2| j�� }|�|j� |�� q z tjdd� |D �| jdd� W n tj yn t d��Y n0 d S )Nc S s g | ]}t �|j��qS r )�gevent�spawnr- )�.0r7 r r r � <listcomp>� r z&GreenTest.tearDown.<locals>.<listcomp>T)r' Z raise_errorr( ) r) r r r* r+ r, rp Zjoinallr1 �Timeoutr3 )r r5 r6 r r r r4 � s � zGreenTest.tearDownc C s t d��d S �Nz Skipping because we are greenr r r r r � skip_green� s zGreenTest.skip_greenN) rf rg rh �__doc__r r1 rT r4 rv r r r r rl � s rl c s � fdd�}|S )Nc s* | j rtd��n� | g|�R i |��S d S ru )r r )r rQ rR ��fr r � skipping_test� s z!skip_green.<locals>.skipping_testr )ry rz r rx r rv � s rv ) rn rZ � threadingr Zunittestr r � ImportErrorZ unittest2Zpytestr r Z zmq.utilsr rp r r r! �version�PYPYZ_idZskipifZ skip_pypyrY Z require_zmq_4r rk rl rv r r r r �<module> s0 k#
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка