Mh)| d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZ d dl m
Z
d dl m Z m
Z
d dlmZ d dlmZmZ d dlmZ d dlmZ d d lmZ d d
lmZmZ 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. Z/ G d de. Z0 G d de. Z1 G d de. Z2 G d de# Z3 G d d e# 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 d0 d1e. Z> G d2 d3e Z? G d4 d5e? Z@ G d6 d7e. ZA G d8 d9e? ZBe G d: d;e? ZCe G d< d=eC ZD G d> d?eD ZE G d@ dAeD ZF G dB dCeD ZG G dD dEeC ZHe G dF dGejI ZJ G dH dIeJ ZK ejL e-du dJ G dK dLeJ ZM G dM dNe? ZN G dO dPe? ZO G dQ dRe? ZP G dS dTe? ZQ G dU dVe? ZRdS )W 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 [/var/www/html/test/jupyter/venv/lib/python3.11/site-packages/tornado/test/websocket_test.py
initializez TestWebSocketHandler.initialize5 s (#6 c | j S r r# r$ s r% get_compression_optionsz,TestWebSocketHandler.get_compression_options9 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_messageB 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 A s/ ] ] r' r8 c e Zd Zd ZdS )ErrorInOnMessageHandlerc ddz d S )N r r6 r? s r% rA z"ErrorInOnMessageHandler.on_messageM s Ar' Nr2 r3 r4 rA r6 r' r% rD rD L 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.openR 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 Q 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_headersh s 13IJJJJJr' c | j j D ]B\ }}| d r| || Cd S )Nzx-test)rZ r[ get_alllower
startswithrS )r$ kvs r% preparezHeaderEchoHandler.preparek sc L(0022 & &DAqwwyy##H--
&1%%% & &r' N)r2 r3 r4 rf rm r6 r' r% rb rb g s5 K K K& & & & &r' rb c e Zd Zd ZdS )NonWebSocketHandlerc 0 | d d S )Nok)rQ r* s r% r\ zNonWebSocketHandler.getr s
4r' Nr2 r3 r4 r\ r6 r' r% ro ro q s# r' ro c e Zd Zd ZdS )RedirectHandlerc 0 | d d S )N/echo)rR r* s r% r\ zRedirectHandler.getw s
g r' Nrr r6 r' r% rt rt v 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_key2 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_genH 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..Y s diikk r' ) r r r r r resultr: r r r" add_done_callbackr} r s ` r% test_websocket_callbacksz&WebSocketTest.test_websocket_callbacksO 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_messaged 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_messagek 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_messager 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_messagey 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_subdomains7 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_subprotocolsN 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_offeredW 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_openg 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_openn 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_nodelayu 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_ping4 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_ping@ 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_pingE 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.initializeT sI $
$$T*** ww))!-CV * r' r1 )r2 r3 r4 r& r )r r s @r% r r S sC
r' r r )r r r )r$ r appr s @r% r z ServerPingTimeoutTest.get_appO s` 02
. C-.//
r' c J d } || j j | j _ dS )z&Suppress the client's "pong" response.c 0 dt dt f fd }|S )Noppcoder c , | dk rd S | | S )N
r6 )r r fcns r% _innerzDServerPingTimeoutTest.suppress_pong..wrapper.._innerd s# c>>Fs7D)))r' )r r< )r r s ` r% wrapperz4ServerPingTimeoutTest.suppress_pong..wrapperc s6
*
*5
*
*
*
*
*
* Mr' N)r _handle_message)r r
s r%
suppress_pongz#ServerPingTimeoutTest.suppress_pong_ s2 '.gbk.I&J&J ###r' c # > K d}| d||dz V }| j d }t d D ]Z}t j d V | |j | |j |j j J [| | t j |dz V |
|j d |
|j d |
|j j d d S )
Ng?r r r g ?i zping timed out) r r r r r r r. r/ r r r )r$ intervalr handler_s r% test_client_ping_timeoutz.ServerPingTimeoutTest.test_client_ping_timeouto sA ?? xhl #
-"q 2 2A)C..
g 0 1 1 1 g 2 3 3 3 ;)1111
2 i3'''''
+T222 -/?@@@
/66666r' N)r2 r3 r4 r staticmethodr r r r6 r' r% r r N s\
K
K \
K 7 7 X 7 7 7r' 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 r 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 r s r% test_large_messagez%MaxMessageSizeTest.test_large_message s ??3''
'
'
__&&&& s### s###__&&&&
dD!!! --- *;<<<<r< 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 "B7 B7 B7 B7 B7 1 B7 B7 B7J0 0 0 0 0* 0 0 00= = = = =. = = = = =s .
A9 9B B& &B0/B0