R?gr S SK r S SKrS SKrS SKrS SKrS SKrS SKrS SKJr S SK J
r
S SK J r J
r
S SKJr S SKJrJr S SKJr S SKJr S S KJr S S
KJrJrJ r J r S S K J r J r S SK!r S S K"J#r# S S
K!J&r&J'r'J(r(J)r) S SK J*r* " S S\&5 r+ " S S\+5 r, " S S\+5 r- " S S\+5 r. " S S\+5 r/ " S S\ 5 r0 " S S \ 5 r1 " S S \+5 r2 " S S \+5 r3 " S! S"\+5 r4 " S# S$\+5 r5 " S% S&\+5 r6 " S' S(\+5 r7 " S) S*\+5 r8 " S+ S,\+5 r9 " S- S.\+5 r: " S/ S0\+5 r; " S1 S2\5 r< " S3 S4\<5 r= " S5 S6\+5 r> " S7 S8\<5 r? " S9 S:\@5 rA " S; S<\A5 rB " S= S>\B\<5 rC " S? S@\B\<5 rD " SA SB\B\<5 rE " SC SD\A\<5 rF " SE SF\@5 rG " SG SH\G\R 5 rI\R " \*SL SI5 " SJ SK\G\R 5 5 rK " SL SM\<5 rL " SN SO\<5 rM " SP SQ\<5 rN " SR SS\<5 rOg! \$ a \RJ " 5 e f = f! \$ a Sr* GNf = f)T N)Future)gen) HTTPError HTTPRequest)Event)gen_logapp_log)ResolverSimpleAsyncHTTPClient)
DictLoader)AsyncHTTPTestCasegen_testbind_unused_port ExpectLog) ApplicationRequestHandler_websocket_mask_python)WebSocketHandlerwebsocket_connectWebSocketErrorWebSocketClosedError)speedupsc . \ rS rSrSrSS jrS rS rSrg) TestWebSocketHandler, zBase 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 Xl X l g N close_futurecompression_options)selfr! r" s =/usr/lib/python3/dist-packages/tornado/test/websocket_test.py
initialize TestWebSocketHandler.initialize4 s (#6 c U R $ r r" r# s r$ get_compression_options,TestWebSocketHandler.get_compression_options8 s '''r' c U R b2 U R R U R U R 45 g g r )r!
set_result
close_code close_reasonr* s r$ on_close TestWebSocketHandler.on_close; s6 ( ( ($//4;L;L)M N )r' r )NN) __name__
__module__ __qualname____firstlineno____doc__r% r+ r1 __static_attributes__ r' r$ r r , s 7(Or' r c 8 \ rS rSr\R
S 5 rSrg) EchoHandler@ c # # U R U[ U[ 5 5 v g ! [ R a g [
a g f = f7fr )
write_message
isinstancebytesasyncioCancelledErrorr r# messages r$
on_messageEchoHandler.on_messageA sF $$Wj%.HI I%% # s/ A "' A A A A A A A r9 N)r3 r4 r5 r6 r coroutinerE r8 r9 r' r$ r; r; @ s ]] r' r; c \ rS rSrS rSrg)ErrorInOnMessageHandlerK c SS- g )N r r9 rC s r$ rE "ErrorInOnMessageHandler.on_messageL s Ar' r9 Nr3 r4 r5 r6 rE r8 r9 r' r$ rI rI K s r' rI c \ rS rSrS rSrg)
HeaderHandlerP c 8 [ R " U R S5 [ R " U R S5 [ R " U R SS5 [ R " U R
SS5 [ R " U R S5 U R U R /nU H n U" 5 [ S5 e U R U R R R SS5 5 g ! [ a M[ f = f) 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$ openHeaderHandler.openQ s djj*@ A dmm-I J doox < doo{F C doos 3 JJ KK
&F
@AA &
4<<//33HbAB
s D
DDr9 Nr3 r4 r5 r6 rg r8 r9 r' r$ rP rP P s Cr' rP c \ rS rSrS rS rSrg)HeaderEchoHandlerf c ( U R SS5 g )NX-Extra-Response-HeaderExtra-Response-Value)r[ r* s r$ set_default_headers%HeaderEchoHandler.set_default_headersg s 13IJr' c U R R R 5 H< u pUR 5 R S5 ( d M+ U R X5 M> g )Nzx-test)rb rc get_alllower
startswithr[ )r# kvs r$ prepareHeaderEchoHandler.preparej sD LL((002DAwwy##H--% 3r' r9 N)r3 r4 r5 r6 rp rx r8 r9 r' r$ rk rk f s
K&r' rk c \ rS rSrS rSrg)NonWebSocketHandlerp c & U R S5 g )Nok)rY r* s r$ rd NonWebSocketHandler.getq s
4r' r9 Nr3 r4 r5 r6 rd r8 r9 r' r$ r{ r{ p s r' r{ c \ rS rSrS rSrg)RedirectHandleru c & U R S5 g )N/echo)rZ r* s r$ rd RedirectHandler.getv s
g r' r9 Nr r9 r' r$ r r u s r' r c \ rS rSrS rSrg)CloseReasonHandlerz c 6 SU l U R SS5 g )NF goodbye)on_close_calledcloser* s r$ rg CloseReasonHandler.open{ s $
4#r' )r Nri r9 r' r$ r r z $r' r c > \ rS rSr\R
S 5 rS rSrg)AsyncPrepareHandler c # 0 # [ R v g 7fr )r momentr* s r$ rx AsyncPrepareHandler.prepare s jjs c & U R U5 g r r> rC s r$ rE AsyncPrepareHandler.on_message s 7#r' r9 N) r3 r4 r5 r6 r rG rx rE r8 r9 r' r$ r r s ]] $r' r c \ rS rSrS rSrg)PathArgsHandler c & U R U5 g r r )r# args r$ rg PathArgsHandler.open s 3 r' r9 Nri r9 r' r$ r r r' r c L ^ \ rS rSrU 4S jr\R S 5 rSrU =r $ )CoroutineOnMessageHandler c 4 > [ TU ] " S0 UD6 SU l g Nr r9 superr% sleepingr# kwargs __class__s r$ r% $CoroutineOnMessageHandler.initialize
$V$
r' c # # U R S: a U R S5 U =R S-
sl [ R " S5 v U =R S- sl U R U5 g 7fNr z%another coroutine is already sleepingrL {Gz?r r> r sleeprC s r$ rE $CoroutineOnMessageHandler.on_message sX ==1 F G
iio
7#s A6A8r )
r3 r4 r5 r6 r% r rG rE r8
__classcell__r s @r$ r r s ]]$ $r' r c \ rS rSrS rSrg)RenderMessageHandler c B U R U R SUS95 g )N message.html)rD )r>
render_stringrC s r$ rE RenderMessageHandler.on_message s 4--ng-NOr' r9 NrN r9 r' r$ r r s Pr' r c 4 ^ \ rS rSrU 4S jrS rS rSrU =r$ )SubprotocolHandler c 4 > [ TU ] " S0 UD6 SU l g NFr9 )r r% select_subprotocol_calledr s r$ r% SubprotocolHandler.initialize s
$V$).&r' c X U R ( a [ S5 eSU l SU; a gg )Nz select_subprotocol called twiceT goodproto)r r` )r# subprotocolss r$ select_subprotocol%SubprotocolHandler.select_subprotocol s- ) ) => >)-& , & r' c x U R ( d [ S5 eU R SU R - 5 g )Nz select_subprotocol not calledzsubprotocol=%s)r r` r> selected_subprotocolr* s r$ rg SubprotocolHandler.open s1 -- ;< < +d.G.GGHr' )r ) r3 r4 r5 r6 r% r rg r8 r r s @r$ r r s /I Ir' r c R ^ \ rS rSrU 4S jr\R S 5 rS rSr U =r
$ )OpenCoroutineHandler c @ > [ TU ] " S0 UD6 Xl SU l g r )r r% test
open_finished)r# r r r s r$ r% OpenCoroutineHandler.initialize s
$V$ "r' c # # U R R R 5 v [ R " S5 v SU l g 7f)Nr T)r message_sentwaitr r r r* s r$ rg OpenCoroutineHandler.open s5 ii$$))++ii !s AA c ^ U R ( d [ S5 eU R S5 g )Nz&on_message called before open finishedr~ )r r` r> rC s r$ rE OpenCoroutineHandler.on_message s% !! DE E 4 r' )r r ) r3 r4 r5 r6 r% r rG rg rE r8 r r s @r$ r r s* #
]]" "
! !r' r c \ rS rSrS rSrg)ErrorInOpenHandler c [ S5 e)Nboom)r` r* s r$ rg ErrorInOpenHandler.open s
r' r9 Nri r9 r' r$ r r r r' r c \ rS rSrS rSrg)ErrorInAsyncOpenHandler c ` # [ R " S5 I S h vN [ S5 e N7f)Nr r )rA r r` r* s r$ rg ErrorInAsyncOpenHandler.open s' mmA s .,.r9 Nri r9 r' r$ r r s r' r c \ rS rSrS rSrg)NoDelayHandler c H U R S5 U R S5 g )NThello) set_nodelayr> r* s r$ rg NoDelayHandler.open s 7#r' r9 Nri r9 r' r$ r r r r' r c X ^ \ rS rSrU 4S jrU 4S jr\R S 5 rSr U =r
$ )WebSocketBaseTestCase c 0 > [ TU ] 5 / U l g r )r setUpconns_to_closer# r s r$ r WebSocketBaseTestCase.setUp s
r' c h > U R H nUR 5 M [ TU ]
5 g r )r r r tearDown)r# connr s r$ r WebSocketBaseTestCase.tearDown s' ''D JJL (
r' c + # [ SU R 5 U4- 40 UD6v nU R R U5 [ R
" U5 e7f)Nzws://127.0.0.1:%d%s)r
get_http_portr appendr Return)r# pathr wss r$
ws_connect WebSocketBaseTestCase.ws_connect sV $ !T%7%7%94$@ @
DJ
""2&jjn s AA)r ) r3 r4 r5 r6 r r r rG r r8 r r s @r$ r r s% !
]] r' r c , ^ \ rS rSrS rS rU 4S jrS rS rS r \
S 5 r S r \
S
5 r
\
S 5 r\
S 5 r\
S
5 r\
S 5 r\
S 5 r\
S 5 r\
S 5 r\
S 5 r\
S 5 r\
S 5 r\
S 5 r\
S 5 r\
S 5 r\
S 5 r\
S 5 r \
S 5 r \
S 5 r \
S 5 r \
S 5 r \
S 5 r!\
S 5 r"\
S 5 r#\
S! 5 r$\
S" 5 r%\
S# 5 r&\
S$ 5 r'\
S% 5 r(\
S& 5 r)S'r*U =r+$ )(
WebSocketTest c [ 5 U l [ S[ [ U R S94S[
4S[ 4S[ [ U R S94S[ [ U R S94S[ [ U R S94S[ [ U R S94S [ [ U R S94S
[ [ U R S94S [ [ U R S94S [ [ U R S94S
[ [ U R S94S[ [ U R U S94S[" 4S[$ 4S[& 4/[) SS05 S9$ )Nr )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 r; dictr{ r rP rk r rI r r r r r r r r r r
r* s r$ get_appWebSocketTest.get_app sv "H+t9J9J'KL /0 o.M4T=N=N+OP"%d&7&78 $&d&7&78 ++d&7&78 %'d&7&78 &#d&7&78 !-d&7&78
0$DDUDU2VW"&d&7&78 &(d&7&7dC
"#56')@A^,a1
d '8N'O Pg4
4
r' c [ 5 $ r r r* s r$ get_http_client WebSocketTest.get_http_client$ s $&&r' c ^ > [ TU ] 5 [ R R 5 g r )r r r _template_loadersclearr s r$ r WebSocketTest.tearDown( s
((..0r' c ^ U R S5 nU R UR S5 g )Nr fetch assertEqualcoder# responses r$ test_http_request WebSocketTest.test_http_request, s$ ::g& ,r' c d U R SSSSS.S9nU R UR S5 g )Nr Upgrade WebSocket13
Connectionr& zSec-WebSocket-Versionrc r r r! s r$ test_missing_websocket_key(WebSocketTest.test_missing_websocket_key1 < :: '&)-
,r' c d U R SSSSS.S9nU R UR S5 g )Nr r& r' 12r) r+ i r r! s r$ test_bad_websocket_version(WebSocketTest.test_bad_websocket_version< r. r' c # # U R S5 v nUR S5 v UR 5 v nU R US5 g 7f)Nr r r r> read_messager r# r r" s r$ test_websocket_gen WebSocketTest.test_websocket_genG sF ??7+
+ w'' ** 7+s A Ac ^ [ ST R 5 - T R S9 T R 5 R 5 nUR S5 UR
T R 5 T R 5 R 5 nT R US5 T R R U 4S j5 UR 5 T R 5 g )Nws://127.0.0.1:%d/echo)callbackr c $ > TR 5 $ r )stop)fr# s r$ 8WebSocketTest.test_websocket_callbacks..W s diikr' ) r r r= r resultr> r5 r r! add_done_callbackr r6 s ` r$ test_websocket_callbacks&WebSocketTest.test_websocket_callbacksN s $t'9'9'; ;dii
YY[
!
!
"99;%%' 7+ ++,AB
r' c # # U R S5 v nUR SSS9 UR 5 v nU R US5 g 7f)Nr s hello Tbinaryr4 r6 s r$ test_binary_message!WebSocketTest.test_binary_message[ sH ??7+
+
t4 ** =1s A A c # # U R S5 v nUR S5 UR 5 v nU R US5 g 7fNr u hello ér4 r6 s r$ test_unicode_message"WebSocketTest.test_unicode_messageb sC ??7+
+
( ** >2 A
A c # # U R S5 v nUR 5 U R [ 5 UR S5 S S S 5 g ! , ( d f g = f7frK )r r assertRaisesr r> r# r s r$ )test_error_in_closed_client_write_message7WebSocketTest.test_error_in_closed_client_write_messagei sG ??7+
+
3
4 ^ , 5
4
4s 9A'A
A'
A$ A'c # # U R S5 v nUR S5 UR 5 v nU R US5 g 7f)Nr
r z hellor4 r6 s r$ test_render_message!WebSocketTest.test_render_messagep sC ??9-
-
! ** >2rN c # # U R S5 v nUR S5 [ [ S5 UR 5 v nS S S 5 U R WS 5 g ! , ( d f N!= f7f)Nr r Uncaught exception)r r> r r r5 assertIsr6 s r$ test_error_in_on_message&WebSocketTest.test_error_in_on_messagew sZ ??#9:
:
!
w 4
5 __ ..H 6
h% 6
5s 5A6A%
A6%
A3/A6c # # U R [ 5 nU R S5 v S S S 5 U R WR R
S5 g ! , ( d f N5= f7f)Nz /notfoundi )rP r r r exceptionr )r# cms r$ test_websocket_http_fail&WebSocketTest.test_websocket_http_fail sK
y
)R//+. . * **C0 *
)s A,A/A,
A)%A,c # # U R [ 5 U R S5 v S S S 5 g ! , ( d f g = f7f)Nr )rP r r r* s r$ test_websocket_http_success)WebSocketTest.test_websocket_http_success s-
~
.//), , /
.
. A5 A
AAc # # U R [ 5 U R S5 v S S S 5 g ! , ( d f g = f7f)Nr )rP r r r* s r$ test_websocket_http_redirect*WebSocketTest.test_websocket_http_redirect s-
y
)//+. . *
)
)rd c # # [ 5 u pUR 5 U R [ 5 [ [
SSS9 [
SU- SS9v S S S 5 S S S 5 g ! , ( d f N= f! , ( d f g = f7f)Nz.*F)requiredzws://127.0.0.1:%d/i )connect_timeout)r r rP IOErrorr r r )r# sockports r$ test_websocket_network_fail)WebSocketTest.test_websocket_network_fail se %'
w
'7D59'(4/ : (
'99 (
's4 2BA6A%A6 B%
A3 /A66
B Bc # # [ R " [ SU R 5 - 5 v 5 nUR S5 UR S5 UR
R
5 S S S 5 g ! , ( d f g = f7f)Nr: r world)
contextlibclosingr r r> streamr rQ s r$ "test_websocket_close_buffered_data0WebSocketTest.test_websocket_close_buffered_data si
$%=@R@R@T%TU
U
W % W % IIOO
s 3B =A;2 B ;
B B c # # [ R " [ [ SU R 5 - SS0S95 v 5 nUR 5 v nU R
US5 S S S 5 g ! , ( d f g = f7f)Nzws://127.0.0.1:%d/headerrS r r+ )rr rs r r r r5 r r6 s r$ test_websocket_headers$WebSocketTest.test_websocket_headers sv
' 2T5G5G5II!)7 3
__ ..H Xw /
s =A>%A-$ A>-
A;7A>c # d # [ R " [ [ SU R 5 - SS0S95 v 5 nU R UR R S5 S5 U R UR R S5 S5 S S S 5 g ! , ( d f g = f7f)Nz ws://127.0.0.1:%d/header_echoz X-Test-Hellor r+ rn ro )rr rs r r r r rc rd rQ s r$ test_websocket_header_echo(WebSocketTest.test_websocket_header_echo s
' 7$:L:L:NN!/ 9
RZZ^^N ;W E
89;Q
s =B0AB B0
B-)B0c # . # U R S5 v nUR 5 v nU R US 5 U R UR S5 U R UR
S5 U R v u p4U R US5 g 7f)Nr r r )r r5 rY r r/ r0 r! )r# r msgr reasons r$ test_server_close_reason&WebSocketTest.test_server_close_reason s} ???3
3OO%%
c4 - )4 ! . ..
t$s BBc # # U R S5 v nUR SS5 U R v u p#U R US5 U R US5 g 7f)Nr r r )r r r! r )r# r r r s r$ test_client_close_reason&WebSocketTest.test_client_close_reason sT ??7+
+
y! ! . .. t$ +s AA c # # U R S5 v nUR 5 v nU R US 5 U R [ 5 UR S5 S S S 5 g ! , ( d f g = f7f)Nr r )r r5 rY rP r r> )r# r r~ s r$ test_write_after_close$WebSocketTest.test_write_after_close s[ ???3
3OO%%
c4
3
4 W % 5
4
4s A
A;A*! A;*
A84A;c # # U R S5 v nUR S5 UR 5 v nU R US5 g 7f)Nr r r4 r# r ress r$ test_async_prepare WebSocketTest.test_async_prepare sF ??#34
4
!OO%% g&rN c # z # U R S5 v nUR 5 v nU R US5 g 7f)Nz/path_args/hellor r r5 r r s r$ test_path_args WebSocketTest.test_path_args s6 ??#56
6OO%% g& 9;c # # U R S5 v nUR S5 v UR S5 v UR 5 v nU R US5 UR 5 v nU R US5 g 7f)Nr hello1hello2r4 r s r$ test_coroutine WebSocketTest.test_coroutine sv ??<0
0 x(( x((OO%% h'OO%% h' BBc # 2 # U R 5 nSU- nSSU- 0n[ R " [ [ X#S95 v 5 nUR S5 UR
5 v nU R US5 S S S 5 g ! , ( d f g = f7f)Nr: Originzhttp://127.0.0.1:%dr+ r r rr rs r r r> r5 r r# rm urlrc r r" s r$ test_check_origin_valid_no_path-WebSocketTest.test_check_origin_valid_no_path s !!#&- 2T 9:
$[%FG
G
W % __ ..H Xw /
AB6B= B
BBc # 2 # U R 5 nSU- nSSU- 0n[ R " [ [ X#S95 v 5 nUR S5 UR
5 v nU R US5 S S S 5 g ! , ( d f g = f7f)Nr: r z http://127.0.0.1:%d/somethingr+ r r r s r$ !test_check_origin_valid_with_path/WebSocketTest.test_check_origin_valid_with_path s !!#&- EWebSocketTest.test_check_origin_invalid_subdomains..= s 484Aw8s z"localhost does not resolve to ipv4zws://localhost:%d/echor zhttp://subtenant.localhostr+ r )r r
resolvesetsocketAF_INETskipTestrP r r r r r] r )r# rm addrinfofamiliesr rc r^ s r$ $test_check_origin_invalid_subdomains2WebSocketTest.test_check_origin_invalid_subdomains5 s !!#
"++K>>4844 >> ) MM> ? &- 9:
y
)R#K$EF F *
**C0 *
)s BCC /C
CCc # # U R SSS/S9v nU R UR S5 UR 5 v nU R US5 g 7f)Nr badprotor )r zsubprotocol=goodproto)r r r r5 r s r$ test_subprotocols WebSocketTest.test_subprotocolsL s_ ?? *k)B #
00+>OO%% 56s AAc # # U R S5 v nU R UR S 5 UR 5 v nU R US5 g 7f)Nr zsubprotocol=None)r rY r r5 r r s r$ test_subprotocols_not_offered+WebSocketTest.test_subprotocols_not_offeredU sJ ??>2
2
b--t4OO%% 01s AAc # # [ 5 U l U R S5 v nUR S5 v U R R 5 UR 5 v nU R
US5 g 7f)Nr r r~ )r r r r> r r5 r r s r$ test_open_coroutine!WebSocketTest.test_open_coroutine\ sc !G??#45
5 w'' OO%% d#s A5A7c # # [ [ S5 U R S5 v nUR 5 v nS S S 5 U R W5 g ! , ( d f N = f7f)NrX r
r r r r5 assertIsNoner s r$ test_error_in_open WebSocketTest.test_error_in_opene sN
w 4
5'788B))C 6
# 6
5 A$&AA$
A! A$c # # [ [ S5 U R S5 v nUR 5 v nS S S 5 U R W5 g ! , ( d f N = f7f)NrX r r r s r$ test_error_in_async_open&WebSocketTest.test_error_in_async_openl sN
w 4
5'=>>B))C 6
# 6
5r c # z # U R S5 v nUR 5 v nU R US5 g 7f)Nr r r r s r$ test_nodelayWebSocketTest.test_nodelays s5 ??:.
.OO%% g&r )r! r ),r3 r4 r5 r6 r r r r# r, r1 r r7 rC rH rL rR rU rZ r_ rb rf rn ru rx r{ r r r r r r r r r r r r r r r r r r8 r r s @r$ r r s 6
p'1-
- - , , 2 2 3 3 - - 3 3 & & 1 1
- - / /
0
0 & % % , , & & ' ' ' '
( ( 0 0 0 0 1 1 1 1 1 1, 7 7 2 2 $ $ ' 'r' r c . ^ \ rS rSrU 4S jrS rSrU =r$ ) NativeCoroutineOnMessageHandleriz c 4 > [ TU ] " S0 UD6 SU l g r r r s r$ r% *NativeCoroutineOnMessageHandler.initialize{ r r' c # U R S: a U R S5 U =R S-
sl [ R " S5 I S h vN U =R S- sl U R U5 g N+7fr r rC s r$ rE *NativeCoroutineOnMessageHandler.on_message s` ==1 F G
iio
7# s AB A>,B r )r3 r4 r5 r6 r% rE r8 r r s @r$ r r z s $ $r' r c * \ rS rSrS r\S 5 rSrg) WebSocketNativeCoroutineTesti c & [ S[ 4/5 $ )N/native)r r r* s r$ r $WebSocketNativeCoroutineTest.get_app s Y(G HIJJr' c # # U R S5 v nUR S5 v UR S5 v UR 5 v nU R US5 UR 5 v nU R US5 g 7f)Nr r r r4 r s r$ test_native_coroutine2WebSocketNativeCoroutineTest.test_native_coroutine sv ??9-
- x(( x((OO%% h'OO%% h'r r9 N)r3 r4 r5 r6 r r r r8 r9 r' r$ r r s K ( (r' r c \ rS rSrSrS rS rS rS\S\SS 4S
jr \
S \ R 4S j5 r
\
S \ R 4S
j5 rSrg )CompressionTestMixini z Hello world. Testing 123 123c " S S[ 5 n[ S[ [ U R 5 S94SU[ U R 5 S94/5 $ )Nc * \ rS rSr\S 5 rS rSrg)4CompressionTestMixin.get_app..LimitedHandleri c g)N r9 r* s r$ max_message_sizeECompressionTestMixin.get_app..LimitedHandler.max_message_size s r' c J U R [ [ U5 5 5 g r )r> strlenrC s r$ rE ?CompressionTestMixin.get_app..LimitedHandler.on_message s ""3s7|#45r' r9 N)r3 r4 r5 r6 propertyr rE r8 r9 r' r$ LimitedHandlerr s
6r' r r r) /limited)r r r; r get_server_compression_options)r# r s r$ r CompressionTestMixin.get_app s_ 6 1 6 T-P-P-RS "T-P-P-RS
r' c g r r9 r* s r$ r 3CompressionTestMixin.get_server_compression_options r' c g r r9 r* s r$ get_client_compression_options3CompressionTestMixin.get_client_compression_options r r' bytes_in bytes_outreturnNc [ 5 er NotImplementedErrorr# r r s r$ verify_wire_bytes&CompressionTestMixin.verify_wire_bytes !##r' r# c # d # U R SU R 5 S9v n[ S5 HK nUR U R 5 UR 5 v nU R
X0R 5 MM U R
UR R [ U R 5 S- 5 U R
UR R [ U R 5 S- 5 U R UR R UR R 5 g 7f)Nr r) )r r ranger> MESSAGEr5 r protocol_message_bytes_outr _message_bytes_inr _wire_bytes_in_wire_bytes_outr# r ir" s r$ test_message_sizes'CompressionTestMixin.test_message_sizes s ?? )L)L)N #
qA T\\ * __ ..H X|| 4
77T\\9JQ9NO 66DLL8IA8MN r{{ 9 92;;;V;VWs D.D0c # # U R SU R 5 S9v nUR S5 UR 5 v nU R US5 UR S5 UR 5 v nU R U5 g 7f)Nr r) ڀaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa128 aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa)r r r> r5 r r r6 s r$ test_size_limit$CompressionTestMixin.test_size_limit s ?? D,O,O,Q #
# ** 5) $ ** (#s B B
r9 )r3 r4 r5 r6 r r r r intr r typingAnyr
r r8 r9 r' r$ r r sq ,G
0$# $# $$ $ X X X $fjj $ $r' r c : \ rS rSrSrS\R 4S jrSrg)UncompressedTestMixini zESpecialization of CompressionTestMixin when we expect no compression.r# c U R US[ U R 5 S- - 5 U R US[ U R 5 S- - 5 g )Nr )r r r r s r$ r 'UncompressedTestMixin.verify_wire_bytes sH AT\\):Q)>$?@ 1DLL(9A(=#>?r' r9 N) r3 r4 r5 r6 r7 r r r r8 r9 r' r$ r r s O@
@r' r c \ rS rSrSrg)NoCompressionTesti r9 N)r3 r4 r5 r6 r8 r9 r' r$ r r s r' r c \ rS rSrS rSrg)ServerOnlyCompressionTesti c 0 $ r r9 r* s r$ r 8ServerOnlyCompressionTest.get_server_compression_options r' r9 N)r3 r4 r5 r6 r r8 r9 r' r$ r! r! r' r! c \ rS rSrS rSrg)ClientOnlyCompressionTesti c 0 $ r r9 r* s r$ r 8ClientOnlyCompressionTest.get_client_compression_options r$ r' r9 N)r3 r4 r5 r6 r r8 r9 r' r$ r' r' r% r' r' c & \ rS rSrS rS rS rSrg)DefaultCompressionTesti c 0 $ r r9 r* s r$ r 5DefaultCompressionTest.get_server_compression_options r$ r' c 0 $ r r9 r* s r$ r 5DefaultCompressionTest.get_client_compression_options r$ r' c U R US[ U R 5 S- - 5 U R US[ U R 5 S- - 5 U R X!S- 5 g )Nr r r )
assertLessr r r r s r$ r (DefaultCompressionTest.verify_wire_bytes sV 1DLL(9A(=#>? !s4<<'81'<"=> rM2r' r9 N)r3 r4 r5 r6 r r r r8 r9 r' r$ r+ r+ s 3r' r+ c L \ rS rSrS\S\S\4S jrS\R 4S jrSr g )
MaskFunctionMixini maskdatar c [ 5 er r r# r6 r7 s r$ r6 MaskFunctionMixin.mask r r' r# c U R U R SS5 S5 U R U R SS5 S5 U R U R SS5 S5 U R U R SS5 S 5 U R U R S
S 5 S 5 U R U R S
S5 S5 g )Ns abcdr' b s 54321s TVPVPs ZXCVs 98765432s c`t`olpds s s s s s )r r6 r* s r$ test_maskMaskFunctionMixin.test_mask s 7C0#6 7D17; 7H5x@ 7K8+F
II)+F G '
II)+F G '
r' r9 N)
r3 r4 r5 r6 r@ r6 r r r> r8 r9 r' r$ r5 r5 s, $ $e $ $
r' r5 c \ rS rSrS rSrg)PythonMaskFunctionTesti c [ X5 $ r r r9 s r$ r6 PythonMaskFunctionTest.mask s
%d11r' r9 Nr3 r4 r5 r6 r6 r8 r9 r' r$ rA rA s 2r' rA z#tornado.speedups module not presentc \ rS rSrS rSrg)CythonMaskFunctionTesti c . [ R " X5 $ r )r websocket_maskr9 s r$ r6 CythonMaskFunctionTest.mask s &&t22r' r9 NrD r9 r' r$ rF rF s 3r' rF c * \ rS rSrS r\S 5 rSrg)ServerPeriodicPingTesti# c : " S S[ 5 n[ SU4/SS9$ )Nc \ rS rSrS rSrg)3ServerPeriodicPingTest.get_app..PingHandleri% c & U R S5 g )Ngot pongr r# r7 s r$ on_pong;ServerPeriodicPingTest.get_app..PingHandler.on_pong& "":.r' r9 N)r3 r4 r5 r6 rR r8 r9 r' r$ PingHandlerrN %
/r' rU /r )websocket_ping_intervalr r r# rU s r$ r ServerPeriodicPingTest.get_app$ s& /. / S+ ./NNr' c # # U R S5 v n[ S5 H' nUR 5 v nU R US5 M) g 7f)NrW r rP )r r r5 r r s r$ test_server_ping'ServerPeriodicPingTest.test_server_ping+ sC ??3'
'qA __ ..H Xz 2 s A A
r9 N)r3 r4 r5 r6 r r r] r8 r9 r' r$ rK rK # s O 3 3r' rK c * \ rS rSrS r\S 5 rSrg)ClientPeriodicPingTesti4 c < " S S[ 5 n[ SU4/5 $ )Nc \ rS rSrS rSrg)3ClientPeriodicPingTest.get_app..PingHandleri6 c & U R S5 g )Ngot pingr rQ s r$ on_ping;ClientPeriodicPingTest.get_app..PingHandler.on_ping7 rT r' r9 Nr3 r4 r5 r6 rf r8 r9 r' r$ rU rc 6 rV r' rU rW rY rZ s r$ r ClientPeriodicPingTest.get_app5 s$ /. / S+ ./00r' c # # U R SSS9v n[ S5 H' nUR 5 v nU R US5 M) UR 5 g 7f)NrW r )
ping_intervalr re )r r r5 r r r s r$ test_client_ping'ClientPeriodicPingTest.test_client_ping< sR ??3d?;
;qA __ ..H Xz 2
s AA r9 N)r3 r4 r5 r6 r r rl r8 r9 r' r$ r` r` 4 s 1 r' r` c * \ rS rSrS r\S 5 rSrg)ManualPingTestiF c < " S S[ 5 n[ SU4/5 $ )Nc \ rS rSrS rSrg)+ManualPingTest.get_app..PingHandleriH c @ U R U[ U[ 5 S9 g )NrF )r> r? r@ rQ s r$ rf 3ManualPingTest.get_app..PingHandler.on_pingI s ""4
40G"Hr' r9 Nrh r9 r' r$ rU rr H s
Ir' rU rW rY rZ s r$ r ManualPingTest.get_appG s& I. I S+ ./00r' c # H # U R S5 v nU R [ UR S5 UR S5 UR 5 v nU R US5 UR S5 UR 5 v nU R US5 g 7f)NrW ~aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaar s hellos binary hello)r rP
ValueErrorpingr5 r )r# r resps r$ test_manual_ping ManualPingTest.test_manual_pingN s ??3'
' *bggy9
__&& x(
__&& /s B B"r9 N)r3 r4 r5 r6 r r r{ r8 r9 r' r$ ro ro F s 1 0 0r' ro c * \ rS rSrS r\S 5 rSrg)MaxMessageSizeTesti^ c $ [ S[ 4/SS9$ )NrW r )websocket_max_message_size)r r; r* s r$ r MaxMessageSizeTest.get_app_ s S+ ./DQQr' c # ~ # U R S5 v nSnUR U5 UR 5 v nU R X25 UR US- 5 UR 5 v nU R US 5 U R UR
S5 U R UR S5 g 7f)NrW aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaabi zmessage too big)r r> r5 r rY r/ r0 )r# r r~ rz s r$ test_large_message%MaxMessageSizeTest.test_large_messageb s ??3'
'
__&& # s#__&&
dD! - *;r s
% 5 ( $ ; ' T T 3
3
O+ O(& 2
C( C,&, &.
n
$- $ $. $ *
$ 4 $ P/ P
I- I&!/ !$ -
2 $) $ - &L') L'^ $&: $
(#8
( @$6 @$F@ 0 @ -/D
57L
57L
3 13H 3
.2 .0A0A 2
T!#HI3 .0A0A 3 J3
3 2
3" 2 $0* 00=. =O
" Hs &
H, =I ,III