Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/zmq/tests/__pycache__/test_monqueue.cpython-39.pyc
Ðазад
a a�h � @ sv d dl Z d dlmZ d dlZd dlmZ d dlmZmZmZ d dl m Z esXe� � dkrbej ej _G dd� de�ZdS ) � N)�TestCase)�devices)�BaseZMQTestCase�SkipTest�PYPY)�unicode)� � c @ sb e Zd Zg Zddd�Zdd� Zdd � Zd d � Zd d � Zdd� Z dd� Z dd� Z dd� Z dd� Z dS )�TestMonitoredQueue� � in� outc C s� t �tjtjtj||�| _| j�tj�}| j�tj�}| j�tj�}|� d�}|� d�}|� d�} |� tj |� | j� d| � | j� d| � | j�d| � | j�� t�d� z|�tj� W n tjy� Y n0 | j�|||g� |||fS )N�tcp://127.0.0.1�tcp://127.0.0.1:%ig�������?)r �ThreadMonitoredQueue�zmqZPAIR�PUB�device�context�socketZSUBZbind_to_random_port� setsockoptZ SUBSCRIBEZ connect_inZ connect_outZ connect_mon�start�time�sleep�recv_multipart�NOBLOCK�ZMQError�sockets�extend) �selfZmon_subZ in_prefixZ out_prefix�alice�bob�monZaportZbportZmport� 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_monqueue.py� build_device s* � z TestMonitoredQueue.build_devicec C s | j D ]}|�� ~q| `d S )N)r �closer )r r r# r# r$ �teardown_device2 s z"TestMonitoredQueue.teardown_devicec C sj | � � \}}}d�� }|�|� | �|�}| �||� d�� }|�|� | �|�}| �||� | �� d S )N� hello bob� hello alice�r% �split�send_multipartr � assertEqualr' )r r r! r" �alices�bobsr# r# r$ � test_reply8 s z TestMonitoredQueue.test_replyc C s� | � � \}}}d�� }|�|� d�� }|�|� d�� }|�|� | �|�}| �||� | �|�}| �||� | �|�}| �||� d�� }|�|� | �|�}| �||� | �� d S )Nr( � hello again� hello again and againr) r* )r r r! r" r. �alices2�alices3r/ r# r# r$ � test_queueD s$ z TestMonitoredQueue.test_queuec C s* | � � \}}}d�� }|�|� d�� }|�|� d�� }|�|� | �|�}| �||� | �|�}| �dg| |� | �|�}| �||� | �|�}| �||� | �|�}| �dg| |� d�� }|�|� | �|�}| �||� | �|�}| �dg| |� | �|�}| �dg| |� | �� d S )Nr( r1 r2 r r) r r* � r r r! r" r. r3 r4 r/ �monsr# r# r$ � test_monitorX s4 z TestMonitoredQueue.test_monitorc C s0 | � ddd�\}}}d�� }|�|� d�� }|�|� d�� }|�|� | �|�}| �||� | �|�}| �dg| |� | �|�}| �||� | �|�}| �||� | �|�}| �dg| |� d�� }|�|� | �|�}| �||� | �|�}| �dg| |� | �|�}| �dg| |� | �� d S )Nr s foos barr( r1 r2 r) r* r6 r# r# r$ � test_prefixt s4 z TestMonitoredQueue.test_prefixc C s� | � d�\}}}d�� }|�|� d�� }|�|� d�� }|�|� | �|�}| �||� | �|�}| �||� | �|�}| �||� d�� }|�|� | �|�}| �||� | �|�}| �dg| |� | �� d S )Nr r( r1 r2 r) r* r6 r# r# r$ �test_monitor_subscribe� s( z)TestMonitoredQueue.test_monitor_subscribec C s~ t �tjtjtjdd�}|| _|�tjd� |�tjd� |� tjd� |� d�}|� d�}| j � tj�}d|_| j � tj�}d|_| j�||g� |�d| � |�d| � |�� t�d� t�� d k�rd d g}||fD ]6}|�|� z|�tj� W q� tj�y Y q�0 q�d d g}|�dg| � | �|�} | � | dg| � |�| � | �|�} | � | dg| � | � � dS )z test router-router MQ devicesr r r r � a� br r )� r r s pings pongs hellos thereN) r r r �ROUTERr r � setsockopt_in�LINGER�setsockopt_out�setsockopt_monZbind_in_to_random_portZbind_out_to_random_portr r �DEALER�identityr r �connectr r r �zmq_version_infor, �recvr r r r- r' ) r �devZportaZportb�a�bZping_msg�s�msgZbmsgZamsgr# r# r$ �test_router_router� s@ z%TestMonitoredQueue.test_router_routerc C sX t �tjtjtj� | _}|�tjd� |� tjd� |� tjd� |� � | � � d S )Nr ) r r r r> rC r r r? r@ rA rB r r' )r rH r# r# r$ �test_default_mq_args� s z'TestMonitoredQueue.test_default_mq_argsc C sd | j �tj�}| j �tj�}| j �tj�}| j�|||g� td�}td�}| � t t j |||� d S )N�in�out) r r r r> rC r r r r Z assertRaises� TypeErrorr Zmonitoredqueue)r ZinsZoutsr7 r# r# r$ �test_mq_check_prefix� s z'TestMonitoredQueue.test_mq_check_prefixN)r r r )�__name__� __module__� __qualname__r r% r' r0 r5 r8 r9 r: rM rN rR r# r# r# r$ r s & r )r Zunittestr r r Z zmq.testsr r r Zzmq.utils.strtypesr rF �ContextZDeviceZcontext_factoryr r# r# r# r$ �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка