Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/tornado/test/__pycache__/websocket_test.cpython-39.pyc
Ðазад
a _�h�n � @ sP d dl Z d dlZd dlZd dlZd dlmZ d dlmZ d dlm Z m Z d dl m Z d dl mZmZ d dlmZ d dlmZ d d lmZmZmZmZ d d lmZmZ zd dl Zd d l m Z W n e y� e� � � Y n0 d d l m!Z!m"Z"m#Z#m$Z$ zd d lm%Z% W n e �y dZ%Y n0 G dd� de!�Z&G dd� de&�Z'G dd� de&�Z(G dd� de&�Z)G dd� de&�Z*G dd� de�Z+G dd� de&�Z,G d d � d e&�Z-G d d � d e&�Z.G d d!� d!e&�Z/G d"d#� d#e&�Z0G d$d%� d%e&�Z1G d&d'� d'e&�Z2G d(d)� d)e&�Z3G d*d+� d+e&�Z4G d,d-� d-e&�Z5G d.d/� d/e�Z6G d0d1� d1e6�Z7G d2d3� d3e&�Z8G d4d5� d5e6�Z9G d6d7� d7e:�Z;G d8d9� d9e;�Z<G d:d;� d;e<e6�Z=G d<d=� d=e<e6�Z>G d>d?� d?e<e6�Z?G d@dA� dAe;e6�Z@G dBdC� dCe:�ZAG dDdE� dEeAejB�ZCe�De%du dF�G dGdH� dHeAejB��ZEG dIdJ� dJe6�ZFG dKdL� dLe6�ZGG dMdN� dNe6�ZHG dOdP� dPe6�ZIdS )Q� N)�Future)�gen)� HTTPError� HTTPRequest)�Event)�gen_log�app_log��SimpleAsyncHTTPClient)� DictLoader)�AsyncHTTPTestCase�gen_test�bind_unused_port� ExpectLog)� Application�RequestHandler��_websocket_mask_python)�WebSocketHandler�websocket_connect�WebSocketError�WebSocketClosedError)�speedupsc @ s* e Zd ZdZd dd�Zdd� Zdd� ZdS ) �TestWebSocketHandlerz�Base class for testing handlers that exposes the on_close event. This allows for tests to see the close code and reason on the server side. Nc C s || _ || _d S �N)� close_future�compression_options)�selfr r � r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/tornado/test/websocket_test.py� initialize0 s z TestWebSocketHandler.initializec C s | j S r �r �r r r r �get_compression_options4 s z,TestWebSocketHandler.get_compression_optionsc C s" | j d ur | j �| j| jf� d S r )r Z set_result� close_code� close_reasonr" r r r �on_close7 s z TestWebSocketHandler.on_close)NN)�__name__� __module__� __qualname__�__doc__r r# r& r r r r r ( s r c @ s e Zd Zejdd� �ZdS )� EchoHandlerc c sB z| � |t|t��V W n$ tjy, Y n ty< Y n0 d S r )� write_message� isinstance�bytes�asyncioZCancelledErrorr �r �messager r r � on_message= s zEchoHandler.on_messageN)r' r( r) r � coroutiner2 r r r r r+ < s r+ c @ s e Zd Zdd� ZdS )�ErrorInOnMessageHandlerc C s dd d S )N� r r r0 r r r r2 H s z"ErrorInOnMessageHandler.on_messageN�r' r( r) r2 r r r r r4 G s r4 c @ s e Zd Zdd� ZdS )� HeaderHandlerc C s� t �| jd�t �| jd�t �| jdd�t �| jdd�t �| jd�| j| jg}|D ]*}z|� t d��W qP t yx Y qP0 qP| � | j j �dd�� d S ) NzThis should not workzhttp://localhost/elsewhere�X-Test� Z ChocolateZChipi� z did not get expected exception)� functools�partial�write�redirect� set_header� set_cookieZ set_status�flush�finish� Exception� RuntimeErrorr, �request�headers�get)r Zmethods_to_test�methodr r r �openM s � zHeaderHandler.openN�r' r( r) rH r r r r r7 L s r7 c @ s e Zd Zdd� Zdd� ZdS )�HeaderEchoHandlerc C s | � dd� d S )N�X-Extra-Response-Header�Extra-Response-Value)r> r" r r r �set_default_headersc s z%HeaderEchoHandler.set_default_headersc C s4 | j j�� D ]"\}}|�� �d�r | �||� q d S )Nzx-test)rD rE �get_all�lower� startswithr> )r �k�vr r r �preparef s zHeaderEchoHandler.prepareN)r' r( r) rM rS r r r r rJ b s rJ c @ s e Zd Zdd� ZdS )�NonWebSocketHandlerc C s | � d� d S )N�ok)r< r" r r r rF m s zNonWebSocketHandler.getN)r' r( r) rF r r r r rT l s rT c @ s e Zd Zdd� ZdS )�CloseReasonHandlerc C s d| _ | �dd� d S )NF�� �goodbye)Zon_close_called�closer" r r r rH r s zCloseReasonHandler.openNrI r r r r rV q s rV c @ s" e Zd Zejdd� �Zdd� ZdS )�AsyncPrepareHandlerc c s t jV d S r )r Zmomentr" r r r rS x s zAsyncPrepareHandler.preparec C s | � |� d S r �r, r0 r r r r2 | s z AsyncPrepareHandler.on_messageN)r' r( r) r r3 rS r2 r r r r rZ w s rZ c @ s e Zd Zdd� ZdS )�PathArgsHandlerc C s | � |� d S r r[ )r �argr r r rH � s zPathArgsHandler.openNrI r r r r r\ � s r\ c s* e Zd Z� fdd�Zejdd� �Z� ZS )�CoroutineOnMessageHandlerc s t t| �jf i |�� d| _d S �Nr )�superr^ r �sleeping�r �kwargs�� __class__r r r � s z$CoroutineOnMessageHandler.initializec c sJ | j dkr| �d� | j d7 _ t�d�V | j d8 _ | �|� d S �Nr z%another coroutine is already sleepingr5 �{�G�z�?�ra r, r �sleepr0 r r r r2 � s z$CoroutineOnMessageHandler.on_message)r' r( r) r r r3 r2 � __classcell__r r rd r r^ � s r^ c @ s e Zd Zdd� ZdS )�RenderMessageHandlerc C s | � | jd|d�� d S )N� message.html)r1 )r, Z render_stringr0 r r r r2 � s z RenderMessageHandler.on_messageNr6 r r r r rk � s rk c s, e Zd Z� fdd�Zdd� Zdd� Z� ZS )�SubprotocolHandlerc s t t| �jf i |�� d| _d S �NF)r` rm r �select_subprotocol_calledrb rd r r r � s z SubprotocolHandler.initializec C s$ | j rtd��d| _ d|v r dS d S )Nz select_subprotocol called twiceT� goodproto)ro rB )r � subprotocolsr r r �select_subprotocol� s z%SubprotocolHandler.select_subprotocolc C s" | j std��| �d| j � d S )Nz select_subprotocol not calledzsubprotocol=%s)ro rB r, �selected_subprotocolr" r r r rH � s zSubprotocolHandler.open)r' r( r) r rr rH rj r r rd r rm � s rm c s2 e Zd Z� fdd�Zejdd� �Zdd� Z� ZS )�OpenCoroutineHandlerc s& t t| �jf i |�� || _d| _d S rn )r` rt r �test� open_finished)r ru rc rd r r r � s z OpenCoroutineHandler.initializec c s$ | j j�� V t�d�V d| _d S )Nrg T)ru � message_sent�waitr ri rv r" r r r rH � s zOpenCoroutineHandler.openc C s | j std��| �d� d S )Nz&on_message called before open finishedrU )rv rB r, r0 r r r r2 � s z OpenCoroutineHandler.on_message) r' r( r) r r r3 rH r2 rj r r rd r rt � s rt c @ s e Zd Zdd� ZdS )�ErrorInOpenHandlerc C s t d��d S )N�boom)rB r" r r r rH � s zErrorInOpenHandler.openNrI r r r r ry � s ry c @ s e Zd Zdd� ZdS )�ErrorInAsyncOpenHandlerc � s t �d�I d H td��d S )Nr rz )r/ ri rB r" r r r rH � s z ErrorInAsyncOpenHandler.openNrI r r r r r{ � s r{ c @ s e Zd Zdd� ZdS )�NoDelayHandlerc C s | � d� | �d� d S )NT�hello)Z set_nodelayr, r" r r r rH � s zNoDelayHandler.openNrI r r r r r| � s r| c @ s e Zd Zejdd� �ZdS )�WebSocketBaseTestCasec k s, t d| �� |f fi |��V }t�|��d S )Nzws://127.0.0.1:%d%s)r � get_http_portr �Return)r �pathrc �wsr r r � ws_connect� s ��z WebSocketBaseTestCase.ws_connectN)r' r( r) r r3 r� r r r r r~ � s r~ c s� e Zd Zdd� Zdd� Z� fdd�Zdd� Zd d � Zd d � Ze d d� �Z dd� Z e dd� �Z e dd� �Z e dd� �Ze dd� �Ze dd� �Ze dd � �Ze d d � �Ze d d � �Ze d!d"� �Ze d#d$� �Ze d%d&� �Ze d'd(� �Ze d)d*� �Ze d+d,� �Ze d-d.� �Ze d/d0� �Ze d1d2� �Z e d3d4� �Z e d5d6� �Z e d7d8� �Z e d9d:� �Z e d;d<� �Z!e d=d>� �Z"e d?d@� �Z#e dAdB� �Z$e dCdD� �Z%e dEdF� �Z&� Z'S )G� WebSocketTestc C s� t � | _tdtt| jd�fdtfdtt| jd�fdtt| jd�fdtt| jd�fdt t| jd�fdt t| jd�fd t t| jd�fd t t| jd�fd t t| jd�fd tt| jd�fd tt| j| d�fdtfdtfdtfgtddi�d�S )N�/echo)r �/non_wsz/headerz /header_echo� /close_reason�/error_in_on_message�/async_preparez/path_args/(.*)� /coroutine�/render� /subprotocol�/open_coroutine)r ru �/error_in_open�/error_in_async_open�/nodelayrl z<b>{{ message }}</b>)Ztemplate_loader)r r r r+ �dictrT r7 rJ rV r4 rZ r\ r^ rk rm rt ry r{ r| r r" r r r �get_app� sX � � � � � � � ��1 �zWebSocketTest.get_appc C s t � S r r r" r r r �get_http_client s z WebSocketTest.get_http_clientc s t t| ��� tj�� d S r )r` r� �tearDownr Z_template_loaders�clearr" rd r r r� s zWebSocketTest.tearDownc C s | � d�}| �|jd� d S )Nr� � ��fetch� assertEqual�code�r �responser r r �test_http_request s z WebSocketTest.test_http_requestc C s( | j ddddd�d�}| �|jd� d S )Nr� �Upgrade� WebSocketZ13�� Connectionr� zSec-WebSocket-Version�rE r� r� r� r r r �test_missing_websocket_key s ��z(WebSocketTest.test_missing_websocket_keyc C s( | j ddddd�d�}| �|jd� d S )Nr� r� r� Z12r� r� i� r� r� r r r �test_bad_websocket_version( s ��z(WebSocketTest.test_bad_websocket_versionc c s2 | � d�V }|�d�V |�� V }| �|d� d S )Nr� r} �r� r, � read_messager� �r r� r� r r r �test_websocket_gen3 s z WebSocketTest.test_websocket_genc sx t d� �� � jd� � �� �� }|�d� |�� j� � �� �� }� �|d� � j� � fdd�� |� � � �� d S )N�ws://127.0.0.1:%d/echo)�callbackr} c s � � � S r )�stop)�fr" r r �<lambda>C � z8WebSocketTest.test_websocket_callbacks.<locals>.<lambda>) r r r� rx �resultr, r� r� r Zadd_done_callbackrY r� r r" r �test_websocket_callbacks: s � z&WebSocketTest.test_websocket_callbacksc c s4 | � d�V }|jddd� |�� V }| �|d� d S )Nr� s hello �T��binaryr� r� r r r �test_binary_messageG s z!WebSocketTest.test_binary_messagec c s0 | � d�V }|�d� |�� V }| �|d� d S )Nr� u hello ér� r� r r r �test_unicode_messageN s z"WebSocketTest.test_unicode_messagec c s0 | � d�V }|�d� |�� V }| �|d� d S )Nr� r} z <b>hello</b>r� r� r r r �test_render_messageU s z!WebSocketTest.test_render_messagec c sZ | � d�V }|�d� ttd�� |�� V }W d � n1 s@0 Y | �|d � d S )Nr� r} �Uncaught exception)r� r, r r r� �assertIsr� r r r �test_error_in_on_message\ s (z&WebSocketTest.test_error_in_on_messagec c sJ | � t�� }| �d�V W d � n1 s,0 Y | �|jjd� d S )Nz /notfoundi� )� assertRaisesr r� r� � exceptionr� )r �cmr r r �test_websocket_http_faild s *z&WebSocketTest.test_websocket_http_failc c s: | � t�� | �d�V W d � n1 s,0 Y d S )Nr� )r� r r� r" r r r �test_websocket_http_successj s z)WebSocketTest.test_websocket_http_successc c s| t � \}}|�� | �t��L ttd��" td| dd�V W d � n1 sP0 Y W d � n1 sn0 Y d S )Nz.*zws://127.0.0.1:%d/i )�connect_timeout)r rY r� �IOErrorr r r )r �sock�portr r r �test_websocket_network_failo s �z)WebSocketTest.test_websocket_network_failc c s4 t d| �� �V }|�d� |�d� |j�� d S )Nr� r} Zworld)r r r, �streamrY �r r� r r r �"test_websocket_close_buffered_datay s z0WebSocketTest.test_websocket_close_buffered_datac c s8 t td| �� ddid��V }|�� V }| �|d� d S )Nzws://127.0.0.1:%d/headerr8 r} r� )r r r r� r� r� r r r �test_websocket_headers� s �� z$WebSocketTest.test_websocket_headersc c sJ t td| �� ddid��V }| �|j�d�d� | �|j�d�d� d S )Nz ws://127.0.0.1:%d/header_echoz X-Test-Hellor} r� rK rL )r r r r� rE rF r� r r r �test_websocket_header_echo� s �� �z(WebSocketTest.test_websocket_header_echoc c sZ | � d�V }|�� V }| �|d � | �|jd� | �|jd� | jV \}}| �|d� d S )Nr� rW rX )r� r� r� r� r$ r% r )r r� �msgr� �reasonr r r �test_server_close_reason� s z&WebSocketTest.test_server_close_reasonc c s@ | � d�V }|�dd� | jV \}}| �|d� | �|d� d S )Nr� rW rX )r� rY r r� )r r� r� r� r r r �test_client_close_reason� s z&WebSocketTest.test_client_close_reasonc c sZ | � d�V }|�� V }| �|d � | �t�� |�d� W d � n1 sL0 Y d S )Nr� r} )r� r� r� r� r r, )r r� r� r r r �test_write_after_close� s z$WebSocketTest.test_write_after_closec c s0 | � d�V }|�d� |�� V }| �|d� d S )Nr� r} r� �r r� �resr r r �test_async_prepare� s z WebSocketTest.test_async_preparec c s& | � d�V }|�� V }| �|d� d S )Nz/path_args/hellor} �r� r� r� r� r r r �test_path_args� s z WebSocketTest.test_path_argsc c sT | � d�V }|�d�V |�d�V |�� V }| �|d� |�� V }| �|d� d S )Nr� �hello1�hello2r� r� r r r �test_coroutine� s z WebSocketTest.test_coroutinec c sR | � � }d| }dd| i}tt||d��V }|�d� |�� V }| �|d� d S )Nr� �Originzhttp://127.0.0.1:%dr� r} �r r r r, r� r� �r r� �urlrE r� r� r r r � test_check_origin_valid_no_path� s z-WebSocketTest.test_check_origin_valid_no_pathc c sR | � � }d| }dd| i}tt||d��V }|�d� |�� V }| �|d� d S )Nr� r� z http://127.0.0.1:%d/somethingr� r} r� r� r r r �!test_check_origin_valid_with_path� s z/WebSocketTest.test_check_origin_valid_with_pathc c sl | � � }d| }dd| i}| �t��"}tt||d��V W d � n1 sN0 Y | �|jjd� d S )Nr� r� z 127.0.0.1:%dr� � �r r� r r r r� r� r� �r r� r� rE r� r r r �%test_check_origin_invalid_partial_url� s 0z3WebSocketTest.test_check_origin_invalid_partial_urlc c sh | � � }d| }ddi}| �t��"}tt||d��V W d � n1 sJ0 Y | �|jjd� d S )Nr� r� zhttp://somewhereelse.comr� r� r� r� r r r �test_check_origin_invalid� s 0z'WebSocketTest.test_check_origin_invalidc c sh | � � }d| }ddi}| �t��"}tt||d��V W d � n1 sJ0 Y | �|jjd� d S )Nzws://localhost:%d/echor� zhttp://subtenant.localhostr� r� r� r� r r r �$test_check_origin_invalid_subdomains s 0z2WebSocketTest.test_check_origin_invalid_subdomainsc c s< | j dddgd�V }| �|jd� |�� V }| �|d� d S )Nr� Zbadprotorp )rq zsubprotocol=goodproto)r� r� rs r� r� r r r �test_subprotocols s � z WebSocketTest.test_subprotocolsc c s4 | � d�V }| �|jd � |�� V }| �|d� d S )Nr� zsubprotocol=None)r� r� rs r� r� r� r r r � test_subprotocols_not_offered s z+WebSocketTest.test_subprotocols_not_offeredc c sD t � | _| �d�V }|�d�V | j�� |�� V }| �|d� d S )Nr� r} rU )r rw r� r, �setr� r� r� r r r �test_open_coroutine% s z!WebSocketTest.test_open_coroutinec c sN t td��& | �d�V }|�� V }W d � n1 s60 Y | �|� d S )Nr� r� �r r r� r� � assertIsNoner� r r r �test_error_in_open. s (z WebSocketTest.test_error_in_openc c sN t td��& | �d�V }|�� V }W d � n1 s60 Y | �|� d S )Nr� r� r� r� r r r �test_error_in_async_open5 s (z&WebSocketTest.test_error_in_async_openc c s& | � d�V }|�� V }| �|d� d S )Nr� r} r� r� r r r � test_nodelay< s zWebSocketTest.test_nodelay)(r' r( r) r� r� r� r� r� r� r r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� rj r r rd r r� � s~ 7 r� c s$ e Zd Z� fdd�Zdd� Z� ZS )� NativeCoroutineOnMessageHandlerc s t � jf i |�� d| _d S r_ )r` r ra rb rd r r r D s z*NativeCoroutineOnMessageHandler.initializec � sN | j dkr| �d� | j d7 _ t�d�I d H | j d8 _ | �|� d S rf rh r0 r r r r2 H s z*NativeCoroutineOnMessageHandler.on_message)r' r( r) r r2 rj r r rd r r� C s r� c @ s e Zd Zdd� Zedd� �ZdS )� WebSocketNativeCoroutineTestc C s t dtfg�S )N�/native)r r� r" r r r r� R s z$WebSocketNativeCoroutineTest.get_appc c sT | � d�V }|�d�V |�d�V |�� V }| �|d� |�� V }| �|d� d S )Nr� r� r� r� r� r r r �test_native_coroutineU s z2WebSocketNativeCoroutineTest.test_native_coroutineN)r' r( r) r� r r� r r r r r� Q s r� c @ s@ e Zd ZdZdd� Zdd� Zdd� Zedd � �Zed d � �Z d S ) �CompressionTestMixinz Hello world. Testing 123 123c C s< G dd� dt �}tdtt| �� d�fd|t| �� d�fg�S )Nc @ s e Zd Zedd� �Zdd� ZdS )z4CompressionTestMixin.get_app.<locals>.LimitedHandlerc S s dS )N� r r" r r r �max_message_sizef s zECompressionTestMixin.get_app.<locals>.LimitedHandler.max_message_sizec S s | � tt|��� d S r )r, �str�lenr0 r r r r2 j s z?CompressionTestMixin.get_app.<locals>.LimitedHandler.on_messageN)r' r( r) �propertyr� r2 r r r r �LimitedHandlere s r� r� r! �/limited)r r r+ r� � get_server_compression_options)r r� r r r r� d s � ���z CompressionTestMixin.get_appc C s d S r r r" r r r r� | s z3CompressionTestMixin.get_server_compression_optionsc C s d S r r r" r r r � get_client_compression_options s z3CompressionTestMixin.get_client_compression_optionsc c s� | j d| �� d�V }td�D ](}|�| j� |�� V }| �|| j� q | �|jjt | j�d � | �|jj t | j�d � | � |jj |jj � d S )Nr� r! � )r� r� �ranger, �MESSAGEr� r� �protocolZ_message_bytes_outr� Z_message_bytes_in�verify_wire_bytesZ_wire_bytes_inZ_wire_bytes_out�r r� �ir� r r r �test_message_sizes� s � z'CompressionTestMixin.test_message_sizesc c sV | j d| �� d�V }|�d� |�� V }| �|d� |�d� |�� V }| �|� d S )Nr� r! Z�aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaZ128A aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa)r� r� r, r� r� r� r� r r r �test_size_limit� s � z$CompressionTestMixin.test_size_limitN) r' r( r) r� r� r� r� r r� r r r r r r� a s r� c @ s e Zd ZdZdd� ZdS )�UncompressedTestMixinzESpecialization of CompressionTestMixin when we expect no compression.c C s8 | � |dt| j�d � | � |dt| j�d � d S )Nr� � � )r� r� r� �r Zbytes_inZ bytes_outr r r r� � s z'UncompressedTestMixin.verify_wire_bytesN)r' r( r) r* r� r r r r r � s r c @ s e Zd ZdS )�NoCompressionTestN)r' r( r) r r r r r � s r c @ s e Zd Zdd� ZdS )�ServerOnlyCompressionTestc C s i S r r r" r r r r� � s z8ServerOnlyCompressionTest.get_server_compression_optionsN)r' r( r) r� r r r r r � s r c @ s e Zd Zdd� ZdS )�ClientOnlyCompressionTestc C s i S r r r" r r r r� � s z8ClientOnlyCompressionTest.get_client_compression_optionsN)r' r( r) r� r r r r r � s r c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�DefaultCompressionTestc C s i S r r r" r r r r� � s z5DefaultCompressionTest.get_server_compression_optionsc C s i S r r r" r r r r� � s z5DefaultCompressionTest.get_client_compression_optionsc C sH | � |dt| j�d � | � |dt| j�d � | �||d � d S )Nr� r r � )Z assertLessr� r� r� r r r r r� � s z(DefaultCompressionTest.verify_wire_bytesN)r' r( r) r� r� r� r r r r r � s r c @ s e Zd Zdd� ZdS )�MaskFunctionMixinc C s| | � | �dd�d� | � | �dd�d� | � | �dd�d� | � | �dd�d � | � | �d d �d � | � | �d d�d� d S )Ns abcdr� � b� s 54321s TVPVPs ZXCVs 98765432s c`t`olpds s ������s ������s ����s s ������)r� �maskr" r r r � test_mask� s � �zMaskFunctionMixin.test_maskN)r' r( r) r r r r r r � s r c @ s e Zd Zdd� ZdS )�PythonMaskFunctionTestc C s t ||�S r r �r r �datar r r r � s zPythonMaskFunctionTest.maskN�r' r( r) r r r r r r � s r z#tornado.speedups module not presentc @ s e Zd Zdd� ZdS )�CythonMaskFunctionTestc C s t �||�S r )r Zwebsocket_maskr r r r r � s zCythonMaskFunctionTest.maskNr r r r r r � s r c @ s e Zd Zdd� Zedd� �ZdS )�ServerPeriodicPingTestc C s" G dd� dt �}td|fgdd�S )Nc @ s e Zd Zdd� ZdS )z3ServerPeriodicPingTest.get_app.<locals>.PingHandlerc S s | � d� d S )N�got pongr[ �r r r r r �on_pong� s z;ServerPeriodicPingTest.get_app.<locals>.PingHandler.on_pongN)r' r( r) r r r r r � PingHandler� s r �/rg )Zwebsocket_ping_interval�r r �r r r r r r� � s z ServerPeriodicPingTest.get_appc c s4 | � d�V }td�D ]}|�� V }| �|d� qd S )Nr r� r �r� r� r� r� r� r r r �test_server_ping� s z'ServerPeriodicPingTest.test_server_pingN)r' r( r) r� r r r r r r r � s r c @ s e Zd Zdd� Zedd� �ZdS )�ClientPeriodicPingTestc C s G dd� dt �}td|fg�S )Nc @ s e Zd Zdd� ZdS )z3ClientPeriodicPingTest.get_app.<locals>.PingHandlerc S s | � d� d S )N�got pingr[ r r r r �on_ping� s z;ClientPeriodicPingTest.get_app.<locals>.PingHandler.on_pingN�r' r( r) r r r r r r � s r r r r r r r r� � s z ClientPeriodicPingTest.get_appc c s8 | j ddd�V }td�D ]}|�� V }| �|d� qd S )Nr rg )Z ping_intervalr� r r r� r r r �test_client_ping� s z'ClientPeriodicPingTest.test_client_pingN)r' r( r) r� r r" r r r r r � s r c @ s e Zd Zdd� Zedd� �ZdS )�ManualPingTestc C s G dd� dt �}td|fg�S )Nc @ s e Zd Zdd� ZdS )z+ManualPingTest.get_app.<locals>.PingHandlerc S s | j |t|t�d� d S )Nr� )r, r- r. r r r r r s z3ManualPingTest.get_app.<locals>.PingHandler.on_pingNr! r r r r r s r r r r r r r r� s zManualPingTest.get_appc c s` | � d�V }| �t|jd� |�d� |�� V }| �|d� |�d� |�� V }| �|d� d S )Nr Z~aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaar} s hellos binary hello)r� r� � ValueErrorZpingr� r� )r r� �respr r r �test_manual_ping s z ManualPingTest.test_manual_pingN)r' r( r) r� r r& r r r r r# s r# c @ s e Zd Zdd� Zedd� �ZdS )�MaxMessageSizeTestc C s t dtfgdd�S )Nr r� )Zwebsocket_max_message_size)r r+ r" r r r r� ! s zMaxMessageSizeTest.get_appc c st | � d�V }d}|�|� |�� V }| �||� |�|d � |�� V }| �|d � | �|jd� | �|jd� d S )Nr A aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa�bi� zmessage too big)r� r, r� r� r� r$ r% )r r� r� r% r r r �test_large_message$ s z%MaxMessageSizeTest.test_large_messageN)r' r( r) r� r r) r r r r r' s r' )Jr/ r: � tracebackZunittestZtornado.concurrentr �tornador Ztornado.httpclientr r Z tornado.locksr Z tornado.logr r Ztornado.simple_httpclientr Ztornado.templater Ztornado.testingr r r r Z tornado.webr r Ztornado.websocketZ tornado.utilr � ImportError� print_excr r r r r r r+ r4 r7 rJ rT rV rZ r\ r^ rk rm rt ry r{ r| r~ r� r� r� �objectr� r r r r r r ZTestCaser ZskipIfr r r r# r' r r r r �<module> sv m@
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка