Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/zmq/tests/__pycache__/test_poll.cpython-39.pyc
Ðазад
a a�h\ � @ s� d dl Z d dlZd dlZd dlmZ d dlZd dlmZmZm Z dd� Z G dd� de�Z G dd � d e�Z er�d dl Z d d lmZ G d d � d e e �ZdS ) � N)�mark)�PollZMQTestCase� have_gevent� GreenTestc C s t �d� d S )N� �?)�time�sleep� r 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_poll.py�wait s r c @ sX e Zd ZejZdd� Zdd� Zdd� Zdd� Ze j e j � d �d d �d d � �Zdd� ZdS )�TestPollc C s( | � tjtj�\}}t� | �� }|�|tjtjB � |�|tjtjB � t|� � �}| � || tj� | � || tj� |� d� |� d� t� t|� � �}| � || tjtjB � | � || tjtjB � |� � |� � t|� � �}| � || tj� | � || tj� |� |� |� |� d S )N� msg1� msg2)�create_bound_pair�zmq�PAIRr �Poller�register�POLLIN�POLLOUT�dict�poll� assertEqual�send�recv� unregister��self�s1�s2�poller�socksr r r � test_pair s* zTestPoll.test_pairc C sx | � tjtj�\}}t� | �� }|�|tjtjB � |�|tjtjB � t |� � �}| � ||v d� | � || tj� |� d� t |� � �}| � ||v d� t �d� t |� � �}| � || tj� |�� t |� � �}| � || tj� |� d� t |� � �}| � ||v d� t �d� t |� � �}| � || tj� |�� t |� � �}| � || tj� |�|� |�|� d S )Nr r g �?r )r r ZREPZREQr r r r r r r r r r r r r r r r r � test_reqrep6 s8 zTestPoll.test_reqrepc C sv | � tjtj�\}}| �� }|�|tjtjB � |�|d� | �||v � | �||v � |�|d� | �||v � d S )Nr ) r r r r r r r � assertTrueZ assertFalse)r r r r r r r �test_no_eventsf s zTestPoll.test_no_eventsc C s | � tjtj�\}}|�tjd� t� | �� }|�|tj tj B � |�|tj � t |� � �}| � || tj � | � ||v d� |�d� t |� � �}| � || tj � t� t |� � �}| � || tj � |�� t |� � �}| � ||v d� |�|� |�|� d S )N� r r )r r ZPUBZSUB� setsockoptZ SUBSCRIBEr r r r r r r r r r r r r r r � test_pubsubp s( zTestPoll.test_pubsub�win�Windows)�reasonc C s� t �� \}}t �|d�}t �|d�}| �� }|�|tj� t|�d��}|i ksTJ �|� d� |� � t|�d��}||� � tjiks�J �|� � |� � d S )N�rb�wb� � x) �os�pipe�fdopenr r r r r r �write�flush�fileno�close)r �r�w�pr! r r r �test_raw� s zTestPoll.test_rawc C s� | � tjtj�\}}| �� }|�|tj� t�� }|�d�}t�� }| �|| dk � t�� }|�d�}t�� }| �|| dk � | �|| dk� t�� }|�d�}t�� }| �|| dk � | �|| dk� dS )zAmake sure Poller.poll timeout has the right units (milliseconds).�{�G�zt?皙�����?� ���MbP?i� r. N) r r r r r r r r r$ )r r r r �ticZevt�tocr r r � test_timeout� s" zTestPoll.test_timeoutN)�__name__� __module__� __qualname__r r r" r# r% r( r Zskipif�sys�platform� startswithr: rA r r r r r s 0 ! r c @ s e Zd Zdd� Zdd� ZdS )� TestSelectc C sv | � tjtj�\}}t� t�||g||g||g�\}}}| �||v � | �||v � | �||v� | �||v� d S )N)r r r r �selectZassert_)r r r ZrlistZwlistZxlistr r r r" � s zTestSelect.test_pairc C s� | � tjtj�\}}t�� }t�||gg g d�\}}}t�� }| �|| dk � | �|| dk� t�� }t�||gg g d�\}}}t�� }| �|| dk � | �|| dk� dS )z7make sure select timeout has the right units (seconds).r; r. r> r r< N)r r r r rI r$ )r r r r? r7 r8 �xr@ r r r rA � s zTestSelect.test_timeoutN)rB rC rD r" rA r r r r rH � s rH )�greenc @ s" e Zd ZejZdd� Zdd� ZdS )� TestPollGreenc s| | � tjtj�\�}| �� � � �|tj� t�� }t�� fdd��}t��fdd��}|� � t�� }| � || dk � d S )Nc s � � d�S �Ni' �r r )r r r �<lambda>� r& z+TestPollGreen.test_wakeup.<locals>.<lambda>c s � � d�S �Nr �r r �r r r rO � r& r. ) r r r r r r r �gevent�spawn�joinr$ )r r r? r7 �sr@ r )r r r � test_wakeup� s zTestPollGreen.test_wakeupc sf | � tjtj�\� �t�� }t��fdd��}t�� fdd��}|�� t�� }| �|| dk � d S )Nc s � � d�S rM rN r )r r r rO � r& z0TestPollGreen.test_socket_poll.<locals>.<lambda>c s � � d�S rP rQ r rR r r rO � r& r. )r r r r rS rT rU r$ )r r? r7 rV r@ r )r r r �test_socket_poll� s z TestPollGreen.test_socket_pollN)rB rC rD �gzmqr rW rX r r r r rL � s rL )r0 rE r Zpytestr r Z zmq.testsr r r r r rH rS rK rY rL r r r r �<module> s $
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка