Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/zmq/tests/__pycache__/test_device.cpython-39.pyc
Ðазад
a a�h � @ s� d dl Z d dlZd dlmZ d dlmZmZmZmZmZ d dl m Z m Z m Z erZej ej_G dd� de�Zer�d dlZd dlZG dd� dee�ZdS ) � N)�devices)�BaseZMQTestCase�SkipTest� have_gevent� GreenTest�PYPY)�bytes�unicode� basestringc @ sL e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dS )� TestDevicec C s< t jt jt jfD ]&}t�|t jt j�}| �|j|� ~qd S )N) �zmqZSTREAMERZ FORWARDER�QUEUEr �DeviceZPAIR� assertEqual� device_type)�selfZdevtype�dev� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/zmq/tests/test_device.py�test_device_types s z TestDevice.test_device_typesc C sX t �tjtjtj�}| �|jtj� | �|jtj� | �|j tj� | �|j d� ~d S )NT) r r r r ZSUBZPUBr Zin_typeZout_typer �daemon)r r r r r �test_device_attributes s z!TestDevice.test_device_attributesc C s t �� dv r tdt �� ��t�t jt jd�}| j�t j �}|� d�}|� d| � |� � t �d� d}|�|� | �|| �|�� ~|�� t�t jt jd�}| j�t j �}|� d�}|�d| � |� � t �d� d}|�|� | �|| �|�� ~|�� d S � N)z4.1.1z4.0.6z%libzmq-%s broke single-socket devices����tcp://127.0.0.1�tcp://127.0.0.1:%i� �?� hellos hello again)r � zmq_versionr r � ThreadDevicer �REP�context�socket�REQ�bind_to_random_portZ connect_in�start�time�sleep�sendr �recv�closeZ connect_out)r r �req�port�msgr r r �$test_single_socket_forwarder_connect s0 z/TestDevice.test_single_socket_forwarder_connectc C s t �� dv r tdt �� ��t�t jt jd�}|�d�}| j� t j �}|� d| � |� � t �d� d}|�|� | �|| �|�� ~|�� t�t jt jd�}|�d�}| j� t j �}|� d| � |� � t �d� d}|�|� | �|| �|�� ~|�� d S r )r r r r r r r �bind_in_to_random_portr! r" r# �connectr% r& r' r( r r) r* )r r r, r+ r- r r r �!test_single_socket_forwarder_bind9 s0 z,TestDevice.test_single_socket_forwarder_bindc C st t �tjtjd�}d}g }d\}}|�|j|||d�|j|||d�g� |D ]"}||k s`||krL| �d| � qLd S )Nr r �i� i� �Zmin_portZmax_port�Unexpected port number: %i) r r r �PULL�PUSH�extendr/ �bind_out_to_random_port�fail�r r �ifaceZports�min�maxr, r r r �$test_device_bind_to_random_with_argsS s �z/TestDevice.test_device_bind_to_random_with_argsc C sp t �tjtjd�}d}z"td�D ]}|j|ddd� q W n( tjy` } zW Y d }~d S d }~0 0 | �d� d S )Nr r � i' i' r3 zShould have failed) r r r r5 r6 �ranger/ Z ZMQBindErrorr9 )r r r; �i�er r r �$test_device_bind_to_random_binderror` s � z/TestDevice.test_device_bind_to_random_binderrorc C s t �� dk rtd��t�t jt jt j�}d}|�|�}|�|�}|� |�}|� � t � d� d}| j �t j�}|�d||f � | j �t j�}|�d||f � | j �t j�} | �d||f � |�|� | j�||| g� | �|| �|�� | �|| �| �� d S )N�� � �Proxies only in libzmq >= 3r r r z%s:%i)r �zmq_version_infor r � ThreadProxyr5 r6 r/ r8 �bind_mon_to_random_portr% r& r' r! r" r0 r( �socketsr7 r r) ) r r r; r, Zport2Zport3r- �push�pull�monr r r � test_proxym s( zTestDevice.test_proxyc C s� t �� dk rtd��t�t jt jt j�}d}g }d\}}|�|j|||d�|j |||d�|j |||d�g� |D ]"}||k s�||krp| � d| � qpd S )NrD rG r r2 r3 r4 ) r rH r r rI r5 r6 r7 r/ r8 rJ r9 r: r r r �#test_proxy_bind_to_random_with_args� s �z.TestDevice.test_proxy_bind_to_random_with_argsN) �__name__� __module__� __qualname__r r r. r1 r> rC rO rP r r r r r s r c @ s e Zd Zdd� ZdS )�TestDeviceGreenc C s� | j �tj�}| j �tj�}| j�||g� |�d�}t� tj j tj ||�}|� d| � |�d� t�d�}|�� t� |j�}| �|�d�d� |�� |jdd� d S )Nr r s hirE rF T)�block)r! r" r r r# rK r7 r$ �gevent�spawn�greenZdevicer r0 r( �Timeoutr% r) r �get�cancel�kill)r �repr+ r, �g�timeoutZreceiverr r r �test_green_device� s z!TestDeviceGreen.test_green_deviceN)rQ rR rS r` r r r r rT � s rT )r& r r Z zmq.testsr r r r r Zzmq.utils.strtypesr r r �Contextr Zcontext_factoryr rV Z zmq.greenrT r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка