Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/tornado/test/__pycache__/twisted_test.cpython-39.pyc
Ðазад
a _�h� � @ s` d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlmZ d dl m Z d dl m Z d dl mZ d dlmZmZmZ d dlmZmZ z\d d lmZmZmZ d d lmZ d d l m Z d d l m Z m Z d d l!m"Z" d dl#m$Z$ dZ%W n e&y� dZ%Y n 0 d dl'Ze�(e%d�Z)dd� Z*dd� Z+e)G dd� dej,��Z-e)G dd� de��Z.e/dk�r\e�0� dS )� N)�utf8)�gen)�AsyncHTTPClient)� HTTPServer)�IOLoop)�bind_unused_port� AsyncTestCase�gen_test)�RequestHandler� Application)�Deferred�inlineCallbacks� returnValue)�Protocol)�AsyncioSelectorReactor)�Agent�readBody)�Resource)�SiteTFztwisted module not presentc C s@ i } t jt jt jfD ]}t �|�| |< qdt| �v r<td��| S )NZtwistedz)twisted signal handlers already installed)�signal�SIGINT�SIGTERM�SIGCHLD� getsignal�repr� Exception)�saved�sig� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/tornado/test/twisted_test.py�save_signal_handlers4 s r c C s" | � � D ]\}}t�||� qd S �N)�itemsr )r r �handlerr r r �restore_signal_handlers> s r$ c @ sd e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z dd� Z dS )�CompatibilityTestsc C s& t � | _t� | _| j�� t� | _d S r! )r � saved_signalsr �io_loopZ make_currentr �reactor��selfr r r �setUpI s zCompatibilityTests.setUpc C s0 | j �� | j�� | jjdd� t| j� d S )NT)Zall_fds)r( Z disconnectAllr' Z clear_current�closer$ r& r) r r r �tearDownO s zCompatibilityTests.tearDownc C s< G dd� dt �}t|� �}| jjd|dd�}|�� j| _d S )Nc @ s e Zd ZdZdd� ZdS )z>CompatibilityTests.start_twisted_server.<locals>.HelloResourceTc S s dS )N� Hello from twisted!r )r* �requestr r r � render_GETY s zICompatibilityTests.start_twisted_server.<locals>.HelloResource.render_GETN)�__name__� __module__� __qualname__ZisLeafr0 r r r r � HelloResourceV s r4 r z 127.0.0.1)Z interface)r r r( Z listenTCPZgetHost�port� twisted_port)r* r4 �siter5 r r r �start_twisted_serverU s z'CompatibilityTests.start_twisted_serverc C sJ G dd� dt �}td|fgdd� d�}t|�}t� \}| _|�|g� d S )Nc @ s e Zd Zdd� ZdS )z=CompatibilityTests.start_tornado_server.<locals>.HelloHandlerc S s | � d� d S )NzHello from tornado!)�writer) r r r �getb s zACompatibilityTests.start_tornado_server.<locals>.HelloHandler.getN)r1 r2 r3 r: r r r r � HelloHandlera s r; �/c S s d S r! r )�xr r r �<lambda>e � z9CompatibilityTests.start_tornado_server.<locals>.<lambda>)Z log_function)r r r r � tornado_portZ add_sockets)r* r; Zapp�server�sockr r r �start_tornado_server` s z'CompatibilityTests.start_tornado_serverc C s" | j j| _| j j| _| j �� d S r! )r( �stop� stop_loop�runr) r r r � run_reactorj s z CompatibilityTests.run_reactorc s6 t � }t�|�|��}|�� fdd�� |� |�� S )Nc s � � � S r! )rE )�fr) r r r> y r? z2CompatibilityTests.tornado_fetch.<locals>.<lambda>)r �asyncioZ ensure_future�fetchZadd_done_callback�result)r* �url�runner�clientZfutr r) r � tornado_fetchv s z CompatibilityTests.tornado_fetchc sx g �t �j�}|�dt|��}G �fdd�dt�� � fdd�}|�|� �fdd�}|�|� |� ���� d���S ) N� GETc s( e Zd Zdd� Z� fdd�Zdd� ZdS )z5CompatibilityTests.twisted_fetch.<locals>.Accumulatorc S s || _ d S r! )�finished)r* rQ r r r �__init__� s z>CompatibilityTests.twisted_fetch.<locals>.Accumulator.__init__c s � � |� d S r! )�append)r* �data��chunksr r � dataReceived� s zBCompatibilityTests.twisted_fetch.<locals>.Accumulator.dataReceivedc S s | j �d � d S r! )rQ �callback)r* �reasonr r r �connectionLost� s zDCompatibilityTests.twisted_fetch.<locals>.Accumulator.connectionLostN)r1 r2 r3 rR rW rZ r rU r r � Accumulator� s r[ c s t � }| �� |�� |S r! )r Z deliverBody)�responserQ )r[ r r rX � s z2CompatibilityTests.twisted_fetch.<locals>.callbackc sH t � d�r� �� n0| d urDz | �� W n tjddd� Y n0 d S )NrE z exception before starting loopT)�exc_info)�hasattrrE ZraiseException�logging�error)Zfailurer) r r �shutdown� s z2CompatibilityTests.twisted_fetch.<locals>.shutdownr? ) r r( r/ r r Z addCallbackZaddBothZ assertTrue�join)r* rL rM rN �drX ra r )r[ rV r* r � twisted_fetch} s z CompatibilityTests.twisted_fetchc s6 d g� t j� ��fdd��}�j�|� |� � d S )Nc 3 sl t �j�} | �dt���V }t�� �, tjdtd� t|�V � d< W d � n1 sV0 Y �� � d S )NrP �ignore)�categoryr ) r r( r/ r �warnings�catch_warnings� simplefilter�DeprecationWarningr rE )rN r\ ��bodyr* rL r r rH � s ,z5CompatibilityTests.twisted_coroutine_fetch.<locals>.fr )r � coroutiner' Z add_callback)r* rL rM rH r rk r �twisted_coroutine_fetch� s z*CompatibilityTests.twisted_coroutine_fetchc C s. | � � | �d| j | j�}| �|jd� d S )N�http://127.0.0.1:%dr. )r8 rO r6 rG � assertEqualrl �r* r\ r r r �%testTwistedServerTornadoClientReactor� s �z8CompatibilityTests.testTwistedServerTornadoClientReactorc C s, | � � | �d| j | j�}| �|d� d S �Nro s Hello from tornado!)rC rd r@ rG rp rq r r r �%testTornadoServerTwistedClientReactor� s �z8CompatibilityTests.testTornadoServerTwistedClientReactorc C s, | � � | �d| j | j�}| �|d� d S rs )rC rn r@ rG rp rq r r r �.testTornadoServerTwistedCoroutineClientReactor� s �zACompatibilityTests.testTornadoServerTwistedCoroutineClientReactorN)r1 r2 r3 r+ r- r8 rC rG rO rd rn rr rt ru r r r r r% G s (r% c @ s$ e Zd Zedd� �Zedd� �ZdS )�ConvertDeferredTestc c s$ t dd� �}|� V }| �|d� d S )Nc s s t d� d S )N�* )r r r r r �fn� s z,ConvertDeferredTest.test_success.<locals>.fnrw )r rp )r* rx �resr r r � test_success� s z ConvertDeferredTest.test_successc c sB t dd� �}| �t�� |� V W d � n1 s40 Y d S )Nc s s dd d S )N� r r r r r r rx � s z,ConvertDeferredTest.test_failure.<locals>.fn)r Z assertRaises�ZeroDivisionError)r* rx r r r � test_failure� s z ConvertDeferredTest.test_failureN)r1 r2 r3 r rz r} r r r r rv � s rv �__main__)1rI r_ r Zunittestrg Ztornado.escaper �tornador Ztornado.httpclientr Ztornado.httpserverr Ztornado.ioloopr Ztornado.testingr r r Z tornado.webr r Ztwisted.internet.deferr r r Ztwisted.internet.protocolr Z twisted.internet.asyncioreactorr Ztwisted.web.clientr r Ztwisted.web.resourcer Ztwisted.web.serverr Z have_twisted� ImportErrorZtornado.platform.twistedZ skipUnlessZskipIfNoTwistedr r$ ZTestCaser% rv r1 �mainr r r r �<module> s@
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка