^h S SK r S SKrS SKrS SKrS SKrS SKrS SKrS SKrS SKJ r S SK
J r S SK J
r
Jr S SKJr S SKJrJr S SKJr S SKJr S S KJr S S
KJrJ r S S K J r J r J r J!r! S S K"J#r#J$r$ S SK%r
S S
K&J'r' S SK%J*r*J+r+J,r,J-r- S SK
J.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( S)\/5 r; " S* S+\/5 r< " S, S-\/5 r= " S. S/\/5 r> " S0 S1\/5 r? " S2 S3\ 5 r@ " S4 S5\@5 rA " S6 S7\/5 rB " S8 S9\@5 rC\ " S: S;\@5 5 rD\ " S< S=\D5 5 rE " S> S?\E5 rF " S@ SA\E5 rG " SB SC\E5 rH " SD SE\D5 rI\ " SF SG\R 5 5 rK " SH SI\K5 rL\R " \.SL SJ5 " SK SL\K5 5 rN " SM SN\@5 rO " SO SP\@5 rP " SQ SR\@5 rQ " SS ST\R 5 rR " SU SV\@5 rS " SW SX\@5 rTg! \( a \RR " 5 e f = f! \( a Sr. GNf = f)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 . \ 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 U/home/james-whalen/.local/lib/python3.13/site-packages/tornado/test/websocket_test.py
initialize TestWebSocketHandler.initialize6 s (#6 c U R $ r! r$ r% s r& get_compression_options,TestWebSocketHandler.get_compression_options: 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- r3 __static_attributes__ r) r& r r . s 7(Or) r c 8 \ rS rSr\R
S 5 rSrg) EchoHandlerB 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_messageC sF $$Wj%.HI I%% # s/ A "' A A A A A A A r< N)r6 r7 r8 r9 r coroutinerH r; r< r) r& r> r> B s ]] r) r> c \ rS rSrS rSrg)ErrorInOnMessageHandlerM c SS- g )N r r< rF s r& rH "ErrorInOnMessageHandler.on_messageN s Ar) r< Nr6 r7 r8 r9 rH r; r< r) r& rL rL M s r) rL c \ rS rSrS rSrg)
HeaderHandlerR 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 RuntimeErrorrA requestheadersget)r% methods_to_testmethods r& openHeaderHandler.openS s djj*@ A dmm-I J doox < doo{F C doos 3 JJ KK
&F
@AA &
4<<//33HbAB
s D
DDr< Nr6 r7 r8 r9 rj r; r< r) r& rS rS R s Cr) rS c \ rS rSrS rS rSrg)HeaderEchoHandlerh c ( U R SS5 g )NX-Extra-Response-HeaderExtra-Response-Value)r^ r, s r& set_default_headers%HeaderEchoHandler.set_default_headersi s 13IJr) c U R R R 5 H< u pUR 5 R S5 ( d M+ U R X5 M> g )Nzx-test)re rf get_alllower
startswithr^ )r% kvs r& prepareHeaderEchoHandler.preparel sD LL((002DAwwy##H--% 3r) r< N)r6 r7 r8 r9 rs r{ r; r< r) r& rn rn h s
K&r) rn c \ rS rSrS rSrg)NonWebSocketHandlerr c & U R S5 g )Nok)r\ r, s r& rg NonWebSocketHandler.gets s
4r) r< Nr6 r7 r8 r9 rg r; r< r) r& r~ r~ r s r) r~ c \ rS rSrS rSrg)RedirectHandlerw c & U R S5 g )N/echo)r] r, s r& rg RedirectHandler.getx s
g r) r< Nr r< r) r& r r w s r) r c \ rS rSrS rSrg)CloseReasonHandler| c 6 SU l U R SS5 g )NF goodbye)on_close_calledcloser, s r& rj CloseReasonHandler.open} s $
4#r) )r Nrl r< r) r& r r | $r) r c > \ rS rSr\R
S 5 rS rSrg)AsyncPrepareHandler c # 0 # [ R v g 7fr! )r momentr, s r& r{ AsyncPrepareHandler.prepare s jjs c & U R U5 g r! rA rF s r& rH AsyncPrepareHandler.on_message s 7#r) r< N) r6 r7 r8 r9 r rJ r{ rH r; r< r) r& r r s ]] $r) r c \ rS rSrS rSrg)PathArgsHandler c & U R U5 g r! r )r% args r& rj PathArgsHandler.open s 3 r) r< Nrl r< 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 r< 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 sleepingrO {Gz?r rA r sleeprF s r& rH $CoroutineOnMessageHandler.on_message sX ==1 F G
iio
7#s A6A8r )
r6 r7 r8 r9 r' r rJ rH r;
__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)rG )rA
render_stringrF s r& rH RenderMessageHandler.on_message s 4--ng-NOr) r< NrQ r< 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 NFr< )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 rc )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 rc rA selected_subprotocolr, s r& rj SubprotocolHandler.open s1 -- ;< < +d.G.GGHr) )r ) r6 r7 r8 r9 r' r rj r; 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& rj OpenCoroutineHandler.open s5 ii$$))++ii !s AA c ^ U R ( d [ S5 eU R S5 g )Nz&on_message called before open finishedr )r rc rA rF s r& rH OpenCoroutineHandler.on_message s% !! DE E 4 r) )r r ) r6 r7 r8 r9 r' r rJ rj rH r; r r s @r& r r s* #
]]" "
! !r) r c \ rS rSrS rSrg)ErrorInOpenHandler c [ S5 e)Nboom)rc r, s r& rj ErrorInOpenHandler.open s
r) r< Nrl r< r) r& r r r r) r c \ rS rSrS rSrg)ErrorInAsyncOpenHandler c ` # [ R " S5 I S h vN [ S5 e N7f)Nr r )rD r rc r, s r& rj ErrorInAsyncOpenHandler.open s' mmA s .,.r< Nrl r< r) r& r r s r) r c \ rS rSrS rSrg)NoDelayHandler c H U R S5 U R S5 g )NThello) set_nodelayrA r, s r& rj NoDelayHandler.open s 7#r) r< Nrl r< 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 ) r6 r7 r8 r9 r r r rJ r r; 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 rS rn r rL 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-Versionrf r r r$ s r& test_missing_websocket_key(WebSocketTest.test_missing_websocket_key3 < :: '&)-
,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> r1 r) c # # U R S5 v nUR S5 v UR 5 v nU R US5 g 7f)Nr r r rA read_messager" r% r r% s r& test_websocket_gen WebSocketTest.test_websocket_genI sF ??7+
+ w'' ** 7+s A Ac
^ [ 5 [ ST R 5 - T R S9 S S S 5 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 ! , ( d f N= f)Nws://127.0.0.1:%d/echo)callbackr c $ > TR 5 $ r! )stop)fr% s r& 8WebSocketTest.test_websocket_callbacks..Z s diikr) ) r r r r@ r resultrA r8 r" r# add_done_callbackr r9 s ` r& test_websocket_callbacks&WebSocketTest.test_websocket_callbacksP s
! (4+=+=+??$))
" YY[
!
!
"99;%%' 7+ ++,AB
"
!s &C44
Dc # # U R S5 v nUR SSS9 UR 5 v nU R US5 g 7f)Nr s hello Tbinaryr7 r9 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 ér7 r9 s r& test_unicode_message"WebSocketTest.test_unicode_messagee 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 = f7frN )r r assertRaisesr rA r% r s r& )test_error_in_closed_client_write_message7WebSocketTest.test_error_in_closed_client_write_messagel 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 hellor7 r9 s r& test_render_message!WebSocketTest.test_render_messages sC ??9-
-
! ** >2rQ c # # U R S5 v nUR S5 [ [ S5 UR 5 v nS S S 5 U R W5 g ! , ( d f N = f7f)Nr
r Uncaught exception)r rA r r r8 assertIsNoner9 s r& test_error_in_on_message&WebSocketTest.test_error_in_on_messagez sZ ??#9:
:
!
w 4
5 __ ..H 6 (# 6
5s 5A5A$
A5$
A2.A5c # # U R [ 5 nU R S5 v S S S 5 U R WR R
S5 g ! , ( d f N5= f7f)Nz /notfoundi )rS 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 )rS 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 )rS r r r, s r& test_websocket_http_redirect*WebSocketTest.test_websocket_http_redirect s-
y
)//+. . *
)
)rg 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 rS 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 rA streamr rT 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/headerrV r r. )ru rv r r r r8 r" r9 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. rq rr )ru rv r r r r" rf rg rT 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 r8 assertIsr" r1 r2 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$ + 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 r8 r rS r rA )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 r7 r% r ress r& test_async_prepare WebSocketTest.test_async_prepare sF ??#34
4
!OO%% g&rQ c # z # U R S5 v nUR 5 v nU R US5 g 7f)Nz/path_args/hellor r r8 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 hello1hello2r7 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 ru rv r r rA r8 r" r% rp urlrf 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 !!#&- >(01G1 >> ) MM> ? &- 9:
y
)R#K$EF F *
**C0 2 *
)s) 1C!C AC!C 4C!
C C!c # # U R SSS/S9v nU R UR S5 UR 5 v nU R US5 g 7f)Nr badprotor )r zsubprotocol=goodproto)r r" r r8 r s r& test_subprotocols WebSocketTest.test_subprotocolsO 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 r r r8 r" r s r& test_subprotocols_not_offered+WebSocketTest.test_subprotocols_not_offeredX 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 rA setr8 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)Nr[ r r r r r8 r\ r s r& test_error_in_open WebSocketTest.test_error_in_openh 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)Nr[ r r r s r& test_error_in_async_open&WebSocketTest.test_error_in_async_openo 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_nodelayv s5 ??:.
.OO%% g&r )r# r ),r6 r7 r8 r9 r r r r& r/ r4 r r: rF rK rO rU rX r] rb re ri rq rx r{ r~ r r r r r r r r r r r r r r r r r r; 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$ ) NativeCoroutineOnMessageHandleri} 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 rF s r& rH *NativeCoroutineOnMessageHandler.on_message s` ==1 F G
iio
7# s AB A>,B r )r6 r7 r8 r9 r' rH r; r r s @r& r r } 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 r7 r s r& test_native_coroutine2WebSocketNativeCoroutineTest.test_native_coroutine sv ??9-
- x(( x((OO%% h'OO%% h'r r< N)r6 r7 r8 r9 r r r r; r< r) r& r r s K ( (r) r c ` \ rS rSrSrS rS rS rS\S\SS 4S
jr \
S 5 r \
S 5 r S
r
g )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 r< r, s r& max_message_sizeECompressionTestMixin.get_app..LimitedHandler.max_message_size s r) c J U R [ [ U5 5 5 g r! )rA strlenrF s r& rH ?CompressionTestMixin.get_app..LimitedHandler.on_message s ""3s7|#45r) r< N)r6 r7 r8 r9 propertyr rH r; r< 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! r< r, s r& r 3CompressionTestMixin.get_server_compression_options r) c g r! r< 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) 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 rangerA MESSAGEr8 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 rA r8 r" r\ r9 s r& test_size_limit$CompressionTestMixin.test_size_limit s ?? D,O,O,Q #
# ** 5) $ ** (#s B B
r< )r6 r7 r8 r9 r r r r intr r r
r r; r< r) r& r r sZ ,G
0$# $# $$ $ X X $ $r) r c \ rS rSrSrS rSrg)UncompressedTestMixini zESpecialization of CompressionTestMixin when we expect no compression.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) r< N)r6 r7 r8 r9 r: r r; r< r) r& r r s O@r) r c \ rS rSrSrg)NoCompressionTesti r< N)r6 r7 r8 r9 r; r< r) r& r r s r) r c \ rS rSrS rSrg)ServerOnlyCompressionTesti c 0 $ r! r< r, s r& r 8ServerOnlyCompressionTest.get_server_compression_options r) r< N)r6 r7 r8 r9 r r; r< r) r& r r r) r c \ rS rSrS rSrg)ClientOnlyCompressionTesti c 0 $ r! r< r, s r& r 8ClientOnlyCompressionTest.get_client_compression_options r" r) r< N)r6 r7 r8 r9 r r; r< r) r& r% r% r# r) r% c & \ rS rSrS rS rS rSrg)DefaultCompressionTesti c 0 $ r! r< r, s r& r 5DefaultCompressionTest.get_server_compression_options r" r) c 0 $ r! r< 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) r< N)r6 r7 r8 r9 r r r r; r< 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% r4 r5 s r& r4 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" r4 r, s r& test_maskMaskFunctionMixin.test_mask s 7C0#6 7D17; 7H5x@ 7K8+F
II)+F G '
II)+F G '
r) r< N)
r6 r7 r8 r9 rC r4 typingAnyr< r; r< r) r& r3 r3 s, $ $e $ $
r) r3 c \ rS rSrS rSrg)PythonMaskFunctionTesti c [ X5 $ r! r r7 s r& r4 PythonMaskFunctionTest.mask s
%d11r) r< Nr6 r7 r8 r9 r4 r; r< r) r& rA rA s 2r) rA z#tornado.speedups module not presentc \ rS rSrS rSrg)CythonMaskFunctionTesti# c . [ R " X5 $ r! )r websocket_maskr7 s r& r4 CythonMaskFunctionTest.mask% s &&t22r) r< NrD r< r) r& rF rF # s 3r) rF c * \ rS rSrS r\S 5 rSrg)ServerPeriodicPingTesti) c < " S S[ 5 n[ SU4/SSS9$ )Nc \ rS rSrS rSrg)3ServerPeriodicPingTest.get_app..PingHandleri+ c & U R S5 g )Ngot pongr r% r5 s r& on_pong;ServerPeriodicPingTest.get_app..PingHandler.on_pong, "":.r) r< N)r6 r7 r8 r9 rR r; r< r) r& PingHandlerrN +
/r) rU /r r )websocket_ping_intervalwebsocket_ping_timeoutr r r% rU s r& r ServerPeriodicPingTest.get_app* s/ /. / ;
$(#$
r) c # # U R S5 v n[ S5 H' nUR 5 v nU R US5 M) g 7f)NrW r rP )r r r8 r" r s r& test_server_ping'ServerPeriodicPingTest.test_server_ping5 sC ??3'
'qA __ ..H Xz 2 s A A
r< N)r6 r7 r8 r9 r r r^ r; r< r) r& rK rK ) s
3 3r) rK c * \ rS rSrS r\S 5 rSrg)ClientPeriodicPingTesti> c < " S S[ 5 n[ SU4/5 $ )Nc \ rS rSrS rSrg)3ClientPeriodicPingTest.get_app..PingHandleri@ c & U R S5 g )Ngot pingr rQ s r& on_ping;ClientPeriodicPingTest.get_app..PingHandler.on_pingA rT r) r< Nr6 r7 r8 r9 rg r; r< r) r& rU rd @ rV r) rU rW rZ r[ s r& r ClientPeriodicPingTest.get_app? s$ /. / S+ ./00r) c # # U R SSSS9v n[ S5 H' nUR 5 v nU R US5 M) UR 5 g 7f)NrW r r
ping_interval ping_timeoutr rf )r r r8 r" r r s r& test_client_ping'ClientPeriodicPingTest.test_client_pingF sT ??3d?K
KqA __ ..H Xz 2
r r< N)r6 r7 r8 r9 r r ro r; r< r) r& ra ra > s 1 r) ra c : \ rS rSrS r\S 5 r\S 5 rSr g)ServerPingTimeoutTestiO c Z ^ / U l U m " U4S jS[ 5 n[ SU4/5 nU$ )Nc 0 >^ \ rS rSrSU U4S jjrSrU =r$ )2ServerPingTimeoutTest.get_app..PingHandleriT c v > TR U l U R R U 5 [ TU ]
XS9$ )Nr" )handlersr r r' )r% r# r$ r r s r& r' =ServerPingTimeoutTest.get_app..PingHandler.initializeU s: $
$$T* w)!- * r) rw r5 )r6 r7 r8 r9 r' r; r )r r s @r& rU ru T s
r) rU rW )rw r r )r% rU appr s @r& r ServerPingTimeoutTest.get_appP s5 02
. C-./
r) c ^ ST l ST l U 4S jnU" T R R 5 T R l g)z1Optionally suppress the client's "pong" response.Fr c 4 >^ S[ S[ 4U U4S jjnU$ )Nopcoder5 c n > U S:X a' T=R S-
sl TR ( a g T" X5 $ )N
rO )pongs_received
drop_pongs)r~ r5 fcnr s r& _innerCServerPingTimeoutTest.install_hook..wrapper.._innerh s0 S=%%*%}} 6((r) )r rC )r r r s ` r& wrapper3ServerPingTimeoutTest.install_hook..wrapperg s"
)s
)%
)
) Mr) N)r r r _handle_message)r r s ` r& install_hook"ServerPingTimeoutTest.install_hook` s6
'.bkk.I.I&J #r) c # # SnU R SXS- S9v nU R U5 U R S n[ S5 Hj n[ R
" U5 v U R
UR 5 U R
UR 5 UR R c Mj e U R UR S5 SUl [ R
" US- 5 v U R UR S 5 U R UR S
5 U R UR R S 5 g 7f) Ng?rW rl r Tg ?i zping timed out)r r rw r r r r\ r1 r2 r assertGreaterEqualr r r" )r% intervalr handler_s r& test_client_ping_timeout.ServerPingTimeoutTest.test_client_ping_timeoutu s- ?? xl #
" --"qA))H% %
g 0 0 1 g 2 2 3 ;;))1 11
1 115
ii3''
++T2 --/?@
//6s
B)E/B!Ery N)
r6 r7 r8 r9 r staticmethodr r r r; r< r) r& rr rr O s1 K K( %7 %7r) rr c \ rS rSrS rSrg)PingCalculationTesti c
Z SSK Jn [ R " SSSSSS[ R R S9nSn[ R " SSSSS S
[ R R S9nUR UR
5 UUR
5 S 9nU R US 5 g )
Nr )WebSocketProtocol13i rO r/ )tzinfor ; 6 )last_ping_timer nowr )tornado.websocketr datetimetimezoneutcping_sleep_time timestampr" )r% r r r r
sleep_times r& test_ping_sleep_time(PingCalculationTest.test_ping_sleep_time s 9 aB1X=N=N=R=RS!** !QB8+<+<+@+@
)88)335
9
Q'r) r< N)r6 r7 r8 r9 r r; r< r) r& r r s
(r) r c * \ rS rSrS r\S 5 rSrg)ManualPingTesti c < " S S[ 5 n[ SU4/5 $ )Nc \ rS rSrS rSrg)+ManualPingTest.get_app..PingHandleri c @ U R U[ U[ 5 S9 g )NrI )rA rB rC rQ s r& rg 3ManualPingTest.get_app..PingHandler.on_ping s ""4
40G"Hr) r< Nri r< r) r& rU r s
Ir) rU rW rZ r[ s r& r ManualPingTest.get_app 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 rS
ValueErrorpingr8 r" )r% r resps r& test_manual_ping ManualPingTest.test_manual_ping s ??3'
' *bggy9
__&& x(
__&& /s B B"r< N)r6 r7 r8 r9 r r r r; r< r) r& r r s 1 0 0r) r 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 rA r8 r" r r1 r2 )r% r r r s r& test_large_message%MaxMessageSizeTest.test_large_message s ??3'
'
__&& # s#__&&
dD! - *; unittesttornado.concurrentr tornador tornado.httpclientr r
tornado.locksr tornado.logr r tornado.netutilr
tornado.simple_httpclientr tornado.templater
tornado.test.utilr r tornado.testingr r r r tornado.webr r r tornado.utilr ImportError print_excr r r r r r r> rL rS rn r~ r r r r r r r r r r r r r r r r r r r r% r) TestCaser3 rA skipIfrF rK ra rr r r r r< r) r& r s
% 5 ( $ ; ' D T T 3
3
O+ O(& 2
C( C,&, &.
n
$- $ $. $ *
$ 4 $ P/ P
I- I&!/ !$ -
2 $) $ - &M') M'` $&: $
(#8
( @$0 @$ @$F @ 0 @ @ -
5
5
3 1 3
))
.2 . 2
T!#HI3 . 3 J3
3 2 3* 2 "L7 1 L7^((++ ("0* 00=. =]
" Hs 2
I I3 I03I?>I?