Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/tornado/test/__pycache__/concurrent_test.cpython-39.pyc
Ðазад
a _�h � @ s d dl mZ d dlZd dlZd dlZd dlZd dlmZmZm Z d dl m Z m Z d dl mZ d dlmZ d dlmZ d dlmZmZmZ G d d � d e�ZG d d � d e�ZG d d� de�ZG dd� de�Z G dd� de �Z G dd� de�Z G dd� de e�Z G dd� de�Z e!dk�r e�"� dS )� )�futuresN)�Future�run_on_executor�"future_set_result_unless_cancelled)�utf8� to_unicode)�gen)�IOStream)� TCPServer)� AsyncTestCase�bind_unused_port�gen_testc @ s e Zd Zdd� ZdS )�MiscFutureTestc C sv t � }t|d� | �|�� d� | �|�� � t � }|�� |�� }t|d� | �|�� |� |sr| �|�� d� d S �N�* )r r � assertEqual�resultZ assertFalseZ cancelled�cancel)�selfZfutZ is_cancelled� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/tornado/test/concurrent_test.py�'test_future_set_result_unless_cancelled" s z6MiscFutureTest.test_future_set_result_unless_cancelledN)�__name__� __module__� __qualname__r r r r r r ! s r c @ s e Zd Zejdd� �ZdS )� CapServerc c sN |� d�V }t|�}||�� kr,|�d� n|�td|�� �� |�� d S )N� s error already capitalized zok %s)� read_untilr �upper�writer �close)r �stream�address�datar r r � handle_stream6 s zCapServer.handle_streamN)r r r r � coroutiner$ r r r r r 5 s r c @ s e Zd ZdS )�CapErrorN)r r r r r r r r& B s r& c @ s e Zd Zdd� Zdd� ZdS )� BaseCapClientc C s || _ d S �N��port)r r* r r r �__init__G s zBaseCapClient.__init__c C sD t �dt|��}|d u r td��|�� \}}|dkr8|S t|��d S )Nz (.*) (.*) z did not match�ok)�re�matchr � Exception�groupsr& )r r# �m�status�messager r r �process_responseJ s z BaseCapClient.process_responseN)r r r r+ r4 r r r r r' F s r' c @ s e Zd Zejdd� �ZdS )�GeneratorCapClientc c s� t �d� tt�� �}t �d� |�d| jf�V |�t|d �� t �d� |�d�V }t �d� |� � t � | � |���d S )N� capitalizeZ connectingz 127.0.0.1� �readingr Z returning) �logging�debugr �socket�connectr* r r r r r �Returnr4 )r Z request_datar! r# r r r r6 V s z GeneratorCapClient.capitalizeN)r r r r r% r6 r r r r r5 U s r5 c sH e Zd Z� fdd�Z� fdd�Zdd� Zdd� Zd d � Zd d � Z� Z S ) �ClientTestMixinc s@ t t| ��� t� | _t� \}}| j�|g� | j|d�| _d S )Nr) ) �superr> �setUpr �serverr Z add_sockets� client_class�client)r �sockr* �� __class__r r r@ e s zClientTestMixin.setUpc s | j �� tt| ��� d S r( )rA �stopr? r> �tearDown�r rE r r rH l s zClientTestMixin.tearDownc C s8 | j �d�}| j�|| j� | �� | �|�� d� d S �NZhello�HELLO)rC r6 �io_loop� add_futurerG �waitr r �r �futurer r r � test_futurep s zClientTestMixin.test_futurec C s8 | j �d�}| j�|| j� | �� | �td|j� d S )NrK �already capitalized) rC r6 rL rM rG rN �assertRaisesRegexpr& r rO r r r �test_future_errorv s z!ClientTestMixin.test_future_errorc s" t j� fdd��}� j�|� d S )Nc 3 s � j �d�V } � �| d� d S rJ )rC r6 r )r rI r r �f} s z)ClientTestMixin.test_generator.<locals>.f�r r% rL Zrun_sync�r rU r rI r �test_generator| s z ClientTestMixin.test_generatorc s" t j� fdd��}� j�|� d S )Nc 3 s> � � td�� � j�d�V W d � n1 s00 Y d S )NrR rK )rS r& rC r6 r rI r r rU � s z/ClientTestMixin.test_generator_error.<locals>.frV rW r rI r �test_generator_error� s z$ClientTestMixin.test_generator_error) r r r r@ rH rQ rT rX rY � __classcell__r r rE r r> d s r> c @ s e Zd ZeZdS )�GeneratorClientTestN)r r r r5 rB r r r r r[ � s r[ c @ s< e Zd Zedd� �Zedd� �Zedd� �Zedd� �Zd S ) �RunOnExecutorTestc c s0 G dd� dt �}|� }|�� V }| �|d� d S )Nc @ s e Zd Zdd� Zedd� �ZdS )z1RunOnExecutorTest.test_no_calling.<locals>.Objectc S s t j�d�| _d S �N� �r �thread�ThreadPoolExecutor�executorrI r r r r+ � s z:RunOnExecutorTest.test_no_calling.<locals>.Object.__init__c S s dS r r rI r r r rU � s z3RunOnExecutorTest.test_no_calling.<locals>.Object.fN�r r r r+ r rU r r r r �Object� s rd r ��objectrU r �r rd �o�answerr r r �test_no_calling� s z!RunOnExecutorTest.test_no_callingc c s0 G dd� dt �}|� }|�� V }| �|d� d S )Nc @ s" e Zd Zdd� Ze� dd� �ZdS )z8RunOnExecutorTest.test_call_with_no_args.<locals>.Objectc S s t j�d�| _d S r] r_ rI r r r r+ � s zARunOnExecutorTest.test_call_with_no_args.<locals>.Object.__init__c S s dS r r rI r r r rU � s z:RunOnExecutorTest.test_call_with_no_args.<locals>.Object.fNrc r r r r rd � s rd r re rg r r r �test_call_with_no_args� s z(RunOnExecutorTest.test_call_with_no_argsc c s0 G dd� dt �}|� }|�� V }| �|d� d S )Nc @ s& e Zd Zdd� Zedd�dd� �ZdS )z9RunOnExecutorTest.test_call_with_executor.<locals>.Objectc S s t j�d�| _d S r] )r r` ra �_Object__executorrI r r r r+ � s zBRunOnExecutorTest.test_call_with_executor.<locals>.Object.__init__rl )rb c S s dS r r rI r r r rU � s z;RunOnExecutorTest.test_call_with_executor.<locals>.Object.fNrc r r r r rd � s rd r re rg r r r �test_call_with_executor� s z)RunOnExecutorTest.test_call_with_executorc # s: G dd� dt �}|� � � fdd�}|� V }| �|d� d S )Nc @ s" e Zd Zdd� Ze� dd� �ZdS )z2RunOnExecutorTest.test_async_await.<locals>.Objectc S s t j�d�| _d S r] r_ rI r r r r+ � s z;RunOnExecutorTest.test_async_await.<locals>.Object.__init__c S s dS r r rI r r r rU � s z4RunOnExecutorTest.test_async_await.<locals>.Object.fNrc r r r r rd � s rd c � s � � � I d H } | S r( )rU )ri �rh r r rU � s z-RunOnExecutorTest.test_async_await.<locals>.fr )rf r )r rd rU r r rn r �test_async_await� s z"RunOnExecutorTest.test_async_awaitN)r r r r rj rk rm ro r r r r r\ � s r\ �__main__)#Z concurrentr r9 r- r; ZunittestZtornado.concurrentr r r Ztornado.escaper r �tornador Ztornado.iostreamr Ztornado.tcpserverr Ztornado.testingr r r r r r/ r& rf r' r5 r> r[ r\ r �mainr r r r �<module> s( )?
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка