File: //usr/local/CyberCP/lib/python3.10/site-packages/tornado/test/__pycache__/wsgi_test.cpython-310.pyc
o
�hN � @ s� d dl Z d dlZd dlZd dlmZ d dlmZ d dlm Z m
Z
d dl m Z G dd� d�Z
G dd � d e
e �ZG d
d � d e
e �ZdS ) � N)� validator)�
RuleRouter)�AsyncHTTPTestCase�gen_test)�
WSGIContainerc @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
S )� WSGIAppMixinc C s t � ��N)�NotImplementedError��self� r �I/usr/local/CyberCP/lib/python3.10/site-packages/tornado/test/wsgi_test.py� get_executor s zWSGIAppMixin.get_executorc sP | � � � tjddd�| _� fdd�}td|| j�fd|| j�fd|| j�fg�S ) N� g333333�?)�timeoutc s t t| �� d�S )N��executor)r r )�appr r r
�make_container s z,WSGIAppMixin.get_app.<locals>.make_container�/simple�/barrier�/streaming_barrier)r � threading�Barrier�barrierr �simple_wsgi_app�barrier_wsgi_app�streaming_barrier_wsgi_app)r r r r r
�get_app s ��zWSGIAppMixin.get_appc C s d}dg}|||� d S )Nz200 OK)z Content-Typez
text/plainr )r �start_response�status�response_headersr r r
�
respond_plain" s zWSGIAppMixin.respond_plainc C s | � |� dgS )N� Hello world!)r" )r �environr r r r
r ' s
z WSGIAppMixin.simple_wsgi_appc C s> | � |� z| j�� }W n
tjy dg Y S w d| gS )N� broken barriers ok %d�r" r �waitr �BrokenBarrierError�r r$ r �nr r r
r + s
�
z WSGIAppMixin.barrier_wsgi_appc c sL � | � |� dV z| j�� }W n tjy dV Y d S w d| V d S )Ns ok r% s %dr& r) r r r
r 4 s �
�z'WSGIAppMixin.streaming_barrier_wsgi_appN) �__name__�
__module__� __qualname__r r r" r r r r r r r
r s r c @ �4 e Zd Zdd� Zdd� Zedd� �Zedd� �Zd S )
� WSGIContainerDummyExecutorTestc C s d S r r r
r r r
r @ s z+WSGIContainerDummyExecutorTest.get_executorc C � | � d�}| �|jd� d S �Nr r# ��fetch� assertEqual�body�r �responser r r
� test_simpleC �
z*WSGIContainerDummyExecutorTest.test_simplec � �V �| j �� t�| j�| �d��| j�| �d���I d H }|D ] }| �|jd� q d S )Nr r% � r �reset�asyncio�gather� http_clientr3 �get_urlr4 r5 �r �resps�respr r r
�test_concurrent_barrierG � �
��z6WSGIContainerDummyExecutorTest.test_concurrent_barrierc � r: )Nr s ok broken barrierr; rA r r r
�!test_concurrent_streaming_barrierQ rE z@WSGIContainerDummyExecutorTest.test_concurrent_streaming_barrierN�r+ r, r- r r8 r rD rF r r r r
r/ ? s
r/ c @ r. )
�WSGIContainerThreadPoolTestc C s
t j�� S r )�
concurrent�futures�ThreadPoolExecutorr
r r r
r ] s
z(WSGIContainerThreadPoolTest.get_executorc C r0 r1 r2 r6 r r r
r8 ` r9 z'WSGIContainerThreadPoolTest.test_simplec � �\ �| j �� t�| j�| �d��| j�| �d���I d H }| �ddgtdd� |D ��� d S )Nr � ok 0� ok 1c S � g | ]}|j �qS r �r5 ��.0rC r r r
�
<listcomp>k � zGWSGIContainerThreadPoolTest.test_concurrent_barrier.<locals>.<listcomp>� r r< r= r> r? r3 r@ r4 �sorted�r rB r r r
rD d � �
�"z3WSGIContainerThreadPoolTest.test_concurrent_barrierc � rL )Nr rM rN c S rO r rP rQ r r r
rS t rT zQWSGIContainerThreadPoolTest.test_concurrent_streaming_barrier.<locals>.<listcomp>rU rW r r r
rF m rX z=WSGIContainerThreadPoolTest.test_concurrent_streaming_barrierNrG r r r r
rH \ s
rH )r= �concurrent.futuresrI r �wsgiref.validater �tornado.routingr �tornado.testingr r � tornado.wsgir r r/ rH r r r r
�<module> s 3