j d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlm Z d dl
m Z d dl m
Z
mZ d dlmZ d dlmZmZ d dlmZ d dlmZ d d lmZ d d
lmZm Z d d l m Z m Z m Z m!Z! d d l"m#Z#m$Z$ d dl%Z
d d
l&m'Z' n# e($ r ej) w xY wd dl%m*Z*m+Z+m,Z,m-Z- d dl
m.Z. n
# e($ r dZ.Y nw xY w G d de* Z/ G d de/ Z0 G d de/ Z1 G d de/ Z2 G d de/ Z3 G d de$ Z4 G d d e$ Z5 G d d e/ Z6 G d d!e/ Z7 G d" d#e/ Z8 G d$ d%e/ Z9 G d& d'e/ Z: G d( d)e/ Z; G d* d+e/ Z< G d, d-e/ Z= G d. d/e/ Z> G d0 d1e/ Z? G d2 d3e Z@ G d4 d5e@ ZA G d6 d7e/ ZB G d8 d9e@ ZCe G d: d;e@ ZDe G d< d=eD ZE G d> d?eE ZF G d@ dAeE ZG G dB dCeE ZH G dD dEeD ZIe G dF dGejJ ZK G dH dIeK ZL ejM e.du dJ G dK dLeK ZN G dM dNe@ ZO G dO dPe@ ZP G dQ dRe@ ZQ G dS dTejJ ZR G dU dVe@ ZS G dW dXe@ ZTdS )Y N)Future)gen) HTTPError HTTPRequest)Event)gen_logapp_log)ResolverSimpleAsyncHTTPClient)
DictLoader)abstract_base_testignore_deprecation)AsyncHTTPTestCasegen_testbind_unused_port ExpectLog) ApplicationRequestHandler_websocket_mask_python)WebSocketHandlerwebsocket_connectWebSocketErrorWebSocketClosedError)speedupsc & e Zd ZdZddZd Zd ZdS )TestWebSocketHandlerzBase 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 " || _ || _ d S N close_futurecompression_options)selfr" r# s h/var/www/finuniver-perm.ru/html/student/venv/lib/python3.11/site-packages/tornado/test/websocket_test.py
initializez TestWebSocketHandler.initialize6 s (#6 c | j S r r# r$ s r% get_compression_optionsz,TestWebSocketHandler.get_compression_options: s ''r' c d | j (| j | j | j f d S d S r )r"
set_result
close_code close_reasonr* s r% on_closez TestWebSocketHandler.on_close= s: ( ( ($/4;L)M N N N N N ) (r' NN)__name__
__module__ __qualname____doc__r& r+ r0 r' r% r r . sU 7 7 7 7( ( (O O O O Or' r c . e Zd Zej d ZdS ) EchoHandlerc # K | |t |t V d S # t j $ r Y d S t
$ r Y d S w xY wr )
write_message
isinstancebytesasyncioCancelledErrorr r$ messages r%
on_messagezEchoHandler.on_messageC su $$Wj%.H.HII I I I I I% DD# DD s +1 A AAN)r2 r3 r4 r coroutinerA r6 r' r% r8 r8 B s/ ] ] r' r8 c e Zd Zd ZdS )ErrorInOnMessageHandlerc ddz d S )N r r6 r? s r% rA z"ErrorInOnMessageHandler.on_messageN s Ar' Nr2 r3 r4 rA r6 r' r% rD rD M s# r' rD c e Zd Zd ZdS )
HeaderHandlerc t j | j d t j | j d t j | j dd t j | j dd t j | j d | j | j g}|D ]+} | t d # t $ r Y (w xY w| | j j
dd d S ) NzThis should not workzhttp://localhost/elsewhereX-Test ChocolateChipi z did not get expected exception) functoolspartialwriteredirect
set_header
set_cookie
set_statusflushfinish Exception RuntimeErrorr: requestheadersget)r$ methods_to_testmethods r% openzHeaderHandler.openS s dj*@ A A dm-I J J dox < < do{F C C dos 3 3 J K
& F
@AAA
4</33HbAABBBBBs B,,
B98B9Nr2 r3 r4 r_ r6 r' r% rI rI R s( C C C C Cr' rI c e Zd Zd Zd ZdS )HeaderEchoHandlerc 2 | dd d S )NX-Extra-Response-HeaderExtra-Response-Value)rS r* s r% set_default_headersz%HeaderEchoHandler.set_default_headersi s 13IJJJJJr' c | j j D ]B\ }}| d r| || Cd S )Nzx-test)rZ r[ get_alllower
startswithrS )r$ kvs r% preparezHeaderEchoHandler.preparel sc L(0022 & &DAqwwyy##H--
&1%%% & &r' N)r2 r3 r4 rf rm r6 r' r% rb rb h s5 K K K& & & & &r' rb c e Zd Zd ZdS )NonWebSocketHandlerc 0 | d d S )Nok)rQ r* s r% r\ zNonWebSocketHandler.gets s
4r' Nr2 r3 r4 r\ r6 r' r% ro ro r s# r' ro c e Zd Zd ZdS )RedirectHandlerc 0 | d d S )N/echo)rR r* s r% r\ zRedirectHandler.getx s
g r' Nrr r6 r' r% rt rt w s# r' rt c e Zd Zd ZdS )CloseReasonHandlerc @ d| _ | dd d S )NF goodbye)on_close_calledcloser* s r% r_ zCloseReasonHandler.open} s$ $
4#####r' Nr` r6 r' r% rx rx | # $ $ $ $ $r' rx c 4 e Zd Zej d Zd ZdS )AsyncPrepareHandlerc # & K t j V d S r )r momentr* s r% rm zAsyncPrepareHandler.prepare s jr' c 0 | | d S r r: r? s r% rA z AsyncPrepareHandler.on_message s 7#####r' N)r2 r3 r4 r rB rm rA r6 r' r% r r s> ] ]$ $ $ $ $r' r c e Zd Zd ZdS )PathArgsHandlerc 0 | | d S r r )r$ args r% r_ zPathArgsHandler.open s 3 r' Nr` r6 r' r% r r # r' r c > e Zd Z fdZej d Z xZS )CoroutineOnMessageHandlerc H t j di | d| _ d S Nr r6 superr& sleepingr$ kwargs __class__s r% r& z$CoroutineOnMessageHandler.initialize + $$V$$$
r' c # K | j dk r| d | xj dz
c_ t j d V | xj dz c_ | | d S Nr z%another coroutine is already sleepingrF {Gz?r r: r sleepr? s r% rA z$CoroutineOnMessageHandler.on_message sv =1 F G G G
ioo
7#####r' )r2 r3 r4 r& r rB rA
__classcell__r s @r% r r sU ]$ $ ]$ $ $ $ $r' r c e Zd Zd ZdS )RenderMessageHandlerc Z | | d| d S )N message.html)r@ )r:
render_stringr? s r% rA z RenderMessageHandler.on_message s/ 4--ng-NNOOOOOr' NrG r6 r' r% r r s( P P P P Pr' r c * e Zd Z fdZd Zd Z xZS )SubprotocolHandlerc H t j di | d| _ d S NFr6 )r r& select_subprotocol_calledr s r% r& z SubprotocolHandler.initialize s. $$V$$$).&&&r' c L | j rt d d| _ d|v rdS d S )Nz select_subprotocol called twiceT goodproto)r rX )r$ subprotocolss r% select_subprotocolz%SubprotocolHandler.select_subprotocol s9 ) ? =>> >)-& , & & ;tr' c l | j st d | d| j z d S )Nz select_subprotocol not calledzsubprotocol=%s)r rX r: selected_subprotocolr* s r% r_ zSubprotocolHandler.open s? - = ;<< < +d.GGHHHHHr' )r2 r3 r4 r& r r_ r r s @r% r r s] / / / / / I I I I I I Ir' r c D e Zd Z fdZej d Zd Z xZS )OpenCoroutineHandlerc V t j di | || _ d| _ d S r )r r& test
open_finished)r$ r r r s r% r& z OpenCoroutineHandler.initialize s5 $$V$$$ "r' c # K | j j V t j d V d| _ d S )Nr T)r message_sentwaitr r r r* s r% r_ zOpenCoroutineHandler.open sG i$))+++++i !r' c \ | j st d | d d S )Nz&on_message called before open finishedrq )r rX r: r? s r% rA z OpenCoroutineHandler.on_message s7 ! F DEE E 4 r' ) r2 r3 r4 r& r rB r_ rA r r s @r% r r sd # # # # #
]" " ]"
! ! ! ! ! ! !r' r c e Zd Zd ZdS )ErrorInOpenHandlerc t d )Nboom)rX r* s r% r_ zErrorInOpenHandler.open s r' Nr` r6 r' r% r r r r' r c e Zd Zd ZdS )ErrorInAsyncOpenHandlerc X K t j d d {V t d )Nr r )r= r rX r* s r% r_ z ErrorInAsyncOpenHandler.open s6 mA r' Nr` r6 r' r% r r s# r' r c e Zd Zd ZdS )NoDelayHandlerc Z | d | d d S )NThello) set_nodelayr: r* s r% r_ zNoDelayHandler.open s0 7#####r' Nr` r6 r' r% r r r~ r' r c H e Zd Z fdZ fdZej d Z xZS )WebSocketBaseTestCasec V t g | _ d S r )r setUpconns_to_closer$ r s r% r zWebSocketBaseTestCase.setUp s"
r' c | j D ]}| t d S r )r r} r tearDown)r$ connr s r% r z WebSocketBaseTestCase.tearDown s@ ' D JJLLLL
r' c + K t d| |fz fi |V }| j | t j | )Nzws://127.0.0.1:%d%s)r
get_http_portr appendr Return)r$ pathr wss r%
ws_connectz WebSocketBaseTestCase.ws_connect sl $ !T%7%7%9%94$@ @
DJ
""2&&&jnn r' ) r2 r3 r4 r r r rB r r r s @r% r r sn ! ! ! ! !
] ] r' r c e Zd Zd Zd Z fdZd Zd Zd Ze d Z
d Z e d Z e d
Z
e d Ze d Ze d
Ze d Ze d Ze d Ze d Ze d Ze d Ze d Ze d Ze d Ze d Ze d Ze d Z e d Z e d Z e d Z e d Z e d Z!e d Z"e d Z#e d! Z$e d" Z%e d# Z&e d$ Z'e d% Z( xZ)S )&
WebSocketTestc " t | _ t dt t | j fdt
fdt fdt t | j fdt t | j fdt t | j fdt t | j fd t t | j fd
t t | j fd t t | j fd t t | j fd
t t | j fdt t | j | fdt" fdt$ fdt& fgt) ddi S )Nrv )r" /non_ws /redirectz/headerz /header_echo
/close_reason/error_in_on_message/async_preparez/path_args/(.*)
/coroutine/render /subprotocol/open_coroutine)r" r /error_in_open/error_in_async_open/nodelayr z{{ message }})template_loader)r r" r r8 dictro rt rI rb rx rD r r r r r r r r r r
r* s r% get_appzWebSocketTest.get_app s "HH+t9J'K'K'KL /0 o.M4T=N+O+O+OP"%d&7888 $&d&7888 ++d&7888 %'d&7888 &#d&7888 !-d&7888
0$DDU2V2V2VW"&d&7888 &(d&7dCCC
"#56')@A^,a1
d '8N'O P Pg4
4
4
4
r' c t S r r r* s r% get_http_clientz WebSocketTest.get_http_client& s $&&&r' c t t j d S r )r r r _template_loadersclearr s r% r zWebSocketTest.tearDown* s4
(..00000r' c f | d }| |j d d S )Nrv fetch assertEqualcoder$ responses r% test_http_requestz WebSocketTest.test_http_request. s1 ::g&& ,,,,,r' c r | ddddd }| |j d d S )Nrv Upgrade WebSocket13
Connectionr zSec-WebSocket-Versionr[ r r r s r% test_missing_websocket_keyz(WebSocketTest.test_missing_websocket_key3 P :: '&)-
,,,,,r' c r | ddddd }| |j d d S )Nrv r r 12r r i r r s r% test_bad_websocket_versionz(WebSocketTest.test_bad_websocket_version> r r' c # K | d V }| d V | V }| |d d S )Nrv r r r: read_messager r$ r r s r% test_websocket_genz WebSocketTest.test_websocket_genI sh ??7++
+
+ w''''' **** 7+++++r' c V t 5 t d z j d d d n # 1 swxY w Y }| d | j } |d j
fd | d S )Nws://127.0.0.1:%d/echo)callbackr c , S r )stop)fr$ s r% z8WebSocketTest.test_websocket_callbacks..Z s diikk r' ) r r r r r resultr: r r r" add_done_callbackr} r s ` r% test_websocket_callbacksz&WebSocketTest.test_websocket_callbacksP sD
!
! (4+=+=+?+??$)
YY[[
!
!
!!!
"""99;;%%'' 7+++ ++,A,A,A,ABBB
s ,AA A c # K | d V }| dd | V }| |d d S )Nrv s hello Tbinaryr r s r% test_binary_messagez!WebSocketTest.test_binary_message^ sg ??7++
+
+
t444 **** =11111r' c # K | d V }| d | V }| |d d S Nrv u hello ér r s r% test_unicode_messagez"WebSocketTest.test_unicode_messagee sb ??7++
+
+
((( **** >22222r' c # K | d V }| | t 5 | d d d d d S # 1 swxY w Y d S r )r r} assertRaisesr r: r$ r s r% )test_error_in_closed_client_write_messagez7WebSocketTest.test_error_in_closed_client_write_messagel s ??7++
+
+
3
4
4 - - ^ , , , - - - - - - - - - - - - - - - - - -s A++A/2A/c # K | d V }| d | V }| |d d S )Nr r z hellor r s r% test_render_messagez!WebSocketTest.test_render_messages sb ??9--
-
-
!!! **** >22222r' c # K | d V }| d t t d 5 | V }d d d n # 1 swxY w Y | | d S )Nr r Uncaught exception)r r: r r r assertIsNoner s r% test_error_in_on_messagez&WebSocketTest.test_error_in_on_messagez s ??#9::
:
:
!!!
w 4
5
5 / / __ . ...H / / / / / / / / / / / / / / / (#####s A''A+.A+c # K | t 5 }| d V d d d n # 1 swxY w Y | |j j d d S )Nz /notfoundi )r r r r exceptionr )r$ cms r% test_websocket_http_failz&WebSocketTest.test_websocket_http_fail s
y
)
) /R//+.. . . . / / / / / / / / / / / / / / / *C00000s AAAc # K | t 5 | d V d d d d S # 1 swxY w Y d S )Nr )r r r r* s r% test_websocket_http_successz)WebSocketTest.test_websocket_http_success s
~
.
. - -//),, , , , - - - - - - - - - - - - - - - - - - AA Ac # K | t 5 | d V d d d d S # 1 swxY w Y d S )Nr )r r r r* s r% test_websocket_http_redirectz*WebSocketTest.test_websocket_http_redirect s
y
)
) / ///+.. . . . / / / / / / / / / / / / / / / / / /r# c # D K t \ }}| | t 5 t t
dd 5 t
d|z d V d d d n # 1 swxY w Y d d d d S # 1 swxY w Y d S )Nz.*F)requiredzws://127.0.0.1:%d/i )connect_timeout)r r} r IOErrorr r r )r$ sockports r% test_websocket_network_failz)WebSocketTest.test_websocket_network_fail s/ %''
d
w
'
' 7D5999
'(4/
s6 BA=1 B=B BB BB Bc # 2 K t j t d| z V 5 }| d | d |j d d d d S # 1 swxY w Y d S )Nr r world)
contextlibclosingr r r: streamr} r s r% "test_websocket_close_buffered_dataz0WebSocketTest.test_websocket_close_buffered_data s
$%=@R@R@T@T%TUU
U
U
W % % % W % % % IOO
s AB BBc # & K t j t t d| z ddi V 5 }| V }| |d d d d d S # 1 swxY w Y d S )Nzws://127.0.0.1:%d/headerrK r r )r/ r0 r r r r r r s r% test_websocket_headersz$WebSocketTest.test_websocket_headers s
' 2T5G5G5I5II!)7 3
0 __ . ...H Xw / / / 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0s -BB
B
c # K t j t t d| z ddi V 5 }| |j d d | |j d d d d d d S # 1 swxY w Y d S )Nz ws://127.0.0.1:%d/header_echoz X-Test-Hellor r rd re )r/ r0 r r r r r[ r\ r s r% test_websocket_header_echoz(WebSocketTest.test_websocket_header_echo s
' 7$:L:L:N:NN!/ 9
RZ^^N ; ;W E E E
899;Q
s A B66B:=B:c # @ K | d V }| V }| |d | |j d | |j d | j V \ }}| |d d S )Nr rz r{ )r r assertIsr r. r/ r" )r$ r msgr reasons r% test_server_close_reasonz&WebSocketTest.test_server_close_reason s ???33
3
3OO%%%%
c4 --- )444 ! ... f
t$$$$$r' c # K | d V }| dd | j V \ }}| |d | |d d S )Nrv rz r{ )r r} r" r )r$ r r r: s r% test_client_close_reasonz&WebSocketTest.test_client_close_reason su ??7++
+
+
y!!! ! ... f t$$$ +++++r' c # K | d V }| V }| |d | t 5 | d d d d d S # 1 swxY w Y d S )Nr r )r r r8 r r r: )r$ r r9 s r% test_write_after_closez$WebSocketTest.test_write_after_close s ???33
3
3OO%%%%
c4
3
4
4 & & W % % % & & & & & & & & & & & & & & & & & &s BB
Bc # K | d V }| d | V }| |d d S )Nr r r r$ r ress r% test_async_preparez WebSocketTest.test_async_prepare se ??#344
4
4
!!!OO%%%% g&&&&&r' c # K | d V }| V }| |d d S )Nz/path_args/hellor r r r rA s r% test_path_argsz WebSocketTest.test_path_args sO ??#566
6
6OO%%%% g&&&&&r' c # D K | d V }| d V | d V | V }| |d | V }| |d d S )Nr hello1hello2r rA s r% test_coroutinez WebSocketTest.test_coroutine s ??<00
0
0 x((((( x(((((OO%%%% h'''OO%%%% h'''''r' c # b K | }d|z }dd|z i}t j t t || V 5 }| d | V }| |d d d d d S # 1 swxY w Y d S )Nr Originzhttp://127.0.0.1:%dr r r r/ r0 r r r: r r r$ r+ urlr[ r r s r% test_check_origin_valid_no_pathz-WebSocketTest.test_check_origin_valid_no_path s !!##&- 2T 9:
$[g%F%F%FGG
G
G
0
W % % % __ . ...H Xw / / / 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 AB$$B(+B(c # b K | }d|z }dd|z i}t j t t || V 5 }| d | V }| |d d d d d S # 1 swxY w Y d S )Nr rL z http://127.0.0.1:%d/somethingr r rM rN s r% !test_check_origin_valid_with_pathz/WebSocketTest.test_check_origin_valid_with_path s !!##&- zEWebSocketTest.test_check_origin_invalid_subdomains..@ s 111DG111r' z"localhost does not resolve to ipv4zws://localhost:%d/echorL zhttp://subtenant.localhostr rU )
r r
resolvesocketAF_INETskipTestr r r r r r r )r$ r+ addrinfofamiliesrO r[ r s r% $test_check_origin_invalid_subdomainsz2WebSocketTest.test_check_origin_invalid_subdomains8 sA !!##
"++K>>>>11111 > ) ) MM> ? ? ? F&- 9:
y
)
) GR#KW$E$E$EFF F F F G G G G G G G G G G G G G G G
*C00000s !B<<C C c # K | dddg V }| |j d | V }| |d d S )Nr badprotor )r zsubprotocol=goodproto)r r r r rA s r% test_subprotocolsz WebSocketTest.test_subprotocolsO s ?? *k)B #
0+>>>OO%%%% 566666r' c # K | d V }| |j d | V }| |d d S )Nr zsubprotocol=None)r r8 r r r rA s r% test_subprotocols_not_offeredz+WebSocketTest.test_subprotocols_not_offeredX sf ??>22
2
2
b-t444OO%%%% 011111r' c # K t | _ | d V }| d V | j | V }| |d d S )Nr r rq )r r r r: setr r rA s r% test_open_coroutinez!WebSocketTest.test_open_coroutine_ s !GG??#455
5
5 w''''' OO%%%% d#####r' c # K t t d 5 | d V }| V }d d d n # 1 swxY w Y | | d S )Nr r r r r r r rA s r% test_error_in_openz WebSocketTest.test_error_in_openh s
w 4
5
5 * *'78888B))))C * * * * * * * * * * * * * * *
# .AAAc # K t t d 5 | d V }| V }d d d n # 1 swxY w Y | | d S )Nr r rq rA s r% test_error_in_async_openz&WebSocketTest.test_error_in_async_openo s
w 4
5
5 * *'=>>>>B))))C * * * * * * * * * * * * * * *
# rs c # K | d V }| V }| |d d S )Nr r rE rA s r% test_nodelayzWebSocketTest.test_nodelayv sN ??:..
.
.OO%%%% g&&&&&r' )*r2 r3 r4 r r r r r r r r r r r r r r r r" r% r, r2 r4 r6 r; r= r? rC rF rJ rP rS rX rZ rg rj rl ro rr ru rw r r s @r% r r s 6
6
6
p' ' '1 1 1 1 1- - -
- - - - - - , , X, 2 2 X2 3 3 X3 - - X- 3 3 X3 $ $ X$ 1 1 X1
- - X- / / X/ X X
0
0 X
0 X& % % X % , , X, & & X& ' ' X' ' ' X'
( ( X( 0 0 X 0 0 0 X 0 1 1 X1 1 1 X 1 1 1 X1, 7 7 X7 2 2 X2 $ $ X$ X X ' ' X' ' ' ' 'r' r c $ e Zd Z fdZd Z xZS ) NativeCoroutineOnMessageHandlerc H t j di | d| _ d S r r r s r% r& z*NativeCoroutineOnMessageHandler.initialize~ r r' c K | j dk r| d | xj dz
c_ t j d d {V | xj dz c_ | | d S r r r? s r% rA z*NativeCoroutineOnMessageHandler.on_message s =1 F G G G
ioo
7#####r' )r2 r3 r4 r& rA r r s @r% ry ry } sG $ $ $ $ $ $ $r' ry c * e Zd Zd Zed ZdS ) WebSocketNativeCoroutineTestc 0 t dt fg S )N/native)r ry r* s r% r z$WebSocketNativeCoroutineTest.get_app s Y(G HIJJJr' c # D K | d V }| d V | d V | V }| |d | V }| |d d S )Nr rH rI r rA s r% test_native_coroutinez2WebSocketNativeCoroutineTest.test_native_coroutine s ??9--
-
- x((((( x(((((OO%%%% h'''OO%%%% h'''''r' N)r2 r3 r4 r r r r6 r' r% r} r} sA K K K ( ( X( ( (r' r} c d e Zd ZdZd Zd Zd Zdededdfd Ze d
Z
e d Z dS ) CompressionTestMixinz Hello world. Testing 123 123c G d dt }t dt t | fd|t | fg S )Nc * e Zd Zed Zd ZdS )4CompressionTestMixin.get_app..LimitedHandlerc dS )N r6 r* s r% max_message_sizezECompressionTestMixin.get_app..LimitedHandler.max_message_size s tr' c d | t t | d S r )r: strlenr? s r% rA z?CompressionTestMixin.get_app..LimitedHandler.on_message s* ""3s7||#4#455555r' N)r2 r3 r4 propertyr rA r6 r' r% LimitedHandlerr s<
X
6
6
6
6
6r' r rv r) /limited)r r r8 r get_server_compression_options)r$ r s r% r z CompressionTestMixin.get_app s 6 6 6 6 6 1 6 6 6 T-P-P-R-RSSS "T-P-P-R-RSSS
r' c d S r r6 r* s r% r z3CompressionTestMixin.get_server_compression_options tr' c d S r r6 r* s r% get_client_compression_optionsz3CompressionTestMixin.get_client_compression_options r r' bytes_in bytes_outreturnNc t r NotImplementedErrorr$ r r s r% verify_wire_bytesz&CompressionTestMixin.verify_wire_bytes !###r' c # B K | d| V }t d D ]M}| | j | V }| || j N| |j j t | j dz | |j j
t | j dz | |j j |j j
d S )Nrv r) )r r ranger: MESSAGEr r protocol_message_bytes_outr _message_bytes_inr _wire_bytes_in_wire_bytes_outr$ r ir s r% test_message_sizesz'CompressionTestMixin.test_message_sizes s ?? )L)L)N)N #
q 5 5A T\ * * * __ . ...H Xt| 4 4 4 4 7T\9J9JQ9NOOO 6DL8I8IA8MNNN r{ 92;;VWWWWWr' c # b K | d| V }| d | V }| |d | d | V }| | d S )Nr r) ڀaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa128 aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa)r r r: r r r r s r% test_size_limitz$CompressionTestMixin.test_size_limit s ?? D,O,O,Q,Q #
### **** 5))) $$$ **** (#####r' ) r2 r3 r4 r r r r intr r r r r6 r' r% r r s ,G
0 $# $# $$ $ $ $ $ X X X X $ $ X $ $ $r' r c e Zd ZdZd ZdS )UncompressedTestMixinzESpecialization of CompressionTestMixin when we expect no compression.c | |dt | j dz z | |dt | j dz z d S )Nr )r r r r s r% r z'UncompressedTestMixin.verify_wire_bytes s\ AT\):):Q)>$?@@@ 1DL(9(9A(=#>?????r' N)r2 r3 r4 r5 r r6 r' r% r r s. OO@ @ @ @ @r' r c e Zd ZdS )NoCompressionTestN)r2 r3 r4 r6 r' r% r r s Dr' r c e Zd Zd ZdS )ServerOnlyCompressionTestc i S r r6 r* s r% r z8ServerOnlyCompressionTest.get_server_compression_options r' N)r2 r3 r4 r r6 r' r% r r # r' r c e Zd Zd ZdS )ClientOnlyCompressionTestc i S r r6 r* s r% r z8ClientOnlyCompressionTest.get_client_compression_options r r' N)r2 r3 r4 r r6 r' r% r r r r' r c e Zd Zd Zd Zd ZdS )DefaultCompressionTestc i S r r6 r* s r% r z5DefaultCompressionTest.get_server_compression_options r r' c i S r r6 r* s r% r z5DefaultCompressionTest.get_client_compression_options r r' c | |dt | j dz z | |dt | j dz z | ||dz d S )Nr r r )
assertLessr r r r s r% r z(DefaultCompressionTest.verify_wire_bytes sr 1DL(9(9A(=#>??? !s4<'8'81'<"=>>> HrM22222r' N)r2 r3 r4 r r r r6 r' r% r r sA 3 3 3 3 3r' r c 8 e Zd ZdededefdZdej fdZdS )MaskFunctionMixinmaskdatar c t r r r$ r r s r% r zMaskFunctionMixin.mask r r' r$ c | | 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 r r* s r% test_maskzMaskFunctionMixin.test_mask s 7C00#666 7D117;;; 7H55x@@@ 7K88+FFF
II)+F G G '
II)+F G G '
r' N)r2 r3 r4 r< r typingAnyr r6 r' r% r r sZ $ $e $ $ $ $ $
r' r c e Zd Zd ZdS )PythonMaskFunctionTestc " t || S r r r s r% r zPythonMaskFunctionTest.mask s %dD111r' Nr2 r3 r4 r r6 r' r% r r s# 2 2 2 2 2r' r z#tornado.speedups module not presentc e Zd Zd ZdS )CythonMaskFunctionTestc , t j || S r )r websocket_maskr s r% r zCythonMaskFunctionTest.mask% s &tT222r' Nr r6 r' r% r r # s# 3 3 3 3 3r' r c * e Zd Zd Zed ZdS )ServerPeriodicPingTestc R G d dt }t d|fgdd S )Nc e Zd Zd ZdS )3ServerPeriodicPingTest.get_app..PingHandlerc 0 | d d S )Ngot pongr r$ r s r% on_pongz;ServerPeriodicPingTest.get_app..PingHandler.on_pong, "":.....r' N)r2 r3 r4 r r6 r' r% PingHandlerr + #
/
/
/
/
/r' r /r r )websocket_ping_intervalwebsocket_ping_timeoutr r r$ r s r% r z ServerPeriodicPingTest.get_app* sW / / / / /. / / / ;
$(#$
r' c # K | d V }t d D ].}| V }| |d /d S )Nr r r )r r r r r s r% test_server_pingz'ServerPeriodicPingTest.test_server_ping5 sj ??3''
'
'q 3 3A __ . ...H Xz 2 2 2 2 3 3r' N)r2 r3 r4 r r r r6 r' r% r r ) s>
3 3 X3 3 3r' r c * e Zd Zd Zed ZdS )ClientPeriodicPingTestc L G d dt }t d|fg S )Nc e Zd Zd ZdS )3ClientPeriodicPingTest.get_app..PingHandlerc 0 | d d S )Ngot pingr r s r% on_pingz;ClientPeriodicPingTest.get_app..PingHandler.on_pingA r r' Nr2 r3 r4 r r6 r' r% r r @ r r' r r r r s r% r z ClientPeriodicPingTest.get_app? sE / / / / /. / / / S+ ./000r' c # K | ddd V }t d D ].}| V }| |d /| d S )Nr r r
ping_interval ping_timeoutr r )r r r r r} r s r% test_client_pingz'ClientPeriodicPingTest.test_client_pingF sw ??3d?KK
K
Kq 3 3A __ . ...H Xz 2 2 2 2
r' N)r2 r3 r4 r r r r6 r' r% r r > s> 1 1 1 X r' r c @ e Zd Zd Zed Zed ZdS )ServerPingTimeoutTestc h g | _ | G fddt }t d|fg }|S )Nc $ e Zd Zd fd Z xZS )2ServerPingTimeoutTest.get_app..PingHandlerNc j | _ | j | t || S )Nr! )handlersr r r& )r$ r" r# r r s r% r& z=ServerPingTimeoutTest.get_app..PingHandler.initializeU sI $
$$T*** ww))!-CV * r' r1 )r2 r3 r4 r& r )r r s @r% r r T sC
r' r r )r r r )r$ r appr s @r% r z ServerPingTimeoutTest.get_appP s` 02
. C-.//
r' c l d _ d _ fd} | j j j _ dS )z1Optionally suppress the client's "pong" response.Fr c 4 dt dt f fd }|S )Nopcoder c Z | dk rxj dz
c_ j rd S | | S )N
rF )pongs_received
drop_pongs)r r fcnr s r% _innerzCServerPingTimeoutTest.install_hook..wrapper.._innerh sA S==%%*%%} s64(((r' )r r< )r
r r s ` r% wrapperz3ServerPingTimeoutTest.install_hook..wrapperg s<
)s
)%
)
)
)
)
)
)
) Mr' N)r r r _handle_message)r r s ` r% install_hookz"ServerPingTimeoutTest.install_hook` sN
'.gbk.I&J&J ###r' c # K d}| d||dz V }| | | j d }t d D ]Z}t j | V | |j | |j |j j J [|
|j d d|_ t j |dz V |
|j d |
|j d
|
|j j d d S ) Ng?r r r Tg ?i zping timed out)r r r r r r r r. r/ r assertGreaterEqualr r r )r$ intervalr handler_s r% test_client_ping_timeoutz.ServerPingTimeoutTest.test_client_ping_timeoutu sg ?? xhl #
" -"q 2 2A)H%% % % %
g 0 1 1 1 g 2 3 3 3 ;)1111
11555
i3'''''
+T222 -/?@@@
/66666r' N)r2 r3 r4 r staticmethodr r r r6 r' r% r r O s\ K K \K( %7 %7 X%7 %7 %7r' r c e Zd Zd ZdS )PingCalculationTestc b ddl m} t j ddddddt j j }d}t j ddddd d
t j j }| | || }| |d d S )
Nr )WebSocketProtocol13i rF r )tzinfor ; 6 )last_ping_timer nowr )tornado.websocketr datetimetimezoneutcping_sleep_time timestampr )r$ r r! r r
sleep_times r% test_ping_sleep_timez(PingCalculationTest.test_ping_sleep_time s 999999 aB1X=N=RSSS!* !QB8+<+@
)88)3355
9
Q'''''r' N)r2 r3 r4 r) r6 r' r% r r s#
(
(
(
(
(r' r c * e Zd Zd Zed ZdS )ManualPingTestc L G d dt }t d|fg S )Nc e Zd Zd ZdS )+ManualPingTest.get_app..PingHandlerc Z | |t |t d S )Nr
)r: r; r< r s r% r z3ManualPingTest.get_app..PingHandler.on_ping s+ ""4
40G0G"HHHHHr' Nr r6 r' r% r r. s(
I
I
I
I
Ir' r r r r s r% r zManualPingTest.get_app sM I I I I I. I I I S+ ./000r' c # ~ K | d V }| t |j d | d | V }| |d | d | V }| |d d S )Nr ~aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaar s hellos binary hello)r r
ValueErrorpingr r )r$ r resps r% test_manual_pingz ManualPingTest.test_manual_ping s ??3''
'
' *bgy999
__&&&& x(((
__&&&& /////r' N)r2 r3 r4 r r r5 r6 r' r% r+ r+ s> 1 1 1 0 0 X 0 0 0r' r+ c * e Zd Zd Zed ZdS )MaxMessageSizeTestc 4 t dt fgd S )Nr r )websocket_max_message_size)r r8 r* s r% r zMaxMessageSizeTest.get_app s S+ ./DQQQQr' c # K | d V }d}| | | V }| || | |dz | V }| |d | |j d | |j d d S )Nr aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaabi zmessage too big)r r: r r r8 r. r/ )r$ r r9 r4 s r% test_large_messagez%MaxMessageSizeTest.test_large_message s ??3''
'
'
__&&&& s### s###__&&&&
dD!!! --- *;<<<<rP s
% % % % % % 5 5 5 5 5 5 5 5 ( ( ( ( ( ( ( ( $ $ $ $ $ $ ; ; ; ; ; ; ' ' ' ' ' ' D D D D D D D D T T T T T T T T T T T T 3 3 3 3 3 3 3 3
3333333
I
HHHO O O O O+ O O O( & 2
C C C C C( C C C,& & & & &, & & & .
n
$ $ $ $ $- $ $ $ $ $ $ $ $. $ $ $ *
$ $ $ $ $ 4 $ $ $ P P P P P/ P P P
I I I I I- I I I&! ! ! ! !/ ! ! !$ -
2 $ $ $ $ $) $ $ $ - &M' M' M' M' M') M' M' M'` $ $ $ $ $&: $ $ $
(
(
(
(
(#8
(
(
( @$ @$ @$ @$ @$0 @$ @$ @$F @ @ @ @ @ 0 @ @ @ -
5
5
3 3 3 3 3 1 3 3 3
)
.2 2 2 2 2 . 2 2 2
T!#HII3 3 3 3 3 . 3 3 JI3
3 3 3 3 3 2 3 3 3* 2 "L7 L7 L7 L7 L7 1 L7 L7 L7^( ( ( ( ((+ ( ( ("0 0 0 0 0* 0 0 00= = = = =. = = = = =s 2
A= =B#B* *B43B4